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

谐波装置修改

Browse Source
This commit is contained in:
wr
2023-04-12 12:34:38 +08:00
parent 20e4c0cd75
commit 1707ce3ed2
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/TerminalTreeServiceImpl.java
View File

@@ -166,11 +166,20 @@ public class TerminalTreeServiceImpl implements TerminalTreeService {
} else { } else {
groupLine = childrenData.stream().collect(Collectors.groupingBy(TerminalTree::getPid)); groupLine = childrenData.stream().collect(Collectors.groupingBy(TerminalTree::getPid));
} }
//变电站
targetData = targetData.stream().peek(terminalTree -> { targetData = targetData.stream().peek(terminalTree -> {
if(isLine){ if(isLine){
//监测点的数量 //变电站集合
int size = groupLine.get(terminalTree.getId()).size(); List<TerminalTree> terminalTrees = groupLine.get(terminalTree.getId());
int size = terminalTrees.stream().map(x -> {
// 获取父id字符串，通过 逗号 分割 成一个数组
String[] pid = x.getPids().split(",");
return pid[LineBaseEnum.DEVICE_LEVEL.getCode()];
}).distinct().collect(Collectors.toList()).size();
terminalTree.setName(terminalTree.getName()+"（"+size+"台装置）"); terminalTree.setName(terminalTree.getName()+"（"+size+"台装置）");
terminalTree.setChildren(groupLine.get(terminalTree.getId())); terminalTree.setChildren(groupLine.get(terminalTree.getId()));
}else{ }else{
terminalTree.setChildren(groupLine.get(terminalTree.getId())); terminalTree.setChildren(groupLine.get(terminalTree.getId()));