水位超低于死水位,水位数据异常 告警规则新增

zhongrj

2023-06-02 317b1f7b9fe6d5fa73a7caa19d492622239ceb63

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

@@ -64,10 +64,16 @@
    *
    * @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) {
@@ -76,7 +82,8 @@
         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,14 +195,18 @@
         }
      }
      // 根据角色，水库编号查询对应的告警人员信息
      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;
   }

   /**
@@ -206,7 +235,7 @@
         // 调用中台服务接口查询数据
         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()) {
@@ -239,12 +268,10 @@
         // 调用中台服务接口查询数据
         JSONArray ztData = getZtData("", ZtApiUrlConstant.res_z_not_normal_api);
         // 只发短信，将发短信信息组装好
         SmsRequestTemplate smsRequestTemplate = getSendSmsTemplate(ztData, "2431012248591",alarmRule, ZtApiDataColumnConstant.waterInfoNotList);
         // 拼接内容后面的联系方式,当前模板拼接平台服务电话
         // 遍历，拼接平台服务电话
         SmsRequestTemplate smsRequestTemplate
            = getSendSmsTemplate(ztData, "2431012248591",alarmRule, ZtApiDataColumnConstant.waterDataExcList,false);
         // 拼接后面内容
         for (List<String> list : smsRequestTemplate.getTemplateContent()) {
            // 添加平台电话
            list.add(PtInfoConstant.serverPhone);
            // 保存告警记录信息
            AlarmRecord alarmRecord = saveAlarmRecord(list,alarmRule);
            if (null != alarmRecord) {
@@ -259,15 +286,37 @@
   }

   /**
    * 策略3: 水位超低于死水位
    * 策略3: 水位超低于死水位(水库技术责任人、巡查责任人)
    *
    * @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());
//               list.add("123789");
            }
         }
         // 调用短信服务
         smsService.sendSignMsg(smsRequestTemplate);
      }
      // 返回
      return "水位超低于死水位";
   }

   /**