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

zhongrj

2023-06-02 317b1f7b9fe6d5fa73a7caa19d492622239ceb63

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

 skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/constant/ZtApiDataColumnConstant.java

@@ -20,4 +20,24 @@
        add("res_nm");
    }};

    /**
     * 水位数据异常（不包含责任人相关信息）
     */
    public static List<String>  waterDataExcList = new ArrayList<String>()
    {{
        add("county_nm,town_nm");
        add("res_nm");
        add("rz");
    }};

    /**
     * 水位超低于死水位(水库技术责任人、巡查责任人)
     */
    public static List<String>  waterLessDeadList = new ArrayList<String>()
    {{
        add("town_nm");
        add("res_nm");
        add("rz");
    }};

}

 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 "水位超低于死水位";
    }

    /**

 skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/strategy/NoticeStrategyContext.java

@@ -38,6 +38,7 @@
    public void initStrategies() {
        strategyMap.put("waterInfoNotHandle", (arg1, arg2) -> noticeStrategyImpl.waterInfoNotHandle(arg1, arg2));
        strategyMap.put("waterDataExcHandle", (arg1, arg2) -> noticeStrategyImpl.waterDataExcHandle(arg1, arg2));
        strategyMap.put("waterLessDeadHandle", (arg1, arg2) -> noticeStrategyImpl.waterLessDeadHandle(arg1, arg2));
    }

    /**

 skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/util/FormatUtil.java

@@ -1,6 +1,7 @@
package cn.gistack.alerts.notice.util;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
@@ -50,7 +51,18 @@
//        String s2 = "1,2,3";
//
//
//        String format = String.format(s1, Arrays.asList(s2.split(",")));
//        System.out.println("format = " + format);
////        String format = String.format(s1, Arrays.asList(s2.split(",")));
////        System.out.println("format = " + format);
//
//        String tm = "2023-06-02T08:00:00.000+00:00";
//        String day = "";
//        String hour = "";
//        String minute = "";
//        day = tm.substring(8,10);
//        hour = tm.substring(11,13);
//        minute = tm.substring(14,16);
//        System.out.println("day = " + day);
//        System.out.println("hour = " + hour);
//        System.out.println("minute = " + minute);
//    }
}