Bläddra i källkod

侠客行流水数据

yumeng 8 månader sedan
förälder
incheckning
97b0253043

+ 27 - 5
job-adq/src/main/java/cn/com/ctop/job/adq/handler/AdqAccountReportJob.java

@@ -1,10 +1,7 @@
 package cn.com.ctop.job.adq.handler;
 
 
-import cn.com.ctop.job.adq.data.service.IAdqAccountReportService;
-import cn.com.ctop.job.adq.data.service.IAdqAdIncomeService;
-import cn.com.ctop.job.adq.data.service.IAdqAssetReportService;
-import cn.com.ctop.job.adq.data.service.IAdqMaterialReportService;
+import cn.com.ctop.job.adq.data.service.*;
 import cn.com.ctop.job.adq.data.utils.Check;
 import cn.com.ctop.job.adq.data.utils.DateUtils;
 import com.alibaba.fastjson.JSONObject;
@@ -38,7 +35,9 @@ public class AdqAccountReportJob {
     private static ExecutorService nowDateHourExecutorService = Executors.newFixedThreadPool(5);
     private static ExecutorService yesDateHourExecutorService = Executors.newFixedThreadPool(5);
     private static ExecutorService dailyExecutorService = Executors.newFixedThreadPool(5);
-
+    private static ExecutorService balanceExecutorService = Executors.newFixedThreadPool(5);
+    @Autowired
+    private IDailyBalanceReportService dailyBalanceReportService;
     @XxlJob("nowDateAccountHour")
     public void nowDateAccountHour() throws Exception {
         String param = XxlJobHelper.getJobParam(); // 执行参数
@@ -178,4 +177,27 @@ public class AdqAccountReportJob {
             adqAdIncomeService.getAdqAdIncomeRate(app, appletId, yesDate, yesDate);
         }
     }
+
+
+    @XxlJob("yesDateBalance")
+    public void yesDateBalance() throws Exception {
+        String param = XxlJobHelper.getJobParam(); // 执行参数
+        if (Check.isNull(param)) {
+            log.error("入参为空");
+            return;
+        }
+
+        String nowDate = DateUtils.getNowDate("yyyy-MM-dd");
+        String yesDate = DateUtils.getAnotherDay("yyyy-MM-dd", nowDate, -1);
+        String[] s = param.split("_");
+        Long advertiserId = Long.valueOf(s[0]);
+        String accessToken = s[1];
+        balanceExecutorService.submit(new Runnable() {
+            @Override
+            public void run() {
+                dailyBalanceReportService.getAdqBalanceReport(advertiserId, accessToken, yesDate, yesDate, 1, null);
+            }
+        });
+    }
+
 }