|
@@ -1,6 +1,7 @@
|
|
|
package cn.com.ctop.job.bytedance.handler;
|
|
|
|
|
|
import cn.com.ctop.common.module.utils.Check;
|
|
|
+import cn.com.ctop.toutiao.modules.report.service.IBytedanceCreativeDailyReportService;
|
|
|
import com.xxl.job.core.biz.model.ReturnT;
|
|
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
|
|
import com.xxl.job.core.log.XxlJobLogger;
|
|
@@ -19,17 +20,17 @@ import java.util.concurrent.Executors;
|
|
|
@Component
|
|
|
public class ByteDanceCleanMaterialJob {
|
|
|
@Autowired
|
|
|
- private IByteDanceCleanMaterialReportService cleanMaterialService;
|
|
|
+ private IBytedanceCreativeDailyReportService creativeDailyReportService;
|
|
|
static ExecutorService executorService = Executors.newFixedThreadPool(3);
|
|
|
|
|
|
@XxlJob("byteDanceCleanMaterial")
|
|
|
public ReturnT<String> execute(String param) throws Exception {
|
|
|
- List<String> signatureList = cleanMaterialService.getSignature();
|
|
|
+ List<String> signatureList = creativeDailyReportService.getSignatureList();
|
|
|
if (Check.isNull(signatureList)) {
|
|
|
XxlJobLogger.log("头条素材数据获取为空");
|
|
|
return ReturnT.FAIL;
|
|
|
}
|
|
|
- signatureList.forEach(signature -> executorService.submit(() -> cleanMaterialService.calculationMaterialReport(signature)));
|
|
|
+ signatureList.forEach(signature -> executorService.submit(() -> creativeDailyReportService.calculationMaterialReport(signature)));
|
|
|
return ReturnT.SUCCESS;
|
|
|
}
|
|
|
}
|