监盘数据由接口调用改为消息推送

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/MonitoringServiceIMQTTmpl.java

@@ -301,6 +301,21 @@ public class MonitoringServiceIMQTTmpl {
                 HashMap<String, List<String>> realTimeTemperatureResult = monitorFanIndicator.getRealTimeTemperature(equipmentNumber, stationBasicId,"实时监控表计");
                 IPage<IndexDto> realTimedata=monitorFanIndicator.getFanIdxInfoByPage(equipmentNumber,stationBasicId,"实时运行数据",1,99,"");
                 Map<String, Object> windSpeedOfFan=monitorFanIndicator.getDetailsWindSpeed(stationBasic.getFanGatewayId(),equipmentNumber);
+                //发电机系统
+                IPage<IndexDto> fdjSystem=monitorFanIndicator.getFanIdxInfoByPage(equipmentNumber,stationBasicId,"实时运行数据",1,99,"发电机系统");
+                List<Map<String, Object>> fdjSystemStatus = monitorFanIndicator.getStatusMonitoring(stationBasic.getFanGatewayId(),equipmentNumber,"发电机系统");
+                //机舱与塔筒系统
+                IPage<IndexDto> jcyttSystem=monitorFanIndicator.getFanIdxInfoByPage(equipmentNumber,stationBasicId,"实时运行数据",1,99,"机舱与塔筒系统");
+                List<Map<String, Object>> jcyttSystemStatus = monitorFanIndicator.getStatusMonitoring(stationBasic.getFanGatewayId(),equipmentNumber,"机舱与塔筒系统");
+                //偏航与液压系统
+                IPage<IndexDto> phyyySystem=monitorFanIndicator.getFanIdxInfoByPage(equipmentNumber,stationBasicId,"实时运行数据",1,99,"偏航与液压系统");
+                List<Map<String, Object>> phyyySystemStatus = monitorFanIndicator.getStatusMonitoring(stationBasic.getFanGatewayId(),equipmentNumber,"偏航与液压系统");
+                //变流与主控系统
+                IPage<IndexDto> blyzkSystem=monitorFanIndicator.getFanIdxInfoByPage(equipmentNumber,stationBasicId,"实时运行数据",1,99,"变流与主控系统");
+                List<Map<String, Object>> blyzkSystemStatus = monitorFanIndicator.getStatusMonitoring(stationBasic.getFanGatewayId(),equipmentNumber,"变流与主控系统");
+                //变流与主控系统
+                IPage<IndexDto> ylSystem=monitorFanIndicator.getFanIdxInfoByPage(equipmentNumber,stationBasicId,"实时运行数据",1,99,"叶轮系统");
+                List<Map<String, Object>> ylSystemStatus = monitorFanIndicator.getStatusMonitoring(stationBasic.getFanGatewayId(),equipmentNumber,"叶轮系统");
                 try {
                     //{stationBasicId}_{equipmentNumber}_fanBasicInfo_topic
                     emqKeeper.getMqttClient().publish(topicPrefix+ "_fanBasicInfo_topic", JSON.toJSON(info).toString().getBytes("UTF-8"), 1, true);
@@ -318,6 +333,26 @@ public class MonitoringServiceIMQTTmpl {
                     emqKeeper.getMqttClient().publish(topicPrefix+ "_realTimedata_topic", JSON.toJSON(realTimedata).toString().getBytes("UTF-8"), 1, true);
                     //{stationBasicId}_{equipmentNumber}_windSpeedOfFan_topic
                     emqKeeper.getMqttClient().publish(topicPrefix+ "_windSpeedOfFan_topic", JSON.toJSON(windSpeedOfFan).toString().getBytes("UTF-8"), 1, true);
+                    //{stationBasicId}_{equipmentNumber}_fdjSystem_topic
+                    emqKeeper.getMqttClient().publish(topicPrefix+ "_fdjSystem_topic", JSON.toJSON(fdjSystem).toString().getBytes("UTF-8"), 1, true);
+                    //{stationBasicId}_{equipmentNumber}_fdjSystemStatus_topic
+                    emqKeeper.getMqttClient().publish(topicPrefix+ "_fdjSystemStatus_topic", JSON.toJSON(fdjSystemStatus).toString().getBytes("UTF-8"), 1, true);
+                    //{stationBasicId}_{equipmentNumber}_windSpeedOfFan_topic
+                    emqKeeper.getMqttClient().publish(topicPrefix+ "_jcyttSystem_topic", JSON.toJSON(jcyttSystem).toString().getBytes("UTF-8"), 1, true);
+                    //{stationBasicId}_{equipmentNumber}_windSpeedOfFan_topic
+                    emqKeeper.getMqttClient().publish(topicPrefix+ "_jcyttSystemStatus_topic", JSON.toJSON(jcyttSystemStatus).toString().getBytes("UTF-8"), 1, true);
+                    //{stationBasicId}_{equipmentNumber}_windSpeedOfFan_topic
+                    emqKeeper.getMqttClient().publish(topicPrefix+ "_phyyySystem_topic", JSON.toJSON(phyyySystem).toString().getBytes("UTF-8"), 1, true);
+                    //{stationBasicId}_{equipmentNumber}_windSpeedOfFan_topic
+                    emqKeeper.getMqttClient().publish(topicPrefix+ "_phyyySystemStatus_topic", JSON.toJSON(phyyySystemStatus).toString().getBytes("UTF-8"), 1, true);
+                    //{stationBasicId}_{equipmentNumber}_windSpeedOfFan_topic
+                    emqKeeper.getMqttClient().publish(topicPrefix+ "_blyzkSystem_topic", JSON.toJSON(blyzkSystem).toString().getBytes("UTF-8"), 1, true);
+                    //{stationBasicId}_{equipmentNumber}_windSpeedOfFan_topic
+                    emqKeeper.getMqttClient().publish(topicPrefix+ "_blyzkSystemStatus_topic", JSON.toJSON(blyzkSystemStatus).toString().getBytes("UTF-8"), 1, true);
+                    //{stationBasicId}_{equipmentNumber}_windSpeedOfFan_topic
+                    emqKeeper.getMqttClient().publish(topicPrefix+ "_ylSystem_topic", JSON.toJSON(ylSystem).toString().getBytes("UTF-8"), 1, true);
+                    //{stationBasicId}_{equipmentNumber}_windSpeedOfFan_topic
+                    emqKeeper.getMqttClient().publish(topicPrefix+ "_ylSystemStatus_topic", JSON.toJSON(ylSystemStatus).toString().getBytes("UTF-8"), 1, true);
                     logger.info("-----------------发送风电站风机基础数据消息=================== 成功！");
                 } catch (Exception exception) {
                     logger.error("-----------------发送风电站风机基础数据消息=================== 失败！");