From 03b2e2034f73abfe5f865a72361fee9fa5c1feec Mon Sep 17 00:00:00 2001
From: guoshilong <123456>
Date: Mon, 25 Sep 2023 16:20:54 +0800
Subject: [PATCH] 根据超汛限和病险对水库下发巡查任务
---
skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/PatrolXxlJob.java | 22 ++++++++++++++++++++++
1 files changed, 22 insertions(+), 0 deletions(-)
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/PatrolXxlJob.java b/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/PatrolXxlJob.java
index bcfb89e..2014861 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/PatrolXxlJob.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/PatrolXxlJob.java
@@ -44,4 +44,26 @@
XxlJobLogger.log("总数量：<span style='color:red'>" + taskJobHandler.get(0) + "</span> ... 失败数量:<span style='color:red'>" + taskJobHandler.get(1) + "</span> ");
return ReturnT.SUCCESS;
}
+
+ /**
+ * 给巡查责任人定时创建任务执行器
+ * @param param
+ * @return
+ * @throws Exception
+ */
+ @XxlJob("createTaskJobByConditionHandler")
+ public ReturnT<String> createTaskJobByConditionHandler(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.createTaskJobByConditionHandler(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;
+ }
}
--
Gitblit v1.9.3