guoshilong
2023-12-05 ae830f0421032b415ab505e8fbd82d257d01f1d5
skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/patrol/feign/PatrolTaskImplClient.java
@@ -4,7 +4,9 @@
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.AttResBase;
import cn.gistack.sm.sjztmd.entity.PatrolResponsiblePerson;
import cn.gistack.sm.sjztmd.service.IAttResBaseService;
import cn.gistack.sm.sjztmd.service.IAttResManagePersonService;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
@@ -52,6 +54,7 @@
   private static final String ONLINE = "http://10.42.6.192";
   private final IPatrolTaskService patrolTaskService;
   private final IAttResManagePersonService attResManagePersonService;
   private final IAttResBaseService attResBaseService;
   @Autowired
   private RestTemplate restTemplate;
@@ -111,6 +114,32 @@
      return taskJob;
   }
   @Override
   public String createTask(String processDefinitionId, String taskType, String title, String content, String resCd) {
      //根据水库id获取巡查责任人
      List<String> resList = new ArrayList<>();
      resList.add(resCd);
      List<PatrolResponsiblePerson> patrolResponsiblePersonByResCdList = attResManagePersonService.getPatrolResponsiblePersonByResCdList(resList);
      PatrolResponsiblePerson patrolResponsiblePerson = patrolResponsiblePersonByResCdList.get(0);
      //不确定是否有多个,循环下发
         PatrolTask patrolTask = new PatrolTask();
         patrolTask.setProcessDefinitionId(processDefinitionId);
         patrolTask.setToUserId(patrolResponsiblePerson.getUserId());
         patrolTask.setProjectId(resCd);
         patrolTask.setReservoirName(patrolResponsiblePerson.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(title);
         patrolTask.setContent(content);
         patrolTask.setTaskType(taskType);
         patrolTaskService.startProcess(patrolTask);
         String taskId = patrolTask.getId().toString();
         return taskId;
   }
   /**
    * 请求中台接口,返回resultList结果集