站内信水位初次超汛限告警修改（新增病险水库区分）

zhongrj

2023-07-27 5fff66150b79e1cf41afc976972da36932263012

 skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeStrategyImpl.java

@@ -101,25 +101,13 @@
    */
   public String waterDataExcHandle(String arg1, String arg2) {
      String templateId = "2431012248591";
      //String adCode = "421181000000";
      String adCode = null;
      String uuid = templateId + UUID.randomUUID().toString();
      // 查询当前策略对应的告警规则信息
      AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
      if (null!=alarmRule) {
         // 调用中台服务接口查询数据
         JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.res_z_not_normal_api);
         // 只发短信，将发短信信息组装好
         SmsRequestTemplate smsRequestTemplate
            = noticeHandle.getSendSmsTemplate(ztData, templateId,alarmRule, ZtApiDataColumnConstant.waterDataExcList,false,null,uuid);
         // 拼接后面内容
         for (List<String> list : smsRequestTemplate.getTemplateContent()) {
            // 保存告警记录信息
            AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list,alarmRule,uuid);
            if (null != alarmRecord) {
               list.add(alarmRecord.getId().toString());
            }
         }
         // 调用短信服务
         smsService.sendSignMsg(smsRequestTemplate);
         asyncNoticeHandle.waterDataExcHandle(alarmRule,templateId,uuid,adCode,false);
      }
      // 返回
      return "水位数据异常";
@@ -133,30 +121,14 @@
    * @return
    */
   public String waterLessDeadHandle(String arg1, String arg2) {
      String adCode = "420607000000";
//      String adCode = null;
      String templateId = "2431012248594";
      String uuid = templateId + UUID.randomUUID().toString();
      // 查询当前策略对应的告警规则信息
      AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
      if (null!=alarmRule) {
         // 调用中台服务接口查询数据
         JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.res_diff_dead_z_api);
         // 只发短信，将发短信信息组装好
         SmsRequestTemplate smsRequestTemplate = noticeHandle.getSendSmsTemplate(ztData, templateId,alarmRule, ZtApiDataColumnConstant.waterLessDeadList,true,null,uuid);
         // 拼接内容后面的联系方式,当前模板县水利部人员姓名电话
         // 遍历，拼接县水利部人员电话
         for (List<String> list : smsRequestTemplate.getTemplateContent()) {
            // 查询县水利部人员（通过水库编号）
//            list.add("测试:13112341234");
            // 保存告警记录信息
            AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list,alarmRule,uuid);
            if (null != alarmRecord) {
               list.add(alarmRecord.getId().toString());
            }
         }
         // 调用短信服务
         Map<String, Object> map = smsService.sendSignMsg(smsRequestTemplate);
         // 返回
         return "本次-水位初次超汛限告警短信成功通知数量：" + map.get("smsRecord");
         asyncNoticeHandle.waterLessDeadHandle(templateId,uuid,alarmRule,adCode,false);
      }
      // 返回
      return "水位超低于死水位";
@@ -177,7 +149,7 @@
   }

   /**
    * 策略5: 水位接近汛限告警
    * 策略5: 水位接近汛限告警（站内信）
    *
    * @param arg1
    * @param arg2
@@ -190,7 +162,7 @@
      // 查询当前策略对应的告警规则信息
      AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
      if (null!=alarmRule) {
         asyncNoticeHandle.waterComeOverHandle(templateId,uuid,alarmRule, null);
         asyncNoticeHandle.waterComeOverHandle(templateId,uuid,alarmRule, adCode,true);
      }
      return "水位接近汛限告警";
   }
@@ -335,8 +307,17 @@
    * @return
    */
   public String alreadyHeavyRainHandle(String arg1, String arg2) {
      // 业务逻辑处理 2...
      return "";
      //String adCode = "420607000000";
      String adCode = null;
      String templateId = "2431012248569";
      String uuid = templateId + UUID.randomUUID().toString();
      // 查询当前策略对应的告警规则信息
      AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
      if (null!=alarmRule) {
         asyncNoticeHandle.alreadyHeavyRainHandle(templateId,uuid,alarmRule,adCode,false);
      }
      // 返回
      return "已降大雨告警";
   }

   /**
@@ -347,8 +328,17 @@
    * @return
    */
   public String alreadyRainstormHandle(String arg1, String arg2) {
      // 业务逻辑处理 2...
      return "";
      //String adCode = "420607000000";
      String adCode = null;
      String templateId = "2431012216683";
      String uuid = templateId + UUID.randomUUID().toString();
      // 查询当前策略对应的告警规则信息
      AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
      if (null!=alarmRule) {
         asyncNoticeHandle.alreadyRainstormHandle(templateId,uuid,alarmRule,adCode,false);
      }
      // 返回
      return "已降暴雨告警";
   }

   /**
@@ -371,8 +361,17 @@
    * @return
    */
   public String sixHourRainHandle(String arg1, String arg2) {
      // 业务逻辑处理 2...
      return "";
      //String adCode = "420607000000";
      String adCode = null;
      String templateId = "2431012216686";
      String uuid = templateId + UUID.randomUUID().toString();
      // 查询当前策略对应的告警规则信息
      AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
      if (null!=alarmRule) {
         asyncNoticeHandle.sixHourRainHandle(templateId,uuid,alarmRule,adCode,false);
      }
      // 返回
      return "6小时降雨告警";
   }

}