定时任务

2025年3月4日20:48:48

modules/calculation/src/main/java/com/thing/calculation/handler/CalcExecuteHandler.java

@@ -50,7 +50,7 @@ public class CalcExecuteHandler {
      *
      * @param request 计算请求
      */
-    public void handleCalculate(ExecuteCalcRequest request) {
+    public void handleCalculate(ExecuteCalcRequest request,List<Long> ids) {
         long calcStart = System.currentTimeMillis();
         // 清理过期日志:7天
         calcLogService.clearExpiredCalculatedLog();
@@ -59,6 +59,9 @@ public class CalcExecuteHandler {
         if (CollectionUtils.isEmpty(targetConfigs)) {
             return;
         }
+        if(!CollectionUtils.isEmpty(ids)){
+            targetConfigs = targetConfigs.stream().filter(config -> ids.contains(config.getId())).toList();
+        }
         // 按照结果对象的id分组
         Map<Long, CalcTargetConfigDTO> configMap =
                 targetConfigs.stream()

modules/calculation/src/main/java/com/thing/calculation/service/impl/CalcTargetConfigServiceImpl.java

@@ -357,7 +357,7 @@ public class CalcTargetConfigServiceImpl
         calcLogSaveHandler.handleLogSave(tskvList, configList, true);
 
         // 立即执行计算
-        calcExecuteHandler.handleCalculate(new ExecuteCalcRequest(request.getStartTime(), request.getEndTime()));
+        calcExecuteHandler.handleCalculate(new ExecuteCalcRequest(request.getStartTime(), request.getEndTime()),ids);
     }
 
     @Override

modules/quartz/src/main/java/com/thing/quartz/calc/task/CalcTask.java

@@ -31,6 +31,6 @@ public class CalcTask implements ITask {
         } else {
             request = JSONObject.parseObject(params, ExecuteCalcRequest.class);
         }
-        calcExecuteHandler.handleCalculate(request);
+        calcExecuteHandler.handleCalculate(request,null);
     }
 }