|
|
@@ -25,7 +25,8 @@ import java.util.concurrent.Executors;
|
|
|
public class AdqAccountReportJob {
|
|
|
@Autowired
|
|
|
private IAdqAccountReportService accountReportService;
|
|
|
- private static ExecutorService hourExecutorService = Executors.newFixedThreadPool(3);
|
|
|
+ private static ExecutorService nowDateHourExecutorService = Executors.newFixedThreadPool(3);
|
|
|
+ private static ExecutorService yesDateHourExecutorService = Executors.newFixedThreadPool(3);
|
|
|
private static ExecutorService dailyExecutorService = Executors.newFixedThreadPool(3);
|
|
|
|
|
|
@XxlJob("nowDateAccountHour")
|
|
|
@@ -40,7 +41,7 @@ public class AdqAccountReportJob {
|
|
|
String[] s = param.split("_");
|
|
|
Long advertiserId = Long.valueOf(s[0]);
|
|
|
String accessToken = s[1];
|
|
|
- hourExecutorService.submit(new Runnable() {
|
|
|
+ nowDateHourExecutorService.submit(new Runnable() {
|
|
|
@Override
|
|
|
public void run() {
|
|
|
accountReportService.getAdqAccountHour(advertiserId, accessToken, nowDate, nowDate, 1, 1);
|
|
|
@@ -62,7 +63,7 @@ public class AdqAccountReportJob {
|
|
|
String[] s = param.split("_");
|
|
|
Long advertiserId = Long.valueOf(s[0]);
|
|
|
String accessToken = s[1];
|
|
|
- hourExecutorService.submit(new Runnable() {
|
|
|
+ yesDateHourExecutorService.submit(new Runnable() {
|
|
|
@Override
|
|
|
public void run() {
|
|
|
accountReportService.getAdqAccountHour(advertiserId, accessToken, yesDate, yesDate, 1, 1);
|