zhaoxian 1 год назад
Родитель
Сommit
8f8a13aaf1

+ 2 - 2
job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/controller/KuaishouController.java

@@ -131,9 +131,9 @@ public class KuaishouController {
         String nowDate = DateUtils.getNowDate("yyyy-MM-dd");
         String token = tokenService.getByAccountId(accountId);
         //更新 组
-        adUnitReportService.getAdUnitReport(accountId,null, token, nowDate, nowDate, 1);
+        adUnitReportService.checkGroupInfo(accountId, token, nowDate, nowDate, 1);
         //更新 组时报
-        unitReportHourlyService.getUnitReportHour(accountId, token, nowDate, nowDate, 1);
+//        unitReportHourlyService.getUnitReportHour(accountId, token, nowDate, nowDate, 1);
     }
 
 

+ 29 - 2
job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouGroupJob.java

@@ -32,8 +32,35 @@ public class KuaishouGroupJob {
      *
      * @throws Exception
      */
-    @XxlJob("ocpxActionTypeTrackUrlJob")
-    public void execute() throws Exception {
+    @XxlJob("todayOcpxActionTypeTrackUrlJob")
+    public void todayOcpxActionTypeTrackUrlJob() throws Exception {
+        String param = XxlJobHelper.getJobParam(); // 执行参数
+        if (Check.isNull(param)) {
+            log.error("入参为空");
+            return;
+        }
+        String token = tokenService.getByAccountId(Long.valueOf(param));
+        if (Check.isNull(token)) {
+            log.error("此账户未获取到相关token,accountId:{}", param);
+            return;
+        }
+        String today = DateUtils.getNowDate("yyyy-MM-dd");
+        dailyExecutorService.submit(
+                new Runnable() {
+                    @Override
+                    public void run() {
+                        unitReportService.checkGroupInfo(Long.valueOf(param), token, today, today, 1);
+                    }
+                });
+    }
+
+    /**
+     * 项目转化目标、转化出价预警
+     *
+     * @throws Exception
+     */
+    @XxlJob("yesterdayOcpxActionTypeTrackUrlJob")
+    public void yesterdayOcpxActionTypeTrackUrlJob() throws Exception {
         String param = XxlJobHelper.getJobParam(); // 执行参数
         if (Check.isNull(param)) {
             log.error("入参为空");