山西直流电源系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
whycxzp
1 天以前 e5b3e3492a7d5f079cad2ca5958a724cabfec401 
 src/main/java/com/whyc/service/LeaderHomeService.java


@@ -1,8 +1,7 @@


package com.whyc.service;




import com.sun.org.glassfish.gmbal.NameValue;


import com.whyc.constant.BattSingalIdEnum;


import com.whyc.constant.Capperformance;


import com.whyc.constant.BattCapperformanceEnum;


import com.whyc.constant.DevAlarmEnum;


import com.whyc.constant.PowerAlarmEnum;


import com.whyc.dto.*;


@@ -154,14 +153,14 @@




        //本年优良劣化损坏数量


        List<BattCapInfoDto> battCapInfoList = getBattCapInfo(battInfList,yearStartTime,null);


        long battGoodCount = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_1.getStateName())).count();


        long battBadCount = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_2.getStateName())).count();


        long battDamageCount = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_3.getStateName())).count();


        long battGoodCount = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_1.getStateName())).count();


        long battBadCount = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_2.getStateName())).count();


        long battDamageCount = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_3.getStateName())).count();


        //去年优良劣化损坏数量


        List<BattCapInfoDto> battCapInfoListLastYear = getBattCapInfo(battInfList,lastYearStartTime,lastYearEndTime);


        long battGoodCountLastYear = battCapInfoListLastYear.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_1.getStateName())).count();


        long battBadCountLastYear = battCapInfoListLastYear.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_2.getStateName())).count();


        long battDamageCountLastYear = battCapInfoListLastYear.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_3.getStateName())).count();


        long battGoodCountLastYear = battCapInfoListLastYear.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_1.getStateName())).count();


        long battBadCountLastYear = battCapInfoListLastYear.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_2.getStateName())).count();


        long battDamageCountLastYear = battCapInfoListLastYear.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_3.getStateName())).count();


        map.put("battGoodCount", battGoodCount);


        map.put("battBadCount", battBadCount);


        map.put("battDamageCount", battDamageCount);


@@ -176,7 +175,7 @@


    private void alarmRealtimeStatistics(Integer userId, Map<String, Object> map) {


        //电池告警信息统计


        List<AlarmDto> battAlarmListNew = new ArrayList<>();


        List<AlarmDto> battAlarmList = battAlarmService.getListByUserId(userId);


        List<AlarmDto> battAlarmList = battAlarmService.getListByUserId(userId, null);


        //合并单体告警的告警信息,对AlarmDto中AlmId 在17~28之间的进行合并.


        Map<String, List<AlarmDto>> mergeMap = battAlarmList.stream()


                .filter(alarm -> alarm.getAlmId() >= 17 && alarm.getAlmId() <= 28)


@@ -205,7 +204,7 @@


        });




        //设备告警信息统计


        List<AlarmDto> devAlarmList = devAlarmService.getListByUserId(userId);


        List<AlarmDto> devAlarmList = devAlarmService.getListByUserId(userId,null);


        //对告警名称赋值


        devAlarmList.forEach(alarmDto -> {


            alarmDto.setAlmName(DevAlarmEnum.getValue(alarmDto.getAlmId()));


@@ -213,7 +212,7 @@




        //电源告警信息统计


        List<AlarmDto> powerAlarmListNew = new ArrayList<>();


        List<AlarmDto> powerAlarmList = powerAlarmService.getListByUserId(userId);


        List<AlarmDto> powerAlarmList = powerAlarmService.getListByUserId(userId,null);


        //整流器总故障合并


        //ALARM_3300001(3300001,"整流器1总故障告警"),


        //    ALARM_3300002(3300002,"整流器2总故障告警"),


@@ -689,7 +688,7 @@


    }






    private void testDataInfoStatistics(Integer userId, Map<String, Object> map) {


    protected void testDataInfoStatistics(Integer userId, Map<String, Object> map) {


        List<BatttestdataInf> testInfList = battTestDataInfService.getListByUserId(userId);


        //过滤出本月的


        LocalDateTime startOfMonth = DateUtil.getStartOfMonth();


@@ -766,7 +765,7 @@


        return testInfOfMonth;


    }




    private void batteryInfoStatistics(Integer userId, Map<String, Object> map) {


    protected void batteryInfoStatistics(Integer userId, Map<String, Object> map) {


        List<BattInf> battInfList = battInfService.getListByUserId(userId);


        Map<String, List<BattInf>> brandMap = battInfList.stream().collect(Collectors.groupingBy(BattInf::getProduct));


        Map<Float, List<BattInf>> volMap = battInfList.stream().collect(Collectors.groupingBy(BattInf::getMonvolstd));


@@ -786,7 +785,7 @@


        map.put("battGroupInfo_vol",volList);


    }




    private void powerInfoStatistics(Integer userId, Map<String, Object> map) {


    protected void powerInfoStatistics(Integer userId, Map<String, Object> map) {


        List<PowerInf> powerInfList = powerInfService.getListByUserId(userId);


        Map<String, List<PowerInf>> brandMap = powerInfList.stream().collect(Collectors.groupingBy(PowerInf::getCompany));


        Map<Integer, List<PowerInf>> typeMap = powerInfList.stream().collect(Collectors.groupingBy(PowerInf::getPowerType));


@@ -861,7 +860,7 @@


        List<NameValueIntDto> data = new ArrayList<>();


        List<NameValueListDto> data2 = new ArrayList<>();


        //筛选出 站点优良,劣化,损坏 的电池组,并按照这个字段分组


        List<BattCapInfoDto> goodList = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_1.getStateName()))


        List<BattCapInfoDto> goodList = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_1.getStateName()))


                .sorted(Comparator.comparing(BattCapInfoDto::getRealCap).reversed()).collect(Collectors.toList());


        if(goodList.size()==0){


            data.add(new NameValueIntDto("优良",0));


@@ -870,7 +869,7 @@


            data.add(new NameValueIntDto("优良",goodList.size()));


            data2.add(new NameValueListDto("优良",goodList.subList(0, Math.min(goodList.size(), 2))));


        }


        List<BattCapInfoDto> badList = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_2.getStateName()))


        List<BattCapInfoDto> badList = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_2.getStateName()))


                .sorted(Comparator.comparing(BattCapInfoDto::getRealCap)).collect(Collectors.toList());


        if(badList.size()==0){


            data.add(new NameValueIntDto("劣化",0));


@@ -879,7 +878,7 @@


            data.add(new NameValueIntDto("劣化",badList.size()));


            data2.add(new NameValueListDto("劣化",badList.subList(0, Math.min(badList.size(), 2))));


        }


        List<BattCapInfoDto> damageList = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_3.getStateName()))


        List<BattCapInfoDto> damageList = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_3.getStateName()))


                .sorted(Comparator.comparing(BattCapInfoDto::getRealCap)).collect(Collectors.toList());


        if(damageList.size()==0){


            data.add(new NameValueIntDto("损坏",0));


@@ -907,9 +906,9 @@


        List<NameValueListDto<NameValueDto>> data = new ArrayList<>();


        brandMap.forEach((brand,battCapInfoListTemp)->{


            //k -品牌


            long goodCount = battCapInfoListTemp.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_1.getStateName())).count();


            long badCount = battCapInfoListTemp.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_2.getStateName())).count();


            long damageCount = battCapInfoListTemp.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_3.getStateName())).count();


            long goodCount = battCapInfoListTemp.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_1.getStateName())).count();


            long badCount = battCapInfoListTemp.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_2.getStateName())).count();


            long damageCount = battCapInfoListTemp.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_3.getStateName())).count();


            long total = goodCount  + badCount + damageCount;


            //良好,劣化,损坏的百分比.（保留0位小数）


            int goodPercent = Math.round((float) goodCount / total * 100);


@@ -926,7 +925,7 @@


        });


        //data2,优良里面最大的和最小的品牌


        List<NameValueListDto<NameValueDto>> data2 = new ArrayList<>();


        List<BattCapInfoDto> goodList = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_1.getStateName()))


        List<BattCapInfoDto> goodList = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_1.getStateName()))


                .sorted(Comparator.comparing(BattCapInfoDto::getRealCap)).collect(Collectors.toList());


        NameValueListDto<NameValueDto> goodListDto = new NameValueListDto<>();


        List<NameValueDto> goodListValue = new ArrayList<>();


@@ -948,7 +947,7 @@


        goodListDto.setValue(goodListValue);


        data2.add(goodListDto);


        //劣化里面最大的和最小的品牌


        List<BattCapInfoDto> badList = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_2.getStateName()))


        List<BattCapInfoDto> badList = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_2.getStateName()))


                .sorted(Comparator.comparing(BattCapInfoDto::getRealCap)).collect(Collectors.toList());


        NameValueListDto<NameValueDto> badListDto = new NameValueListDto<>();


        List<NameValueDto> badListValue = new ArrayList<>();


@@ -971,7 +970,7 @@


        data2.add(badListDto);




        //损坏里面最大的和最小的品牌


        List<BattCapInfoDto> damageList = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_3.getStateName()))


        List<BattCapInfoDto> damageList = battCapInfoList.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_3.getStateName()))


                .sorted(Comparator.comparing(BattCapInfoDto::getRealCap)).collect(Collectors.toList());




        NameValueListDto<NameValueDto> damageListDto = new NameValueListDto<>();


@@ -1035,9 +1034,9 @@


        List<NameValueListDto<NameValueIntDto>> data = new ArrayList<>();


        NameValueListDto<NameValueIntDto> time1Dto = new NameValueListDto<>();


        time1Dto.setName(time1+"年内");


        List<BattCapInfoDto> badListOfTime1 = time1List.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_2.getStateName()))


        List<BattCapInfoDto> badListOfTime1 = time1List.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_2.getStateName()))


                .sorted(Comparator.comparing(BattCapInfoDto::getRealCap)).collect(Collectors.toList());


        List<BattCapInfoDto> damageListOfTime1 = time1List.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_3.getStateName()))


        List<BattCapInfoDto> damageListOfTime1 = time1List.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_3.getStateName()))


                .sorted(Comparator.comparing(BattCapInfoDto::getRealCap)).collect(Collectors.toList());


        NameValueIntDto time1BadDto = new NameValueIntDto();


        time1BadDto.setName("劣化");


@@ -1049,9 +1048,9 @@




        NameValueListDto<NameValueIntDto> time12Dto = new NameValueListDto<>();


        time12Dto.setName(time1+"-"+time2+"年");


        List<BattCapInfoDto> badListOfTime12 = time12List.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_2.getStateName()))


        List<BattCapInfoDto> badListOfTime12 = time12List.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_2.getStateName()))


                .sorted(Comparator.comparing(BattCapInfoDto::getRealCap)).collect(Collectors.toList());


        List<BattCapInfoDto> damageListOfTime12 = time12List.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_3.getStateName()))


        List<BattCapInfoDto> damageListOfTime12 = time12List.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_3.getStateName()))


                .sorted(Comparator.comparing(BattCapInfoDto::getRealCap)).collect(Collectors.toList());


        NameValueIntDto time12BadDto = new NameValueIntDto();


        time12BadDto.setName("劣化");


@@ -1063,9 +1062,9 @@




        NameValueListDto<NameValueIntDto> time2Dto = new NameValueListDto<>();


        time2Dto.setName(time2+"年以上");


        List<BattCapInfoDto> badListOfTime2 = time2List.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_2.getStateName()))


        List<BattCapInfoDto> badListOfTime2 = time2List.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_2.getStateName()))


                .sorted(Comparator.comparing(BattCapInfoDto::getRealCap)).collect(Collectors.toList());


        List<BattCapInfoDto> damageListOfTime2 = time2List.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(Capperformance.BATTSTATE_3.getStateName()))


        List<BattCapInfoDto> damageListOfTime2 = time2List.stream().filter(battCapInfo -> battCapInfo.getPerformance().equals(BattCapperformanceEnum.BATTSTATE_3.getStateName()))


                .sorted(Comparator.comparing(BattCapInfoDto::getRealCap)).collect(Collectors.toList());


        NameValueIntDto time2BadDto = new NameValueIntDto();


        time2BadDto.setName("劣化");


@@ -1155,7 +1154,7 @@


            if (testInf == null) {


                capInfo.setRealCap(0f);


                capInfo.setCapPercentage("0");


                capInfo.setPerformance(Capperformance.BATTSTATE_4.getStateName());


                capInfo.setPerformance(BattCapperformanceEnum.BATTSTATE_4.getStateName());


                continue;


            }


            //找这次放电的最后一笔数据


@@ -1163,21 +1162,21 @@


            if (idDataList == null || idDataList.size() == 0) {


                capInfo.setRealCap(0f);


                capInfo.setCapPercentage("0");


                capInfo.setPerformance(Capperformance.BATTSTATE_4.getStateName());


                capInfo.setPerformance(BattCapperformanceEnum.BATTSTATE_4.getStateName());


                continue;


            }


            Float moncapStd = battInf.getMoncapstd();


            int hourRate = BattCapFactory.GetHourRate(testInf.getTestCap(), testInf.getTestCurr());


            Float groupRealCap = (float) BattCapFactory.GetMonomerCap(testInf.getTestCap(), hourRate, testInf.getTestCap(), testInf.getMaxMonvol(), testInf.getMinMonvol(), testInf.getGroupVol(), BattCapFactory.CapType_Real);


            Float groupRealCap = (float) BattCapFactory.GetMonomerCap(battInf.getMoncapstd(), hourRate, testInf.getTestCap(), testInf.getMaxMonvol(), testInf.getMinMonvol(), testInf.getGroupVol(), BattCapFactory.CapType_Real);


            capInfo.setRealCap(groupRealCap);


            if (groupRealCap >= moncapStd * badValue) {


                capInfo.setPerformance(Capperformance.BATTSTATE_1.getStateName());


                capInfo.setPerformance(BattCapperformanceEnum.BATTSTATE_1.getStateName());


            }


            if (groupRealCap <= moncapStd * damageValue) {


                capInfo.setPerformance(Capperformance.BATTSTATE_3.getStateName());


                capInfo.setPerformance(BattCapperformanceEnum.BATTSTATE_3.getStateName());


            }


            if ((groupRealCap > moncapStd * damageValue) && (groupRealCap < moncapStd * badValue)) {


                capInfo.setPerformance(Capperformance.BATTSTATE_2.getStateName());


                capInfo.setPerformance(BattCapperformanceEnum.BATTSTATE_2.getStateName());


            }


            //保留5位小数


            String capPercentage = String.format("%.5f", (groupRealCap / battInf.getMoncapstd() * 100));