From c8b03d3da4e29fc3fb9a42ca157738256c331a00 Mon Sep 17 00:00:00 2001
From: guoshilong <123456>
Date: Wed, 13 Mar 2024 13:55:08 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/jtdev' into jtdev
---
skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeStrategyImpl.java | 848 ++++++++++++++++++++++++++++++--------------------------
1 files changed, 455 insertions(+), 393 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 b6aeac9..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
@@ -1,37 +1,16 @@
package cn.gistack.alerts.notice.service.impl;
-import cn.gistack.alerts.alarmRule.entity.AlarmRecord;
import cn.gistack.alerts.alarmRule.entity.AlarmRule;
-import cn.gistack.alerts.alarmRule.service.AlarmRecordService;
+import cn.gistack.alerts.alarmRule.entity.AlarmRuleDetail;
+import cn.gistack.alerts.alarmRule.service.AlarmRuleDetailService;
import cn.gistack.alerts.alarmRule.service.AlarmRuleService;
-import cn.gistack.alerts.notice.constant.ZtConfigConstant;
-import cn.gistack.alerts.sms.service.ISmsTemplateService;
-import cn.gistack.common.utils.SpringContextUtil;
-import cn.gistack.alerts.notice.constant.PtInfoConstant;
import cn.gistack.alerts.notice.constant.ZtApiDataColumnConstant;
import cn.gistack.alerts.notice.constant.ZtApiUrlConstant;
-import cn.gistack.alerts.notice.enums.PersonEnum;
-import cn.gistack.alerts.notice.util.FormatUtil;
-import cn.gistack.sm.sjztmd.vo.PersonVO;
-import cn.gistack.sm.sjztmd.feign.IAttResManagePersonClient;
-import cn.gistack.alerts.sms.entity.SmsTemplate;
-import cn.gistack.alerts.sms.service.SmsService;
-import cn.gistack.alerts.sms.vo.SmsRequestTemplate;
-import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpEntity;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
-import org.springframework.util.MultiValueMap;
-import org.springframework.web.client.RestTemplate;
-import java.util.ArrayList;
import java.util.List;
-import java.util.Map;
import java.util.UUID;
/**
@@ -44,240 +23,19 @@
public class NoticeStrategyImpl {
@Autowired
- private SmsService smsService;
-
- @Autowired
private AlarmRuleService alarmRuleService;
@Autowired
- private AlarmRecordService alarmRecordService;
+ private AlarmRuleDetailService alarmRuleDetailService;
@Autowired
- private ISmsTemplateService smsTemplateService;
+ private NoticeHandle noticeHandle;
@Autowired
- private RestTemplate restTemplate;
-
- @Autowired
- private IAttResManagePersonClient attResManagePersonClient;
+ private AsyncNoticeHandle asyncNoticeHandle;
- /**
- * 短信发送数据组装
- *
- * @param jsonArray
- * @param templateId
- * @param alarmRule
- * @param columnsList 列名集合信息
- * @param flag 是否包含日期
- * @return
- */
- private SmsRequestTemplate getSendSmsTemplate(JSONArray jsonArray,
- String templateId,
- AlarmRule alarmRule,
- List<String> columnsList,
- Boolean flag) {
- // 通过模板id 查询模板相关信息
- SmsTemplate smsTemplate = smsTemplateService.getOne(new QueryWrapper<SmsTemplate>().eq("template_id",templateId).eq("is_deleted",0));
- if (null != smsTemplate) {
- SmsRequestTemplate smsRequestTemplate = new SmsRequestTemplate();
- // 设置模板信息
- smsRequestTemplate.setSmsTemplate(smsTemplate);
- // 解析模板并设置 title
- smsRequestTemplate.setTitle(FormatUtil.composeMessage(smsTemplate.getContent()));
- // 列名数据转换
- getColumnData(jsonArray, columnsList,smsRequestTemplate,alarmRule,flag);
- //返回
- return smsRequestTemplate;
- }
- return null;
- }
- /**
- * 列名数据转换
- * @param jsonArray
- * @param columnsList
- * @param smsRequestTemplate
- * @param flag
- * @return
- */
- private void getColumnData(JSONArray jsonArray,
- List<String> columnsList,
- SmsRequestTemplate smsRequestTemplate,
- AlarmRule alarmRule,
- Boolean flag) {
- List<PersonVO> personLists = new ArrayList<>();
- List<List<String>> lists = new ArrayList<>();
- for (int i = 0; i < jsonArray.size(); i++) {
- String county_cd = jsonArray.getJSONObject(i).getString("county_cd");
- // city_cd,county_cd
- if (county_cd.equals("421303000000")) {
- // 根据水库编号，所在区域查询需要发送的人员手机号及设置
- String res_cd = jsonArray.getJSONObject(i).getString("res_cd");
- // 判断时间是否存在
- String tm = jsonArray.getJSONObject(i).getString("tm");
- String day = "";
- String hour = "";
- String minute = "";
- if (null != tm && !tm.equals("") && flag) {
- flag = true;
- // 加入天，时，分
- day = tm.substring(8, 10);
- hour = tm.substring(11, 13);
- minute = tm.substring(14, 16);
- } else {
- flag = false;
- }
- // 查询告警人员信息
- List<PersonVO> personVOList = getPersonListByResGuid(res_cd, alarmRule);
- if (personVOList.size() > 0) {
- for (PersonVO personVO : personVOList) {
- List<String> list = new ArrayList<>();
- list.add(res_cd);
- list.add(personVO.getPhone());
- if (flag) {
- list.add(day);
- list.add(hour);
- list.add(minute);
- }
- // 变量将值放入集合中
- for (String column : columnsList) {
- String[] split = column.split(",");
- String format = "";
- for (String s : split) {
- format = format + jsonArray.getJSONObject(i).getString(s);
- }
- list.add(format);
- }
- lists.add(list);
- }
- }
- personLists.addAll(personVOList);
- }
- }
- // 设置信息
- smsRequestTemplate.setPersonVOList(personLists);
- smsRequestTemplate.setTemplateContent(lists);
- }
-
- /**
- * 保存告警记录信息
- * @param list
- * @param alarmRule 告警规则
- * @param uuid 临时id
- * @return
- */
- private AlarmRecord saveAlarmRecord(List<String> list,AlarmRule alarmRule,String uuid) {
- AlarmRecord alarmRecord = alarmRecordService.getOne(new QueryWrapper<AlarmRecord>()
- .eq("temp_code",uuid)
- .eq("alarm_rule_id",alarmRule.getId())
- .eq("reservoir_number",list.get(0))
- );
- if (null!=alarmRecord) {
- return alarmRecord;
- }else {
- AlarmRecord alarm = new AlarmRecord();
- // 设置相关信息
- alarm.setAlarmRuleId(alarmRule.getId().toString());
-
- alarm.setReservoirNumber(list.get(0));
- alarm.setAlarmCondition(alarmRule.getRuleRemark());
- alarm.setTempCode(uuid);
- // 新增
- boolean save = alarmRecordService.save(alarm);
- if (save) {
- return alarm;
- }
- }
- // 返回
- return null;
- }
-
- /**
- * 查询告警人员信息
- * @param res_cd 水库 guid
- * @param alarmRule
- * @return
- */
- private List<PersonVO> getPersonListByResGuid(String res_cd,AlarmRule alarmRule) {
- // 查询对应的角色信息
- String roles = alarmRule.getAlarmPerson();
- String[] roleArray = roles.split(",");
- List<String> personList = new ArrayList<>();
- List<String> areaList = new ArrayList<>();
- // 遍历
- for (String role : roleArray) {
- if (role.contains("责任人")){
- personList.add(PersonEnum.findByName(role).getType().toString());
- }else {
- areaList.add(role);
- }
- }
- // 根据角色，水库编号查询对应的告警人员信息
- List<PersonVO> list = new ArrayList<>();
- //1. 根据水库编号查询除责任人之外的人员信息
- if (areaList.size() > 0) {
- List<PersonVO> personVOList = attResManagePersonClient.getUserListByResGuid(res_cd);
- list.addAll(personVOList);
- }
- //2. 根据水库编号及责任人类型查询相关责任人信息
- List<PersonVO> personVOList1 = attResManagePersonClient.getPersonListByResGuid(res_cd,String.join(",",personList));
- // 合并人员数据
- list.addAll(personVOList1);
- // 返回数据
- return list;
- }
-
- /**
- * 依次添加巡查责任人，技术责任人信息
- * @param list
- */
- private void addPatrolTechnologyInfo(List<String> list) {
- // 查询巡查责任人姓名，技术责任人姓名信息
- List<PersonVO> personVOList = attResManagePersonClient.getPersonListByResGuid(list.get(0),"4,5");
- if (personVOList.size()>0) {
- String xczrr = "";
- String jszrr = "";
- for (PersonVO personVO : personVOList) {
- if (personVO.getType().equals("5")) {
- xczrr = personVO.getName();
- }
- if (personVO.getType().equals("4")) {
- jszrr = personVO.getName();
- }
- }
- // 巡查责任人姓名
- list.add(xczrr);
- // 技术责任人姓名
- list.add(jszrr);
- }else {
- // 巡查责任人姓名
- list.add("");
- // 技术责任人姓名
- list.add("");
- }
- }
-
-
- /**
- * 拼接市县水利部人员姓名及联系方式
- * @param list
- */
- private void addCityCountyBusinessPersonInfo(List<String> list) {
- // 根据水库编号查询市县水利部人员姓名及联系方式
- List<PersonVO> personVOList = attResManagePersonClient.getCityCountyPersonListByResGuid(list.get(0));
- if (personVOList.size()>0){
- // 如果没有找到人员？
- StringBuilder builder = new StringBuilder();
- for (PersonVO personVO : personVOList) {
- builder.append(personVO.getName()).append(":").append(personVO.getPhone()).append(",");
- }
- // 拼接水利部人员信息
- list.add(builder.substring(0,builder.length()-1));
- }else {
- list.add("");
- }
- }
/**
* 默认实现
@@ -299,28 +57,24 @@
* @return
*/
public String waterInfoNotHandle(String arg1, String arg2) {
- String templateId = "2431012216668";
- String uuid = templateId + UUID.randomUUID().toString();
+ //String adCode = "421181000000";
+ String adCode = null;
// 查询当前策略对应的告警规则信息
AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.no_z_last_api_all);
+ // 获取告警规则详情，判断告警类型（短信，电话，站内信）
if (null!=alarmRule) {
- // 调用中台服务接口查询数据
- JSONArray ztData = getZtData("", ZtApiUrlConstant.res_z_null_api);
- // 只发短信，将发短信信息组装好
- SmsRequestTemplate smsRequestTemplate = getSendSmsTemplate(ztData, templateId,alarmRule, ZtApiDataColumnConstant.waterInfoNotList,false);
- // 拼接内容后面的联系方式,当前模板拼接平台服务电话
- // 遍历，拼接平台服务电话
- for (List<String> list : smsRequestTemplate.getTemplateContent()) {
- // 添加平台电话
- list.add(PtInfoConstant.serverPhone);
- // 保存告警记录信息
- AlarmRecord alarmRecord = saveAlarmRecord(list,alarmRule,uuid);
- if (null != alarmRecord) {
- list.add(alarmRecord.getId().toString());
+ // 查询告警详情信息
+ 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.waterInfoNotHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.waterInfoNotList,false, adCode, false);
+ }
}
}
- // 调用短信服务
- smsService.sendSignMsg(smsRequestTemplate);
}
// 返回
return "水位信息接收不到";
@@ -334,26 +88,24 @@
* @return
*/
public String waterDataExcHandle(String arg1, String arg2) {
- String templateId = "2431012248591";
- String uuid = templateId + UUID.randomUUID().toString();
+ //String adCode = "421181000000";
+ String adCode = null;
// 查询当前策略对应的告警规则信息
AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.res_z_not_normal_api);
+ // 获取告警规则详情，判断告警类型（短信，电话，站内信）
if (null!=alarmRule) {
- // 调用中台服务接口查询数据
- JSONArray ztData = getZtData("", ZtApiUrlConstant.res_z_not_normal_api);
- // 只发短信，将发短信信息组装好
- SmsRequestTemplate smsRequestTemplate
- = getSendSmsTemplate(ztData, templateId,alarmRule, ZtApiDataColumnConstant.waterDataExcList,false);
- // 拼接后面内容
- for (List<String> list : smsRequestTemplate.getTemplateContent()) {
- // 保存告警记录信息
- AlarmRecord alarmRecord = saveAlarmRecord(list,alarmRule,uuid);
- if (null != alarmRecord) {
- list.add(alarmRecord.getId().toString());
+ // 查询告警详情信息
+ 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.waterInfoNotHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.waterDataExcList,false, adCode, false);
+ }
}
}
- // 调用短信服务
- smsService.sendSignMsg(smsRequestTemplate);
}
// 返回
return "水位数据异常";
@@ -367,34 +119,30 @@
* @return
*/
public String waterLessDeadHandle(String arg1, String arg2) {
- String templateId = "2431012248594";
- String uuid = templateId + UUID.randomUUID().toString();
+ String adCode = "420881000000";
+// String adCode = null;
// 查询当前策略对应的告警规则信息
AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.res_diff_dead_z_api);
+ // 获取告警规则详情，判断告警类型（短信，电话，站内信）
if (null!=alarmRule) {
- // 调用中台服务接口查询数据
- JSONArray ztData = getZtData("", ZtApiUrlConstant.res_diff_dead_z_api);
- // 只发短信，将发短信信息组装好
- SmsRequestTemplate smsRequestTemplate = getSendSmsTemplate(ztData, templateId,alarmRule, ZtApiDataColumnConstant.waterLessDeadList,true);
- // 拼接内容后面的联系方式,当前模板县水利部人员姓名电话
- // 遍历，拼接县水利部人员电话
- for (List<String> list : smsRequestTemplate.getTemplateContent()) {
- // 查询县水利部人员（通过水库编号）
-// list.add("测试:13112341234");
- // 保存告警记录信息
- AlarmRecord alarmRecord = saveAlarmRecord(list,alarmRule,uuid);
- if (null != alarmRecord) {
- list.add(alarmRecord.getId().toString());
+ // 查询告警详情信息
+ 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.waterLessDeadHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.waterLessDeadList,true, adCode, false);
+ }
}
}
- // 调用短信服务
- Map<String,Object> map = smsService.sendSignMsg(smsRequestTemplate);
- // 返回
- return "本次-水位初次超汛限告警短信成功通知数量：" + map.get("smsRecord");
}
// 返回
return "水位超低于死水位";
}
+
+
/**
* 策略4: 水位高于死水位，低于旱警水位
@@ -409,38 +157,30 @@
}
/**
- * 策略5: 水位接近汛限告警
+ * 策略5: 水位接近汛限告警（站内信）
*
* @param arg1
* @param arg2
* @return
*/
public String waterComeOverHandle(String arg1, String arg2) {
- String templateId = "znxsw10000001";
- String uuid = templateId + UUID.randomUUID().toString();
+ String adCode = null;
// 查询当前策略对应的告警规则信息
AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.res_z_is_warn_over_flse_api);
+ // 获取告警规则详情，判断告警类型（短信，电话，站内信）
if (null!=alarmRule) {
- // 调用中台服务接口查询数据
- JSONArray ztData = getZtData("", ZtApiUrlConstant.res_diff_dead_z_api);
- // 只发送站内信
- SmsRequestTemplate smsRequestTemplate = getSendSmsTemplate(ztData, templateId,alarmRule, ZtApiDataColumnConstant.waterLessDeadList,true);
- // 拼接内容后面的联系方式,当前模板县水利部人员姓名电话
- // 遍历，拼接县水利部人员电话
- for (List<String> list : smsRequestTemplate.getTemplateContent()) {
- // 后面依次拼接 巡查责任人姓名，技术责任人姓名，市县水利部门人员姓名电话（暂时不要）
- addPatrolTechnologyInfo(list);
- // 市县水利部门人员姓名电话（暂时不要）
-// list.add("测试:13112341234");
- // 保存告警记录信息
- AlarmRecord alarmRecord = saveAlarmRecord(list,alarmRule,uuid);
- if (null != alarmRecord) {
- list.add(alarmRecord.getId().toString());
-// list.add("999");
+ // 查询告警详情信息
+ 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.waterComeOverHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.waterComeOverList,true, adCode, true);
+ }
}
}
- // 保存站内信记录信息
- smsService.saveInStationInfo(smsRequestTemplate);
}
return "水位接近汛限告警";
}
@@ -448,41 +188,29 @@
/**
- * 策略6: 水位初次超汛限告警
+ * 策略6: 水位初次超汛限告警(当前测试发送站内信)
*
* @param arg1
* @param arg2
* @return
*/
public String waterFirstOverHandle(String arg1, String arg2) {
- String templateId = "2431012216671";
- String uuid = templateId + UUID.randomUUID().toString();
+ String adCode = "421303000000";
// 查询当前策略对应的告警规则信息
AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.over_z_res_api);
+ // 获取告警规则详情，判断告警类型（短信，电话，站内信）
if (null!=alarmRule) {
- // 调用中台服务接口查询数据
- JSONArray ztData = getZtData("", ZtApiUrlConstant.over_z_res_api);
- // 只发短信，将发短信信息组装好
- SmsRequestTemplate smsRequestTemplate
- = getSendSmsTemplate(ztData, templateId,alarmRule, ZtApiDataColumnConstant.waterFirstOverList,true);
- // 拼接后面内容
- if (smsRequestTemplate.getPersonVOList().size()>0) {
- for (List<String> list : smsRequestTemplate.getTemplateContent()) {
- // 依次拼接巡查责任人，技术责任人姓名
- addPatrolTechnologyInfo(list);
- // 拼接市县水利部人员姓名及联系方式
- addCityCountyBusinessPersonInfo(list);
- // 保存告警记录信息
- AlarmRecord alarmRecord = saveAlarmRecord(list,alarmRule,uuid);
- if (null != alarmRecord) {
- list.add(alarmRecord.getId().toString());
-// list.add("999");
+ // 查询告警详情信息
+ 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.waterFirstOverHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.waterFirstOverList,true, adCode, true);
}
}
- // 调用短信服务
- Map<String, Object> map = smsService.sendSignMsg(smsRequestTemplate);
- // 返回
- return "本次-水位初次超汛限告警短信成功通知数量：" + map.get("smsRecord");
}
}
// 返回
@@ -498,8 +226,29 @@
* @return
*/
public String waterSmallScaleOverHandle(String arg1, String arg2) {
- // 业务逻辑处理 2...
- return "";
+// String adCode = "421303000000";
+ String adCode = null;
+ String uuid = UUID.randomUUID().toString();
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.res_over_z_small_over_api);
+ // 获取告警规则详情，判断告警类型（短信，电话，站内信）
+ if (null!=alarmRule) {
+ // 查询告警详情信息
+ List<AlarmRuleDetail> alarmRuleDetailList = alarmRuleDetailService.list(new QueryWrapper<AlarmRuleDetail>().eq("alarm_rule_id", alarmRule.getId()));
+ if (alarmRuleDetailList.size()>0){
+ // 遍历
+ if (alarmRuleDetailList.get(0).getAlarmMode().equals("短信")) {
+ asyncNoticeHandle.waterSmallScaleOverHandle1(alarmRule, alarmRuleDetailList.get(0), ztData,ZtApiDataColumnConstant.waterSmallScaleOverList,true, adCode, false,uuid);
+ }
+ if (alarmRuleDetailList.get(1).getAlarmMode().equals("短信")) {
+ asyncNoticeHandle.waterSmallScaleOverHandle2(alarmRule, alarmRuleDetailList.get(1), ztData,ZtApiDataColumnConstant.waterSmallScaleOverList,true, adCode, false,uuid);
+ }
+ }
+ }
+ // 返回
+ return "水位小幅超汛限告警";
}
/**
@@ -510,8 +259,29 @@
* @return
*/
public String waterBigScaleOverHandle(String arg1, String arg2) {
- // 业务逻辑处理 2...
- return "";
+ //String adCode = "421303000000";
+ String adCode = null;
+ String uuid = UUID.randomUUID().toString();
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.res_over_z_big_over_api);
+ // 获取告警规则详情，判断告警类型（短信，电话，站内信）
+ if (null!=alarmRule) {
+ // 查询告警详情信息
+ List<AlarmRuleDetail> alarmRuleDetailList = alarmRuleDetailService.list(new QueryWrapper<AlarmRuleDetail>().eq("alarm_rule_id", alarmRule.getId()));
+ if (alarmRuleDetailList.size()>0){
+ // 遍历
+ if (alarmRuleDetailList.get(0).getAlarmMode().equals("短信")) {
+ asyncNoticeHandle.waterBigScaleOverHandle1(alarmRule, alarmRuleDetailList.get(0), ztData,ZtApiDataColumnConstant.waterBigScaleOverList1,true, adCode, false,uuid);
+ }
+ if (alarmRuleDetailList.get(1).getAlarmMode().equals("短信")) {
+ asyncNoticeHandle.waterBigScaleOverHandle2(alarmRule, alarmRuleDetailList.get(1), ztData,ZtApiDataColumnConstant.waterBigScaleOverList2,true, adCode, false,uuid);
+ }
+ }
+ }
+ // 返回
+ return "水位大幅超汛限告警";
}
/**
@@ -522,8 +292,32 @@
* @return
*/
public String waterComeDesignHandle(String arg1, String arg2) {
- // 业务逻辑处理 2...
- return "";
+ String adCode = null;
+ String uuid = UUID.randomUUID().toString();
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.res_over_des_is_warn_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.waterComeDesignHandleBySms(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.waterComeDesignList1,true, adCode, false,uuid);
+ }
+// if (alarmRuleDetail.getAlarmMode().equals("电话")) {
+// asyncNoticeHandle.outCallHandleCall(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.waterComeDesignList2,true, adCode, false,uuid);
+// }
+ if (alarmRuleDetail.getAlarmMode().equals("站内信")) {
+ asyncNoticeHandle.waterComeDesignHandleStation(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.waterComeDesignList3,true, adCode, true,uuid);
+ }
+ }
+ }
+ }
+ return "水位接近设计洪水位告警";
}
/**
@@ -534,8 +328,30 @@
* @return
*/
public String waterMoreDesignHandle(String arg1, String arg2) {
- // 业务逻辑处理 2...
- return "";
+ String adCode = null;
+ String uuid = UUID.randomUUID().toString();
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.over_des_rz_warn_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.waterMoreDesignHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.waterMoreDesignList,true, adCode, false,uuid);
+ }
+// if (alarmRuleDetail.getAlarmMode().equals("电话")) {
+// asyncNoticeHandle.outCallHandleCall(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.waterMoreDesignList,true, adCode, false,uuid);
+// }
+ }
+ }
+ }
+ // 返回
+ return "水位超设计洪水位告警";
}
/**
@@ -546,8 +362,30 @@
* @return
*/
public String waterMoreCheckHandle(String arg1, String arg2) {
- // 业务逻辑处理 2...
- return "";
+ String adCode = null;
+ String uuid = UUID.randomUUID().toString();
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.res_over_chec_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.waterMoreCheckHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.waterMoreCheckList,true, adCode, false,uuid);
+ }
+// if (alarmRuleDetail.getAlarmMode().equals("电话")) {
+// asyncNoticeHandle.outCallHandleCall(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.waterMoreCheckList,true, adCode, false,uuid);
+// }
+ }
+ }
+ }
+ // 返回
+ return "水位超校核洪水位告警";
}
/**
@@ -558,8 +396,27 @@
* @return
*/
public String waterComeOneHourUpHandle(String arg1, String arg2) {
- // 业务逻辑处理 2...
- return "";
+ String adCode = null;
+ String uuid = UUID.randomUUID().toString();
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.res_z_diff_up_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.waterComeOneHourUpHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.waterComeOneHourUpList,true, adCode, false,uuid);
+ }
+ }
+ }
+ }
+ // 返回
+ return "近1h水位陡升";
}
/**
@@ -570,8 +427,27 @@
* @return
*/
public String waterComeOneHourDownHandle(String arg1, String arg2) {
- // 业务逻辑处理 2...
- return "";
+ String adCode = null;
+ String uuid = UUID.randomUUID().toString();
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.res_z_diff_down_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.waterComeOneHourDownHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.waterComeOneHourDownList,true, adCode, false,uuid);
+ }
+ }
+ }
+ }
+ // 返回
+ return "近1h水位陡降";
}
/**
@@ -594,8 +470,27 @@
* @return
*/
public String alreadyHeavyRainHandle(String arg1, String arg2) {
- // 业务逻辑处理 2...
- return "";
+ //String adCode = "420607000000";
+ String adCode = null;
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.alarm_rain_dy_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.alreadyHeavyRainHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.alreadyHeavyRainList,true, adCode, false);
+ }
+ }
+ }
+ }
+ // 返回
+ return "已降大雨告警";
}
/**
@@ -606,8 +501,27 @@
* @return
*/
public String alreadyRainstormHandle(String arg1, String arg2) {
- // 业务逻辑处理 2...
- return "";
+ //String adCode = "420607000000";
+ String adCode = null;
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ // 调用中台服务接口查询数据
+ JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.alarm_rain_by_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.alreadyRainstormHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.alreadyRainstormList,true, adCode, false);
+ }
+ }
+ }
+ }
+ // 返回
+ return "已降暴雨告警";
}
/**
@@ -630,44 +544,192 @@
* @return
*/
public String sixHourRainHandle(String arg1, String arg2) {
- // 业务逻辑处理 2...
- return "";
+ //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_rain_6_over_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.sixHourRainHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.sixHourRainList,true, adCode, false,uuid);
+ }
+// if (alarmRuleDetail.getAlarmMode().equals("电话")) {
+// asyncNoticeHandle.outCallHandleCall(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.sixHourRainList,true, adCode, false,uuid);
+// }
+ }
+ }
+ }
+ // 返回
+ return "6小时降雨告警";
+ }
+
+
+ /**
+ * 策略19: 大坝安全监测告警-数据缺失
+ *
+ * @param arg1
+ * @param arg2
+ * @return
+ */
+ public String damSafetyHandle(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_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 "大坝安全监测告警";
}
/**
- * 调用中台接口查询数据
+ * 策略20: 大坝安全监测告警-渗压管水位大于校核洪水位
*
- * @param params
- * @param url
+ * @param arg1
+ * @param arg2
* @return
*/
- private JSONArray getZtData(String params, String url) {
- // 获取环境
- String activeProfile = SpringContextUtil.getActiveProfile();
- if (activeProfile.equals("dev")){
- url = ZtApiUrlConstant.url_prefix_dev + url;
+ public String damSafetySyHandle(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("?is_alarm=1", ZtApiUrlConstant.alarm_db_sy_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.damSafetySyHandle(alarmRule, alarmRuleDetail, ztData,ZtApiDataColumnConstant.damSafetySyList,true, adCode, true,uuid);
+ }
+ }
+ }
}
- if (activeProfile.equals("prod")){
- url = ZtApiUrlConstant.url_prefix_prod + url;
- }
- //设置请求头
- HttpHeaders headers = new HttpHeaders();
- headers.add(ZtConfigConstant.header_key, ZtConfigConstant.header_value);
- //封装请求头
- HttpEntity<MultiValueMap<String, Object>> formEntity = new HttpEntity<MultiValueMap<String, Object>>(headers);
- try {
- //有请求头，有参数请求
- ResponseEntity<String> responseEntity =
- restTemplate.exchange(url + params,
- HttpMethod.GET,
- formEntity,
- String.class);
- JSONObject jsonObject = JSON.parseObject(responseEntity.getBody());
- // 返回
- return JSONArray.parseArray(jsonObject.get("data").toString());
- } catch (Exception e) {
- e.printStackTrace();
- }
- return null;
+ // 返回
+ 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