|
@@ -46,7 +46,7 @@ public class KuaishouHourlyReportLoadJob implements Job {
|
|
log.info("定时获取头条数据异常:为获取到可用的token");
|
|
log.info("定时获取头条数据异常:为获取到可用的token");
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
- executorService = Executors.newFixedThreadPool(2);
|
|
|
|
|
|
+ executorService = Executors.newFixedThreadPool(10);
|
|
countDownLatch = new CountDownLatch(tokens.size());
|
|
countDownLatch = new CountDownLatch(tokens.size());
|
|
Date finalGetDate = getDate;
|
|
Date finalGetDate = getDate;
|
|
tokens.forEach(token -> {
|
|
tokens.forEach(token -> {
|
|
@@ -61,7 +61,6 @@ public class KuaishouHourlyReportLoadJob implements Job {
|
|
kuaishouInterfaceService.getAdvertiserGroupReportHourly(token, finalGetDate, finalGetDate);
|
|
kuaishouInterfaceService.getAdvertiserGroupReportHourly(token, finalGetDate, finalGetDate);
|
|
//4: 获取广告创意信息数据
|
|
//4: 获取广告创意信息数据
|
|
kuaishouInterfaceService.getAdvertiserCreativeReportHourly(token, finalGetDate, finalGetDate);
|
|
kuaishouInterfaceService.getAdvertiserCreativeReportHourly(token, finalGetDate, finalGetDate);
|
|
- kuaishouInterfaceService.updateCreativeReportHourlyStatistic(token, finalGetDate);
|
|
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
e.printStackTrace();
|
|
} finally {
|
|
} finally {
|
|
@@ -76,5 +75,8 @@ public class KuaishouHourlyReportLoadJob implements Job {
|
|
e.printStackTrace();
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
executorService.shutdown();
|
|
executorService.shutdown();
|
|
|
|
+ for (CtopOauthToken token : tokens) {
|
|
|
|
+ kuaishouInterfaceService.updateCreativeReportHourlyStatistic(token, getDate);
|
|
|
|
+ }
|
|
}
|
|
}
|
|
}
|
|
}
|