| | |
| | | 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())); |
| | |
| | | /** |
| | | * 默认实现 |
| | | * |
| | | * @param arg1 |
| | | * @param arg1 告警规则名称 |
| | | * @param arg2 |
| | | * @return |
| | | */ |
| | |
| | | /** |
| | | * 策略2: 水位数据异常 |
| | | * |
| | | * @param arg1 |
| | | * @param arg1 告警规则名称 |
| | | * @param arg2 |
| | | * @return |
| | | */ |
| | |
| | | /** |
| | | * 策略3: 水位超低于死水位(水库技术责任人、巡查责任人) |
| | | * |
| | | * @param arg1 |
| | | * @param arg1 告警规则名称 |
| | | * @param arg2 |
| | | * @return |
| | | */ |
| | |
| | | // 遍历,拼接县水利部人员电话 |
| | | 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"); |
| | | } |
| | | } |
| | | // 调用短信服务 |
| | |
| | | * @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 "水位接近汛限告警"; |
| | | } |
| | | |
| | | /** |