+ * 每日变电站-母线数据总条目表 Mapper 接口 + *
@@ -39,24 +54,130 @@ public class PmsRunStatisticServiceImpl extends MppServiceImpl deptGetChildrenMoreDTOList = commTerminalService.deptGetLine(deptGetLineParam); List poList = new ArrayList<>(); + + //获取在运母线，在运电站数量 + List midLedgerStationList = this.getBusBarAndStationInfo(0); + List midLedgerBusBarList = this.getBusBarAndStationInfo(1); + + //获取在运,符合上送国网的测点,用于过滤监测母线，监测电站 + DictData dictData = dicDataFeignClient.getDicDataByCodeAndType(DicDataEnum.RUN.getCode(),DicDataTypeEnum.LINE_STATE.getCode()).getData(); + List monitorList = monitorMapper.selectList(new LambdaQueryWrapper().eq(Monitor::getMonitorState,dictData.getId()).eq(Monitor::getIsUpToGrid,DataStateEnum.ENABLE.getCode())); + + List statationStatList = statationStatMapper.selectList(new LambdaQueryWrapper().isNotNull(StatationStat::getMidStationId)); + + + //数据完整性 + List rStatIntegrityIds = rStatIntegrityDMapper.selectList(new LambdaQueryWrapper().eq(RStatIntegrityD::getTimeId,localDate).gt(RStatIntegrityD::getRealTime,0)).stream().map(RStatIntegrityD::getLineIndex).distinct().collect(Collectors.toList()); + + //对象类型 + List sysdictreepo = dictTreeFeignClient.queryAll().getData(); + List windfarm_user = Stream.of(DicDataEnum.WINDPOWER_STATION.getCode()).collect(Collectors.toList()); + List photovoltaicsit_eusers = Stream.of(DicDataEnum.PHOTOVOLTAIC_POWER_STATION.getCode()).collect(Collectors.toList()); + List tractionstation = Stream.of(DicDataEnum.ELECTRIFIED_RAILWAY.getCode()).collect(Collectors.toList()); + + DictTreeVO dictTreeVO = dictTreeFeignClient.queryByCode(DicTreeEnum.Imp_Users.getCode()).getData(); + List dictTreeVOList = dictTreeFeignClient.query(dictTreeVO.getId()).getData(); + List importUser = dictTreeVOList.stream().map(DictTreeVO::getCode).distinct().collect(Collectors.toList()); + importUser.add(dictTreeVO.getCode()); + + + List windfarm_user_dict = sysdictreepo.stream().filter(temp -> windfarm_user.contains(temp.getCode())).map(SysDicTreePO::getId).collect(Collectors.toList()); + List photovoltaicsit_eusers_dict = sysdictreepo.stream().filter(temp -> photovoltaicsit_eusers.contains(temp.getCode())).map(SysDicTreePO::getId).collect(Collectors.toList()); + List tractionstation_dict = sysdictreepo.stream().filter(temp -> tractionstation.contains(temp.getCode())).map(SysDicTreePO::getId).collect(Collectors.toList()); + List import_dict = sysdictreepo.stream().filter(temp -> importUser.contains(temp.getCode())).map(SysDicTreePO::getId).collect(Collectors.toList()); + + List un_other_interferencesource_users_dict = new ArrayList<>(); + un_other_interferencesource_users_dict.addAll(photovoltaicsit_eusers_dict); + un_other_interferencesource_users_dict.addAll(tractionstation_dict); + un_other_interferencesource_users_dict.addAll(windfarm_user_dict); + un_other_interferencesource_users_dict.addAll(import_dict); + + + //遍历每个部门 for(DeptGetChildrenMoreDTO dto : deptGetChildrenMoreDTOList){ + List childrenDept = dto.getUnitChildrenList(); + + List temPointIds = dto.getLineBaseList().stream().map(LineDevGetDTO::getPointId).distinct().collect(Collectors.toList()); + + List onlinePointIds = temPointIds.stream().filter(rStatIntegrityIds::contains).collect(Collectors.toList()); + PmsRunStatistic pmsRunStatistic = new PmsRunStatistic(); - pmsRunStatistic.setStatisticDate(LocalDate.parse(date)); + pmsRunStatistic.setStatisticDate(localDate); pmsRunStatistic.setDeptId(dto.getUnitId()); - pmsRunStatistic.setRunMonitorIds(dto.getLineBaseList().stream().map(LineDevGetDTO::getPointId).distinct().collect(Collectors.joining(StrUtil.COMMA))); + pmsRunStatistic.setRunMonitorIds(String.join(StrUtil.COMMA, temPointIds)); + pmsRunStatistic.setOnlineMonitorIds(String.join(StrUtil.COMMA, onlinePointIds)); + pmsRunStatistic.setRunDevIds(dto.getLineBaseList().stream().map(LineDevGetDTO::getDevId).distinct().collect(Collectors.joining(StrUtil.COMMA))); + + + long stationCount = midLedgerStationList.stream().filter(it->childrenDept.contains(it.getSectionId())).map(PmsMidLedger::getId).distinct().count(); + pmsRunStatistic.setRunStationNum((int) stationCount); + long busBarCount = midLedgerBusBarList.stream().filter(it->childrenDept.contains(it.getSectionId())).map(PmsMidLedger::getId).distinct().count(); + pmsRunStatistic.setRunBusNum((int) busBarCount); + + List runBusIds = monitorList.stream().filter(it->childrenDept.contains(it.getOrgId())).map(Monitor::getLineId).distinct().collect(Collectors.toList()); + pmsRunStatistic.setOnlineBusIds(String.join(StrUtil.COMMA, runBusIds)); + + List runStationIds = statationStatList.stream().filter(it->childrenDept.contains(it.getOrgId())).map(StatationStat::getPowerId).distinct().collect(Collectors.toList()); + pmsRunStatistic.setOnlineStationIds(String.join(StrUtil.COMMA, runStationIds)); + + //典型统计 + List windPointIds = dto.getLineBaseList().stream().filter(it->windfarm_user_dict.contains(it.getObjType())).map(LineDevGetDTO::getPointId).collect(Collectors.toList()); + List sunPointIds = dto.getLineBaseList().stream().filter(it->photovoltaicsit_eusers_dict.contains(it.getObjType())).map(LineDevGetDTO::getPointId).collect(Collectors.toList()); + List tractionPointIds = dto.getLineBaseList().stream().filter(it->tractionstation_dict.contains(it.getObjType())).map(LineDevGetDTO::getPointId).collect(Collectors.toList()); + List otherPointIds = dto.getLineBaseList().stream().filter(it->!un_other_interferencesource_users_dict.contains(it.getObjType())).map(LineDevGetDTO::getPointId).collect(Collectors.toList()); + pmsRunStatistic.setTypicalWindIds(String.join(StrUtil.COMMA, windPointIds)); + pmsRunStatistic.setTypicalSunIds(String.join(StrUtil.COMMA, sunPointIds)); + pmsRunStatistic.setTypicalTractionIds(String.join(StrUtil.COMMA, tractionPointIds)); + pmsRunStatistic.setTypicalOtherIds(String.join(StrUtil.COMMA, otherPointIds)); poList.add(pmsRunStatistic); } this.saveBatch(poList); } + + @Override + public void statisticLedgerRunMonth(String date) { + DateTime begin = DateUtil.beginOfMonth(DateUtil.parse(date)); + DateTime end = DateUtil.endOfMonth(DateUtil.parse(date)); + + } + + @Override + public void statisticLedgerRunYear(String date) { + + } + + + /** + * 获取中台母线电站信息 + */ + public List getBusBarAndStationInfo(Integer type) { + LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); + lambdaQueryWrapper.eq(PmsMidLedger::getLevel,type) + .eq(PmsMidLedger::getState, DataStateEnum.ENABLE.getCode()); + return pmsMidLedgerMapper.selectList(lambdaQueryWrapper); + } }