From 18ba30c8fa8e3b2c4f07bef1f48a3f42ce06b343 Mon Sep 17 00:00:00 2001
From: xieb <vip_xiaobin810@163.com>
Date: Fri, 24 May 2024 14:14:26 +0800
Subject: [PATCH] 大坝监测渗压告警-渗压水位变幅黄色告警增加详情
---
skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeHandle.java | 38 ++++++
skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/AlarmXxlJob.java | 289 +++++++++++++++++++++++++++++++++++++++++------
skjcmanager/skjcmanager-service-api/skjcmanager-alerts-api/src/main/java/cn/gistack/alerts/alarmRule/entity/AlarmRecord.java | 2
3 files changed, 288 insertions(+), 41 deletions(-)
diff --git a/skjcmanager/skjcmanager-service-api/skjcmanager-alerts-api/src/main/java/cn/gistack/alerts/alarmRule/entity/AlarmRecord.java b/skjcmanager/skjcmanager-service-api/skjcmanager-alerts-api/src/main/java/cn/gistack/alerts/alarmRule/entity/AlarmRecord.java
index 3cbcdfe..dcc1c2d 100644
--- a/skjcmanager/skjcmanager-service-api/skjcmanager-alerts-api/src/main/java/cn/gistack/alerts/alarmRule/entity/AlarmRecord.java
+++ b/skjcmanager/skjcmanager-service-api/skjcmanager-alerts-api/src/main/java/cn/gistack/alerts/alarmRule/entity/AlarmRecord.java
@@ -54,4 +54,6 @@
private String taskId;
private String monitorData;
+
+ private String remark;
}
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeHandle.java b/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeHandle.java
index 2116a79..10d09d0 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeHandle.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeHandle.java
@@ -625,6 +625,44 @@
return null;
}
+ public AlarmRecord saveAlarmRecord(List<String> list, AlarmRule alarmRule, String uuid, String remark) {
+ AlarmRecord alarmRecord = alarmRecordService.getOne(new QueryWrapper<AlarmRecord>()
+ .eq("temp_code", uuid)
+ .eq("alarm_rule_id", alarmRule.getId())
+ .eq("reservoir_number", list.get(1))
+ .eq("alarm_survey_station_code",list.get(0))
+ );
+ if (null != alarmRecord) {
+ //删除测值
+ list.remove(3);
+ // 删除测站编号
+ list.remove(0);
+ return alarmRecord;
+ } else {
+ AlarmRecord alarm = new AlarmRecord();
+ // 设置相关信息
+ alarm.setAlarmRuleId(alarmRule.getId().toString());
+ // 分别设置测站编号和水库编码
+ alarm.setAlarmSurveyStationCode(list.get(0));
+ alarm.setReservoirNumber(list.get(1));
+ alarm.setAlarmCondition(alarmRule.getRuleRemark());
+ alarm.setTempCode(uuid);
+ alarm.setMonitorData(list.get(3));
+ alarm.setRemark(remark);
+ //删除测值
+ list.remove(3);
+ // 新增
+ boolean save = alarmRecordService.save(alarm);
+ // 删除测站编号
+ list.remove(0);
+ if (save) {
+ return alarm;
+ }
+ }
+ // 返回
+ return null;
+ }
+
/**
* 查询告警人员信息
*
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/AlarmXxlJob.java b/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/AlarmXxlJob.java
index 657409e..02cf8c0 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/AlarmXxlJob.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/AlarmXxlJob.java
@@ -8,6 +8,8 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
/**
@@ -31,7 +33,12 @@
public ReturnT<String> waterInfoNotHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位信息接收不到","","waterInfoNotHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位信息接收不到","","waterInfoNotHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -47,7 +54,12 @@
public ReturnT<String> waterDataExcHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位数据异常","","waterDataExcHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位数据异常","","waterDataExcHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -63,7 +75,12 @@
public ReturnT<String> waterLessDeadHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位超低于死水位","","waterLessDeadHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位超低于死水位","","waterLessDeadHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -79,7 +96,12 @@
public ReturnT<String> waterMoreDeadLessHJHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位高于死水位，低于旱警水位","","waterMoreDeadLessHJHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位高于死水位，低于旱警水位","","waterMoreDeadLessHJHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -95,7 +117,12 @@
public ReturnT<String> waterComeOverHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位接近汛限告警","","waterComeOverHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位接近汛限告警","","waterComeOverHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -111,7 +138,12 @@
public ReturnT<String> waterFirstOverHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位初次超汛限告警","","waterFirstOverHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位初次超汛限告警","","waterFirstOverHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -127,7 +159,12 @@
public ReturnT<String> waterSmallScaleOverHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位小幅超汛限告警","","waterSmallScaleOverHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位小幅超汛限告警","","waterSmallScaleOverHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -143,7 +180,12 @@
public ReturnT<String> waterBigScaleOverHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位大幅超汛限告警","","waterBigScaleOverHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位大幅超汛限告警","","waterBigScaleOverHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -159,7 +201,12 @@
public ReturnT<String> waterComeDesignHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位接近设计洪水位告警","","waterComeDesignHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位接近设计洪水位告警","","waterComeDesignHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -175,7 +222,12 @@
public ReturnT<String> waterMoreDesignHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位超设计洪水位告警","","waterMoreDesignHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位超设计洪水位告警","","waterMoreDesignHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -191,7 +243,12 @@
public ReturnT<String> waterMoreCheckHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位超校核洪水位告警","","waterMoreCheckHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位超校核洪水位告警","","waterMoreCheckHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -207,7 +264,12 @@
public ReturnT<String> waterComeOneHourUpHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("近1h水位陡升","","waterComeOneHourUpHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("近1h水位陡升","","waterComeOneHourUpHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -223,7 +285,12 @@
public ReturnT<String> waterComeOneHourDownHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("近1h水位陡降","","waterComeOneHourDownHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("近1h水位陡降","","waterComeOneHourDownHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -239,7 +306,12 @@
public ReturnT<String> rainstormHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("暴雨降雨预警","","rainstormHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("暴雨降雨预警","","rainstormHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -255,7 +327,12 @@
public ReturnT<String> alreadyHeavyRainHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("已降大雨告警","","alreadyHeavyRainHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("已降大雨告警","","alreadyHeavyRainHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -271,7 +348,12 @@
public ReturnT<String> alreadyRainstormHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("已降暴雨告警","","alreadyRainstormHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("已降暴雨告警","","alreadyRainstormHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -287,7 +369,12 @@
public ReturnT<String> twoHourRainHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("2小时降雨告警","","twoHourRainHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("2小时降雨告警","","twoHourRainHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -303,7 +390,12 @@
public ReturnT<String> sixHourRainHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("6小时降雨告警","","sixHourRainHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("6小时降雨告警","","sixHourRainHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -319,7 +411,12 @@
public ReturnT<String> damSafetyHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("监测数据缺失","","damSafetyHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("监测数据缺失","","damSafetyHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -335,7 +432,12 @@
public ReturnT<String> damSafetySyHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("测压管水位大于校核洪水位","","damSafetySyHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("测压管水位大于校核洪水位","","damSafetySyHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -351,7 +453,12 @@
public ReturnT<String> damSafetySyNoneHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("渗压监测数据缺失","","damSafetySyNoneHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("渗压监测数据缺失","","damSafetySyNoneHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -367,7 +474,12 @@
public ReturnT<String> damSafetySlNoneHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("渗流监测数据缺失","","damSafetySlNoneHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("渗流监测数据缺失","","damSafetySlNoneHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -383,7 +495,12 @@
public ReturnT<String> damSafetyWyNoneHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("变形监测数据缺失","","damSafetyWyNoneHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("变形监测数据缺失","","damSafetyWyNoneHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -400,7 +517,12 @@
public ReturnT<String> damSafetySyDataMissingHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("渗压资料缺失","","damSafetySyDataMissingHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("渗压资料缺失","","damSafetySyDataMissingHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -416,7 +538,12 @@
public ReturnT<String> damSafetyBxDataMissingHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("变形资料缺失","","damSafetyBxDataMissingHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("变形资料缺失","","damSafetyBxDataMissingHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -433,7 +560,12 @@
public ReturnT<String> damSafetySyLessThenPipeHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位低于管底高程","","damSafetySyLessThenPipeHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位低于管底高程","","damSafetySyLessThenPipeHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -449,7 +581,12 @@
public ReturnT<String> damSafetySyHigherThenNozzleHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位大于管口高程","","damSafetySyHigherThenNozzleHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位大于管口高程","","damSafetySyHigherThenNozzleHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -465,7 +602,12 @@
public ReturnT<String> damSafetySyHigherThenBdElevationHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位大于坝顶高程","","damSafetySyHigherThenBdElevationHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位大于坝顶高程","","damSafetySyHigherThenBdElevationHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -481,7 +623,12 @@
public ReturnT<String> damSafetySyHigherThenWaterLevelHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位大于库水位","","damSafetySyHigherThenWaterLevelHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位大于库水位","","damSafetySyHigherThenWaterLevelHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -498,7 +645,12 @@
public ReturnT<String> damSafetySyYellowChangeHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位变幅黄色告警","","damSafetySyYellowChangeHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位变幅黄色告警","","damSafetySyYellowChangeHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -514,7 +666,12 @@
public ReturnT<String> damSafetySyOrangeChangeHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位变幅橙色告警","","damSafetySyOrangeChangeHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位变幅橙色告警","","damSafetySyOrangeChangeHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -530,7 +687,12 @@
public ReturnT<String> damSafetySyRedChangeHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("水位变幅红色告警","","damSafetySyRedChangeHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("水位变幅红色告警","","damSafetySyRedChangeHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -547,7 +709,12 @@
public ReturnT<String> damSafetySyRz1hChangeHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("近1h水位陡升陡降","","damSafetySyRz1hChangeHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("近1h水位陡升陡降","","damSafetySyRz1hChangeHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -564,7 +731,12 @@
public ReturnT<String> damSafetyWyOver2Less5Handle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("变形值大于2cm小于5cm","","damSafetyWyOver2Less5Handle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("变形值大于2cm小于5cm","","damSafetyWyOver2Less5Handle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -581,7 +753,12 @@
public ReturnT<String> damSafetyWyOver5Less10Handle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("变形值大于5cm小于10cm","","damSafetyWyOver5Less10Handle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("变形值大于5cm小于10cm","","damSafetyWyOver5Less10Handle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -598,7 +775,12 @@
public ReturnT<String> damSafetyWyOver10Handle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("变形值大于10cm以上","","damSafetyWyOver10Handle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("变形值大于10cm以上","","damSafetyWyOver10Handle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -615,7 +797,12 @@
public ReturnT<String> damSafetyWy1hChangeOver10Handle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("近1h变形值大于10cm以上","","damSafetyWy1hChangeOver10Handle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("近1h变形值大于10cm以上","","damSafetyWy1hChangeOver10Handle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -632,7 +819,12 @@
public ReturnT<String> damSafetySlOver5Less8Handle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("渗流量一日大于5L小于8L连续3日增加","","damSafetySlOver5Less8Handle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("渗流量一日大于5L小于8L连续3日增加","","damSafetySlOver5Less8Handle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -648,7 +840,12 @@
public ReturnT<String> damSafetySlOver8Less10Handle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("渗流量一日大于8L小于10L连续3日增加","","damSafetySlOver8Less10Handle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("渗流量一日大于8L小于10L连续3日增加","","damSafetySlOver8Less10Handle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -664,7 +861,12 @@
public ReturnT<String> damSafetySlOver10Handle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("渗流量一日大于10L连续3日增加","","damSafetySlOver10Handle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("渗流量一日大于10L连续3日增加","","damSafetySlOver10Handle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
@@ -680,7 +882,12 @@
public ReturnT<String> videoOfflineHandle(String param){
XxlJobLogger.log("开始执行任务...");
// 创建外呼任务
- noticeClient.createAlarmNoticeTaskJobHandler("视频信息接收不到","","videoOfflineHandle");
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(() -> {
+ // 这里是你的异步任务逻辑
+ noticeClient.createAlarmNoticeTaskJobHandler("视频信息接收不到","","videoOfflineHandle");
+ });
+
XxlJobLogger.log("结束自动创建任务...");
// 返回
return ReturnT.SUCCESS;
--
Gitblit v1.9.3