|
@@ -1,34 +1,39 @@
|
|
package cn.com.ctop.job.kuaishou.handler;
|
|
package cn.com.ctop.job.kuaishou.handler;
|
|
|
|
|
|
-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.Check;
|
|
import cn.com.ctop.common.module.utils.Check;
|
|
|
|
+import cn.com.ctop.common.module.utils.HttpUtils2;
|
|
import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouGroupTemplate;
|
|
import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouGroupTemplate;
|
|
import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouGroupTemplateService;
|
|
import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouGroupTemplateService;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
+import org.springframework.beans.factory.annotation.Value;
|
|
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;
|
|
|
|
|
|
@Component
|
|
@Component
|
|
public class KuaishouCreateCreativeJob {
|
|
public class KuaishouCreateCreativeJob {
|
|
|
|
|
|
-
|
|
|
|
@Autowired
|
|
@Autowired
|
|
private IKuaiShouGroupTemplateService groupTemplateService;
|
|
private IKuaiShouGroupTemplateService groupTemplateService;
|
|
@Autowired
|
|
@Autowired
|
|
private ICtopOauthTokenService tokenService;
|
|
private ICtopOauthTokenService tokenService;
|
|
- static ExecutorService executorService = Executors.newFixedThreadPool(5);
|
|
|
|
|
|
+
|
|
|
|
+ @Value("${xxl-job.requestUrl}")
|
|
|
|
+ private String jobUrl;
|
|
|
|
|
|
/**
|
|
/**
|
|
* 组创建成功-创意待创建
|
|
* 组创建成功-创意待创建
|
|
*/
|
|
*/
|
|
@XxlJob("kuaihouCreateCreative")
|
|
@XxlJob("kuaihouCreateCreative")
|
|
public void execute() {
|
|
public void execute() {
|
|
|
|
+ String url = jobUrl + "/jeecg-boot/batch/kuaiShouGroupTemplate/createUnitAgain";
|
|
QueryWrapper<KuaiShouGroupTemplate> templateQueryWrapper = new QueryWrapper<>();
|
|
QueryWrapper<KuaiShouGroupTemplate> templateQueryWrapper = new QueryWrapper<>();
|
|
templateQueryWrapper.eq("task_status", 2);
|
|
templateQueryWrapper.eq("task_status", 2);
|
|
templateQueryWrapper.eq("creative_status", 0);
|
|
templateQueryWrapper.eq("creative_status", 0);
|
|
@@ -39,18 +44,10 @@ public class KuaishouCreateCreativeJob {
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
for (KuaiShouGroupTemplate template : list) {
|
|
for (KuaiShouGroupTemplate template : list) {
|
|
- executorService.submit(new Runnable() {
|
|
|
|
- @Override
|
|
|
|
- public void run() {
|
|
|
|
- CtopOauthToken token = tokenService.getTokenByAccountId(template.getAccountId());
|
|
|
|
- if (Check.isNull(token)) {
|
|
|
|
- return;
|
|
|
|
- }
|
|
|
|
- groupTemplateService.createCreative(token.getAccessToken(), template.getUnitId(), template);
|
|
|
|
- }
|
|
|
|
- });
|
|
|
|
-
|
|
|
|
-
|
|
|
|
|
|
+ Map<String, Object> requestMap = new HashMap<>();
|
|
|
|
+ requestMap.put("id", template.getId());
|
|
|
|
+ HttpUtils2.httpGet(url, requestMap, null);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
+
|
|
}
|
|
}
|