Pārlūkot izejas kodu

feat:添加分品类聚类任务

zhaohaipeng 3 nedēļas atpakaļ
vecāks
revīzija
8dae10b7d5

+ 3 - 3
supply-demand-engine-core/src/main/java/com/tzld/piaoquan/sde/service/impl/ExecutionTaskServiceImpl.java

@@ -582,11 +582,11 @@ public class ExecutionTaskServiceImpl implements ExecutionTaskService {
 
         XxlJobParamDto xxlJobParamDto = JSONObject.parseObject(params, XxlJobParamDto.class);
         String table = xxlJobParamDto.getTable();
-        if (StringUtils.isBlank(table)) {
-            XxlJobLogger.log("table must not null");
+        String contentScope = xxlJobParamDto.getContentScope();
+        if (StringUtils.isBlank(table) || StringUtils.isBlank(contentScope)) {
+            XxlJobLogger.log("table and contentScope must not null");
             return;
         }
-        String contentScope = xxlJobParamDto.getContentScopeOrDefault(MANUAL_SELECT_VIDEO_SCOPE);
         String dt = xxlJobParamDto.getDt();
         if (StringUtils.isBlank(dt)) {
             LocalDateTime yesterday = LocalDateTime.now().minusDays(1);