|
@@ -33,29 +33,36 @@ public class KuaishouDailyAudienceReportJob {
|
|
|
@Autowired
|
|
|
private IKuaishouStrategyService kuaishouStrategyService;
|
|
|
|
|
|
- static ExecutorService executorService = Executors.newFixedThreadPool(35);
|
|
|
+ static ExecutorService executorService = null;
|
|
|
|
|
|
@XxlJob("kuaishouDailyAudienceReportJob")
|
|
|
public void execute() throws Exception {
|
|
|
- List<String> dates = new ArrayList<>();
|
|
|
- for (int i = 2; i < 33; i++) {
|
|
|
- String dat = DateUtils.getLastDay(DateUtils.date2Str(), i);
|
|
|
- dates.add(dat);
|
|
|
- }
|
|
|
- // 9556344、9743727、9743738、9812668、9901966、9767034
|
|
|
- CtopOauthToken token = tokenService.getTokenByAccountId(9556344L);
|
|
|
- int page = 1;
|
|
|
- int pageSize = 2000;
|
|
|
- List<KuaiShouGroup> kuaiShouGroups = kuaiShouGroupService.queryUnitInfoByAccountId(token.getAccountId());
|
|
|
- XxlJobHelper.log("---------------广告组:" + kuaiShouGroups.size());
|
|
|
- dates.forEach(date -> executorService.submit(() -> {
|
|
|
- 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);
|
|
|
- // getAudienceReportData(token, date, "clientId", page, pageSize);
|
|
|
- // getAudienceReportData(token, date, "province", page, pageSize);
|
|
|
- }));
|
|
|
+ Thread thread = new Thread() {
|
|
|
+ @Override
|
|
|
+ public void run() {
|
|
|
+ List<String> dates = new ArrayList<>();
|
|
|
+ for (int i = 2; i < 33; i++) {
|
|
|
+ String dat = DateUtils.getLastDay(DateUtils.date2Str(), i);
|
|
|
+ dates.add(dat);
|
|
|
+ }
|
|
|
+ XxlJobHelper.log("-----------清洗日期:" + dates.toString());
|
|
|
+ // 9556344、9743727、9743738、9812668、9901966、9767034
|
|
|
+ CtopOauthToken token = tokenService.getTokenByAccountId(9556344L);
|
|
|
+ int page = 1;
|
|
|
+ int pageSize = 2000;
|
|
|
+ List<KuaiShouGroup> kuaiShouGroups = kuaiShouGroupService.queryUnitInfoByAccountId(token.getAccountId());
|
|
|
+ executorService = Executors.newFixedThreadPool(33);
|
|
|
+ for (String date : dates) {
|
|
|
+ executorService.submit(new Runnable() {
|
|
|
+ @Override
|
|
|
+ public void run() {
|
|
|
+ getAudienceReportData(kuaiShouGroups, token, date, "ageSegment", page, pageSize);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
+ };
|
|
|
+ thread.start();
|
|
|
}
|
|
|
|
|
|
private void getAudienceReportData(List<KuaiShouGroup> kuaiShouGroups, CtopOauthToken token, String date, String type, Integer page, Integer pageSize) {
|