ソースを参照

cps IAA、IAP消耗数据清洗

ZHAOXIAN 1 年間 前
親
コミット
4cef2df8f5

+ 20 - 6
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/CPSReportJob.java

@@ -21,16 +21,30 @@ public class CPSReportJob {
     /**
      * 清洗CPS报表
      */
-    @XxlJob("cleanCPSDailyReports")
-    public void cleanCPSDailyReports() throws Exception {
-        log.info("[cleanCPSDailyReports] 任务启动...");
+    @XxlJob("dayCleanCPSDailyReports")
+    public void dayCleanCPSDailyReports() throws Exception {
+        log.info("[dayCleanCPSDailyReports] 任务启动...");
         try {
             String nowDate = DateUtils.getNowDate("yyyyMMdd");
-            String yesterday = DateUtils.getNowAddDate("yyyyMMdd", -1);
-
             cpsReportService.cleanCPSDailyReports(Integer.valueOf(nowDate));
-            Thread.sleep(5000L);
+            log.info("[dayCleanCPSDailyReports] 任务完成");
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error(e.getMessage());
+        }
+    }
+
+    /**
+     * 清洗CPS报表
+     */
+    @XxlJob("yesCleanCPSDailyReports")
+    public void yesCleanCPSDailyReports() throws Exception {
+        log.info("[yesCleanCPSDailyReports] 任务启动...");
+        try {
+            String nowDate = DateUtils.getNowDate("yyyyMMdd");
+            String yesterday = DateUtils.getNowAddDate("yyyyMMdd", -1);
             cpsReportService.cleanCPSDailyReports(Integer.valueOf(yesterday));
+            log.info("[yesCleanCPSDailyReports] 任务完成");
         } catch (Exception e) {
             e.printStackTrace();
             log.error(e.getMessage());