浏览代码

优化批量开户状态更新任务

zhaotx 8 月之前
父节点
当前提交
9778f22924

+ 5 - 5
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/mapper/xml/PromoteLinkRefreshMapper.xml

@@ -42,15 +42,15 @@
                      app.plat_type
               from (select * from deepthink.bytedance_advertiser_task where create_time >= #{startTime} and create_time <= #{endTime}) t1
                        left join deepthink.mini_app_info app on t1.app_id = app.app_id
-                       LEFT JOIN (select * from deepthink.advertiser_app_list where create_time >= #{startTime} and create_time <= #{endTime}) t2
+                       LEFT JOIN (select instance_id, advertiser_id, task_id, audit_status from deepthink.advertiser_app_list where create_time >= #{startTime} and create_time <= #{endTime}) t2
                                  ON t1.instance_id = t2.instance_id AND t1.advertiser_id = t2.advertiser_id and t1.task_id = t2.task_id
-                       LEFT JOIN (select * from deepthink.advertiser_tools_site where create_time >= #{startTime} and create_time <= #{endTime}) t3
+                       LEFT JOIN (select site_id, advertiser_id, `status` from deepthink.advertiser_tools_site where create_time >= #{startTime} and create_time <= #{endTime}) t3
                                  ON t1.site_id = t3.site_id AND t1.advertiser_id = t3.advertiser_id
-                       LEFT JOIN (select * from deepthink.advertiser_avatar where create_time >= #{startTime} and create_time <= #{endTime}) t4
+                       LEFT JOIN (select advertiser_id, avatar_status from deepthink.advertiser_avatar where create_time >= #{startTime} and create_time <= #{endTime}) t4
                                  ON t1.advertiser_id = t4.advertiser_id
-                       LEFT JOIN (select * from deepthink.advertiser_name_info where create_time >= #{startTime} and create_time <= #{endTime}) t5
+                       LEFT JOIN (select advertiser_id, advertiser_status from deepthink.advertiser_name_info where create_time >= #{startTime} and create_time <= #{endTime}) t5
                                  ON t1.advertiser_id = t5.advertiser_id
-                       LEFT JOIN (select * from deepthink.bytedance_advertiser_task_link where create_time >= #{startTime} and create_time <= #{endTime}) t6
+                       LEFT JOIN (select task_id, advertiser_id, `status` from deepthink.bytedance_advertiser_task_link where create_time >= #{startTime} and create_time <= #{endTime}) t6
                                  ON t1.task_id = t6.task_id AND t1.advertiser_id = t6.advertiser_id
                        LEFT JOIN (select standard_movie_id, standard_movie_name from deepthink.all_moive group by standard_movie_id, standard_movie_name) t7
                                  on t1.movie_id = t7.standard_movie_id

+ 1 - 1
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/PromoteLinkRefreshJob.java

@@ -81,7 +81,7 @@ public class PromoteLinkRefreshJob {
         try {
             // 生成当前时间三小时前的时间字符串(格式:yyyy-MM-dd HH:mm:ss)
             java.util.Calendar cal = java.util.Calendar.getInstance();
-            cal.add(java.util.Calendar.HOUR_OF_DAY, -3);
+            cal.add(java.util.Calendar.HOUR_OF_DAY, -1);
             String startTime = DateUtils.formatDate(cal.getTime(), "yyyy-MM-dd HH:mm:ss");
             String endTime = DateUtils.formatDate(new Date(), "yyyy-MM-dd HH:mm:ss");
             log.info("startTime: " + startTime + ", endTime: " + endTime);