|
@@ -34,7 +34,6 @@ public class KuaishouDailyAudienceReportJob {
|
|
private IKuaishouStrategyService kuaishouStrategyService;
|
|
private IKuaishouStrategyService kuaishouStrategyService;
|
|
|
|
|
|
static ExecutorService executorService = Executors.newFixedThreadPool(35);
|
|
static ExecutorService executorService = Executors.newFixedThreadPool(35);
|
|
- static ExecutorService executorService2 = Executors.newFixedThreadPool(2);
|
|
|
|
|
|
|
|
@XxlJob("kuaishouDailyAudienceReportJob")
|
|
@XxlJob("kuaishouDailyAudienceReportJob")
|
|
public void execute() throws Exception {
|
|
public void execute() throws Exception {
|
|
@@ -116,28 +115,28 @@ public class KuaishouDailyAudienceReportJob {
|
|
|
|
|
|
int page = 1;
|
|
int page = 1;
|
|
int pageSize = 2000;
|
|
int pageSize = 2000;
|
|
- activeTokens.forEach(token -> executorService2.submit(() -> {
|
|
|
|
- getAudienceReportData(token, dates, "ageSegment", page, pageSize);
|
|
|
|
- // getAudienceReportData(token, date, "gender", page, pageSize);
|
|
|
|
- // getAudienceReportData(token, date, "businessInterestTags", page, pageSize);
|
|
|
|
- // getAudienceReportData(token, date, "city", page, pageSize);
|
|
|
|
- // getAudienceReportData(token, date, "clientId", page, pageSize);
|
|
|
|
- // getAudienceReportData(token, date, "province", page, pageSize);
|
|
|
|
- }));
|
|
|
|
|
|
+ for (CtopOauthToken token : activeTokens) {
|
|
|
|
+ dates.forEach(date -> executorService.submit(() -> {
|
|
|
|
+ getAudienceReportData(token, date, "ageSegment", page, pageSize);
|
|
|
|
+ // getAudienceReportData(token, date, "gender", page, pageSize);
|
|
|
|
+ // getAudienceReportData(token, date, "businessInterestTags", page, pageSize);
|
|
|
|
+ // getAudienceReportData(token, date, "city", page, pageSize);
|
|
|
|
+ // getAudienceReportData(token, date, "clientId", page, pageSize);
|
|
|
|
+ // getAudienceReportData(token, date, "province", page, pageSize);
|
|
|
|
+ }));
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
|
|
- private void getAudienceReportData(CtopOauthToken token, List<String> dates, String type, Integer page, Integer pageSize) {
|
|
|
|
- dates.forEach(date -> executorService.submit(() -> {
|
|
|
|
- try {
|
|
|
|
- List<KuaiShouGroup> kuaiShouGroups = kuaiShouGroupService.queryUnitInfoByAccountId(token.getAccountId());
|
|
|
|
- for (KuaiShouGroup kuaiShouGroup : kuaiShouGroups) {
|
|
|
|
- kuaishouAudienceReportDailyService.crowdAnalysisReport(token, date, type, kuaiShouGroup.getCampaignId(), kuaiShouGroup.getUnitId(), page, pageSize);
|
|
|
|
- Thread.sleep(800);
|
|
|
|
- }
|
|
|
|
- } catch (Exception e) {
|
|
|
|
- XxlJobHelper.log("定时获取人群分析报表数据异常", e);
|
|
|
|
|
|
+ private void getAudienceReportData(CtopOauthToken token, String date, String type, Integer page, Integer pageSize) {
|
|
|
|
+ try {
|
|
|
|
+ List<KuaiShouGroup> kuaiShouGroups = kuaiShouGroupService.queryUnitInfoByAccountId(token.getAccountId());
|
|
|
|
+ for (KuaiShouGroup kuaiShouGroup : kuaiShouGroups) {
|
|
|
|
+ kuaishouAudienceReportDailyService.crowdAnalysisReport(token, date, type, kuaiShouGroup.getCampaignId(), kuaiShouGroup.getUnitId(), page, pageSize);
|
|
|
|
+ Thread.sleep(600);
|
|
}
|
|
}
|
|
- }));
|
|
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
+ XxlJobHelper.log("定时获取人群分析报表数据异常", e);
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
|
|
}
|
|
}
|