Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

pms国网上送代码提交

Browse Source
This commit is contained in:
雨木c
2023-12-20 15:20:51 +08:00
parent cb84120c9e
commit 6f3ae8f858
1 changed files with 20 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/MonitorServiceImpl.java
View File

@@ -214,27 +214,31 @@ public class MonitorServiceImpl extends ServiceImpl<MonitorMapper, Monitor> impl
List<Monitor> temList = page.getRecords(); List<Monitor> temList = page.getRecords();
List<String> terminalIds = temList.stream().map(Monitor::getTerminalId).distinct().collect(Collectors.toList());
List<PmsTerminal> pmsTerminalList = terminalMapper.selectList(new LambdaQueryWrapper<PmsTerminal>().in(PmsTerminal::getId,terminalIds));
Map<String,PmsTerminal> mapTerminal = pmsTerminalList.stream().collect(Collectors.toMap(PmsTerminal::getId,Function.identity()));
List<String> busIds = temList.stream().map(Monitor::getLineId).distinct().collect(Collectors.toList());
List<GeneratrixWire> generatrixWireList = generatrixWireMapper.selectList(new LambdaQueryWrapper<GeneratrixWire>().in(GeneratrixWire::getId,busIds));
Map<String,GeneratrixWire> mapBus = generatrixWireList.stream().collect(Collectors.toMap(GeneratrixWire::getId,Function.identity()));
temList = temList.stream().peek(item -> { if(CollUtil.isNotEmpty(temList)) {
if(mapTerminal.containsKey(item.getTerminalId())){ List<String> terminalIds = temList.stream().map(Monitor::getTerminalId).distinct().collect(Collectors.toList());
item.setTerminalCode(mapTerminal.get(item.getTerminalId()).getTerminalCode()); List<PmsTerminal> pmsTerminalList = terminalMapper.selectList(new LambdaQueryWrapper<PmsTerminal>().in(PmsTerminal::getId, terminalIds));
} Map<String, PmsTerminal> mapTerminal = pmsTerminalList.stream().collect(Collectors.toMap(PmsTerminal::getId, Function.identity()));
if(mapBus.containsKey(item.getLineId())){ List<String> busIds = temList.stream().map(Monitor::getLineId).distinct().collect(Collectors.toList());
item.setBusId(mapBus.get(item.getLineId()).getMidBusId()); List<GeneratrixWire> generatrixWireList = generatrixWireMapper.selectList(new LambdaQueryWrapper<GeneratrixWire>().in(GeneratrixWire::getId, busIds));
} Map<String, GeneratrixWire> mapBus = generatrixWireList.stream().collect(Collectors.toMap(GeneratrixWire::getId, Function.identity()));
item.setStandShortCapacity(COverlimit.getStandShortCap(map.get(item.getVoltageLevel()).getValue()));
}).collect(Collectors.toList()); temList = temList.stream().peek(item -> {
if (mapTerminal.containsKey(item.getTerminalId())) {
item.setTerminalCode(mapTerminal.get(item.getTerminalId()).getTerminalCode());
}
if (mapBus.containsKey(item.getLineId())) {
item.setBusId(mapBus.get(item.getLineId()).getMidBusId());
}
item.setStandShortCapacity(COverlimit.getStandShortCap(map.get(item.getVoltageLevel()).getValue()));
}).collect(Collectors.toList());
}
page.setRecords(temList); page.setRecords(temList);