yumeng před 1 rokem
rodič
revize
62e3489949

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

@@ -86,7 +86,7 @@ public class AdqAccountReportJob {
         String[] s = param.split("_");
         Long advertiserId = Long.valueOf(s[0]);
         String accessToken = s[1];
-        hourExecutorService.submit(new Runnable() {
+        dailyExecutorService.submit(new Runnable() {
             @Override
             public void run() {
                 accountReportService.getAdqAccountDaily(advertiserId, accessToken, yesDate, yesDate, 1, 1);

+ 8 - 6
job-adq/src/main/java/cn/com/ctop/job/adq/handler/AdqRetryReportJob.java

@@ -24,8 +24,10 @@ import java.util.concurrent.Executors;
 @Component
 public class AdqRetryReportJob {
 
-    private static ExecutorService dailyExecutorService = Executors.newFixedThreadPool(2);
-    private static ExecutorService hourrExecutorService = Executors.newFixedThreadPool(2);
+    private static ExecutorService dailyCreativeExecutorService = Executors.newFixedThreadPool(2);
+    private static ExecutorService hourCreativeExecutorService = Executors.newFixedThreadPool(2);
+    private static ExecutorService hourrAccountExecutorService = Executors.newFixedThreadPool(2);
+    private static ExecutorService dailyAccountExecutorService = Executors.newFixedThreadPool(2);
 
 
     @Autowired
@@ -50,7 +52,7 @@ public class AdqRetryReportJob {
 
                 if ("creative".equals(dataDimension)) {
                     if (dataType.equals("hour")) { // 广告时报
-                        hourrExecutorService.submit(new Runnable() {
+                        dailyCreativeExecutorService.submit(new Runnable() {
                             @Override
                             public void run() {
                                 if (!Check.isNull(accessToken)) {
@@ -60,7 +62,7 @@ public class AdqRetryReportJob {
                         });
                     }
                     if (dataType.equals("daily")) { // 广告日报
-                        dailyExecutorService.submit(new Runnable() {
+                        hourCreativeExecutorService.submit(new Runnable() {
                             @Override
                             public void run() {
                                 if (!Check.isNull(accessToken)) {
@@ -72,7 +74,7 @@ public class AdqRetryReportJob {
                     }
                 }else if("account".equals(dataDimension)){
                     if (dataType.equals("hour")) { // 广告时报
-                        hourrExecutorService.submit(new Runnable() {
+                        hourrAccountExecutorService.submit(new Runnable() {
                             @Override
                             public void run() {
                                 if (!Check.isNull(accessToken)) {
@@ -83,7 +85,7 @@ public class AdqRetryReportJob {
                     }
 
                     if (dataType.equals("daily")) { // 广告日报
-                        hourrExecutorService.submit(new Runnable() {
+                        dailyAccountExecutorService.submit(new Runnable() {
                             @Override
                             public void run() {
                                 if (!Check.isNull(accessToken)) {