| | |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.github.pagehelper.PageHelper; |
| | | import com.github.pagehelper.PageInfo; |
| | | import com.whyc.constant.Capperformance; |
| | | import com.whyc.constant.BattCapperformanceEnum; |
| | | import com.whyc.constant.PwrCapperformanceEnum; |
| | | import com.whyc.constant.StopReasonEnum; |
| | | import com.whyc.dto.Real.TestDataDto; |
| | | import com.whyc.dto.Response; |
| | |
| | | import com.whyc.pojo.db_ram_db.BattRtdata; |
| | | import com.whyc.pojo.db_ram_db.BattRtstate; |
| | | import com.whyc.pojo.db_station.BattInf; |
| | | import com.whyc.pojo.db_station.PowerInf; |
| | | import com.whyc.pojo.db_user.Baojigroup; |
| | | import com.whyc.util.ActionUtil; |
| | | import com.whyc.util.DateUtil; |
| | | import com.whyc.util.PageInfoUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import java.time.LocalDateTime; |
| | | import java.util.*; |
| | | |
| | | @Service |
| | |
| | | @Autowired(required = false) |
| | | private AppParamService appParamService; |
| | | |
| | | @Autowired(required = false) |
| | | private BaojigroupService bjService; |
| | | |
| | | @Autowired(required = false) |
| | | private PowerInfService powerInfService; |
| | | |
| | | @Autowired(required = false) |
| | | private PwrdevHistorydataIdService pwrHisdataIdService; |
| | | |
| | | |
| | | |
| | |
| | | BattInf binf=battInfService.getBinfByBattgroupId(tinf.getBattgroupId()); |
| | | //实时组端电流,剩余容量,标称容量 |
| | | if(battRtstate!=null){ |
| | | Float restTime= BattCapFactory.getTheoryTime(battRtstate.getGroupCurr(), restCap, binf.getMoncapstd()); |
| | | Float restTime= BattCapFactory.getTheoryTime(battRtstate.getLoadCurr(), restCap, binf.getMoncapstd()); |
| | | tinf.setRestTime(restTime); |
| | | } |
| | | //保留5位小数 |
| | |
| | | wrapper.eq("battgroup_id", battgroupId); |
| | | wrapper.eq("test_type", 3); |
| | | wrapper.eq("test_starttype", 3); |
| | | wrapper.last(" and test_timelong >= 7200 ORDER BY test_starttime DESC "); |
| | | wrapper.eq("data_available", 1);//一次有效的记录 |
| | | wrapper.last(" ORDER BY test_starttime DESC "); |
| | | wrapper.last("limit 1"); |
| | | BatttestdataInf tinf = mapper.selectOne(wrapper); |
| | | tinf.setTestStoptypeReason(StopReasonEnum.getValue(tinf.getTestStoptype())); |
| | | return tinf; |
| | | } |
| | | |
| | | //获取电池组在给定时间段的放电记录(指定时间段的标准核容放电) |
| | | private BatttestdataInf getLastStandardTestDataByTime(Integer battgroupId, Date testStartTime, Date testEndTime) { |
| | | protected BatttestdataInf getLastStandardTestDataByTime(Integer battgroupId, Date testStartTime, Date testEndTime) { |
| | | QueryWrapper wrapper = new QueryWrapper(); |
| | | wrapper.eq("battgroup_id", battgroupId); |
| | | wrapper.eq("test_type", 3); |
| | |
| | | if(testEndTime!=null){ |
| | | wrapper.lt("test_starttime",testEndTime); |
| | | } |
| | | wrapper.last(" and test_timelong >= 7200 ORDER BY test_starttime DESC "); |
| | | wrapper.last("limit 1"); |
| | | wrapper.eq("data_available", 1);//一次有效的记录 |
| | | wrapper.last(" ORDER BY test_starttime DESC "); |
| | | wrapper.last(" limit 1 "); |
| | | BatttestdataInf tinf = mapper.selectOne(wrapper); |
| | | return tinf; |
| | | } |
| | |
| | | if(param.getParamNamePsx().equals("batt_mon_damage_val")){ |
| | | damageValue=param.getParamValue(); |
| | | } |
| | | |
| | | } |
| | | } |
| | | //1查询符合条件的电池组 |
| | |
| | | if(tinf==null){ |
| | | res.setRealCap(0f); |
| | | res.setPrecentCap("0"); |
| | | res.setCapperformance(Capperformance.getValue(Capperformance.BATTSTATE_3.getStateId())); |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_4.getStateId())); |
| | | continue; |
| | | } |
| | | //找这次放电的最后一笔数据 |
| | |
| | | if(idDataList==null||idDataList.size()==0){ |
| | | res.setRealCap(0f); |
| | | res.setPrecentCap("0"); |
| | | res.setCapperformance(Capperformance.getValue(Capperformance.BATTSTATE_3.getStateId())); |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_4.getStateId())); |
| | | continue; |
| | | } |
| | | Float moncapStd=binf.getMoncapstd(); |
| | |
| | | //Float restCap = (float) BattCapFactory.GetMonomerCap(tinf.getTestCap(), hourRate, tinf.getTestCap(), tinf.getMaxMonvol(), tinf.getMinMonvol(), tinf.getGroupVol(), BattCapFactory.CapType_Rest); |
| | | res.setRealCap(grouprealCap); |
| | | if(grouprealCap>=moncapStd*badValue){ |
| | | res.setCapperformance(Capperformance.getValue(Capperformance.BATTSTATE_1.getStateId())); |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_1.getStateId())); |
| | | } |
| | | if(grouprealCap<=moncapStd*damageValue){ |
| | | res.setCapperformance(Capperformance.getValue(Capperformance.BATTSTATE_3.getStateId())); |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_3.getStateId())); |
| | | } |
| | | if((grouprealCap>moncapStd*damageValue)&&(grouprealCap<moncapStd*badValue)){ |
| | | res.setCapperformance(Capperformance.getValue(Capperformance.BATTSTATE_2.getStateId())); |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_2.getStateId())); |
| | | } |
| | | //保留5位小数 |
| | | String precentCap = String.format("%.5f",(grouprealCap/binf.getMoncapstd()*100)); |
| | |
| | | if(stic.getPerformance()==null){ |
| | | reslist.add(res); |
| | | }else{ |
| | | if(res.getCapperformance().equals(Capperformance.getValue(stic.getPerformance()))){ |
| | | if(res.getCapperformance().equals(BattCapperformanceEnum.getValue(stic.getPerformance()))){ |
| | | reslist.add(res); |
| | | } |
| | | } |
| | |
| | | if(tinf==null){ |
| | | res.setRealCap(0f); |
| | | res.setPrecentCap("0"); |
| | | res.setCapperformance(Capperformance.getValue(Capperformance.BATTSTATE_3.getStateId())); |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_3.getStateId())); |
| | | res.setStopReason("--"); |
| | | continue; |
| | | } |
| | |
| | | //Float restCap = (float) BattCapFactory.GetMonomerCap(tinf.getTestCap(), hourRate, tinf.getTestCap(), tinf.getMaxMonvol(), tinf.getMinMonvol(), tinf.getGroupVol(), BattCapFactory.CapType_Rest); |
| | | res.setRealCap(grouprealCap); |
| | | if(grouprealCap>=moncapStd*badValue){ |
| | | res.setCapperformance(Capperformance.getValue(Capperformance.BATTSTATE_1.getStateId())); |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_1.getStateId())); |
| | | } |
| | | if(grouprealCap<=moncapStd*damageValue){ |
| | | res.setCapperformance(Capperformance.getValue(Capperformance.BATTSTATE_3.getStateId())); |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_3.getStateId())); |
| | | } |
| | | if((grouprealCap>moncapStd*damageValue)&&(grouprealCap<moncapStd*badValue)){ |
| | | res.setCapperformance(Capperformance.getValue(Capperformance.BATTSTATE_2.getStateId())); |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_2.getStateId())); |
| | | } |
| | | //保留5位小数 |
| | | String precentCap = String.format("%.5f",(grouprealCap/binf.getMoncapstd()*100)); |
| | |
| | | if(stic.getPerformance()==null){ |
| | | reslist.add(res); |
| | | }else{ |
| | | if(res.getCapperformance().equals(Capperformance.getValue(stic.getPerformance()))){ |
| | | if(res.getCapperformance().equals(BattCapperformanceEnum.getValue(stic.getPerformance()))){ |
| | | reslist.add(res); |
| | | } |
| | | } |
| | |
| | | } |
| | | } |
| | | //1查询符合条件的电池组 |
| | | List<BattInf> binfList=battInfService.getBattCompare15Statistic(stic); |
| | | List<BattInf> binfList=battInfService.getBattCompare17Statistic(stic); |
| | | if(binfList==null||binfList.size()==0){ |
| | | return new Response().set(1,false,"当前用户未管理满足条件的电池组"); |
| | | } |
| | |
| | | String monprecentCap = String.format("%.5f",(monrealCap/binf.getMoncapstd()*100)); |
| | | res.setMonprecentCap(monprecentCap); |
| | | if(monrealCap>=moncapStd*badValue){ |
| | | res.setMoncapperformance(Capperformance.getValue(Capperformance.BATTSTATE_1.getStateId())); |
| | | res.setMoncapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_1.getStateId())); |
| | | } |
| | | if (monrealCap <= moncapStd * damageValue) {//损坏的 |
| | | res.setMoncapperformance(Capperformance.getValue(Capperformance.BATTSTATE_3.getStateId())); |
| | | res.setMoncapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_3.getStateId())); |
| | | } |
| | | if((monrealCap>moncapStd*damageValue)&&(monrealCap<moncapStd*badValue)){ |
| | | res.setMoncapperformance(Capperformance.getValue(Capperformance.BATTSTATE_2.getStateId())); |
| | | res.setMoncapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_2.getStateId())); |
| | | } |
| | | if(stic.getPerformance()==null){ |
| | | reslist.add(res); |
| | | }else{ |
| | | if(res.getMoncapperformance().equals(Capperformance.getValue(stic.getPerformance()))){ |
| | | if(res.getMoncapperformance().equals(BattCapperformanceEnum.getValue(stic.getPerformance()))){ |
| | | reslist.add(res); |
| | | } |
| | | } |
| | |
| | | res.setMonNum(i+1); |
| | | res.setMonrealCap(0f); |
| | | res.setMonprecentCap("0"); |
| | | res.setMoncapperformance(Capperformance.getValue(Capperformance.BATTSTATE_3.getStateId())); |
| | | res.setMoncapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_4.getStateId())); |
| | | if(performance==null){ |
| | | reslist.add(res); |
| | | }else{ |
| | | if(res.getMoncapperformance().equals(Capperformance.getValue(performance))){ |
| | | if(res.getMoncapperformance().equals(BattCapperformanceEnum.getValue(performance))){ |
| | | reslist.add(res); |
| | | } |
| | | } |
| | |
| | | List<TestDataDto> List3=new ArrayList<>(); |
| | | List<TestDataDto> List4=new ArrayList<>(); |
| | | List<TestDataDto> List5=new ArrayList<>(); |
| | | map.put("1",List1); //核容放电 |
| | | map.put("2",List2); //核容充电 |
| | | map.put("3",List3); //监测放电 |
| | | map.put("4",List4); //监测充电 |
| | | map.put("5",List5); //停电放电 |
| | | map.put("核容放电",List1); //核容放电 |
| | | map.put("核容充电",List2); //核容充电 |
| | | map.put("监测放电",List3); //监测放电 |
| | | map.put("监测充电",List4); //监测充电 |
| | | map.put("停电放电",List5); //停电放电 |
| | | QueryWrapper wrapper=new QueryWrapper(); |
| | | wrapper.eq("battgroup_id",battgroupId); |
| | | wrapper.orderByDesc("test_starttime"); |
| | |
| | | dto.setMoncapstd(binf.getMoncapstd()); |
| | | dto.setMonCount(binf.getMoncount()); |
| | | dto.setMonvolstd(binf.getMonvolstd()); |
| | | dto.setFloatchartVol(tinf.getFloatGroupVol()); |
| | | if(battRtstate!=null){ |
| | | Float restTime= BattCapFactory.getTheoryTime(battRtstate.getGroupCurr(), realCap, binf.getMoncapstd()); |
| | | Float restTime= BattCapFactory.getTheoryTime(battRtstate.getLoadCurr(), realCap, binf.getMoncapstd()); |
| | | dto.setRestTime(restTime); |
| | | dto.setFloatchartVol(battRtstate.getGroupVol()); |
| | | }else{ |
| | | dto.setRestTime(0f); |
| | | dto.setFloatchartVol(0f); |
| | | } |
| | | //找这次放电的指定一笔数据 |
| | | List<BatttestdataId> idDataList=battTestdataIdService.getLastDataByBattgroupId(tinf.getBattgroupId(),tinf.getTestRecordCount(),1); |
| | | if(idDataList!=null&&idDataList.size()>=0){ |
| | | if(idDataList!=null&&idDataList.size()>0){ |
| | | BatttestdataId idData=idDataList.get(0); |
| | | dto.setOnlineVol(idData.getOnlineVol()); |
| | | dto.setGroupCurr(idData.getTestCurr()); |
| | |
| | | // 测试类型为放电 |
| | | if (tinf.getTestStarttype() == 3) { |
| | | List1.add(dto); |
| | | } else { |
| | | } else if(tinf.getTestStarttype() == 4){ |
| | | List5.add(dto); |
| | | }else { |
| | | List3.add(dto); |
| | | } |
| | | } else if (tinf.getTestType() == 2) { |
| | |
| | | } |
| | | return new Response().setII(1,true,map,"历史测试记录"); |
| | | } |
| | | //本年度已放电数量统计(1.2.5)<只查看已放电数据> |
| | | public Response getDischr5Statistic(DisChargeStic stic) { |
| | | //班组 |
| | | Map<String, Object> bzmap=new HashMap<>(); |
| | | //性能 |
| | | Map<String, Integer> xnmap=new HashMap<>(); |
| | | xnmap.put("优秀",0); |
| | | xnmap.put("劣化",0); |
| | | xnmap.put("损坏",0); |
| | | xnmap.put("未放电",0); |
| | | //查询出所有的班组并赋予初始值 |
| | | setBanZuDefault(bzmap); |
| | | //获取核容优劣,损坏参数 |
| | | List<AppParam> paramList=appParamService.getHrParam(); |
| | | Float badValue=0f; |
| | | Float damageValue=0f; |
| | | if(paramList!=null){ |
| | | for (AppParam param:paramList) { |
| | | if(param.getParamNamePsx().equals("batt_mon_deteriorate_val")){ |
| | | badValue=param.getParamValue(); |
| | | } |
| | | if(param.getParamNamePsx().equals("batt_mon_damage_val")){ |
| | | damageValue=param.getParamValue(); |
| | | } |
| | | |
| | | } |
| | | } |
| | | //1查询符合条件的电池组 |
| | | List<BattInf> binfList=battInfService.getDischr5Statistic(stic); |
| | | if(binfList==null||binfList.size()==0){ |
| | | return new Response().set(1,false,"当前用户未管理满足条件的电池组"); |
| | | } |
| | | List<SticDischarge5Res> reslist=new ArrayList<>(); |
| | | for (BattInf binf:binfList) { |
| | | //查询电池组所在的班组 |
| | | String groupName=bjService.getGroupName(binf.getPowerId()); |
| | | SticDischarge5Res res=new SticDischarge5Res(); |
| | | res.setProvice(binf.getProvice()); |
| | | res.setCity(binf.getCity()); |
| | | res.setCountry(binf.getCountry()); |
| | | res.setStationName(binf.getStationName()); |
| | | res.setBattgroupName(binf.getBattgroupName()); |
| | | res.setStationId(binf.getStationId()); |
| | | res.setPowerId(binf.getPowerId()); |
| | | res.setBattgroupId(binf.getBattgroupId()); |
| | | res.setDevId(binf.getDevId()); |
| | | //2.获取电池组在给定时间段的放电记录(指定时间段的标准核容放电) |
| | | BatttestdataInf tinf =getLastStandardTestDataByTime(binf.getBattgroupId(),stic.getTestStartTime(),stic.getTestEndTime()); |
| | | if(tinf==null){ |
| | | continue; |
| | | } |
| | | if(!groupName.equals("none")){ |
| | | BanZu bz= (BanZu) bzmap.get(groupName); |
| | | int dischargeNum=bz.getDischargeNum(); |
| | | bz.setDischargeNum(dischargeNum+1); |
| | | bzmap.put(groupName,bz); |
| | | } |
| | | res.setTestStartTime(tinf.getTestStarttime()); |
| | | res.setTestTimelong(tinf.getTestTimelong()); |
| | | res.setTestCap(tinf.getTestCap()); |
| | | res.setStopReason(StopReasonEnum.getValue(tinf.getTestStoptype())); |
| | | if (tinf.getTestType() == 3) { |
| | | // 测试类型为放电 |
| | | if (tinf.getTestStarttype() == 3) { |
| | | res.setDischargeName("核容放电"); |
| | | } else if(tinf.getTestStarttype() == 4){ |
| | | res.setDischargeName("停电放电"); |
| | | }else { |
| | | res.setDischargeName("监测放电"); |
| | | } |
| | | } |
| | | res.setTestRecordCount(tinf.getTestRecordCount()); |
| | | Float moncapStd=binf.getMoncapstd(); |
| | | int hourRate = BattCapFactory.GetHourRate(tinf.getTestCap(), tinf.getTestCurr()); |
| | | Float grouprealCap = (float) BattCapFactory.GetMonomerCap(tinf.getTestCap(), hourRate, tinf.getTestCap(), tinf.getMaxMonvol(), tinf.getMinMonvol(), tinf.getGroupVol(), BattCapFactory.CapType_Real); |
| | | res.setRealCap(grouprealCap); |
| | | //res.setDisChargeType(1); |
| | | if(grouprealCap>=moncapStd*badValue){ |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_1.getStateId())); |
| | | int value=xnmap.get(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_1.getStateId())); |
| | | xnmap.put(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_1.getStateId()),value+1); |
| | | } |
| | | if(grouprealCap<=moncapStd*damageValue){ |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_3.getStateId())); |
| | | int value=xnmap.get(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_3.getStateId())); |
| | | xnmap.put(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_3.getStateId()),value+1); |
| | | } |
| | | if((grouprealCap>moncapStd*damageValue)&&(grouprealCap<moncapStd*badValue)){ |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_2.getStateId())); |
| | | int value=xnmap.get(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_2.getStateId())); |
| | | xnmap.put(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_2.getStateId()),value+1); |
| | | } |
| | | reslist.add(res); |
| | | } |
| | | PageInfo pageInfo=PageInfoUtils.list2PageInfo(reslist, stic.getPageNum(), stic.getPageSize()); |
| | | return new Response().setIIII(1,reslist.size()>0,pageInfo,bzmap,xnmap,"本年度已放电数量统计"); |
| | | } |
| | | |
| | | //查询出所有的班组并赋予初始值 |
| | | private void setBanZuDefault(Map<String, Object> map) { |
| | | List<Baojigroup> banZuList=bjService.getGroupList(); |
| | | for (Baojigroup bj:banZuList) { |
| | | BanZu bz=new BanZu(); |
| | | bz.setBaojiGroupId(bj.getBaojiGroupId()); |
| | | bz.setBaojiGroupName(bj.getBaojiGroupName()); |
| | | bz.setDischargeNum(0); |
| | | bz.setNochargeNum(0); |
| | | map.put(bj.getBaojiGroupName(),bz); |
| | | } |
| | | } |
| | | |
| | | //本年度未放电数量统计(1.2.6) |
| | | public Response getDischr6Statistic(DisChargeStic stic) { |
| | | //班组 |
| | | Map<String, Object> bzmap=new HashMap<>(); |
| | | //查询出所有的班组并赋予初始值 |
| | | setBanZuDefault(bzmap); |
| | | //1查询符合条件的电池组 |
| | | List<BattInf> binfList=battInfService.getDischr6Statistic(stic); |
| | | if(binfList==null||binfList.size()==0){ |
| | | return new Response().set(1,false,"当前用户未管理满足条件的电池组"); |
| | | } |
| | | List<SticDischarge6Res> reslist=new ArrayList<>(); |
| | | for (BattInf binf:binfList) { |
| | | //查询电池组所在的班组 |
| | | String groupName=bjService.getGroupName(binf.getPowerId()); |
| | | SticDischarge6Res res=new SticDischarge6Res(); |
| | | res.setProvice(binf.getProvice()); |
| | | res.setCity(binf.getCity()); |
| | | res.setCountry(binf.getCountry()); |
| | | res.setStationName(binf.getStationName()); |
| | | res.setBattgroupName(binf.getBattgroupName()); |
| | | res.setMoncapstd(binf.getMoncapstd()); |
| | | res.setMonvolstd(binf.getMonvolstd()); |
| | | res.setMoncount(binf.getMoncount()); |
| | | res.setProduct(binf.getProduct()); |
| | | res.setStationId(binf.getStationId()); |
| | | res.setPowerId(binf.getPowerId()); |
| | | res.setBattgroupId(binf.getBattgroupId()); |
| | | res.setDevId(binf.getDevId()); |
| | | //获取电池组未放电记录(指定时间段的标准核容放电) |
| | | getNoDischargeData(binf.getBattgroupId(),stic.getTestStartTime(),stic.getTestEndTime(),null,res); |
| | | /*if(stic.getStopReasonType()==0){ |
| | | reslist.add(res); |
| | | }else { |
| | | if(res.getStopReasonType()==stic.getStopReasonType()){ |
| | | reslist.add(res); |
| | | } |
| | | }*/ |
| | | reslist.add(res); |
| | | if(!groupName.equals("none")){ |
| | | BanZu bz= (BanZu) bzmap.get(groupName); |
| | | int nochargeNum=bz.getNochargeNum(); |
| | | bz.setNochargeNum(nochargeNum+1); |
| | | bzmap.put(groupName,bz); |
| | | } |
| | | } |
| | | PageInfo pageInfo=PageInfoUtils.list2PageInfo(reslist, stic.getPageNum(), stic.getPageSize()); |
| | | return new Response().setIII(1,reslist.size()>0,pageInfo,bzmap,"本年度未放电数量统计"); |
| | | } |
| | | //2.获取电池组未放电记录(指定时间段的标准核容放电) |
| | | private void getNoDischargeData(Integer battgroupId, Date testStartTime, Date testEndTime, List<Integer> typeList, SticDischarge6Res res) { |
| | | List<BatttestdataInf> tinfList=mapper.getNoDischargeData(battgroupId,testStartTime,testEndTime,null); |
| | | List<String> stopList=new ArrayList<>(); |
| | | if(tinfList!=null&&tinfList.size()>0){ |
| | | res.setErrorNum(tinfList.size()); |
| | | //res.setStopReasonType(1); |
| | | for (int i=0;i<tinfList.size();i++) { |
| | | BatttestdataInf tinf=tinfList.get(i); |
| | | if(i==0){ |
| | | res.setTestRecordCount(tinf.getTestRecordCount()); |
| | | if (tinf.getTestType() == 3) { |
| | | // 测试类型为放电 |
| | | if (tinf.getTestStarttype() == 3) { |
| | | res.setDischargeName("核容放电"); |
| | | } else if(tinf.getTestStarttype() == 4){ |
| | | res.setDischargeName("停电放电"); |
| | | }else { |
| | | res.setDischargeName("监测放电"); |
| | | } |
| | | } |
| | | } |
| | | String stopReason=StopReasonEnum.getValue(tinf.getTestStoptype()); |
| | | stopList.add(stopReason); |
| | | } |
| | | res.setStopList(stopList); |
| | | }else { |
| | | res.setErrorNum(0); |
| | | res.setStopList(new ArrayList<>()); |
| | | //res.setStopReasonType(0); |
| | | } |
| | | } |
| | | //获取核容停止原因类型(下拉) |
| | | public Response getStopReasonType() { |
| | | Map<String,Map<Integer,String>> map= StopReasonEnum.getOpInfo(); |
| | | return new Response().setII(1,true,map,"获取核容停止原因类型(下拉)"); |
| | | } |
| | | //电池组电池性能统计(未放电,优秀,劣化,损坏)统计(1.2.8/9/10) |
| | | public Response getPerformanceStatistic(PerformanceStic stic) { |
| | | //获取核容优劣,损坏参数 |
| | | List<AppParam> paramList=appParamService.getHrParam(); |
| | | Float badValue=0f; |
| | | Float damageValue=0f; |
| | | if(paramList!=null){ |
| | | for (AppParam param:paramList) { |
| | | if(param.getParamNamePsx().equals("batt_mon_deteriorate_val")){ |
| | | badValue=param.getParamValue(); |
| | | } |
| | | if(param.getParamNamePsx().equals("batt_mon_damage_val")){ |
| | | damageValue=param.getParamValue(); |
| | | } |
| | | |
| | | } |
| | | } |
| | | //1查询符合条件的电池组 |
| | | List<BattInf> binfList=battInfService.getPerformanceStatistic(stic); |
| | | if(binfList==null||binfList.size()==0){ |
| | | return new Response().set(1,false,"当前用户未管理满足条件的电池组"); |
| | | } |
| | | List<PerformanceRes> reslist=new ArrayList<>(); |
| | | for (BattInf binf:binfList) { |
| | | PerformanceRes res=new PerformanceRes(); |
| | | res.setProvice(binf.getProvice()); |
| | | res.setCity(binf.getCity()); |
| | | res.setCountry(binf.getCountry()); |
| | | res.setStationName(binf.getStationName()); |
| | | res.setBattgroupName(binf.getBattgroupName()); |
| | | res.setProduct(binf.getProduct()); |
| | | res.setInuseYear(ActionUtil.getDateYear(new Date())-ActionUtil.getDateYear(binf.getInuseTime())+1); |
| | | res.setMonvolstd(binf.getMonvolstd()); |
| | | res.setMoncapstd(binf.getMoncapstd()); |
| | | res.setMoncount(binf.getMoncount()); |
| | | res.setStationId(binf.getStationId()); |
| | | res.setPowerId(binf.getPowerId()); |
| | | res.setBattgroupId(binf.getBattgroupId()); |
| | | res.setDevId(binf.getDevId()); |
| | | //2.获取电池组在给定时间段的放电记录(指定时间段的标准核容放电) |
| | | BatttestdataInf tinf =getLastStandardTestDataByTime(binf.getBattgroupId(),stic.getTestStartTime(),stic.getTestEndTime()); |
| | | if(tinf==null){ |
| | | res.setRealCap(0f); |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_4.getStateId())); |
| | | }else{ |
| | | //找这次放电的最后一笔数据 |
| | | List<BatttestdataId> idDataList=battTestdataIdService.getLastDataByBattgroupId(tinf.getBattgroupId(),tinf.getTestRecordCount(),tinf.getRecordNum()); |
| | | if(idDataList==null||idDataList.size()==0){ |
| | | res.setRealCap(0f); |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_4.getStateId())); |
| | | }else{ |
| | | Float moncapStd=binf.getMoncapstd(); |
| | | int hourRate = BattCapFactory.GetHourRate(tinf.getTestCap(), tinf.getTestCurr()); |
| | | Float grouprealCap = (float) BattCapFactory.GetMonomerCap(tinf.getTestCap(), hourRate, tinf.getTestCap(), tinf.getMaxMonvol(), tinf.getMinMonvol(), tinf.getGroupVol(), BattCapFactory.CapType_Real); |
| | | res.setRealCap(grouprealCap); |
| | | if(grouprealCap>=moncapStd*badValue){ |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_1.getStateId())); |
| | | } |
| | | if(grouprealCap<=moncapStd*damageValue){ |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_3.getStateId())); |
| | | } |
| | | if((grouprealCap>moncapStd*damageValue)&&(grouprealCap<moncapStd*badValue)){ |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_2.getStateId())); |
| | | } |
| | | } |
| | | } |
| | | if(res.getCapperformance().equals(BattCapperformanceEnum.getValue(stic.getPerformance()))){ |
| | | reslist.add(res); |
| | | } |
| | | } |
| | | PageInfo pageInfo=PageInfoUtils.list2PageInfo(reslist, stic.getPageNum(), stic.getPageSize()); |
| | | return new Response().setII(1,reslist.size()>0,pageInfo,"电池组电池性能统计(未放电,优秀,劣化,损坏)统计(1.2.8/9/10)"); |
| | | } |
| | | //电池组电池性能统计(劣化<按照单体电压+内阻统计>)统计(1.2.9) |
| | | public Response getPerVolAndRes9Statistic(PerformanceStic stic) { |
| | | //1查询符合条件的电池组 |
| | | List<BattInf> binfList=battInfService.getPerformanceStatistic(stic); |
| | | if(binfList==null||binfList.size()==0){ |
| | | return new Response().set(1,false,"当前用户未管理满足条件的电池组"); |
| | | } |
| | | List<PerformanceRes> reslist=new ArrayList<>(); |
| | | for (BattInf binf:binfList) { |
| | | PerformanceRes res=new PerformanceRes(); |
| | | res.setProvice(binf.getProvice()); |
| | | res.setCity(binf.getCity()); |
| | | res.setCountry(binf.getCountry()); |
| | | res.setStationName(binf.getStationName()); |
| | | res.setBattgroupName(binf.getBattgroupName()); |
| | | res.setProduct(binf.getProduct()); |
| | | res.setInuseYear(ActionUtil.getDateYear(new Date())-ActionUtil.getDateYear(binf.getInuseTime())+1); |
| | | res.setMonvolstd(binf.getMonvolstd()); |
| | | res.setMoncapstd(binf.getMoncapstd()); |
| | | res.setMoncount(binf.getMoncount()); |
| | | res.setStationId(binf.getStationId()); |
| | | res.setPowerId(binf.getPowerId()); |
| | | res.setBattgroupId(binf.getBattgroupId()); |
| | | res.setDevId(binf.getDevId()); |
| | | //2.获取电池组在给定时间段的放电记录(指定时间段的标准核容放电) |
| | | BatttestdataInf tinf =getLastStandardTestDataByTime(binf.getBattgroupId(),stic.getTestStartTime(),stic.getTestEndTime()); |
| | | if(tinf==null){ |
| | | res.setRealCap(0f); |
| | | }else{ |
| | | //找这次放电的最后一笔数据 |
| | | List<BatttestdataId> idDataList=battTestdataIdService.getLastDataByBattgroupId(tinf.getBattgroupId(),tinf.getTestRecordCount(),tinf.getRecordNum()); |
| | | if(idDataList==null||idDataList.size()==0){ |
| | | res.setRealCap(0f); |
| | | }else{ |
| | | int hourRate = BattCapFactory.GetHourRate(tinf.getTestCap(), tinf.getTestCurr()); |
| | | Float grouprealCap = (float) BattCapFactory.GetMonomerCap(tinf.getTestCap(), hourRate, tinf.getTestCap(), tinf.getMaxMonvol(), tinf.getMinMonvol(), tinf.getGroupVol(), BattCapFactory.CapType_Real); |
| | | res.setRealCap(grouprealCap); |
| | | } |
| | | } |
| | | //查询当前电池组当前单体电压或者单体内阻低于其单体电压的下下限或高于上上限判定当前电池组劣化 |
| | | int flag = rtdataService.getVolAndRes(binf.getBattgroupId()); |
| | | if(flag==1){ |
| | | res.setCapperformance(BattCapperformanceEnum.getValue(BattCapperformanceEnum.BATTSTATE_2.getStateId())); |
| | | reslist.add(res); |
| | | } |
| | | } |
| | | PageInfo pageInfo=PageInfoUtils.list2PageInfo(reslist, stic.getPageNum(), stic.getPageSize()); |
| | | return new Response().setII(1,reslist.size()>0,pageInfo,"电池组电池性能统计(未放电,优秀,劣化,损坏)统计(1.2.8/9/10)"); |
| | | } |
| | | //优良电源数量统计(1.2.7) |
| | | public Response getPwr7Statistic(Pwr7Stic stic) throws NoSuchFieldException, IllegalAccessException { |
| | | Date inuseTimeStart =new Date(); |
| | | if(stic.getInuseYear()!=null){ |
| | | if(stic.getInuseYear()==1){ |
| | | //投入使用时间条件筛选 |
| | | LocalDateTime startTime = LocalDateTime.now().minusYears(5); |
| | | inuseTimeStart = DateUtil.convertToDate(startTime); |
| | | }else{ |
| | | //投入使用时间条件筛选 |
| | | LocalDateTime startTime = LocalDateTime.now().minusYears(stic.getInuseYear()); |
| | | inuseTimeStart = DateUtil.convertToDate(startTime); |
| | | } |
| | | stic.setPwrInUseTime(inuseTimeStart); |
| | | } |
| | | //1查询符合条件的电池组 |
| | | List<PowerInf> pinfList=powerInfService.getPwr7Statistic(stic); |
| | | if(pinfList==null||pinfList.size()==0){ |
| | | return new Response().set(1,false,"当前用户未管理满足条件的电源"); |
| | | } |
| | | List<SticPwr7Res> reslist=new ArrayList<>(); |
| | | for (PowerInf pinf:pinfList) { |
| | | SticPwr7Res res = new SticPwr7Res(); |
| | | //查询电源所在的班组 |
| | | String groupName = bjService.getGroupName(pinf.getPowerId()); |
| | | if (stic.getGroupName() == null || groupName == stic.getGroupName()) { |
| | | res.setProvice(pinf.getProvice()); |
| | | res.setCity(pinf.getCity()); |
| | | res.setCountry(pinf.getCountry()); |
| | | res.setStationName(pinf.getStationName()); |
| | | res.setPowerName(pinf.getPowerName()); |
| | | res.setCompany(pinf.getCompany()); |
| | | res.setStationType(pinf.getStationType()); |
| | | res.setGroupName(groupName); |
| | | res.setInuseTime(pinf.getPowerInuseTime()); |
| | | Integer performance= pwrHisdataIdService.getPwrQuarter7(pinf.getPowerId(),pinf.getPowerType()); |
| | | res.setPerformanceName(PwrCapperformanceEnum.getValue(performance)); |
| | | if(stic.getPerformance()==null){ |
| | | reslist.add(res); |
| | | }else{ |
| | | if(performance==stic.getPerformance()){ |
| | | reslist.add(res); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | PageInfo pageInfo=PageInfoUtils.list2PageInfo(reslist, stic.getPageNum(), stic.getPageSize()); |
| | | return new Response().setII(1,reslist.size()>0,pageInfo,"优良电源数量统计(1.2.7)"); |
| | | } |
| | | |
| | | |
| | | public List<BatttestdataInf> getListByUserId(Integer userId) { |
| | | return mapper.getListByUserId(userId); |
| | | } |
| | | |
| | | public int getHrDisCount(Integer userId, Date startTime, Date endTime) { |
| | | return mapper.getHrDisCount(userId, startTime, endTime); |
| | | } |
| | | //获取这一次的放电信息 |
| | | public BatttestdataInf getTinfByTestRecordCount(Integer battgroupId, Integer testRecordCount) { |
| | | QueryWrapper wrapper=new QueryWrapper(); |
| | | wrapper.eq("battgroup_id",battgroupId); |
| | | wrapper.eq("test_record_count",testRecordCount); |
| | | wrapper.last(" limit 1"); |
| | | return mapper.selectOne(wrapper); |
| | | } |
| | | //历史测试数据导出 |
| | | public BatttestdataInf exportTinfDataByTestRecordCount(Integer battgroupId, Integer testRecordCount) { |
| | | QueryWrapper wrapper =new QueryWrapper(); |
| | | wrapper.eq("battgroup_id",battgroupId); |
| | | wrapper.eq("test_record_count",testRecordCount); |
| | | wrapper.last(" limit 1"); |
| | | return mapper.selectOne(wrapper); |
| | | } |
| | | } |