From 29358cfe9b8da07f852c69a57f5d8fedcbbf116e Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Mon, 05 Jun 2023 20:32:53 +0800
Subject: [PATCH] 新增站内信记录保存
---
skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeStrategyImpl.java | 168 +++++++++++++++++++++++++++++++++++++++++++++----------
1 files changed, 137 insertions(+), 31 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 1e97ecc..3634407 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
@@ -6,9 +6,9 @@
import cn.gistack.alerts.alarmRule.service.AlarmRuleService;
import cn.gistack.alerts.sms.service.ISmsTemplateService;
import cn.gistack.sm.intelligentCall.constant.ZtConstant;
-import cn.gistack.alerts.alarmRule.notice.constant.PtInfoConstant;
-import cn.gistack.alerts.alarmRule.notice.constant.ZtApiDataColumnConstant;
-import cn.gistack.alerts.alarmRule.notice.constant.ZtApiUrlConstant;
+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;
@@ -64,19 +64,26 @@
*
* @param jsonArray
* @param templateId
+ * @param alarmRule
* @param columnsList 列名集合信息
+ * @param flag
* @return
*/
- private SmsRequestTemplate getSendSmsTemplate(JSONArray jsonArray, String templateId,AlarmRule alarmRule,List<String> columnsList) {
+ 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,templateId,alarmRule);
+ // 列名数据转换
+ getColumnData(jsonArray, columnsList,smsRequestTemplate,alarmRule,flag);
//返回
return smsRequestTemplate;
}
@@ -88,26 +95,45 @@
* @param jsonArray
* @param columnsList
* @param smsRequestTemplate
- * @param templateId
+ * @param flag
* @return
*/
private void getColumnData(JSONArray jsonArray,
List<String> columnsList,
SmsRequestTemplate smsRequestTemplate,
- String templateId,
- AlarmRule alarmRule) {
+ AlarmRule alarmRule,
+ Boolean flag) {
List<PersonVO> personLists = new ArrayList<>();
List<List<String>> lists = new ArrayList<>();
for (int i = 0; i < jsonArray.size(); i++) {
// 根据水库编号，所在区域查询需要发送的人员手机号及设置
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,templateId,alarmRule);
+ 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(",");
@@ -151,11 +177,10 @@
/**
* 查询告警人员信息
* @param res_cd 水库 guid
- * @param templateId
* @param alarmRule
* @return
*/
- private List<PersonVO> getPersonListByResGuid(String res_cd,String templateId,AlarmRule alarmRule) {
+ private List<PersonVO> getPersonListByResGuid(String res_cd,AlarmRule alarmRule) {
// 查询对应的角色信息
String roles = alarmRule.getAlarmPerson();
String[] roleArray = roles.split(",");
@@ -170,20 +195,24 @@
}
}
// 根据角色，水库编号查询对应的告警人员信息
+ List<PersonVO> list = new ArrayList<>();
//1. 根据水库编号查询除责任人之外的人员信息
- List<PersonVO> personVOList = attResManagePersonClient.getUserListByResGuid(res_cd);
+ 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));
// 合并人员数据
- personVOList.addAll(personVOList1);
+ list.addAll(personVOList1);
// 返回数据
- return personVOList;
+ return list;
}
/**
* 默认实现
*
- * @param arg1
+ * @param arg1 告警规则名称
* @param arg2
* @return
*/
@@ -206,48 +235,87 @@
// 调用中台服务接口查询数据
JSONArray ztData = getZtData("", ZtApiUrlConstant.res_z_null_api);
// 只发短信，将发短信信息组装好
- SmsRequestTemplate smsRequestTemplate = getSendSmsTemplate(ztData, "2431012216668",alarmRule, ZtApiDataColumnConstant.waterInfoNotList);
+ SmsRequestTemplate smsRequestTemplate = getSendSmsTemplate(ztData, "2431012216668",alarmRule, ZtApiDataColumnConstant.waterInfoNotList,false);
// 拼接内容后面的联系方式,当前模板拼接平台服务电话
// 遍历，拼接平台服务电话
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 添加平台电话
list.add(PtInfoConstant.serverPhone);
// 保存告警记录信息
-// AlarmRecord alarmRecord = saveAlarmRecord(list,alarmRule);
-// if (null != alarmRecord) {
-// list.add(alarmRecord.getId().toString());
- list.add("1123");
-// }
+ AlarmRecord alarmRecord = saveAlarmRecord(list,alarmRule);
+ if (null != alarmRecord) {
+ list.add(alarmRecord.getId().toString());
+ }
}
// 调用短信服务
smsService.sendSignMsg(smsRequestTemplate);
}
- // 保存预警记录
+ // 返回
return "水位信息接收不到";
}
/**
* 策略2: 水位数据异常
*
- * @param arg1
+ * @param arg1 告警规则名称
* @param arg2
* @return
*/
public String waterDataExcHandle(String arg1, String arg2) {
- // 业务逻辑处理 2...
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ if (null!=alarmRule) {
+ // 调用中台服务接口查询数据
+ JSONArray ztData = getZtData("", ZtApiUrlConstant.res_z_not_normal_api);
+ // 只发短信，将发短信信息组装好
+ SmsRequestTemplate smsRequestTemplate
+ = getSendSmsTemplate(ztData, "2431012248591",alarmRule, ZtApiDataColumnConstant.waterDataExcList,false);
+ // 拼接后面内容
+ for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+ // 保存告警记录信息
+ AlarmRecord alarmRecord = saveAlarmRecord(list,alarmRule);
+ if (null != alarmRecord) {
+ list.add(alarmRecord.getId().toString());
+ }
+ }
+ // 调用短信服务
+ smsService.sendSignMsg(smsRequestTemplate);
+ }
+ // 返回
return "水位数据异常";
}
/**
- * 策略3: 水位超低于死水位
+ * 策略3: 水位超低于死水位(水库技术责任人、巡查责任人)
*
- * @param arg1
+ * @param arg1 告警规则名称
* @param arg2
* @return
*/
public String waterLessDeadHandle(String arg1, String arg2) {
- // 业务逻辑处理 2...
- return "";
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ if (null!=alarmRule) {
+ // 调用中台服务接口查询数据
+ JSONArray ztData = getZtData("", ZtApiUrlConstant.res_diff_dead_z_api);
+ // 只发短信，将发短信信息组装好
+ SmsRequestTemplate smsRequestTemplate = getSendSmsTemplate(ztData, "2431012248594",alarmRule, ZtApiDataColumnConstant.waterLessDeadList,true);
+ // 拼接内容后面的联系方式,当前模板县水利部人员姓名电话
+ // 遍历，拼接县水利部人员电话
+ for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+ // 查询县水利部人员（通过水库编号）
+// list.add("测试:13112341234");
+ // 保存告警记录信息
+ AlarmRecord alarmRecord = saveAlarmRecord(list,alarmRule);
+ if (null != alarmRecord) {
+ list.add(alarmRecord.getId().toString());
+ }
+ }
+ // 调用短信服务
+ smsService.sendSignMsg(smsRequestTemplate);
+ }
+ // 返回
+ return "水位超低于死水位";
}
/**
@@ -270,8 +338,46 @@
* @return
*/
public String waterComeOverHandle(String arg1, String arg2) {
- // 业务逻辑处理 2...
- return "";
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ if (null!=alarmRule) {
+ // 调用中台服务接口查询数据
+ JSONArray ztData = getZtData("", ZtApiUrlConstant.res_diff_dead_z_api);
+ // 只发送站内信
+ SmsRequestTemplate smsRequestTemplate = getSendSmsTemplate(ztData, "znxsw10000001",alarmRule, ZtApiDataColumnConstant.waterLessDeadList,true);
+ // 拼接内容后面的联系方式,当前模板县水利部人员姓名电话
+ // 遍历，拼接县水利部人员电话
+ for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+ // 后面依次拼接 巡查责任人姓名，技术责任人姓名，市县水利部门人员姓名电话（暂时不要）
+ // 查询巡查责任人姓名，技术责任人姓名信息
+ List<PersonVO> personVOList = attResManagePersonClient.getPersonListByResGuid(list.get(0),"4,5");
+ 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);
+ // 市县水利部门人员姓名电话（暂时不要）
+// list.add("测试:13112341234");
+ // 保存告警记录信息
+ AlarmRecord alarmRecord = saveAlarmRecord(list,alarmRule);
+ if (null != alarmRecord) {
+ list.add(alarmRecord.getId().toString());
+// list.add("999");
+ }
+ }
+ // 保存站内信记录信息
+ smsService.saveInStationInfo(smsRequestTemplate);
+ }
+ return "水位接近汛限告警";
}
/**
--
Gitblit v1.9.3