Commit d88f1080 authored by zhangsen's avatar zhangsen

消息提醒相关信息修改

parent 8c7005d2
...@@ -67,9 +67,8 @@ public class PumpSendMessage implements Job { ...@@ -67,9 +67,8 @@ public class PumpSendMessage implements Job {
marqueeData.setCreateDate(new Date()); marqueeData.setCreateDate(new Date());
marqueeDataMapper.insert(marqueeData); marqueeDataMapper.insert(marqueeData);
// 稳压泵漏水告警添加告警事件信息 // 稳压泵漏水告警添加告警事件信息
equipmentSpecificAlarmLogService.pressurePumpDisposeAlarm(equipmentSpecific.getId(), body); equipmentSpecificAlarmLogService.pressurePumpDisposeAlarm(equipmentSpecific.getId(), equipmentSpecific.getName() + "-" + pressurePumpEnum.getTips());
} }
model.setBody(body); model.setBody(body);
model.setTitle("漏水提醒"); model.setTitle("漏水提醒");
model.setExtras(map); model.setExtras(map);
......
...@@ -644,7 +644,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -644,7 +644,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
} }
log.info(String.format("调用平台消息服务成功:%s", JSON.toJSONString(model))); log.info(String.format("调用平台消息服务成功:%s", JSON.toJSONString(model)));
alarmFlag = true; alarmFlag = true;
messageBody.put("messageBody", bodyMain); messageBody.put("messageBody", equipmentSpecificIndex.getEquipmentSpecificName() + "-" + body);
} }
return alarmFlag; return alarmFlag;
} }
...@@ -710,7 +710,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -710,7 +710,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
systemctlFeign.create(token.getAppKey(), token.getProduct(), token.getToke(), model); systemctlFeign.create(token.getAppKey(), token.getProduct(), token.getToke(), model);
log.info(String.format("调用平台消息服务成功:%s", JSON.toJSONString(model))); log.info(String.format("调用平台消息服务成功:%s", JSON.toJSONString(model)));
alarmFlag = true; alarmFlag = true;
messageBody.put("messageBody", bodyMain); messageBody.put("messageBody", map.get("name") + "-" + body);
} }
} }
return alarmFlag; return alarmFlag;
...@@ -1731,7 +1731,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -1731,7 +1731,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
marqueeData.setCreateDate(new Date()); marqueeData.setCreateDate(new Date());
marqueeDataMapper.insert(marqueeData); marqueeDataMapper.insert(marqueeData);
// 稳压泵告警事件生成 // 稳压泵告警事件生成
equipmentSpecificAlarmLogService.pressurePumpDisposeAlarm(data.getEquipmentId(), body); equipmentSpecificAlarmLogService.pressurePumpDisposeAlarm(data.getEquipmentId(), data.getEquipmentSpecificName() + "-" + pressurePumpEnum.getTips());
} }
switch (pumpMessageEnum) { switch (pumpMessageEnum) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment