告警查询返回调整

zhongrj

2023-06-06 104a9d0ece46ebbcdd9455be023195fa4d0521e0

 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,29 @@
   }

   /**
    * 依次添加巡查责任人，技术责任人信息
    * @param list
    */
   private void addPatrolTechnologyInfo(List<String> list) {
      // 查询巡查责任人姓名，技术责任人姓名信息
      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);
   }

   /**
    * 默认实现
    *
    * @param arg1 告警规则名称
@@ -312,7 +337,9 @@
            }
         }
         // 调用短信服务
         smsService.sendSignMsg(smsRequestTemplate);
         Map<String,Object> map = smsService.sendSignMsg(smsRequestTemplate);
         // 返回
         return "本次-水位初次超汛限告警短信成功通知数量：" + map.get("smsRecord");
      }
      // 返回
      return "水位超低于死水位";
@@ -349,22 +376,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 +392,8 @@
      return "水位接近汛限告警";
   }



   /**
    * 策略6: 水位初次超汛限告警
    *
@@ -388,8 +402,31 @@
    * @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);
            // 保存告警记录信息
            AlarmRecord alarmRecord = saveAlarmRecord(list,alarmRule);
            if (null != alarmRecord) {
               list.add(alarmRecord.getId().toString());
            }
         }
         // 调用短信服务
         Map<String, Object> map = smsService.sendSignMsg(smsRequestTemplate);
         // 返回
         return "本次-水位初次超汛限告警短信成功通知数量：" + map.get("smsRecord");
      }
      // 返回
      return "水位初次超汛限告警";
   }

   /**
@@ -544,9 +581,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 +602,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();
      }