|
@@ -2,7 +2,6 @@ package cn.com.ctop.job.kuaishou.handler;
|
|
|
|
|
|
import cn.com.ctop.common.module.entity.CtopOauthToken;
|
|
|
import cn.com.ctop.common.module.service.ICtopOauthTokenService;
|
|
|
-import cn.com.ctop.common.module.utils.Check;
|
|
|
import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouGroup;
|
|
|
import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouGroupService;
|
|
|
import cn.com.ctop.kuaishou.modules.batch.service.IKuaishouStrategyService;
|
|
@@ -118,27 +117,27 @@ public class KuaishouDailyAudienceReportJob {
|
|
|
int page = 1;
|
|
|
int pageSize = 2000;
|
|
|
activeTokens.forEach(token -> executorService2.submit(() -> {
|
|
|
- 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);
|
|
|
- }));
|
|
|
+ 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);
|
|
|
}));
|
|
|
}
|
|
|
|
|
|
- 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(800);
|
|
|
+ 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);
|
|
|
}
|
|
|
- } catch (Exception e) {
|
|
|
- XxlJobHelper.log("定时获取人群分析报表数据异常", e);
|
|
|
- }
|
|
|
+ }));
|
|
|
}
|
|
|
|
|
|
}
|