package cn.gistack.sm.patrol.feign;
|
|
import cn.gistack.sm.intelligentCall.service.CallService;
|
import cn.gistack.sm.patrol.entity.PatrolTask;
|
import cn.gistack.sm.patrol.service.IPatrolTaskService;
|
import cn.gistack.sm.sjztmd.entity.PatrolResponsiblePerson;
|
import cn.gistack.sm.sjztmd.service.IAttResManagePersonService;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import lombok.AllArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springblade.core.tenant.annotation.NonDS;
|
import org.springblade.core.tool.utils.DateUtil;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
import springfox.documentation.annotations.ApiIgnore;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.concurrent.atomic.AtomicInteger;
|
|
/**
|
* @ClassName SM服务Feign实现类
|
* @Description TODO
|
* @Author zhongrj
|
* @Date 2023-06-03
|
*/
|
@NonDS
|
@ApiIgnore
|
@RestController
|
@AllArgsConstructor
|
@Slf4j
|
public class PatrolTaskImplClient implements PatrolTaskClient {
|
|
private final IPatrolTaskService patrolTaskService;
|
|
private final IAttResManagePersonService attResManagePersonService;
|
|
/**
|
* 给巡查责任人定时创建任务执行器
|
* @param processDefinitionId
|
* @param taskType
|
* @param title
|
* @param content
|
* @return
|
*/
|
@Override
|
@GetMapping(CREATE_TASK_JOB_HANDLER)
|
public List<Integer> createTaskJobHandler(String processDefinitionId,
|
String taskType,
|
String title,
|
String content) {
|
List<PatrolResponsiblePerson> patrolResponsiblePersonList = attResManagePersonService.getPatrolResponsiblePersonAll();
|
AtomicInteger failureCount = new AtomicInteger();
|
patrolResponsiblePersonList.forEach(item -> {
|
log.info("当前创建任务对象:" + JSON.toJSONString(item));
|
try {
|
PatrolTask patrolTask = new PatrolTask();
|
patrolTask.setProcessDefinitionId(processDefinitionId);
|
patrolTask.setToUserId(item.getUserId());
|
patrolTask.setProjectId(item.getResGuid());
|
patrolTask.setReservoirName(item.getName());
|
// 开始时间-结束时间
|
patrolTask.setStartTime(DateUtil.format(new Date(),"yyyy-MM-dd 00:00:00"));
|
patrolTask.setEndTime(DateUtil.format(new Date(),"yyyy-MM-dd 23:59:59"));
|
// 标题格式 月-日 水库名称 每日巡检任务
|
patrolTask.setTitle(DateUtil.format(new Date(),"MM-dd") + item.getName() + "-" + title);
|
patrolTask.setContent(DateUtil.format(new Date(),"yyyyMMdd") +content);
|
patrolTask.setTaskType(taskType);
|
// 创建任务
|
patrolTaskService.startProcess(patrolTask);
|
} catch (Exception e) {
|
log.error("创建任务失败：" + e.getMessage());
|
log.error("创建任务失败对象：" + JSON.toJSONString(item));
|
failureCount.getAndIncrement();
|
}
|
|
});
|
List<Integer> list = new ArrayList<>();
|
list.add(patrolResponsiblePersonList.size());
|
list.add(failureCount.get());
|
// 返回
|
return list;
|
}
|
}
|
