|
|
@@ -24,7 +24,7 @@ public class BytedanceCdpProjectJob {
|
|
|
@Autowired
|
|
|
private IBytedanceCdpProjectService cdpProjectService;
|
|
|
|
|
|
- private static ExecutorService allService = Executors.newFixedThreadPool(4);
|
|
|
+ private static ExecutorService allService = Executors.newFixedThreadPool(6);
|
|
|
private static ExecutorService allttService = Executors.newFixedThreadPool(2);
|
|
|
private static ExecutorService allwxService = Executors.newFixedThreadPool(2);
|
|
|
private static ExecutorService allt2Service = Executors.newFixedThreadPool(2);
|
|
|
@@ -41,6 +41,7 @@ public class BytedanceCdpProjectJob {
|
|
|
log.info("[getAll] 任务启动...");
|
|
|
List<Long> ids = cdpProjectService.queryAllAdverIdList("");
|
|
|
if (!Check.isNull(ids)) {
|
|
|
+ log.info("总数:{}", ids.size());
|
|
|
ids.forEach(id -> allService.submit(() -> cdpProjectService.getpromotionList(id, null)
|
|
|
));
|
|
|
}
|