|
@@ -116,8 +116,9 @@ public class KuaishouDailyAudienceReportJob {
|
|
|
int page = 1;
|
|
|
int pageSize = 2000;
|
|
|
for (CtopOauthToken token : activeTokens) {
|
|
|
+ List<KuaiShouGroup> kuaiShouGroups = kuaiShouGroupService.queryUnitInfoByAccountId(token.getAccountId());
|
|
|
dates.forEach(date -> executorService.submit(() -> {
|
|
|
- getAudienceReportData(token, date, "ageSegment", page, pageSize);
|
|
|
+ getAudienceReportData(kuaiShouGroups, token, date, "ageSegment", page, pageSize);
|
|
|
// getAudienceReportData(token, date, "gender", page, pageSize);
|
|
|
// getAudienceReportData(token, date, "businessInterestTags", page, pageSize);
|
|
|
// getAudienceReportData(token, date, "city", page, pageSize);
|
|
@@ -127,9 +128,8 @@ public class KuaishouDailyAudienceReportJob {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- private void getAudienceReportData(CtopOauthToken token, String date, String type, Integer page, Integer pageSize) {
|
|
|
+ private void getAudienceReportData(List<KuaiShouGroup> kuaiShouGroups, 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);
|