Ver Fonte

adq定时任务

yumeng há 12 horas atrás
pai
commit
edd70cbdda

+ 0 - 1
job-adq/src/main/java/cn/com/ctop/job/adq/data/service/IAdqMaterialReportService.java

@@ -2,5 +2,4 @@ package cn.com.ctop.job.adq.data.service;
 
 public interface IAdqMaterialReportService {
     void getAdqMaterialDailyReport(Long advertiserId, String accessToken, String startDate, String endDate, Integer page, Integer isLog, Long errId, Integer isSend);
-    void getAdqMaterialDailyReport(Long advertiserId, String accessToken, String level, String startDate, String endDate, Integer page, Integer isLog, Long errId, Integer isSend);
 }

+ 1 - 2
job-adq/src/main/java/cn/com/ctop/job/adq/data/service/impl/AdqMaterialReportServiceImpl.java

@@ -40,8 +40,7 @@ public class AdqMaterialReportServiceImpl implements IAdqMaterialReportService {
     /*
     level  REPORT_LEVEL_MATERIAL_IMAGE REPORT_LEVEL_MATERIAL_VIDEO
      */
-    @Override
-    public void getAdqMaterialDailyReport(Long advertiserId, String accessToken, String level, String startDate, String endDate, Integer page, Integer isLog, Long errId, Integer isSend) {
+    private void getAdqMaterialDailyReport(Long advertiserId, String accessToken, String level, String startDate, String endDate, Integer page, Integer isLog, Long errId, Integer isSend) {
         try {
             Map<String, Object> paramsMap = new HashMap<>();
             paramsMap.put("access_token", accessToken);

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

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