修改

whyclxw

2024-07-01 0ce771b4a4ff5897dc91bb1b84a4561781b00ca5

 src/main/java/com/whyc/service/CKPowerDevAlarmHistoryService.java

@@ -41,11 +41,14 @@
    }
   //历史头部统计
    public Response getCountByLevel() throws InterruptedException {
        Map<Integer,Integer> countMap = new HashMap<>();
        countMap.put(0,0);
        countMap.put(1,0);
        countMap.put(2,0);
        countMap.put(3,0);
        Map<String,Integer> countMap = new HashMap<>();
        countMap.put("0",0);
        countMap.put("1",0);
        countMap.put("2",0);
        countMap.put("3",0);
        countMap.put("ac",0);
        countMap.put("dc",0);
        countMap.put("gc",0);
        List<CKPowerDevAlarmHistory> allList=new ArrayList<>();
        //查询所有的历史时间表
        List<String> tableYearListInDB=subTablePageInfoService.getDevAlmHisList();
@@ -60,11 +63,25 @@
            });
        }
        latch.await();
        countMap.put(0,allList.size());
        countMap.put("0",allList.size());
        Map<Integer, List<CKPowerDevAlarmHistory>> levelMap = allList.stream().collect(Collectors.groupingBy(CKPowerDevAlarmHistory::getAlmLevel));
        Set<Integer> levelKeyMap = levelMap.keySet();
        for (Integer level : levelKeyMap) {
            countMap.put(level,levelMap.get(level).size());
            countMap.put(level.toString(),levelMap.get(level).size());
        }
        Map<Integer, List<CKPowerDevAlarmHistory>> typeMap = allList.stream().collect(Collectors.groupingBy(CKPowerDevAlarmHistory::getDevType));
        Set<Integer> typeKeyMap = typeMap.keySet();
        for (Integer type : typeKeyMap) {
            if(type==1){
                countMap.put("ac",levelMap.get(type).size());
            }
            if(type==2){
                countMap.put("dc",levelMap.get(type).size());
            }
            if(type==3){
                countMap.put("gc",levelMap.get(type).size());
            }

        }
        return new Response().set(1,countMap);
    }