消息推送

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

@@ -593,7 +593,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
             public void afterCommit() {
                 // 组态大屏消息推送，设备表实时指标修改
 //                intePageSysDataRefresh(equipmentSpecificIndexList, topicEntity);
-                mqttSendGateway.sendToMqtt(TopicEnum.EQXXTJ.getTopic(), "");
+                mqttSendGateway.sendToMqtt(TopicEnum.EQXXTJ.getTopic(), String.valueOf(System.currentTimeMillis()));
             }
         });
     }
@@ -1159,7 +1159,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
      */
     public void intePageSysDataRefresh(List<EquipmentSpecificIndex> equipmentSpecificIndexList,
                                        TopicEntityVo topicEntity) {
-        mqttSendGateway.sendToMqtt(TopicEnum.EQXXTJ.getTopic(), "");
+        mqttSendGateway.sendToMqtt(TopicEnum.EQXXTJ.getTopic(), String.valueOf(System.currentTimeMillis()));
         iEquipmentSpecificSerivce.integrationPageSysDataRefresh(topicEntity.getCode());
     }