From 877e64ea7a23472297ba93027210bb1d4c4a8c4f Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Sat, 01 Jul 2023 17:23:12 +0800
Subject: [PATCH] 短信导入发送数据返回提示修改，告警短信发送修改（新增市县水利部人员查询并放入短信中）
---
skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeStrategyImpl.java | 124 +++++++++++++++++++++++++++++++++--------
1 files changed, 100 insertions(+), 24 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 3634407..f77b057 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
@@ -4,8 +4,9 @@
import cn.gistack.alerts.alarmRule.entity.AlarmRule;
import cn.gistack.alerts.alarmRule.service.AlarmRecordService;
import cn.gistack.alerts.alarmRule.service.AlarmRuleService;
+import cn.gistack.alerts.notice.constant.ZtConfigConstant;
import cn.gistack.alerts.sms.service.ISmsTemplateService;
-import cn.gistack.sm.intelligentCall.constant.ZtConstant;
+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;
@@ -30,6 +31,7 @@
import org.springframework.web.client.RestTemplate;
import java.util.ArrayList;
import java.util.List;
+import java.util.Map;
/**
* 通知策略
@@ -66,7 +68,7 @@
* @param templateId
* @param alarmRule
* @param columnsList 列名集合信息
- * @param flag
+ * @param flag 是否包含日期
* @return
*/
private SmsRequestTemplate getSendSmsTemplate(JSONArray jsonArray,
@@ -210,6 +212,57 @@
}
/**
+ * 依次添加巡查责任人，技术责任人信息
+ * @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("?");
+ }
+ }
+
+ /**
* 默认实现
*
* @param arg1 告警规则名称
@@ -312,7 +365,9 @@
}
}
// 调用短信服务
- smsService.sendSignMsg(smsRequestTemplate);
+ Map<String,Object> map = smsService.sendSignMsg(smsRequestTemplate);
+ // 返回
+ return "本次-水位初次超汛限告警短信成功通知数量：" + map.get("smsRecord");
}
// 返回
return "水位超低于死水位";
@@ -349,22 +404,7 @@
// 遍历，拼接县水利部人员电话
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);
+ addPatrolTechnologyInfo(list);
// 市县水利部门人员姓名电话（暂时不要）
// list.add("测试:13112341234");
// 保存告警记录信息
@@ -380,6 +420,8 @@
return "水位接近汛限告警";
}
+
+
/**
* 策略6: 水位初次超汛限告警
*
@@ -388,9 +430,36 @@
* @return
*/
public String waterFirstOverHandle(String arg1, String arg2) {
- // 业务逻辑处理 2...
- return "";
+ // 查询当前策略对应的告警规则信息
+ AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
+ if (null!=alarmRule) {
+ // 调用中台服务接口查询数据
+ JSONArray ztData = getZtData("", ZtApiUrlConstant.over_z_res_api);
+ // 只发短信，将发短信信息组装好
+ SmsRequestTemplate smsRequestTemplate
+ = getSendSmsTemplate(ztData, "2431012216671",alarmRule, ZtApiDataColumnConstant.waterFirstOverList,true);
+ // 拼接后面内容
+ for (List<String> list : smsRequestTemplate.getTemplateContent()) {
+ // 依次拼接巡查责任人，技术责任人姓名
+ addPatrolTechnologyInfo(list);
+ // 拼接市县水利部人员姓名及联系方式
+ addCityCountyBusinessPersonInfo(list);
+ // 保存告警记录信息
+ AlarmRecord alarmRecord = saveAlarmRecord(list,alarmRule);
+ if (null != alarmRecord) {
+ list.add(alarmRecord.getId().toString());
+// list.add("999");
+ }
+ }
+ // 调用短信服务
+ Map<String, Object> map = smsService.sendSignMsg(smsRequestTemplate);
+ // 返回
+ return "本次-水位初次超汛限告警短信成功通知数量：" + map.get("smsRecord");
+ }
+ // 返回
+ return "水位初次超汛限告警";
}
+
/**
* 策略7: 水位小幅超汛限告警
@@ -544,9 +613,17 @@
* @return
*/
private JSONArray getZtData(String params, String url) {
+ // 获取环境
+ String activeProfile = SpringContextUtil.getActiveProfile();
+ if (activeProfile.equals("dev")){
+ url = ZtApiUrlConstant.url_prefix_dev + url;
+ }
+ if (activeProfile.equals("prod")){
+ url = ZtApiUrlConstant.url_prefix_prod + url;
+ }
//设置请求头
HttpHeaders headers = new HttpHeaders();
- headers.add(ZtConstant.header_key, ZtConstant.header_value);
+ headers.add(ZtConfigConstant.header_key, ZtConfigConstant.header_value);
//封装请求头
HttpEntity<MultiValueMap<String, Object>> formEntity = new HttpEntity<MultiValueMap<String, Object>>(headers);
try {
@@ -557,9 +634,8 @@
formEntity,
String.class);
JSONObject jsonObject = JSON.parseObject(responseEntity.getBody());
- JSONArray jsonArray = JSONArray.parseArray(jsonObject.get("data").toString());
// 返回
- return jsonArray;
+ return JSONArray.parseArray(jsonObject.get("data").toString());
} catch (Exception e) {
e.printStackTrace();
}
--
Gitblit v1.9.3