风机状态查询慢问题优化

amos-boot-system-jxiop/amos-boot-module-jxiop-api/src/main/java/com/yeejoin/amos/boot/module/jxiop/api/dto/IndexDto.java

@@ -31,4 +31,14 @@ public class IndexDto {
     private String countString;
     private String color;
     private String fanName;
+    private String dataType;
+    private String equipmentIndex;
+    private String isAlarm;
+    private String systemType;
+    private String traceId;
+    private String distinct;
+    private String time;
+    private String displayName;
+    private String pictureName;
+    private String title;
 }

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

@@ -40,6 +40,7 @@ import org.springframework.core.io.Resource;
 import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
+import org.springframework.util.ObjectUtils;
 import org.typroject.tyboot.component.emq.EmqKeeper;
 
 import java.io.IOException;
@@ -59,6 +60,7 @@ import static com.alibaba.fastjson.JSON.parseArray;
 @EnableScheduling
 @Slf4j
 public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
+    private final  static List<String> fanStatesList = Arrays.asList("报警状态","停机状态","故障状态","待机状态","维护状态","正常发电状态");
 
     @Autowired
     private MonitorFanIndicatorMapper monitorFanIndicatorregionMapper;
@@ -309,7 +311,50 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
 
         return equipNumList;
     }
+    public List<IndexDto> getFanStatusListOptimize(String stationId) {
+        StationBasic stationBasic = getOneByStationNumber(stationId);
+        String sqlAll = String.format("SELECT * FROM \"indicators_%s\"",stationBasic.getFanGatewayId());
+        List<IndexDto> indexDtoList = influxDButils.getListData(sqlAll,IndexDto.class);
+//        String sql = String.format("SELECT equipmentNumber, equipmentIndexName as state FROM \"indicators_%s\" WHERE equipmentIndexName =~/^报警状态|停机状态|故障状态|待机状态|维护状态|正常发电状态$/ and value = 'true'", stationBasic.getFanGatewayId());
+//        List<IndexDto> influxDBList = influxDButils.getListData(sql, IndexDto.class);
+//        Map<String, String> collect = influxDBList.stream().collect(Collectors.toMap(IndexDto::getEquipmentNumber, IndexDto::getState, (item1, item2) -> item1));
+//        String sqlEquipNumList = String.format("SELECT (DISTINCT equipmentNumber) as equipmentNumber FROM \"indicators_%s\"", stationBasic.getFanGatewayId());
+//        List<IndexDto> equipNumList = influxDButils.getListData(sqlEquipNumList, IndexDto.class);
+//        String equipmentSpecificNames = fanConfigPower.stream().map(t -> t.get("equipmentSpecificName")).collect(Collectors.joining("|"));
+
+        List<IndexDto> influxDBList = indexDtoList.stream().
+                filter(indexDto -> fanStatesList.contains(indexDto.getEquipmentIndexName())&&indexDto.getValue().equals("true")).collect(Collectors.toList());
+        Map<String, String> collect = influxDBList.stream().collect(Collectors.toMap(IndexDto::getEquipmentNumber, IndexDto::getState, (item1, item2) -> item1));
+        List<IndexDto> equipNumList=indexDtoList.stream().filter(indexDto -> !ObjectUtils.isEmpty(indexDto.getEquipmentNumber())).collect(Collectors.collectingAndThen(Collectors.toCollection(()->new TreeSet<>(Comparator.comparing(IndexDto::getEquipmentNumber))),ArrayList::new));
+        List<Map<String, String>> fanConfigPower = monitorFanIndicatorregionMapper.getFanConfigPower(stationBasic.getFanGatewayId());
+        List<String > equipmentSpecificNames=fanConfigPower.stream().map(t -> t.get("equipmentSpecificName")).collect(Collectors.toList());
+//        String powerSql = String.format("SELECT equipmentNumber, value FROM \"indicators_%s\" WHERE equipmentSpecificName =~/^%s$/ and value = '9.0'", stationBasic.getFanGatewayId(), equipmentSpecificNames);
+//        List<IndexDto> powerNum = influxDButils.getListData(powerSql, IndexDto.class);
+        List<IndexDto> powerNum = indexDtoList.stream().filter(indexDto1 ->indexDto1.getValue().equals("9.0")&&equipmentSpecificNames.contains(indexDto1.getEquipmentSpecificName())).collect(Collectors.toList());
+        List<String> powList = powerNum.stream().map(IndexDto::getEquipmentNumber).collect(Collectors.toList());
+        Date currentDayStartTime = DateUtils.dateAddMinutes(new Date(), -15);
+        String time = "";
+        try {
+            time  = DateUtils.dateFormat(currentDayStartTime, DateUtils.DATE_TIME_PATTERN);
+        } catch (ParseException e) {
+            e.printStackTrace();
+        }
+        String timeSql = String.format("select distinct equipmentNumber from \"indicators_%s\" where time >= '%s'", stationBasic.getFanGatewayId(), time);
+        List<IndexDto> timeSqlList = influxDButils.getListData(timeSql, IndexDto.class);
+        List<String> timeList = timeSqlList.stream().map(IndexDto::getEquipmentNumber).collect(Collectors.toList());
+        equipNumList.forEach(item -> {
+            item.setState(collect.get(item.getEquipmentNumber()));
+            if (!collect.containsKey(item.getEquipmentNumber())) {
+                item.setState("正常运行");
+            } else if (powList.contains(item.getEquipmentNumber())) {
+                item.setState("限功率");
+            } else if (!timeList.contains(item.getEquipmentNumber())) {
+                item.setState("通讯中断");
+            }
+        });
 
+        return equipNumList;
+    }
     public List<IndexDto> getFanStatusStatistics(String stationId) {
         StationBasic stationBasic = getOneByStationNumber(stationId);
         String sql = String.format("SELECT equipmentNumber, equipmentIndexName as state FROM \"indicators_%s\" WHERE equipmentIndexName =~/^报警状态|停机状态|故障状态|待机状态|维护状态|正常发电状态$/ and value = 'true'", stationBasic.getFanGatewayId());