区分站端系统和直流中心系统消息发送修改

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

@@ -186,6 +186,9 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
     @Value("${state.code:code}")
     private String stationCode;
 
+    @Value("${system.type}")
+    private String system;
+
     @Value("${state.name:name}")
     private String stationName;
 
@@ -474,27 +477,30 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
 
                 // 直流中心消息推送刷新
                 publishDataToDCCenterPage(equipmentSpecificIndexList);
+                if("zd".equals(system)){
+                    System.out.println("站端系统----------------");
 
-                // 向预控系统发送消息
-                sendEquipSpecIndexToAutosysTopic(equipmentSpecificIndexList);
+                    // 向预控系统发送消息
+                    sendEquipSpecIndexToAutosysTopic(equipmentSpecificIndexList);
 
-                // 首页性能指标数据订阅
-                mqttSendGateway.sendToMqtt(indexTopic, JSON.toJSONString(indexStateList));
+                    // 首页性能指标数据订阅
+                    mqttSendGateway.sendToMqtt(indexTopic, JSON.toJSONString(indexStateList));
 
-                // 组态大屏消息推送，设备表实时指标修改
-                intePageSysDataRefresh(equipmentSpecificIndexList, topicEntity);
+                    // 组态大屏消息推送，设备表实时指标修改
+                    intePageSysDataRefresh(equipmentSpecificIndexList, topicEntity);
 
-                // 数字换流站同步指标修改
-                syncSpecificIndexsToGS(equipmentSpecificIndexList);
+                    // 数字换流站同步指标修改
+                    syncSpecificIndexsToGS(equipmentSpecificIndexList);
 
-                // 则更新拓扑节点数据及告警状态
-                updateNodeDateByEquipId(equipmentSpecificIndexList);
+                    // 则更新拓扑节点数据及告警状态
+                    updateNodeDateByEquipId(equipmentSpecificIndexList);
 
-                // 向画布推送
-                publishDataToCanvas(equipmentSpecificIndexList);
+                    // 向画布推送
+                    publishDataToCanvas(equipmentSpecificIndexList);
 
-                // 向其他系统推送报警
-                equipmentAlarmLogsToOtherSystems(alarmLogs);
+                    // 向其他系统推送报警
+                    equipmentAlarmLogsToOtherSystems(alarmLogs);
+                }
             }
         });
     }

amos-boot-system-equip/src/main/resources/application-dev.properties

@@ -116,5 +116,8 @@ equipment.pressurepump.stop=FHS_PressurePump_Stop
 state.code=GW190301
 state.name=锦屏换流站
 
+#?????????????
+system.type=zd
+
 # 是否开启遥测数据上报
 is.open.telemetering=false
\ No newline at end of file