|
@@ -2,14 +2,16 @@ package cn.com.ctop.job.kuaishou.handler;
|
|
|
|
|
|
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.service.IRuleDataTargetKuaishouService;
|
|
import cn.com.ctop.kuaishou.modules.report.service.IRuleKuaiShouPlanService;
|
|
import cn.com.ctop.kuaishou.modules.report.service.IRuleKuaiShouPlanService;
|
|
import com.xxl.job.core.context.XxlJobHelper;
|
|
import com.xxl.job.core.context.XxlJobHelper;
|
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
|
-import org.jeecg.common.util.DateUtils;
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Component;
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
|
|
+import java.util.HashMap;
|
|
import java.util.List;
|
|
import java.util.List;
|
|
|
|
+import java.util.Map;
|
|
import java.util.concurrent.ExecutorService;
|
|
import java.util.concurrent.ExecutorService;
|
|
import java.util.concurrent.Executors;
|
|
import java.util.concurrent.Executors;
|
|
|
|
|
|
@@ -17,17 +19,22 @@ import java.util.concurrent.Executors;
|
|
public class RuleKuaiShouDataTargetCleanJob {
|
|
public class RuleKuaiShouDataTargetCleanJob {
|
|
@Autowired
|
|
@Autowired
|
|
private ICtopOauthTokenService oauthTokenService;
|
|
private ICtopOauthTokenService oauthTokenService;
|
|
-
|
|
|
|
@Autowired
|
|
@Autowired
|
|
private IRuleKuaiShouPlanService ruleKuaiShouPlanService;
|
|
private IRuleKuaiShouPlanService ruleKuaiShouPlanService;
|
|
-
|
|
|
|
|
|
+ @Autowired
|
|
|
|
+ private IRuleDataTargetKuaishouService ruleDataTargetKuaishouService;
|
|
private ExecutorService executorService = Executors.newFixedThreadPool(10);
|
|
private ExecutorService executorService = Executors.newFixedThreadPool(10);
|
|
|
|
|
|
@XxlJob("ruleKuaiShouDataTargetCleanJob")
|
|
@XxlJob("ruleKuaiShouDataTargetCleanJob")
|
|
public void execute() throws Exception {
|
|
public void execute() throws Exception {
|
|
XxlJobHelper.log("规则预警定向维度数据开始清洗");
|
|
XxlJobHelper.log("规则预警定向维度数据开始清洗");
|
|
List<CtopOauthToken> tokens = oauthTokenService.selectKuaiShouToken();
|
|
List<CtopOauthToken> tokens = oauthTokenService.selectKuaiShouToken();
|
|
- tokens.forEach(token -> executorService.submit(() -> ruleKuaiShouPlanService.cleanRuleDataTarget(token.getAccountId(), 1)));
|
|
|
|
|
|
+ tokens.forEach(token -> executorService.submit(() ->{
|
|
|
|
+ Map<String,Object>params = new HashMap<>();
|
|
|
|
+ params.put("account_id",token.getAccountId());
|
|
|
|
+ ruleDataTargetKuaishouService.removeByMap(params);
|
|
|
|
+ ruleKuaiShouPlanService.cleanRuleDataTarget(token.getAccountId(), 1);
|
|
|
|
+ }));
|
|
}
|
|
}
|
|
|
|
|
|
}
|
|
}
|