|
@@ -24,6 +24,7 @@ import java.util.concurrent.Executors;
|
|
|
public class AdqCreativeReportJob {
|
|
public class AdqCreativeReportJob {
|
|
|
private static ExecutorService hourExecutorService = Executors.newFixedThreadPool(5);
|
|
private static ExecutorService hourExecutorService = Executors.newFixedThreadPool(5);
|
|
|
private static ExecutorService dailyExecutorService = Executors.newFixedThreadPool(5);
|
|
private static ExecutorService dailyExecutorService = Executors.newFixedThreadPool(5);
|
|
|
|
|
+ private static ExecutorService nowDailyExecutorService = Executors.newFixedThreadPool(5);
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private IAdqCreativeReportService adqReportService;
|
|
private IAdqCreativeReportService adqReportService;
|
|
|
|
|
|
|
@@ -91,4 +92,26 @@ public class AdqCreativeReportJob {
|
|
|
});
|
|
});
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+
|
|
|
|
|
+ @XxlJob("nowDateCreativeDaily")
|
|
|
|
|
+ public void nowDateCreativeDaily() throws Exception {
|
|
|
|
|
+ String param = XxlJobHelper.getJobParam(); // 执行参数
|
|
|
|
|
+ if (Check.isNull(param)) {
|
|
|
|
|
+ log.error("入参为空");
|
|
|
|
|
+ return;
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ String nowDate = DateUtils.getNowDate("yyyy-MM-dd");
|
|
|
|
|
+ String[] s = param.split("_");
|
|
|
|
|
+ Long advertiserId = Long.valueOf(s[0]);
|
|
|
|
|
+ String accessToken = s[1];
|
|
|
|
|
+ nowDailyExecutorService.submit(new Runnable() {
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public void run() {
|
|
|
|
|
+ adqReportService.getAdqCreativeDaily(advertiserId, accessToken, nowDate, nowDate, 1, 1);
|
|
|
|
|
+ }
|
|
|
|
|
+ });
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
}
|
|
}
|