物联信息表指标刷新

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

@@ -20,7 +20,8 @@ public enum TopicEnum {
     CARZXDT("carIndexInsertOrUpdate", "最新动态-告警日志列表"),
     EQXXTJ("fasReportInsertOrUpdate", "设备信号消息统计列表"),
     ALARM_LOG_INSERT("alarm/log/insert","告警日志插入"),
-    IOT_SYSTEM__AlARM("iot-system-alarm", "确警消息");
+    IOT_SYSTEM__AlARM("iot-system-alarm", "确警消息"),
+    SHBZYCXH("fasNormalIndexInsertOrUpdate", "四横八纵遥测信号");
 
     private String topic;
 

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

@@ -492,6 +492,9 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
 
                 // 直流中心消息推送刷新
                 publishDataToDCCenterPage(equipmentSpecificIndexList);
+
+                // 四横八纵遥测信号信息列表刷新
+                publishNormalIndexValueToPage(equipmentSpecificIndexList);
                 if("zd".equals(system)){
                     System.out.println("站端系统----------------");
 
@@ -1364,6 +1367,11 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
         log.info(String.format("直流中心指标消息发送：%s", JSON.toJSONString(equipmentSpecificIndexList)));
     }
 
+    public void publishNormalIndexValueToPage(List<EquipmentSpecificIndex> equipmentSpecificIndexList) {
+        mqttSendGateway.sendToMqtt(TopicEnum.SHBZYCXH.getTopic(), JSON.toJSONString(equipmentSpecificIndexList));
+        log.info(String.format("四横八纵遥测指标消息发送：%s", JSON.toJSONString(equipmentSpecificIndexList)));
+    }
+
     /**
      * 更新数据报表表
      *