|
@@ -4,7 +4,6 @@ import cn.com.ctop.bytedance.entity.BytedanceReportMaterialRetry;
|
|
import cn.com.ctop.bytedance.service.IBytedanceReportService;
|
|
import cn.com.ctop.bytedance.service.IBytedanceReportService;
|
|
import cn.com.ctop.common.module.entity.CtopOauthToken;
|
|
import cn.com.ctop.common.module.entity.CtopOauthToken;
|
|
import cn.com.ctop.common.module.service.ICtopOauthTokenService;
|
|
import cn.com.ctop.common.module.service.ICtopOauthTokenService;
|
|
-import cn.com.ctop.common.module.utils.CtopAdConstant;
|
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.apache.commons.lang.StringUtils;
|
|
import org.apache.commons.lang.StringUtils;
|
|
@@ -13,8 +12,6 @@ import org.jeecg.common.util.DateUtils;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.web.bind.annotation.*;
|
|
import org.springframework.web.bind.annotation.*;
|
|
|
|
|
|
-import java.util.ArrayList;
|
|
|
|
-import java.util.Date;
|
|
|
|
import java.util.List;
|
|
import java.util.List;
|
|
import java.util.concurrent.ExecutorService;
|
|
import java.util.concurrent.ExecutorService;
|
|
import java.util.concurrent.Executors;
|
|
import java.util.concurrent.Executors;
|
|
@@ -147,15 +144,6 @@ public class BytedanceReportController {
|
|
return result;
|
|
return result;
|
|
}
|
|
}
|
|
|
|
|
|
- //非异步
|
|
|
|
- //for (CtopOauthToken token : tokens) {
|
|
|
|
- // //if(token.getAccountId() == 1647352267707396L){
|
|
|
|
- // bytedanceReportService.bytedanceMaterialReport(token,startDate,endDate);
|
|
|
|
- // //}
|
|
|
|
- //}
|
|
|
|
- ////}
|
|
|
|
-
|
|
|
|
- //多线程
|
|
|
|
final ExecutorService executorService = Executors.newFixedThreadPool(8);
|
|
final ExecutorService executorService = Executors.newFixedThreadPool(8);
|
|
tokens.forEach(token -> {
|
|
tokens.forEach(token -> {
|
|
executorService.submit(new Runnable() {
|
|
executorService.submit(new Runnable() {
|