|
@@ -890,17 +890,17 @@ public class TestController {
|
|
return result;
|
|
return result;
|
|
}
|
|
}
|
|
|
|
|
|
- //executorService = Executors.newFixedThreadPool(3);
|
|
|
|
|
|
+ executorService = Executors.newFixedThreadPool(3);
|
|
tokens.forEach(token -> {
|
|
tokens.forEach(token -> {
|
|
- // executorService.submit(new Runnable() {
|
|
|
|
- // @Override
|
|
|
|
- // public void run() {
|
|
|
|
- log.info("获取操作记录开始:accountId:{},startDate:{},endDate:{}", token.getAccountId(), startDate, endDate);
|
|
|
|
- kuaishouInterfaceService2.getOperationRecord(token.getAccountId(), token.getAccessToken(), operationTarget, startDate, endDate);
|
|
|
|
- log.info("获取操作记录开始:accountId:{}", token.getAccountId());
|
|
|
|
- // }
|
|
|
|
|
|
+ executorService.submit(new Runnable() {
|
|
|
|
+ @Override
|
|
|
|
+ public void run() {
|
|
|
|
+ log.info("获取操作记录开始:accountId:{},startDate:{},endDate:{}", token.getAccountId(), startDate, endDate);
|
|
|
|
+ kuaishouInterfaceService2.getOperationRecord(token.getAccountId(), token.getAccessToken(), operationTarget, startDate, endDate);
|
|
|
|
+ log.info("获取操作记录开始:accountId:{}", token.getAccountId());
|
|
|
|
+ }
|
|
|
|
+ });
|
|
});
|
|
});
|
|
- //});
|
|
|
|
}else{
|
|
}else{
|
|
QueryWrapper<CtopOauthToken> queryWrapper = new QueryWrapper<>();
|
|
QueryWrapper<CtopOauthToken> queryWrapper = new QueryWrapper<>();
|
|
queryWrapper.eq("account_id", accountId);
|
|
queryWrapper.eq("account_id", accountId);
|