add log

supply-demand-engine-core/src/main/java/com/tzld/piaoquan/sde/mapper/SdExecutionTaskContentMapper.java

@@ -3,6 +3,7 @@ package com.tzld.piaoquan.sde.mapper;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.tzld.piaoquan.sde.model.entity.SdExecutionTaskContent;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
@@ -11,5 +12,5 @@ public interface SdExecutionTaskContentMapper extends BaseMapper<SdExecutionTask
 
     int insertBatchCustom(List<SdExecutionTaskContent> list);
 
-    int countByContentId(Integer contentType, String contentId);
+    int countByContentId(@Param("contentType") Integer contentType, @Param("contentId") String contentId);
 }

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

@@ -300,6 +300,7 @@ public class ExecutionTaskServiceImpl implements ExecutionTaskService {
             log.info("yesterdayTopReturnVideoExecutionTaskCreateHandler records is empty");
             return;
         }
+        XxlJobLogger.log("yesterdayTopReturnVideoExecutionTaskCreateHandler records size={}", records.size());
         List<Record> findRecords = new ArrayList<>();
         for (Record record : records) {
             if (Objects.isNull(record)) {
@@ -307,7 +308,9 @@ public class ExecutionTaskServiceImpl implements ExecutionTaskService {
             }
             //TODO 待优化，只针对本策略去重
             String videoId = record.getString("videoid");
+            log.info("yesterdayTopReturnVideoExecutionTaskCreateHandler videoId={}", videoId);
             int count = sdExecutionTaskContentMapper.countByContentId(ContentTypeEnum.VIDEO.getValue(), videoId);
+            log.info("yesterdayTopReturnVideoExecutionTaskCreateHandler videoId={}", videoId);
             if (count > 0) {
                 continue;
             }
@@ -320,6 +323,7 @@ public class ExecutionTaskServiceImpl implements ExecutionTaskService {
             XxlJobLogger.log("yesterdayTopReturnVideoExecutionTaskCreateHandler findRecords is empty");
             return;
         }
+        XxlJobLogger.log("yesterdayTopReturnVideoExecutionTaskCreateHandler findRecords size={}", findRecords.size());
         long topCostMs = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start);
         log.info("yesterdayTopReturnVideoExecutionTaskCreateHandler get top video cost={}ms", topCostMs);
         //创建解构任务