From 65b0ff0e67bab9e2d8d55d43d717115540a24cab Mon Sep 17 00:00:00 2001
From: xieb <vip_xiaobin810@163.com>
Date: Wed, 13 Mar 2024 13:52:21 +0800
Subject: [PATCH] 大坝安全监测修改
---
skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeStrategyImpl.java | 106 ++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 105 insertions(+), 1 deletions(-)
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeStrategyImpl.java b/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeStrategyImpl.java
index d24c771..1da3e3c 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeStrategyImpl.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeStrategyImpl.java
@@ -573,7 +573,7 @@
/**
- * 策略19: 大坝安全监测告警
+ * 策略19: 大坝安全监测告警-数据缺失
*
* @param arg1
* @param arg2
@@ -604,6 +604,13 @@
return "大坝安全监测告警";
}
+ /**
+ * 策略20: 大坝安全监测告警-渗压管水位大于校核洪水位
+ *
+ * @param arg1
+ * @param arg2
+ * @return
+ */
public String damSafetySyHandle(String arg1, String arg2) {
//String adCode = "420607000000";
String uuid = UUID.randomUUID().toString();
@@ -628,4 +635,101 @@
// 返回
return "大坝安全监测告警";
}
+
+ /**
+ * 策略21: 大坝安全监测告警-渗压数据缺失
+ *
+ * @param arg1
+ * @param arg2
+ * @return
+ */
+ public String damSafetySyNoneHandle(String arg1, String arg2) {
+ //String adCode = "420607000000";
+ String uuid = UUID.randomUUID().toString();
+ String adCode = null;
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.alarm_db_sy_none_api);
+ // 获取告警规则详情，判断告警类型（短信，电话，站内信）
+ if (null!=alarmRule) {
+ // 查询告警详情信息
+ List<AlarmRuleDetail> alarmRuleDetailList = alarmRuleDetailService.list(new QueryWrapper<AlarmRuleDetail>().eq("alarm_rule_id", alarmRule.getId()));
+ if (alarmRuleDetailList.size()>0){
+ // 遍历
+ for (AlarmRuleDetail alarmRuleDetail : alarmRuleDetailList) {
+ if (alarmRuleDetail.getAlarmMode().equals("短信")) {
+ asyncNoticeHandle.damSafetyHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.damSafetyList,true, adCode, false,uuid);
+ }
+ }
+ }
+ }
+ // 返回
+ return "大坝安全监测告警";
+ }
+
+ /**
+ * 策略22: 大坝安全监测告警-渗流数据缺失
+ *
+ * @param arg1
+ * @param arg2
+ * @return
+ */
+ public String damSafetySlNoneHandle(String arg1, String arg2) {
+ //String adCode = "420607000000";
+ String uuid = UUID.randomUUID().toString();
+ String adCode = null;
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.alarm_db_sl_none_api);
+ // 获取告警规则详情，判断告警类型（短信，电话，站内信）
+ if (null!=alarmRule) {
+ // 查询告警详情信息
+ List<AlarmRuleDetail> alarmRuleDetailList = alarmRuleDetailService.list(new QueryWrapper<AlarmRuleDetail>().eq("alarm_rule_id", alarmRule.getId()));
+ if (alarmRuleDetailList.size()>0){
+ // 遍历
+ for (AlarmRuleDetail alarmRuleDetail : alarmRuleDetailList) {
+ if (alarmRuleDetail.getAlarmMode().equals("短信")) {
+ asyncNoticeHandle.damSafetyHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.damSafetyList,true, adCode, false,uuid);
+ }
+ }
+ }
+ }
+ // 返回
+ return "大坝安全监测告警";
+ }
+
+ /**
+ * 策略23: 大坝安全监测告警-位移数据缺失
+ *
+ * @param arg1
+ * @param arg2
+ * @return
+ */
+ public String damSafetyWyNoneHandle(String arg1, String arg2) {
+ //String adCode = "420607000000";
+ String uuid = UUID.randomUUID().toString();
+ String adCode = null;
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.alarm_db_wy_none_api);
+ // 获取告警规则详情，判断告警类型（短信，电话，站内信）
+ if (null!=alarmRule) {
+ // 查询告警详情信息
+ List<AlarmRuleDetail> alarmRuleDetailList = alarmRuleDetailService.list(new QueryWrapper<AlarmRuleDetail>().eq("alarm_rule_id", alarmRule.getId()));
+ if (alarmRuleDetailList.size()>0){
+ // 遍历
+ for (AlarmRuleDetail alarmRuleDetail : alarmRuleDetailList) {
+ if (alarmRuleDetail.getAlarmMode().equals("短信")) {
+ asyncNoticeHandle.damSafetyHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.damSafetyList,true, adCode, false,uuid);
+ }
+ }
+ }
+ }
+ // 返回
+ return "大坝安全监测告警";
+ }
+
}
--
Gitblit v1.9.3