视频内容同步更新

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

@@ -60,6 +60,10 @@ public class ContentPlatformVideoJob {
         List<String> dtList = DateUtil.getBeforeDays(aggDt, null, videoAggDays);
         // 轮询查询大数据获取最近14天视频
         for (String dt : dtList) {
+            long videoCount = getVideoCount(dt);
+            if (videoCount > 0) {
+                continue;
+            }
             String sql = String.format("SELECT * FROM loghubods.wecom_cooperation_video_candidate_pool WHERE dt=%s;", dt);
             List<Record> dataList = OdpsUtil.getOdpsData(sql);
             Long now = System.currentTimeMillis();
@@ -98,7 +102,6 @@ public class ContentPlatformVideoJob {
                 }
                 // save
                 if (CollectionUtils.isNotEmpty(saveList)) {
-                    planMapperExt.deleteContentPlatformVideo(dt);
                     planMapperExt.batchInsertContentPlatformVideo(saveList);
                 }
             }