video 最近14日聚合

api-module/src/main/java/com/tzld/piaoquan/api/job/ContentPlatformVideoJob.java

@@ -111,6 +111,10 @@ public class ContentPlatformVideoJob {
                 }
             }
         }
+        long videoAggCount = getVideoAggCount(aggDt);
+        if (videoAggCount > 0) {
+            return ReturnT.SUCCESS;
+        }
         // 聚合最近14天视频
         List<ContentPlatformVideoAgg> saveAggList = planMapperExt.getVideoAggList(dtList);
         if (CollectionUtils.isNotEmpty(saveAggList)) {
@@ -136,6 +140,12 @@ public class ContentPlatformVideoJob {
         return videoMapper.countByExample(example);
     }
 
+    private long getVideoAggCount(String dt) {
+        ContentPlatformVideoAggExample example = new ContentPlatformVideoAggExample();
+        example.createCriteria().andDtEqualTo(dt);
+        return videoAggMapper.countByExample(example);
+    }
+
     @XxlJob("checkContentPlatformVideoStatusJob")
     public ReturnT<String> checkContentPlatformVideoStatusJob(String param) {
         String dt = planMapperExt.getVideoMaxDt();