package cn.gistack.job.executor.jobhandler;
|
|
import cn.gistack.sm.patrol.feign.PatrolTaskClient;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.xxl.job.core.biz.model.ReturnT;
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
import com.xxl.job.core.log.XxlJobLogger;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import java.util.List;
|
|
/**
|
* 巡查任务定时任务执行器
|
* @author zhongrj
|
* @date 2023-06-03
|
*/
|
@Component
|
public class PatrolXxlJob {
|
|
@Autowired
|
private PatrolTaskClient patrolTasClient;
|
|
/**
|
* 给巡查责任人定时创建任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("createTaskJobHandler")
|
public ReturnT<String> createTaskJobHandler(String param){
|
XxlJobLogger.log("开始自动创建任务...");
|
JSONObject jsonParam = JSON.parseObject(param);
|
String processDefinitionId = jsonParam.getString("processDefinitionId");
|
String taskType = jsonParam.getString("taskType");
|
String title = jsonParam.getString("title");
|
String content = jsonParam.getString("content");
|
// 远程调用
|
List<Integer> taskJobHandler = patrolTasClient.createTaskJobHandler(processDefinitionId, taskType, title, content);
|
// 打印响应数据
|
XxlJobLogger.log("结束自动创建任务...");
|
XxlJobLogger.log("总数量：<span style='color:red'>" + taskJobHandler.get(0) + "</span> ... 失败数量:<span style='color:red'>" + taskJobHandler.get(1) + "</span> ");
|
return ReturnT.SUCCESS;
|
}
|
}
|
