星图多线程处理

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceReportRetryJob.java

@@ -54,7 +54,8 @@ public class BytedanceReportRetryJob {
     private static ExecutorService productDailyRetrExecutor = Executors.newFixedThreadPool(2);
 
     private static ExecutorService flowDailyRetrExecutor = Executors.newFixedThreadPool(2);
-    private static ExecutorService changduExecutorService = Executors.newFixedThreadPool(2);
+    private static ExecutorService changduExecutorService = Executors.newFixedThreadPool(1);
+    private static ExecutorService xingTuExecutorService = Executors.newFixedThreadPool(2);
 
     @XxlJob("retryReport")
     public void retryReport() throws Exception {
@@ -206,21 +207,21 @@ public class BytedanceReportRetryJob {
                 Long taskId = jsonObject.getJSONObject("msg").getLong("taskId");
 
                 if ("xingtu_task_list".equalsIgnoreCase(dataDimension)) {
-                    changduExecutorService.submit(new Runnable() {
+                    xingTuExecutorService.submit(new Runnable() {
                         @Override
                         public void run() {
                             bytedanceXingTuService.getXingTuTaskList(advertiserId, accessToken, startDate, endDate, 1, id, null, isSend);
                         }
                     });
                 } else if ("xingtu_task_info".equalsIgnoreCase(dataDimension)) {
-                    changduExecutorService.submit(new Runnable() {
+                    xingTuExecutorService.submit(new Runnable() {
                         @Override
                         public void run() {
                             bytedanceXingTuService.getXingTuTaskInfo(advertiserId, taskId, accessToken, id, null, isSend);
                         }
                     });
                 } else if ("xingtu_task_report".equalsIgnoreCase(dataDimension)) {
-                    changduExecutorService.submit(new Runnable() {
+                    xingTuExecutorService.submit(new Runnable() {
                         @Override
                         public void run() {
                             bytedanceXingTuService.getXingTuTaskReport(advertiserId, taskId, accessToken, 1, id, null, isSend);