bug

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

@@ -796,7 +796,7 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
             List<Map<String, String>> boosterStationInfo = monitorFanIndicatorregionMapper.getMajorBoosterStationInfo(gatewayId, "ASC", 10);
             ArrayList<Map<String, String>> resultList = new ArrayList<>();
             for (Map<String, String> map : boosterStationInfo) {
-                String sql = String.format("SELECT equipmentIndexName, value, frontModule, unit, displayName FROM \"indicators_%s\" WHERE systemType = '%s' and frontModule =~/%s/ and (displayName = 'Ia' or displayName = 'P'  or displayName = 'Q' ", gatewayId, "模拟量", map.get("boosterName"));
+                String sql = String.format("SELECT equipmentIndexName, value, frontModule, unit, displayName FROM \"indicators_%s\" WHERE systemType = '%s' and frontModule =~/%s/ and (displayName = 'Ia' or displayName = 'P'  or displayName = 'Q') ", gatewayId, "模拟量", map.get("boosterName"));
                 List<IndicatorsDto> listData = influxDButils.getListData(sql, IndicatorsDto.class);
 
                 HashMap<String, String> stringStringHashMap = new HashMap<>();
@@ -827,7 +827,7 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
             resultPage.setTotal(finallyResultList.size());
             try {
                 log.info("消息内容：{}", JSON.toJSONString(resultPage));
-                emqKeeper.getMqttClient().publish(String.format("%s/%s/%s", stationId, "major", "mnl"), JSON.toJSONString(resultPage).getBytes(),0,false);
+                emqKeeper.getMqttClient().publish(String.format("%s/%s/%s", stationId, "major", "data"), JSON.toJSONString(resultPage).getBytes(),0,false);
             } catch (MqttException e) {
                 log.info("消息发送失败");
                 e.printStackTrace();