From ae830f0421032b415ab505e8fbd82d257d01f1d5 Mon Sep 17 00:00:00 2001
From: guoshilong <123456>
Date: Tue, 05 Dec 2023 17:24:31 +0800
Subject: [PATCH] 大坝安全预警任务下发
---
skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/patrol/feign/PatrolTaskImplClient.java | 29 +++++++++++++++++++++++++++++
1 files changed, 29 insertions(+), 0 deletions(-)
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/patrol/feign/PatrolTaskImplClient.java b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/patrol/feign/PatrolTaskImplClient.java
index 1470f82..abde6fa 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/patrol/feign/PatrolTaskImplClient.java
+++ b/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结果集
--
Gitblit v1.9.3