feat:添加临时任务

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

@@ -379,8 +379,7 @@ public class ExecutionTaskServiceImpl implements ExecutionTaskService {
             LocalDateTime yesterday = LocalDateTime.now().minusDays(1);
             dt = DateUtil.formatLocalDateTime(yesterday, "yyyyMMdd");
         }
-        int topN = TOP_N * 5;
-        String sql = "select * from " + table + " where dt='" + dt + "' ORDER BY 回流人数 DESC LIMIT " + topN + ";";
+        String sql = "select * from " + table + " where dt='" + dt + "' ORDER BY 回流人数 DESC;";
         List<Record> records = odpsManager.query(sql);
         if (Objects.isNull(records) || records.isEmpty()) {
             log.info("topReturnVideoExecutionTaskCreateHandler records is empty");
@@ -395,15 +394,12 @@ public class ExecutionTaskServiceImpl implements ExecutionTaskService {
             if (Objects.isNull(record)) {
                 continue;
             }
-            String videoId = record.getString("videoid");
+            // String videoId = record.getString("videoid");
             // int count = sdExecutionTaskContentMapper.countByContentId(ContentTypeEnum.VIDEO.getValue(), videoId);
             // if (count > 0) {
             //     continue;
             // }
             findRecords.add(record);
-            if (findRecords.size() >= TOP_N) {
-                break;
-            }
         }
         if (findRecords.isEmpty()) {
             XxlJobLogger.log("topReturnVideoExecutionTaskCreateHandler findRecords is empty");