| | |
|---|
| | | import cn.gistack.sm.sjztmd.feign.IAttResManagePersonClient; |
|---|
| | | import cn.gistack.sm.sjztmd.vo.PersonVO; |
|---|
| | | import cn.gistack.system.feign.ISysClient; |
|---|
| | | import cn.gistack.system.user.entity.User; |
|---|
| | | import cn.gistack.system.user.feign.IUserClient; |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.alibaba.fastjson.JSONArray; |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.alibaba.nacos.shaded.com.google.gson.JsonObject; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | | import org.springblade.core.secure.utils.AuthUtil; |
|---|
| | | import org.springblade.core.tool.api.R; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.http.HttpEntity; |
|---|
| | | import org.springframework.http.HttpHeaders; |
|---|
| | |
|---|
| | | @Autowired |
|---|
| | | private IMessageClient messageClient; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private IUserClient userClient; |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | SmsTemplate smsTemplate = smsTemplateService.getOne(new QueryWrapper<SmsTemplate>().eq("template_id",templateId).eq("is_deleted",0)); |
|---|
| | | if (null != smsTemplate) { |
|---|
| | | SmsRequestTemplate smsRequestTemplate = new SmsRequestTemplate(); |
|---|
| | | smsRequestTemplate.setAlarmRule(alarmRule); |
|---|
| | | // 设置模板信息 |
|---|
| | | smsRequestTemplate.setSmsTemplate(smsTemplate); |
|---|
| | | // 解析模板并设置 title |
|---|
| | |
|---|
| | | messageRecord.setTheme(alarmRule.getRuleName()); |
|---|
| | | messageRecord.setSender(AuthUtil.getUserId().toString()); |
|---|
| | | messageRecord.setSource("智能告警"); |
|---|
| | | messageRecord.setStatus(2); |
|---|
| | | messageRecord.setStatus(0); |
|---|
| | | |
|---|
| | | // 设置告警记录信息 |
|---|
| | | AlarmRecordDetail alarmRecordDetail = new AlarmRecordDetail(); |
|---|
| | |
|---|
| | | messageRecordList.add(messageRecord); |
|---|
| | | } |
|---|
| | | // 保存告警记录详情信息 |
|---|
| | | saveMessageRecord(messageRecordList); |
|---|
| | | if (smsRequestTemplate.getIsSendStation()) { |
|---|
| | | saveMessageRecord(messageRecordList); |
|---|
| | | } |
|---|
| | | Map<String, Object> map = new HashMap<>(2); |
|---|
| | | // 返回 |
|---|
| | | return map; |
|---|
| | |
|---|
| | | * @param messageRecordList |
|---|
| | | */ |
|---|
| | | public void saveMessageRecord(List<MessageRecord> messageRecordList) { |
|---|
| | | // 遍历，查询对应的用户id |
|---|
| | | for (MessageRecord messageRecord : messageRecordList) { |
|---|
| | | // 通过手机号获取用户id信息 |
|---|
| | | R<List<User>> listR = userClient.userInfoByPhone("000000", messageRecord.getRecipient()); |
|---|
| | | messageRecord.setRecipient(listR.getData().get(0).getId().toString()); |
|---|
| | | } |
|---|
| | | // 保存记录 |
|---|
| | | messageClient.saveMessageRecord(messageRecordList); |
|---|
| | | // 发起通知 |
|---|
