From 4fa63d4db1e87adabe5b40a4d5fb4e8b10276def Mon Sep 17 00:00:00 2001
From: zrj <646384940@qq.com>
Date: Thu, 22 Aug 2024 09:07:24 +0800
Subject: [PATCH] 错误修正
---
skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/AsyncNoticeHandle.java | 1758 ++++++++++++++++++++++++++++++++++++++--------------------
1 files changed, 1,143 insertions(+), 615 deletions(-)
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/AsyncNoticeHandle.java b/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/AsyncNoticeHandle.java
index 51cdcfb..d9e4e43 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/AsyncNoticeHandle.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/AsyncNoticeHandle.java
@@ -11,10 +11,12 @@
import cn.gistack.resource.vo.AlertTextualResearchAttachVO;
import cn.gistack.sm.intelligentCall.feign.OutCallClient;
import com.alibaba.fastjson.JSONArray;
+import org.springblade.core.tool.utils.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
+import java.time.LocalTime;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -33,13 +35,14 @@
/**
* 1.水位信息接收不到 2. 水位数据异常 需要合并水库的
- * @param alarmRule 告警规则信息
+ *
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
*/
@Async
public void waterInfoNotHandle(AlarmRule alarmRule,
@@ -52,28 +55,32 @@
String uuid = alarmRuleDetail.getTemplateId() + UUID.randomUUID().toString();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 遍历
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list,alarmRule,uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+
+ if (!isTimeSend()) return;
+
// 调用短信服务
smsService.sendMergeSignMsg(smsRequestTemplate);
}
/**
* 3.水位超低于死水位
- * @param alarmRule 告警规则信息
+ *
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
@@ -88,20 +95,30 @@
String uuid = alarmRuleDetail.getTemplateId() + UUID.randomUUID().toString();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接内容后面的联系方式,当前模板县水利部人员姓名电话
- if (smsRequestTemplate.getPersonVOList().size()>0) {
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
// 遍历，拼接县水利部人员电话
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 后面依次拼接市县水利部门人员姓名电话
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("水位：{}\n死水位：{}米\n超低于死水位：{}米\n",
+ list.get(9),
+ String.format("%.2f", Double.valueOf(list.get(9).replace("米", "")) - Double.valueOf(list.get(10))),
+ list.get(10)
+ );
+ list.remove(10);
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list,alarmRule,uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+
+ if (!isTimeSend()) return map;
// 调用短信服务
map = smsService.sendSignMsg(smsRequestTemplate);
// 返回
@@ -113,13 +130,14 @@
/**
* 5.水位接近汛限告警--发送站内信
- * @param alarmRule 告警规则信息
+ *
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
*/
@Async
public void waterComeOverHandle(AlarmRule alarmRule,
@@ -132,36 +150,45 @@
String uuid = alarmRuleDetail.getTemplateId() + UUID.randomUUID().toString();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接内容后面的联系方式,当前模板县水利部人员姓名电话
- if (smsRequestTemplate.getPersonVOList().size()>0) {
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
// 遍历，拼接县水利部人员电话
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 后面依次拼接 巡查责任人姓名，技术责任人姓名，
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("水位：{}\n汛限水位：{}米\n接近汛限水位：{}米\n",
+ list.get(9), list.get(13), String.format("%.2f", Double.valueOf(list.get(9).replace("米", "")) - Double.valueOf(list.get(13)))
+ );
+ list.remove(13);
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list,alarmRule,uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+
+ if(!isTimeSend()) return;
// 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
}
}
/**
* 6.水位初次超汛限告警 处理
- * @param alarmRule 告警规则信息
+ *
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
@@ -176,20 +203,29 @@
String uuid = alarmRuleDetail.getTemplateId() + UUID.randomUUID().toString();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
- if (smsRequestTemplate.getPersonVOList().size()>0) {
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次拼接巡查责任人，技术责任人姓名
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("水位：{}\n汛限水位：{}米\n超汛限水位：{}米\n",
+ list.get(9), list.get(11), String.format("%.2f", Double.valueOf(list.get(9).replace("米", "")) - Double.valueOf(list.get(11)))
+ );
+ list.remove(11);
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list,alarmRule,uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+
+ if (!isTimeSend()) return map;
+
// 调用短信服务
map = smsService.sendSignMsg(smsRequestTemplate);
return map;
@@ -199,44 +235,52 @@
/**
* 7.1 水位小幅超汛限告警（发松给 水库技术责任人、巡查责任人）
- * @param alarmRule 告警规则信息
+ *
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
- * @param uuid 变量
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
+ * @param uuid 变量
* @return
*/
@Async
public Map<String, Object> waterSmallScaleOverHandle1(AlarmRule alarmRule,
- AlarmRuleDetail alarmRuleDetail,
- JSONArray ztData,
- List<String> columnList,
- Boolean flag,
- String adCode,
- Boolean isSendStation,
- String uuid) {
+ AlarmRuleDetail alarmRuleDetail,
+ JSONArray ztData,
+ List<String> columnList,
+ Boolean flag,
+ String adCode,
+ Boolean isSendStation,
+ String uuid) {
Map<String, Object> map = new HashMap<>();
// String uuid = alarmRuleDetail.getTemplateId() + UUID.randomUUID().toString();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
- if (smsRequestTemplate.getPersonVOList().size()>0) {
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次拼接巡查责任人，技术责任人姓名
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("水位：{}\n汛限水位：{}米\n超汛限水位：{}米\n",
+ list.get(9), list.get(12), String.format("%.2f", Double.valueOf(list.get(9).replace("米", "")) - Double.valueOf(list.get(12)))
+ );
+ list.remove(12);
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list,alarmRule,uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (!isTimeSend()) return map;
// 调用短信服务
map = smsService.sendSignMsg(smsRequestTemplate);
return map;
@@ -246,13 +290,14 @@
/**
* 7.2 水位小幅超汛限告警(发送给 县级水利部门有关人员、主管部门责任人)
- * @param alarmRule 告警规则信息
+ *
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
@@ -268,21 +313,28 @@
// String uuid = alarmRuleDetail.getTemplateId() + UUID.randomUUID().toString();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
- if (smsRequestTemplate.getPersonVOList().size()>0) {
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次拼接巡查责任人，技术责任人姓名联系电话
- noticeHandle.addPatrolTechnologyInfo(list,true);
+ noticeHandle.addPatrolTechnologyInfo(list, true);
// 拼接市县水利部人员姓名及联系方式
// noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("水位：{}\n汛限水位：{}米\n超汛限水位：{}米\n",
+ list.get(9), list.get(12), String.format("%.2f", Double.valueOf(list.get(9).replace("米", "")) - Double.valueOf(list.get(12)))
+ );
+ list.remove(12);
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list,alarmRule,uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (!isTimeSend()) return map;
// 调用短信服务
map = smsService.sendSignMsg(smsRequestTemplate);
return map;
@@ -292,13 +344,14 @@
/**
* 8.1 水位大幅超汛限告警（发松给 水库技术责任人、巡查责任人）
- * @param alarmRule 告警规则信息
+ *
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
@@ -314,21 +367,28 @@
// String uuid = alarmRuleDetail.getTemplateId() + UUID.randomUUID().toString();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
- if (smsRequestTemplate.getPersonVOList().size()>0) {
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次拼接巡查责任人，技术责任人姓名
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("水位：{}\n汛限水位：{}米\n超汛限水位：{}米\n",
+ list.get(9), list.get(13), String.format("%.2f", Double.valueOf(list.get(9).replace("米", "")) - Double.valueOf(list.get(13)))
+ );
+ list.remove(13);
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list,alarmRule,uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (!isTimeSend()) return map;
// 调用短信服务
map = smsService.sendSignMsg(smsRequestTemplate);
return map;
@@ -338,13 +398,14 @@
/**
* 8.2 水位大幅超汛限告警(发送给 县级水利部门有关人员、主管部门责任人)
- * @param alarmRule 告警规则信息
+ *
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
@@ -360,21 +421,28 @@
// String uuid = alarmRuleDetail.getTemplateId() + UUID.randomUUID().toString();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
- if (smsRequestTemplate.getPersonVOList().size()>0) {
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次拼接巡查责任人，技术责任人姓名联系电话
- noticeHandle.addPatrolTechnologyInfo(list,true);
+ noticeHandle.addPatrolTechnologyInfo(list, true);
+
+ String remark = StringUtil.format("水位：{}\n汛限水位：{}米\n超汛限水位：{}米\n",
+ list.get(9), list.get(12), String.format("%.2f", Double.valueOf(list.get(9).replace("米", "")) - Double.valueOf(list.get(12)))
+ );
+ list.remove(12);
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list,alarmRule,uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (!isTimeSend()) return map;
// 调用短信服务
- map = smsService.sendSignMsg(smsRequestTemplate);
+// map = smsService.sendSignMsg(smsRequestTemplate);
return map;
}
return map;
@@ -383,13 +451,13 @@
/**
* 策略9.1: 水位接近设计洪水位告警-短信
*
- * @param alarmRule 告警规则信息
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
@@ -419,6 +487,7 @@
list.add(alarmRecord.getId().toString());
}
}
+ if (!isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -428,24 +497,25 @@
/**
* 外呼告警信息
- * @param alarmRule 告警规则信息
+ *
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
public Map<String, Object> outCallHandleCall(AlarmRule alarmRule,
- AlarmRuleDetail alarmRuleDetail,
- JSONArray ztData,
- List<String> columnList,
- Boolean flag,
- String adCode,
- Boolean isSendStation,
- String uuid) {
+ AlarmRuleDetail alarmRuleDetail,
+ JSONArray ztData,
+ List<String> columnList,
+ Boolean flag,
+ String adCode,
+ Boolean isSendStation,
+ String uuid) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
@@ -454,15 +524,20 @@
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 拼接市县水利部人员姓名及联系方式
- noticeHandle.addCityCountyBusinessPersonInfo(list);
+// noticeHandle.addCityCountyBusinessPersonInfo(list);
+ String remark = StringUtil.format("降雨：{}\n",
+ list.get(6) + "毫米"
+ );
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+
+ if(!isTimeSend()) return map;
List<String> list = noticeHandle.createOutCallTaskByAlarm(smsRequestTemplate);
- map.put("list",list);
+ map.put("list", list);
// 调用短信服务
return map;
}
@@ -472,13 +547,13 @@
/**
* 策略9.3: 水位接近设计洪水位告警-站内信
*
- * @param alarmRule 告警规则信息
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
@@ -507,20 +582,23 @@
list.add(alarmRecord.getId().toString());
}
}
+
+ if (!isTimeSend()) return;
// 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
}
}
/**
* 10.1 水位超设计洪水位告警处理--短信
- * @param alarmRule 告警规则信息
+ *
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
@@ -536,20 +614,29 @@
// String uuid = alarmRuleDetail.getTemplateId() + UUID.randomUUID().toString();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+
+
+ String remark = StringUtil.format("水位：{}\n设计洪水位：{}米\n超设计洪水位：{}米\n",
+ list.get(9), list.get(13), String.format("%.2f", Double.valueOf(list.get(9).replace("米", "")) - Double.valueOf(list.get(13)))
+ );
+ list.remove(13);
+
+// System.out.println(remark);
// 依次添加行政责任人,主管部门责任人,技术责任人,巡查责任人信息(姓名，联系电话)
noticeHandle.addWaterMoreDesignPatrolTechnologyInfo(list, "1,2,4,5");
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (!isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -559,29 +646,30 @@
/**
* 10.水位超设计洪水位告警处理 - 电话
- * @param alarmRule 告警规则信息
+ *
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
public Map<String, Object> waterMoreDesignHandleCall(AlarmRule alarmRule,
- AlarmRuleDetail alarmRuleDetail,
- JSONArray ztData,
- List<String> columnList,
- Boolean flag,
- String adCode,
- Boolean isSendStation,
- String uuid) {
+ AlarmRuleDetail alarmRuleDetail,
+ JSONArray ztData,
+ List<String> columnList,
+ Boolean flag,
+ String adCode,
+ Boolean isSendStation,
+ String uuid) {
Map<String, Object> map = new HashMap<>();
// String uuid = alarmRuleDetail.getTemplateId() + UUID.randomUUID().toString();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
@@ -593,6 +681,7 @@
list.add(alarmRecord.getId().toString());
}
}
+ if (!isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -602,42 +691,50 @@
/**
* 11.1 水位超校核洪水位告警--短信
- * @param alarmRule 告警规则信息
+ *
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
public Map<String, Object> waterMoreCheckHandle(AlarmRule alarmRule,
- AlarmRuleDetail alarmRuleDetail,
- JSONArray ztData,
- List<String> columnList,
- Boolean flag,
- String adCode,
- Boolean isSendStation,
- String uuid) {
+ AlarmRuleDetail alarmRuleDetail,
+ JSONArray ztData,
+ List<String> columnList,
+ Boolean flag,
+ String adCode,
+ Boolean isSendStation,
+ String uuid) {
Map<String, Object> map = new HashMap<>();
// String uuid = alarmRuleDetail.getTemplateId() + UUID.randomUUID().toString();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+
// 依次添加行政责任人,主管部门责任人,技术责任人,巡查责任人信息(姓名，联系电话)
noticeHandle.addWaterMoreDesignPatrolTechnologyInfo(list, "1,2,4,5");
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("水位：{}\n校核洪水位：{}米\n{}米\n",
+ list.get(9), list.get(10), list.get(11)
+ );
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (!isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -647,28 +744,29 @@
/**
* 11.2 水位超校核洪水位告警 - 电话
- * @param alarmRule 告警规则信息
+ *
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
public Map<String, Object> waterMoreCheckHandleCall(AlarmRule alarmRule,
- AlarmRuleDetail alarmRuleDetail,
- JSONArray ztData,
- List<String> columnList,
- Boolean flag,
- String adCode,
- Boolean isSendStation,
- String uuid) {
+ AlarmRuleDetail alarmRuleDetail,
+ JSONArray ztData,
+ List<String> columnList,
+ Boolean flag,
+ String adCode,
+ Boolean isSendStation,
+ String uuid) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
@@ -680,6 +778,7 @@
list.add(alarmRecord.getId().toString());
}
}
+ if (!isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -689,41 +788,50 @@
/**
* 12 近1h水位陡升--短信
- * @param alarmRule 告警规则信息
+ *
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
public Map<String, Object> waterComeOneHourUpHandle(AlarmRule alarmRule,
- AlarmRuleDetail alarmRuleDetail,
- JSONArray ztData,
- List<String> columnList,
- Boolean flag,
- String adCode,
- Boolean isSendStation,
- String uuid) {
+ AlarmRuleDetail alarmRuleDetail,
+ JSONArray ztData,
+ List<String> columnList,
+ Boolean flag,
+ String adCode,
+ Boolean isSendStation,
+ String uuid) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
+// // 依次添加行巡查责任人,技术责任人信息,主管部门责任人(姓名)
+// noticeHandle.addPatrolTechnologyInfoNew(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("近1h水位陡升：{}\n",
+ list.get(10)
+ );
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (!isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -733,41 +841,49 @@
/**
* 13 近1h水位陡降--短信
- * @param alarmRule 告警规则信息
+ *
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
public Map<String, Object> waterComeOneHourDownHandle(AlarmRule alarmRule,
- AlarmRuleDetail alarmRuleDetail,
- JSONArray ztData,
- List<String> columnList,
- Boolean flag,
- String adCode,
- Boolean isSendStation,
- String uuid) {
+ AlarmRuleDetail alarmRuleDetail,
+ JSONArray ztData,
+ List<String> columnList,
+ Boolean flag,
+ String adCode,
+ Boolean isSendStation,
+ String uuid) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
- // 拼接市县水利部人员姓名及联系方式
+ noticeHandle.addPatrolTechnologyInfo(list, false);
+// // 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("近1h水位陡降：{}\n",
+ list.get(10)
+ );
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (!isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -778,13 +894,13 @@
/**
* 策略15: 已降大雨告警
*
- * @param alarmRule 告警规则信息
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
@@ -799,20 +915,24 @@
String uuid = alarmRuleDetail.getTemplateId() + UUID.randomUUID().toString();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+
// 依次添加巡查责任人技术责任人信息姓名
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = list.get(9);
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (!isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -823,13 +943,13 @@
/**
* 策略16: 已降暴雨告警
*
- * @param alarmRule 告警规则信息
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
@@ -844,20 +964,25 @@
String uuid = alarmRuleDetail.getTemplateId() + UUID.randomUUID().toString();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+
// 依次添加巡查责任人技术责任人信息姓名
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = list.get(9);
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (!isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -868,13 +993,13 @@
/**
* 策略18: 6小时降雨告警--短信
*
- * @param alarmRule 告警规则信息
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
@@ -889,20 +1014,28 @@
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行政责任人,主管部门责任人,技术责任人,巡查责任人信息(姓名，联系电话)
- noticeHandle.addWaterMoreDesignPatrolTechnologyInfo(list,"1,2,4,5");
+// noticeHandle.addWaterMoreDesignPatrolTechnologyInfo(list, "1,2,4,5");
+ // 主管部门责任人,技术责任人,巡查责任人信息 2024-05-29修改
+ noticeHandle.addWaterMoreDesignPatrolTechnologyInfoNew(list, "2,4,5");
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("降雨：{}\n",
+ list.get(6) + "毫米"
+ );
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (!isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -913,28 +1046,28 @@
/**
* 策略18: 6小时降雨告警--电话
*
- * @param alarmRule 告警规则信息
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
* @return
*/
@Async
public Map<String, Object> sixHourRainHandleByCall(AlarmRule alarmRule,
- AlarmRuleDetail alarmRuleDetail,
- JSONArray ztData,
- List<String> columnList,
- Boolean flag,
- String adCode,
- Boolean isSendStation,
- String uuid) {
+ AlarmRuleDetail alarmRuleDetail,
+ JSONArray ztData,
+ List<String> columnList,
+ Boolean flag,
+ String adCode,
+ Boolean isSendStation,
+ String uuid) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
@@ -946,6 +1079,7 @@
list.add(alarmRecord.getId().toString());
}
}
+ if (!isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -956,28 +1090,29 @@
/**
* 策略19: 大坝安全监测告警-短信
*
- * @param alarmRule 告警规则信息
+ * @param alarmRule 告警规则信息
* @param alarmRuleDetail 告警规则详情信息
- * @param ztData 告警数据
- * @param columnList 告警模板动态内容key
- * @param flag 是否包含日期
- * @param adCode 行政区code用户过滤数据
- * @param isSendStation 是否发送站内信
+ * @param ztData 告警数据
+ * @param columnList 告警模板动态内容key
+ * @param flag 是否包含日期
+ * @param adCode 行政区code用户过滤数据
+ * @param isSendStation 是否发送站内信
+ * @param isDay 是否每日发送，day
* @return
*/
- @Async
public Map<String, Object> damSafetyHandle(AlarmRule alarmRule,
- AlarmRuleDetail alarmRuleDetail,
- JSONArray ztData,
- List<String> columnList,
- Boolean flag,
- String adCode,
- Boolean isSendStation,
- String uuid) {
+ AlarmRuleDetail alarmRuleDetail,
+ JSONArray ztData,
+ List<String> columnList,
+ Boolean flag,
+ String adCode,
+ Boolean isSendStation,
+ String uuid,
+ String isDay) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
@@ -987,19 +1122,22 @@
list.add(alarmRecord.getId().toString());
}
}
- map = smsService.sendSignMsg(smsRequestTemplate);
+ //如果参数是day，表示是每天生成告警，不需要发信息
+ if (isDay.equals("day") || !isTimeSend()) return map;
+ map = smsService.sendSignMsgMergeCd(smsRequestTemplate);
// 调用短信服务
return map;
+
}
return map;
}
- public void damSafetySyHandle(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray ztData, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public void damSafetySyHandle(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray ztData, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(ztData,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接内容后面的联系方式,当前模板县水利部人员姓名电话
- if (smsRequestTemplate.getPersonVOList().size()>0) {
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
// 遍历，拼接县水利部人员电话 拼接发送的模板内容
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 后面依次拼接 巡查责任人姓名，技术责任人姓名，
@@ -1007,22 +1145,51 @@
// 拼接市县水利部人员姓名及联系方式
// noticeHandle.addCityCountyBusinessPersonInfo(list);
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list,alarmRule,uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+
+ //如果参数是day，表示是每天生成告警，不需要发信息
+ if (isDay.equals("day") || !isTimeSend()) return;
// 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
+
}
}
- public Map<String, Object> damSafetySyDataMissingHandle(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+
+ //保存记录
+ public void damSafetySyNoneHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray ztData, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
+
+ SmsRequestTemplate smsRequestTemplate
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
+ // 拼接内容后面的联系方式,当前模板县水利部人员姓名电话
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
+ // 遍历，拼接县水利部人员电话 拼接发送的模板内容
+ for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+ // 保存告警记录信息
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ if (null != alarmRecord) {
+ list.add(alarmRecord.getId().toString());
+ }
+ }
+ //如果参数是day，表示是每天生成告警，不需要发信息
+ if (isDay.equals("day") || !isTimeSend()) return;
+ // 需要合并水库保存站内信记录信息
+ noticeHandle.saveInStationInfoMerge(smsRequestTemplate, alarmRule);
+ }
+
+ }
+
+
+ public Map<String, Object> damSafetyHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(data,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
@@ -1032,6 +1199,34 @@
list.add(alarmRecord.getId().toString());
}
}
+ //如果参数是day，表示是每天生成告警，不需要发信息
+ if (isDay.equals("day") || !isTimeSend()) return map;
+ map = smsService.sendSignMsgMergeCd(smsRequestTemplate);
+ // 调用短信服务
+ return map;
+ }
+ return map;
+
+ }
+
+
+ //渗压资料缺失
+ public Map<String, Object> damSafetySyDataMissingHandle(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
+
+ Map<String, Object> map = new HashMap<>();
+ // 只发短信，将发短信信息组装好
+ SmsRequestTemplate smsRequestTemplate
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
+ // 拼接后面内容
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
+ for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+ // 保存告警记录信息
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ if (null != alarmRecord) {
+ list.add(alarmRecord.getId().toString());
+ }
+ }
+ if (isDay.equals("day") || !isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -1041,30 +1236,37 @@
/**
* 策略26 短信-----渗压水位低于管底高程
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public Map<String, Object> damSafetySyLessThenPipeHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public Map<String, Object> damSafetySyLessThenPipeHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(data,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+
+ String remark = StringUtil.format("渗压水位：{}\n管底高程：{}\n",
+ list.get(3), String.format("%.2f", Double.valueOf(list.get(11)) + Double.valueOf(list.get(12)))
+ );
+// System.out.println(remark);
// 保存告警记录信息
AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (isDay.equals("day") || !isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -1074,61 +1276,74 @@
/**
* 策略26 站内信-----渗压水位低于管底高程
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public void damSafetySyLessThenPipeHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public void damSafetySyLessThenPipeHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
SmsRequestTemplate smsRequestTemplate
= noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+
+ String remark = StringUtil.format("渗压水位：{}\n管底高程：{}\n",
+ list.get(3), String.format("%.2f", Double.valueOf(list.get(11)) + Double.valueOf(list.get(12)))
+ );
+// System.out.println(remark);
// 保存告警记录信息
AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (isDay.equals("day") || !isTimeSend()) return;
// 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
}
}
/**
* 策略27 短信-----渗压水位高于管口高程
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public Map<String, Object> damSafetySyHigherThenNozzleHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public Map<String, Object> damSafetySyHigherThenNozzleHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(data,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+
+ String remark = StringUtil.format("渗压水位：{}\n管口高程：{}\n",
+ list.get(11), list.get(12)
+ );
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
- map = smsService.sendSignMsg(smsRequestTemplate);
+ if (isDay.equals("day") || !isTimeSend()) return map;
+// map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
}
@@ -1137,17 +1352,55 @@
/**
* 策略26 站内信-----渗压水位高于管口高程
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public void damSafetySyHigherThenNozzleHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public void damSafetySyHigherThenNozzleHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
+ SmsRequestTemplate smsRequestTemplate
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
+ // 拼接后面内容
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
+ for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+
+ String remark = StringUtil.format("渗压水位：{}\n管口高程：{}\n",
+ list.get(11), list.get(12)
+ );
+ // 保存告警记录信息
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
+ if (null != alarmRecord) {
+ list.add(alarmRecord.getId().toString());
+ }
+ }
+ if (isDay.equals("day") || !isTimeSend()) return;
+ // 保存站内信记录信息
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
+ }
+ }
+
+ /**
+ * 策略28 短信-----渗压水位高于坝顶高程
+ *
+ * @param alarmRule 告警规则
+ * @param alarmRuleDetail 告警规则详情
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
+ * @return
+ */
+ public Map<String, Object> damSafetySyHigherThenBdElevationHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
+ Map<String, Object> map = new HashMap<>();
+ // 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
= noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
@@ -1159,37 +1412,7 @@
list.add(alarmRecord.getId().toString());
}
}
- // 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
- }
- }
-
- /**
- * 策略28 短信-----渗压水位高于坝顶高程
- * @param alarmRule 告警规则
- * @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
- * @return
- */
- public Map<String, Object> damSafetySyHigherThenBdElevationHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
- Map<String, Object> map = new HashMap<>();
- // 只发短信，将发短信信息组装好
- SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(data,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
- // 拼接后面内容
- if (smsRequestTemplate.getPersonVOList().size() > 0) {
- for (List<String> list : smsRequestTemplate.getTemplateContent()) {
- // 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
- if (null != alarmRecord) {
- list.add(alarmRecord.getId().toString());
- }
- }
+ if (isDay.equals("day") || !isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -1200,17 +1423,58 @@
/**
* 策略28 站内信-----渗压水位高于坝顶高程
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public void damSafetySyHigherThenBdElevationHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public void damSafetySyHigherThenBdElevationHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
+ SmsRequestTemplate smsRequestTemplate
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
+ // 拼接后面内容
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
+ for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+
+ String remark = StringUtil.format("渗压水位：{}\n坝顶高程：{}\n",
+ list.get(11), list.get(13)
+ );
+ list.remove(13);
+
+ // 保存告警记录信息
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
+ if (null != alarmRecord) {
+ list.add(alarmRecord.getId().toString());
+ }
+ }
+ if (isDay.equals("day") || !isTimeSend()) return;
+ // 保存站内信记录信息
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
+ }
+ }
+
+
+ /**
+ * 策略29 短信-----渗压水位高于库水位
+ *
+ * @param alarmRule 告警规则
+ * @param alarmRuleDetail 告警规则详情
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
+ * @return
+ */
+ public Map<String, Object> damSafetySyHigherThenWaterLevelHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
+ Map<String, Object> map = new HashMap<>();
+ // 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
= noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
@@ -1222,38 +1486,7 @@
list.add(alarmRecord.getId().toString());
}
}
- // 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
- }
- }
-
-
- /**
- * 策略29 短信-----渗压水位高于库水位
- * @param alarmRule 告警规则
- * @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
- * @return
- */
- public Map<String, Object> damSafetySyHigherThenWaterLevelHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
- Map<String, Object> map = new HashMap<>();
- // 只发短信，将发短信信息组装好
- SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(data,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
- // 拼接后面内容
- if (smsRequestTemplate.getPersonVOList().size() > 0) {
- for (List<String> list : smsRequestTemplate.getTemplateContent()) {
- // 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
- if (null != alarmRecord) {
- list.add(alarmRecord.getId().toString());
- }
- }
+ if (isDay.equals("day") || !isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -1264,17 +1497,56 @@
/**
* 策略29 站内信-----渗压水位高于库水位
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public void damSafetySyHigherThenWaterLevelHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public void damSafetySyHigherThenWaterLevelHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
+ SmsRequestTemplate smsRequestTemplate
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
+ // 拼接后面内容
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
+ for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+
+ String remark = StringUtil.format("渗压水位：{}\n库水位：{}\n",
+ list.get(11), list.get(12)
+ );
+ // 保存告警记录信息
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
+ if (null != alarmRecord) {
+ list.add(alarmRecord.getId().toString());
+ }
+ }
+ if (isDay.equals("day") || !isTimeSend()) return;
+ // 保存站内信记录信息
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
+ }
+ }
+
+
+ /**
+ * 策略30 短信-----水位长期不变，五日变幅小于5cm，十日变幅大于5cm小于8cm，三十日变幅大于8cm小于10cm
+ *
+ * @param alarmRule 告警规则
+ * @param alarmRuleDetail 告警规则详情
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
+ * @return
+ */
+ public Map<String, Object> damSafetySyYellowChangeHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
+ Map<String, Object> map = new HashMap<>();
+ // 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
= noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
@@ -1286,44 +1558,7 @@
list.add(alarmRecord.getId().toString());
}
}
- // 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
- }
- }
-
-
-
-
-
-
-
-
- /**
- * 策略30 短信-----水位长期不变，五日变幅小于5cm，十日变幅大于5cm小于8cm，三十日变幅大于8cm小于10cm
- * @param alarmRule 告警规则
- * @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
- * @return
- */
- public Map<String, Object> damSafetySyYellowChangeHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
- Map<String, Object> map = new HashMap<>();
- // 只发短信，将发短信信息组装好
- SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(data,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
- // 拼接后面内容
- if (smsRequestTemplate.getPersonVOList().size() > 0) {
- for (List<String> list : smsRequestTemplate.getTemplateContent()) {
- // 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
- if (null != alarmRecord) {
- list.add(alarmRecord.getId().toString());
- }
- }
+ if (isDay.equals("day") || !isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -1334,52 +1569,60 @@
/**
* 策略30 站内信-----水位长期不变，五日变幅小于5cm，十日变幅大于5cm小于8cm，三十日变幅大于8cm小于10cm
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public void damSafetySyYellowChangeHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public void damSafetySyYellowChangeHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
SmsRequestTemplate smsRequestTemplate
= noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+ String remark = StringUtil.format("一日测值：{}\n二日测值：{}\n五日测值：{}\n十日测值：{}\n三十日测值：{}\n" +
+ "二日变幅：{}\n五日变幅：{}\n十日变幅：{}\n三十日变幅：{}\n",
+ list.get(13), list.get(14), list.get(15), list.get(16), list.get(17),
+ list.get(18), list.get(19), list.get(20), list.get(21)
+ );
+// System.out.println(remark);
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (isDay.equals("day") || !isTimeSend()) return;
// 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
}
}
-
/**
* 策略31 短信-----渗压水位一日变幅大于0.5米小于1米，五日变幅大于1米小于2米，十日变幅大于2米小于5米，三十日变幅大于5米小于10米
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public Map<String, Object> damSafetySyOrangeChangeHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public Map<String, Object> damSafetySyOrangeChangeHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(data,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
// for (List<String> list : smsRequestTemplate.getTemplateContent()) {
@@ -1391,7 +1634,7 @@
// }
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
// 保存告警记录信息
@@ -1400,6 +1643,7 @@
list.add(alarmRecord.getId().toString());
}
}
+ if (isDay.equals("day") || !isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -1410,17 +1654,18 @@
/**
* 策略31 站内信-----渗压水位一日变幅大于0.5米小于1米，五日变幅大于1米小于2米，十日变幅大于2米小于5米，三十日变幅大于5米小于10米
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public void damSafetySyOrangeChangeHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public void damSafetySyOrangeChangeHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
SmsRequestTemplate smsRequestTemplate
= noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
@@ -1434,44 +1679,61 @@
// }
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("一日测值：{}\n二日测值：{}\n五日测值：{}\n十日测值：{}\n三十日测值：{}\n" +
+ "二日变幅：{}\n五日变幅：{}\n十日变幅：{}\n三十日变幅：{}\n",
+ list.get(14), list.get(15), list.get(16), list.get(17), list.get(18),
+ list.get(19), list.get(20), list.get(21), list.get(22)
+ );
+ list.remove(14);
+ list.remove(15);
+ list.remove(16);
+ list.remove(17);
+ list.remove(18);
+ list.remove(19);
+ list.remove(20);
+ list.remove(21);
+ list.remove(22);
+// System.out.println(remark);
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (isDay.equals("day") || !isTimeSend()) return;
// 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
}
}
-
/**
* 策略32 短信-----渗压水位一日变幅大于1米小于2米，五日变幅大于2米小于5米，十日变幅大于5米小于10米，三十日变幅大于10米
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public Map<String, Object> damSafetySyRedChangeHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public Map<String, Object> damSafetySyRedChangeHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(data,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
// 保存告警记录信息
@@ -1480,6 +1742,7 @@
list.add(alarmRecord.getId().toString());
}
}
+ if (isDay.equals("day") || !isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -1490,67 +1753,87 @@
/**
* 策略32 站内信-----渗压水位一日变幅大于1米小于2米，五日变幅大于2米小于5米，十日变幅大于5米小于10米，三十日变幅大于10米
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public void damSafetySyRedChangeHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public void damSafetySyRedChangeHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
SmsRequestTemplate smsRequestTemplate
= noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("一日测值：{}\n二日测值：{}\n五日测值：{}\n十日测值：{}\n三十日测值：{}\n" +
+ "二日变幅：{}\n五日变幅：{}\n十日变幅：{}\n三十日变幅：{}\n",
+ list.get(14), list.get(15), list.get(16), list.get(17), list.get(18),
+ list.get(19), list.get(20), list.get(21), list.get(22)
+ );
+ list.remove(14);
+ list.remove(15);
+ list.remove(16);
+ list.remove(17);
+ list.remove(18);
+ list.remove(19);
+ list.remove(20);
+ list.remove(21);
+ list.remove(22);
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (isDay.equals("day") || !isTimeSend()) return;
// 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
}
}
/**
* 策略33 短信-----近1h水位陡降
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public Map<String, Object> damSafetySyRz1hChangeHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public Map<String, Object> damSafetySyRz1hChangeHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(data,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
// 保存告警记录信息
AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (isDay.equals("day") || !isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -1561,63 +1844,70 @@
/**
* 策略33 站内信----- 近1h水位陡降
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public void damSafetySyRz1hChangeHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public void damSafetySyRz1hChangeHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
SmsRequestTemplate smsRequestTemplate
= noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("当前测值：{}\n近1H测值：{}\n{}：{}\n",
+ list.get(11), list.get(14), list.get(12), list.get(13)
+ );
+ // 不拼接短信内容需要删除
+ list.remove(14);
+ System.out.println(remark);
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (isDay.equals("day") || !isTimeSend()) return;
// 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
}
}
-
-
-
/**
* 策略34 短信-----变形值大于20mm小于50mm
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public Map<String, Object> damSafetyWyOver2Less5HandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public Map<String, Object> damSafetyWyOver2Less5HandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(data,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
// 保存告警记录信息
@@ -1626,6 +1916,7 @@
list.add(alarmRecord.getId().toString());
}
}
+ if (isDay.equals("day") || !isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -1636,62 +1927,72 @@
/**
* 策略34 站内信----- 变形值大于20mm小于50mm
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public void damSafetyWyOver2Less5HandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public void damSafetyWyOver2Less5HandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
SmsRequestTemplate smsRequestTemplate
= noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
+
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("上下游：{}\n左右岸：{}\n垂直位移：{}\n",
+ list.get(13), list.get(14), list.get(15)
+ );
+ list.remove(13);
+ list.remove(14);
+ list.remove(15);
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (isDay.equals("day") || !isTimeSend()) return;
// 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
}
}
-
-
/**
* 策略35 短信-----变形值大于50mm小于100mm
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public Map<String, Object> damSafetyWyOver5Less10HandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public Map<String, Object> damSafetyWyOver5Less10HandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(data,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
// 保存告警记录信息
@@ -1700,6 +2001,7 @@
list.add(alarmRecord.getId().toString());
}
}
+ if (isDay.equals("day") || !isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -1710,68 +2012,88 @@
/**
* 策略34 站内信----- 变形值大于50mm小于100mm
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public void damSafetyWyOver5Less10HandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public void damSafetyWyOver5Less10HandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
SmsRequestTemplate smsRequestTemplate
= noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("上下游：{}\n左右岸：{}\n垂直位移：{}\n",
+ list.get(13), list.get(14), list.get(15)
+ );
+ list.remove(13);
+ list.remove(14);
+ list.remove(15);
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (isDay.equals("day") || !isTimeSend()) return;
// 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
}
}
/**
* 策略34 短信-----变形值大于100mm
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public Map<String, Object> damSafetyWyOver10HandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public Map<String, Object> damSafetyWyOver10HandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(data,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("上下游：{}\n左右岸：{}\n垂直位移：{}\n",
+ list.get(13), list.get(14), list.get(15)
+ );
+ list.remove(13);
+ list.remove(14);
+ list.remove(15);
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (isDay.equals("day") || !isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -1782,63 +2104,71 @@
/**
* 策略34 站内信----- 变形值大于100mm
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public void damSafetyWyOver10HandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public void damSafetyWyOver10HandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
SmsRequestTemplate smsRequestTemplate
= noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("上下游：{}\n左右岸：{}\n垂直位移：{}\n",
+ list.get(13), list.get(14), list.get(15)
+ );
+ list.remove(13);
+ list.remove(14);
+ list.remove(15);
+
// 保存告警记录信息
- AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ if (isDay.equals("day") || !isTimeSend()) return;
// 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
}
}
-
-
-
/**
* 策略34 短信-----近1h变形值大于10cm以上
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public Map<String, Object> damSafetyWy1hChangeOver10HandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public Map<String, Object> damSafetyWy1hChangeOver10HandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(data,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
// 保存告警记录信息
@@ -1847,6 +2177,10 @@
list.add(alarmRecord.getId().toString());
}
}
+
+
+ //如果参数是day，表示是每天生成告警，不需要发信息
+ if (isDay.equals("day") || !isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
@@ -1857,24 +2191,25 @@
/**
* 策略34 站内信----- 近1h变形值大于10cm以上
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public void damSafetyWy1hChangeOver10HandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public void damSafetyWy1hChangeOver10HandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
SmsRequestTemplate smsRequestTemplate
= noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
// 保存告警记录信息
@@ -1883,43 +2218,36 @@
list.add(alarmRecord.getId().toString());
}
}
+ //如果参数是day，表示是每天生成告警，不需要发信息
+ if (isDay.equals("day") || !isTimeSend()) return;
// 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
}
}
-
-
-
-
-
-
-
-
-
-
/**
* 策略34 短信-----渗流值
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public Map<String, Object> damSafetySlOverLessHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public Map<String, Object> damSafetySlOverLessHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
Map<String, Object> map = new HashMap<>();
// 只发短信，将发短信信息组装好
SmsRequestTemplate smsRequestTemplate
- = noticeHandle.getSendSmsTemplate(data,alarmRule,alarmRuleDetail,columnList ,flag,adCode,uuid,isSendStation);
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
// 保存告警记录信息
@@ -1928,9 +2256,14 @@
list.add(alarmRecord.getId().toString());
}
}
+
+
+ //如果参数是day，表示是每天生成告警，不需要发信息
+ if (isDay.equals("day") || !isTimeSend()) return map;
map = smsService.sendSignMsg(smsRequestTemplate);
// 调用短信服务
return map;
+
}
return map;
}
@@ -1938,34 +2271,229 @@
/**
* 策略34 站内信----- 渗流值
- * @param alarmRule 告警规则
+ *
+ * @param alarmRule 告警规则
* @param alarmRuleDetail 告警规则详情
- * @param data 中台数据
- * @param columnList 需要展示的数据字段
- * @param flag 是否显示日期
- * @param adCode 行政区划
- * @param isSendStation 是否站内信
- * @param uuid 随机生成id
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
* @return
*/
- public void damSafetySlOverLessHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid) {
+ public void damSafetySlOverLessHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
SmsRequestTemplate smsRequestTemplate
= noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
// 拼接后面内容
if (smsRequestTemplate.getPersonVOList().size() > 0) {
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 依次添加行巡查责任人,技术责任人信息(姓名)
- noticeHandle.addPatrolTechnologyInfo(list,false);
+ noticeHandle.addPatrolTechnologyInfo(list, false);
// 拼接市县水利部人员姓名及联系方式
noticeHandle.addCityCountyBusinessPersonInfo(list);
+
+ String remark = StringUtil.format("当前：{}\n一日：{}\n二日：{}\n",
+ list.get(11), list.get(12), list.get(13)
+ );
+ list.remove(12);
+ list.remove(13);
+ // 保存告警记录信息
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid, remark);
+ if (null != alarmRecord) {
+ list.add(alarmRecord.getId().toString());
+ }
+ }
+ //如果参数是day，表示是每天生成告警，不需要发信息
+ if (isDay.equals("day") || !isTimeSend()) return;
+ // 保存站内信记录信息
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
+ }
+ }
+
+ /**
+ * 策略34 站内信----- 资料缺失
+ *
+ * @param alarmRule 告警规则
+ * @param alarmRuleDetail 告警规则详情
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
+ * @return
+ */
+ public void damSafetySyDataMissingHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
+ SmsRequestTemplate smsRequestTemplate
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
+ // 拼接后面内容
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
+ for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 保存告警记录信息
AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
}
}
+ //如果参数是day，表示是每天生成告警，不需要发信息
+ if (isDay.equals("day") || !isTimeSend()) return;
// 保存站内信记录信息
- noticeHandle.saveInStationInfo(smsRequestTemplate,alarmRule);
+ noticeHandle.saveInStationInfoMergeNoCd(smsRequestTemplate, alarmRule);
}
}
+
+
+ /**
+ * 策略34 站内信----- 视频离线
+ *
+ * @param alarmRule 告警规则
+ * @param alarmRuleDetail 告警规则详情
+ * @param data 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
+ * @return
+ */
+ public void videoOfflineHandleStation(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray data, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
+ SmsRequestTemplate smsRequestTemplate
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
+ // 拼接后面内容
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
+ for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+ // 保存告警记录信息
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ if (null != alarmRecord) {
+ list.add(alarmRecord.getId().toString());
+ }
+ }
+
+ //如果参数是day，表示是每天生成告警，不需要发信息
+ if (isDay.equals("day") || !isTimeSend()) return;
+ // 保存站内信记录信息
+ noticeHandle.saveInStationInfoMergeVideo(smsRequestTemplate, alarmRule);
+ }
+ }
+
+ public void damSafetySyDataMissingHandleSms(AlarmRule alarmRule, AlarmRuleDetail alarmRuleDetail, JSONArray ztData, List<String> columnList, boolean flag, String adCode, boolean isSendStation, String uuid, String isDay) {
+ // 只发短信，将发短信信息组装好
+ SmsRequestTemplate smsRequestTemplate
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
+ // 遍历
+ for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+ // 保存告警记录信息
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ if (null != alarmRecord) {
+ list.add(alarmRecord.getId().toString());
+ }
+ }
+
+ //如果参数是day，表示是每天生成告警，不需要发信息
+ if (isDay.equals("day") || !isTimeSend()) return;
+ // 调用短信服务
+ smsService.sendMergeSignMsg(smsRequestTemplate);
+ }
+
+ public Map<String, Object> videoOfflineHandleSms(AlarmRule alarmRule,
+ AlarmRuleDetail alarmRuleDetail,
+ JSONArray ztData,
+ List<String> columnList,
+ Boolean flag,
+ String adCode,
+ Boolean isSendStation,
+ String uuid,
+ String isDay) {
+ Map<String, Object> map = new HashMap<>();
+ // 只发短信，将发短信信息组装好
+ SmsRequestTemplate smsRequestTemplate
+ = noticeHandle.getSendSmsTemplate(ztData, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
+ // 拼接后面内容
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
+ for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+ // 保存告警记录信息
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
+ if (null != alarmRecord) {
+ list.add(alarmRecord.getId().toString());
+ }
+ }
+ //如果参数是day，表示是每天生成告警，不需要发信息
+ if (isDay.equals("day") || !isTimeSend()) return map;
+ map = smsService.sendSignMsgMergeCdVideo(smsRequestTemplate);
+ // 调用短信服务
+ return map;
+ }
+ return map;
+ }
+
+ /**
+ * 策略42 站内信----- 超防洪高水位告警
+ *
+ * @param alarmRule 告警规则
+ * @param alarmRuleDetail 告警规则详情
+ * @param ztData 中台数据
+ * @param columnList 需要展示的数据字段
+ * @param flag 是否显示日期
+ * @param adCode 行政区划
+ * @param isSendStation 是否站内信
+ * @param uuid 随机生成id
+ * @return
+ */
+ public void topLevOfFloAlertHandleStation(AlarmRule alarmRule,
+ AlarmRuleDetail alarmRuleDetail,
+ JSONArray data,
+ List<String> columnList,
+ boolean flag,
+ String adCode,
+ boolean isSendStation,
+ String uuid,
+ String isDay
+ ) {
+ SmsRequestTemplate smsRequestTemplate
+ = noticeHandle.getSendSmsTemplate(data, alarmRule, alarmRuleDetail, columnList, flag, adCode, uuid, isSendStation);
+ // 拼接后面内容
+ if (smsRequestTemplate.getPersonVOList().size() > 0) {
+ for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+ String remark = StringUtil.format("水位：{}\n防洪高水位：{}米\n超防洪高水位：{}米\n",
+ list.get(9), list.get(13), String.format("%.2f", Double.valueOf(list.get(9).replace("米", "")) - Double.valueOf(list.get(13)))
+ );
+ list.remove(13);
+ System.out.println(remark);
+ // 依次添加行政责任人,主管部门责任人,技术责任人,巡查责任人信息(姓名，联系电话)
+ noticeHandle.addWaterMoreDesignPatrolTechnologyInfo(list, "1,2,4,5");
+ // 拼接市县水利部人员姓名及联系方式
+ noticeHandle.addCityCountyBusinessPersonInfo(list);
+ // 保存告警记录信息
+ AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid,remark);
+ if (null != alarmRecord) {
+ list.add(alarmRecord.getId().toString());
+ }
+ }
+
+ //如果参数是day，表示是每天生成告警，不需要发信息
+ if (isDay.equals("day") || !isTimeSend()) return;
+ // 保存站内信记录信息
+ noticeHandle.saveInStationInfo(smsRequestTemplate, alarmRule);
+ }
+ }
+
+ /**
+ * 是否在时间范围内发送
+ * @return
+ */
+ private boolean isTimeSend(){
+ boolean flag = false;
+ // 判断时间范围
+ // 开始时间
+ LocalTime startTime = LocalTime.parse("08:00");
+ // 结束时间
+ LocalTime endTime = LocalTime.parse("22:00");
+ // 当前时间
+ LocalTime now = LocalTime.now();
+ // 比较
+ flag = !now.isBefore(startTime) && !now.isAfter(endTime);
+ // 返回
+ return flag;
+ }
}
--
Gitblit v1.9.3