Przeglądaj źródła

adq定时任务

yumeng 8 godzin temu
rodzic
commit
309fe997ed

+ 2 - 1
job-adq/src/main/java/cn/com/ctop/job/adq/handler/AdqAccountReportJob.java

@@ -31,6 +31,7 @@ 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 dailyMaterialExecutorService = Executors.newFixedThreadPool(5);
 
     @XxlJob("nowDateAccountHour")
     public void nowDateAccountHour() throws Exception {
@@ -113,7 +114,7 @@ public class AdqAccountReportJob {
         String[] s = param.split("_");
         Long advertiserId = Long.valueOf(s[0]);
         String accessToken = s[1];
-        dailyExecutorService.submit(new Runnable() {
+        dailyMaterialExecutorService.submit(new Runnable() {
             @Override
             public void run() {
                 adqMaterialReportService.getAdqMaterialDailyReport(advertiserId, accessToken, yesDate, yesDate, 1, 1, null, 0);