|
|
|
@ -5,7 +5,9 @@ import com.mh.common.core.domain.entity.AlarmRecords;
|
|
|
|
|
import com.mh.common.core.domain.wechat.*; |
|
|
|
|
import com.mh.common.utils.DateUtils; |
|
|
|
|
import com.mh.common.utils.DictUtils; |
|
|
|
|
import com.mh.system.service.ISysParamsService; |
|
|
|
|
import com.mh.system.service.IWechatService; |
|
|
|
|
import com.mh.system.service.impl.SysParamsServiceImpl; |
|
|
|
|
import com.mh.system.service.operation.IAlarmRecordsService; |
|
|
|
|
import jakarta.annotation.Resource; |
|
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
@ -33,6 +35,9 @@ public class PushDataToWechatTask {
|
|
|
|
|
@Resource |
|
|
|
|
private IWechatService wechatService; |
|
|
|
|
|
|
|
|
|
@Resource |
|
|
|
|
private ISysParamsService sysParamsService; |
|
|
|
|
|
|
|
|
|
public void pushDataToWechat() { |
|
|
|
|
// 查询报警内容
|
|
|
|
|
AlarmRecords alarmRecords = new AlarmRecords(); |
|
|
|
@ -62,9 +67,9 @@ public class PushDataToWechatTask {
|
|
|
|
|
// 设备异常告警提醒
|
|
|
|
|
pushDeviceExceptionParams(map, pushMsgEntity, alarmRecords2); |
|
|
|
|
break; |
|
|
|
|
case "qG3Odr74o4BRx8QigZuoil3l3ZC2aAdDeO49robRLC8": |
|
|
|
|
// 推送用电量、用冷量、EER数据
|
|
|
|
|
// pushAllParams(projectInfoEntity, map, pushMsgEntity, energyDataEntity);
|
|
|
|
|
case "SiyBtZeZuF0Qo8V3NlvGwhc95-vX-a6wsvIxpAq3d_Y": |
|
|
|
|
// 设备告警通知
|
|
|
|
|
pushDeviceArmParams(map, pushMsgEntity, alarmRecords2); |
|
|
|
|
break; |
|
|
|
|
default: |
|
|
|
|
break; |
|
|
|
@ -84,6 +89,43 @@ public class PushDataToWechatTask {
|
|
|
|
|
}); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private void pushDeviceArmParams(Map<String, Object> map, PushMsgEntity pushMsgEntity, AlarmRecords alarmRecords2) { |
|
|
|
|
pushMsgEntity.setTouser(map.get("open_id").toString()); |
|
|
|
|
pushMsgEntity.setTemplateId(map.get("template_id").toString()); |
|
|
|
|
pushMsgEntity.setUrl("http://jnd2.mhwsh.net:8765/"); |
|
|
|
|
First first = new First(); |
|
|
|
|
first.setValue("设备告警通知"); |
|
|
|
|
pushMsgEntity.setFirst(first); |
|
|
|
|
|
|
|
|
|
// 项目名称
|
|
|
|
|
Key1 key1 = new Key1(); |
|
|
|
|
key1.setValue(sysParamsService.queryList().get(0).getProName()); |
|
|
|
|
pushMsgEntity.setKey1(key1); |
|
|
|
|
|
|
|
|
|
// 设备名称
|
|
|
|
|
Key2 key2 = new Key2(); |
|
|
|
|
key2.setValue(alarmRecords2.getDeviceName()); |
|
|
|
|
pushMsgEntity.setKey2(key2); |
|
|
|
|
|
|
|
|
|
// 告警等级
|
|
|
|
|
Key3 key3 = new Key3(); |
|
|
|
|
// 通过告警等级id得到value值
|
|
|
|
|
String alarmLevel = alarmRecords2.getAlarmLevel(); |
|
|
|
|
String alarmLevel1 = DictUtils.getDictLabel("alarm_level", alarmLevel); |
|
|
|
|
key3.setValue(alarmLevel1); |
|
|
|
|
pushMsgEntity.setKey3(key3); |
|
|
|
|
|
|
|
|
|
// 异常原因
|
|
|
|
|
Key4 key4 = new Key4(); |
|
|
|
|
key4.setValue(alarmRecords2.getContent().substring(0, 20)); |
|
|
|
|
pushMsgEntity.setKey4(key4); |
|
|
|
|
|
|
|
|
|
// 发生时间
|
|
|
|
|
Key5 key5 = new Key5(); |
|
|
|
|
key5.setValue(DateUtils.dateToString(alarmRecords2.getCreateTime(), "yyyy-MM-dd HH:mm:ss")); |
|
|
|
|
pushMsgEntity.setKey5(key5); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
* 推送设备异常告警提醒 |
|
|
|
|
* @param map |
|
|
|
|