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 | 53 +++++++++++++++++++++++++++++++++++++++++++++--------
1 files changed, 45 insertions(+), 8 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 2d931d5..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
@@ -78,7 +78,7 @@
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()));
@@ -212,7 +212,7 @@
/**
* 默认实现
*
- * @param arg1
+ * @param arg1 告警规则名称
* @param arg2
* @return
*/
@@ -257,7 +257,7 @@
/**
* 策略2: 水位数据异常
*
- * @param arg1
+ * @param arg1 告警规则名称
* @param arg2
* @return
*/
@@ -288,7 +288,7 @@
/**
* 策略3: 水位超低于死水位(水库技术责任人、巡查责任人)
*
- * @param arg1
+ * @param arg1 告警规则名称
* @param arg2
* @return
*/
@@ -304,12 +304,11 @@
// 遍历，拼接县水利部人员电话
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
// 查询县水利部人员（通过水库编号）
- list.add("测试:13112341234");
+// list.add("测试:13112341234");
// 保存告警记录信息
AlarmRecord alarmRecord = saveAlarmRecord(list,alarmRule);
if (null != alarmRecord) {
list.add(alarmRecord.getId().toString());
-// list.add("123789");
}
}
// 调用短信服务
@@ -339,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