package cn.gistack.alerts.notice.service.impl;
|
|
import cn.gistack.alerts.alarmRule.entity.AlarmRecord;
|
import cn.gistack.alerts.alarmRule.entity.AlarmRule;
|
import cn.gistack.alerts.notice.constant.ZtApiDataColumnConstant;
|
import cn.gistack.alerts.notice.constant.ZtApiUrlConstant;
|
import cn.gistack.alerts.sms.service.SmsService;
|
import cn.gistack.alerts.sms.vo.SmsRequestTemplate;
|
import com.alibaba.fastjson.JSONArray;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Component;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Component
|
public class AsyncNoticeHandle {
|
|
|
@Autowired
|
private NoticeHandle noticeHandle;
|
|
@Autowired
|
private SmsService smsService;
|
|
/**
|
* 异步发送告警信息
|
* @param templateId
|
* @param uuid
|
* @param alarmRule
|
* @return
|
*/
|
@Async
|
public Map<String, Object> handleAlarmInfo(String templateId, String uuid, AlarmRule alarmRule) {
|
Map<String, Object> map = new HashMap<>();
|
// 调用中台服务接口查询数据
|
JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.over_des_rz_warn_api);
|
// 只发短信，将发短信信息组装好
|
SmsRequestTemplate smsRequestTemplate
|
= noticeHandle.getSendSmsTemplate(ztData, templateId, alarmRule, ZtApiDataColumnConstant.waterMoreDesignList, true, null);
|
// 拼接后面内容
|
if (smsRequestTemplate.getPersonVOList().size() > 0) {
|
for (List<String> list : smsRequestTemplate.getTemplateContent()) {
|
// 依次添加行政责任人,主管部门责任人,技术责任人,巡查责任人信息(姓名，联系电话)
|
noticeHandle.addWaterMoreDesignPatrolTechnologyInfo(list, "1,2,4,5");
|
// 拼接市县水利部人员姓名及联系方式
|
noticeHandle.addCityCountyBusinessPersonInfo(list);
|
// 保存告警记录信息
|
AlarmRecord alarmRecord = noticeHandle.saveAlarmRecord(list, alarmRule, uuid);
|
if (null != alarmRecord) {
|
list.add(alarmRecord.getId().toString());
|
}
|
}
|
map = smsService.sendSignMsg(smsRequestTemplate);
|
// 调用短信服务
|
return map;
|
}
|
return map;
|
}
|
|
}
|
