Переглянути джерело

Merge #13 into master from pingkang

fix

* pingkang: (1 commits)
  fix

Signed-off-by: 1129979389@qq.com <accounts_6361eaad7b63b44dd7833e63@mail.teambition.com>
Merged-by: 1129979389@qq.com <accounts_6361eaad7b63b44dd7833e63@mail.teambition.com>

CR-link: https://codeup.aliyun.com/60c06368dbbed34fe0f0c263/job/hr_job-adq/change/13
huangpingkang 11 місяців тому
батько
коміт
5053303b0d

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

@@ -36,6 +36,7 @@ public class AdqRetryReportJob {
     private static ExecutorService flowExecutorService = Executors.newFixedThreadPool(2);
 
     private static ExecutorService dailyExecutorService = Executors.newFixedThreadPool(5);
+    private static ExecutorService adIncomeExecutorService = Executors.newFixedThreadPool(1);
 
     @Autowired
     private IAdqCreativeReportService adqReportService;
@@ -157,7 +158,6 @@ public class AdqRetryReportJob {
 
         List<JSONObject> adqAdIncomeRetryJob = adqAdIncomeService.getAdqAdIncomeRetryJob();
         if (!Check.isNull(adqAdIncomeRetryJob)) {
-            ExecutorService executorService = Executors.newFixedThreadPool(1);
             for (int i = 0; i < adqAdIncomeRetryJob.size(); i++) {
                 JSONObject jsonObject = adqAdIncomeRetryJob.get(i);
                 Long id = jsonObject.getLong("id");
@@ -167,7 +167,7 @@ public class AdqRetryReportJob {
                 JSONObject msg = jsonObject.getJSONObject("msg");
                 String appId = msg.getString("app_id");
                 Long appletId = msg.getLong("applet_id");
-                executorService.submit(new Runnable() {
+                adIncomeExecutorService.submit(new Runnable() {
                     @Override
                     public void run() {
                         adqAdIncomeService.getAdqAdIncome(startDate, endDate, appId, appletId, 1, null, id, isSend);