Merge remote-tracking branch 'origin/develop_dl_plan6' into develop_dl_plan6

amos-boot-module/amos-boot-module-api/amos-boot-module-equip-api/src/main/java/com/yeejoin/equipmanage/common/enums/PressurePumpMessageEnum.java

@@ -2,10 +2,10 @@ package com.yeejoin.equipmanage.common.enums;
 
 public enum PressurePumpMessageEnum {
 
-    MESSAGE_LEVEL_YB("YB", "【%s】分钟内，启停间隔较小",  "","名称：稳压泵启停异常提醒；时间：%s；内容：【%s】- 【%s】 -  【%s】分钟内，设备启停频繁，请及时查看处理"),
-    MESSAGE_LEVEL_YZ("YZ", "【%s】分钟内，启停间隔较小", "", "名称：稳压泵启停异常提醒；时间：%s；内容：【%s】- 【%s】 -  【%s】分钟内，设备启停频繁，请及时查看处理"),
-    MESSAGE_LEVEL_QT_WJ("QT_WJ", "【%s】分钟内，设备启停频繁", "类型：漏水提醒 ；设备位置：【稳压泵设备位置】； 设备名称：【稳压泵设备名称】 ； 时间：系统推送时间", "名称：漏水提醒； 时间：%s；内容：【%s】- 【%s】 - 【%s】分钟内，设备启停频繁，可能存在漏水，请及时查看处理"),
-    MESSAGE_LEVEL_QT_WJ_YXSC("WJ_YXSC", "运行时长超过【%s】分钟，存在漏水可能", "类型：漏水提醒 ；设备位置：【稳压泵设备位置】； 设备名称：【稳压泵设备名称】 ； 时间：系统推送时间", "名称：漏水提醒； 时间：%s；内容：【%s】- 【%s】 - 运行时长超过【%s】分钟，存在漏水可能，请及时查看处理");
+    MESSAGE_LEVEL_YB("YB", "【%s】分钟内，启停间隔较小",  "","【%s】- 【%s】 -  【%s】分钟内，设备启停频繁，请及时查看处理"),
+    MESSAGE_LEVEL_YZ("YZ", "【%s】分钟内，启停间隔较小", "", "【%s】- 【%s】 -  【%s】分钟内，设备启停频繁，请及时查看处理"),
+    MESSAGE_LEVEL_QT_WJ("QT_WJ", "【%s】分钟内，设备启停频繁", "类型：漏水提醒 ；设备位置：【稳压泵设备位置】； 设备名称：【稳压泵设备名称】 ； 时间：系统推送时间", "【%s】- 【%s】 - 【%s】分钟内，设备启停频繁，可能存在漏水，请及时查看处理"),
+    MESSAGE_LEVEL_QT_WJ_YXSC("WJ_YXSC", "运行时长超过【%s】分钟，存在漏水可能", "类型：漏水提醒 ；设备位置：【稳压泵设备位置】； 设备名称：【稳压泵设备名称】 ； 时间：系统推送时间", "【%s】- 【%s】 - 运行时长超过【%s】分钟，存在漏水可能，请及时查看处理");
     private String code;
     private String allMessage;
     private String marqueeMessage;

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/quartz/PumpSendMessage.java

@@ -51,7 +51,7 @@ public class PumpSendMessage implements Job {
             }
             String recordMessage = PressurePumpMessageEnum.MESSAGE_LEVEL_QT_WJ_YXSC.getRecordMessage();
             if (StringUtil.isNotEmpty(recordMessage)) {
-                body = String.format(recordMessage,new SimpleDateFormat(DateUtils.DATE_TIME_PATTERN).format(new Date()), equipmentSpecific.getName(), equipmentSpecific.getPosition(), pressurePumpEnum.getRightValue());
+                body = String.format(recordMessage, equipmentSpecific.getName(), equipmentSpecific.getPosition(), pressurePumpEnum.getRightValue());
             }
             String marqueeMessage = PressurePumpMessageEnum.MESSAGE_LEVEL_QT_WJ_YXSC.getMarqueeMessage();
             if (StringUtil.isNotEmpty(marqueeMessage)) {
@@ -67,7 +67,9 @@ public class PumpSendMessage implements Job {
             }
 
             model.setBody(body);
+            model.setTitle("漏水提醒");
             model.setExtras(map);
+            model.setRelationId(String.valueOf(equipmentSpecific.getId()));
             model.setMsgType("pressurePump");
             model.setIsSendApp(false);
             model.setTerminal("WEB");

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/MqttReceiveServiceImpl.java

@@ -1474,7 +1474,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
         String recordMessage = pumpMessageEnum.getRecordMessage();
         if (StringUtil.isNotEmpty(recordMessage)) {
             String value = StringUtil.isNotEmpty(pressurePumpEnum.getLeftValue()) ? pressurePumpEnum.getLeftValue() : pressurePumpEnum.getRightValue();
-            body = String.format(recordMessage,time, data.getEquipmentSpecificName(), data.getLocation(), value);
+            body = String.format(recordMessage, data.getEquipmentSpecificName(), data.getLocation(), value);
         }
         String marqueeMessage = pumpMessageEnum.getMarqueeMessage();
         if (StringUtil.isNotEmpty(marqueeMessage)) {
@@ -1493,10 +1493,12 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
             case MESSAGE_LEVEL_YB:
             case MESSAGE_LEVEL_YZ:
                 map.put("type", "稳压泵启停异常提醒");
+                model.setTitle("稳压泵启停异常提醒");
                 break;
             case MESSAGE_LEVEL_QT_WJ:
             case MESSAGE_LEVEL_QT_WJ_YXSC:
                 map.put("type", "漏水提醒");
+                model.setTitle("漏水提醒");
                 break;
             default:
                 break;
@@ -1512,6 +1514,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
         model.setCategory(1);
         List<String> receive = new ArrayList<>();
         receive.add("system");
+        model.setRelationId(String.valueOf(data.getEquipmentSpecificId()));
         model.setRecivers(receive);
         Token token = remoteSecurityService.getServerToken();
         systemctlFeign.create(token.getAppKey(), token.getProduct(), token.getToke(), model);