逆变器状态

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

@@ -1744,5 +1744,77 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
         return resultMap;
     }
 
+
+    public Map<String, Object> nbqStatus(String gatewayId) {
+        String sql = " SELECT * FROM indicators_"+gatewayId+" WHERE (equipmentIndexName ='待机' or equipmentIndexName ='故障停机' or equipmentIndexName ='告警运行' or equipmentIndexName ='限额运行' or equipmentIndexName ='停机') and value = 'true'";
+        List<IndicatorsDto> indicatorsDtoList  = influxDButils.getListData(sql,IndicatorsDto.class);
+
+        int djNum = 0 ;
+        int gzNum = 0 ;
+        int gjNum = 0 ;
+        int xeNum = 0 ;
+        int xdNum = 0 ;
+        int txNum = 0 ;
+        int tjNum = 0 ;
+        int zcNum = 0 ;
+        Map<String, Object> numMap = new HashMap<>();
+
+        Set<String> equipNum = new HashSet<>();
+
+        for (IndicatorsDto indicatorsDto : indicatorsDtoList) {
+            switch(indicatorsDto.getEquipmentIndexName()){
+               case "待机":
+                   djNum += 1;
+                   break;
+                case "故障停机":
+                    gzNum += 1;
+                    break;
+                case "告警运行":
+                    gjNum += 1;
+                    break;
+                case "限额运行":
+                    xeNum += 1;
+                    equipNum.add(indicatorsDto.getEquipmentNumber());
+                    break;
+                case "停机":
+                    tjNum += 1;
+                    break;
+            }
+        }
+
+        String xesql = " SELECT * FROM indicators_"+gatewayId+" WHERE equipmentIndexName ='有功功率' and frontModule = '逆变器' and value < '0.5'";
+        List<IndicatorsDto> xeList = influxDButils.getListData(xesql,IndicatorsDto.class);
+        for (IndicatorsDto dto : xeList) {
+            if (!ValidationUtil.isEmpty(equipNum)  && equipNum.contains(dto.getEquipmentNumber())){
+                xdNum += 1;
+            }
+        }
+
+        String querySql = " SELECT * FROM indicators_"+gatewayId+" WHERE ( equipmentIndexName ='告警运行' or equipmentIndexName ='限额运行' ) and value != 'true'";
+        List<IndicatorsDto> queryList  = influxDButils.getListData(querySql,IndicatorsDto.class);
+        List<String> collect = queryList.stream().map(IndicatorsDto::getEquipmentNumber).collect(Collectors.toList());
+        Set<String> strings = new HashSet<>(collect);
+        zcNum = collect.size()-strings.size();
+
+
+        String querySql1 = " SELECT * FROM indicators_"+gatewayId+"  equipmentIndexName ='通讯异常'  and value = 'true'";
+        List<IndicatorsDto> queryList1 = influxDButils.getListData(querySql1,IndicatorsDto.class);
+        List<String> collect1 = queryList.stream().map(IndicatorsDto::getEquipmentNumber).collect(Collectors.toList());
+        Set<String> strings1 = new HashSet<>(collect);
+        txNum = collect.size()-strings.size();
+
+
+        numMap.put("djNum",djNum);
+        numMap.put("gzNum",gzNum);
+        numMap.put("gjNum",gjNum);
+        numMap.put("xeNum",xeNum);
+        numMap.put("xdNum",xdNum);
+        numMap.put("txNum",txNum);
+        numMap.put("tjNum",tjNum);
+        numMap.put("zcNum",zcNum);
+
+        return  numMap;
+
+    }
 }