diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/TerminalBaseController.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/TerminalBaseController.java index 681014fc3..c6897fd30 100644 --- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/TerminalBaseController.java +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/TerminalBaseController.java @@ -211,8 +211,6 @@ public class TerminalBaseController extends BaseController { public HttpResult delTerminal(@RequestParam("id") String id) { String methodDescribe = getMethodDescribe("delTerminal"); terminalBaseService.delTerminal(id); - - return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); } diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/TerminalBaseServiceImpl.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/TerminalBaseServiceImpl.java index 340a077f2..4f8871b8c 100644 --- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/TerminalBaseServiceImpl.java +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/TerminalBaseServiceImpl.java @@ -1664,8 +1664,8 @@ public class TerminalBaseServiceImpl extends ServiceImpl imple lineLambdaQueryWrapper.in(DeptLine::getLineId, lineIndexList); deptLineMapper.delete(lineLambdaQueryWrapper); //通知前置删除监测点 - String[] split = obj.getPids().split(","); - this.askRestartDevice(split[4],DeviceRebootType.LEDGER_MODIFY); + // String[] split = obj.getPids().split(","); + // this.askRestartDevice(split[4],DeviceRebootType.LEDGER_MODIFY); } @@ -1676,8 +1676,8 @@ public class TerminalBaseServiceImpl extends ServiceImpl imple overlimitMapper.deleteById(obj.getId()); deptLineMapper.deleteById(obj.getId()); //通知前置删除监测点 - String[] split = obj.getPids().split(","); - this.askRestartDevice(split[4],DeviceRebootType.LEDGER_MODIFY); + // String[] split = obj.getPids().split(","); + // this.askRestartDevice(split[4],DeviceRebootType.LEDGER_MODIFY); } else { throw new BusinessException(CommonResponseEnum.FAIL); diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/TerminalTreeServiceImpl.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/TerminalTreeServiceImpl.java index 390bcd679..18ebc5fa2 100644 --- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/TerminalTreeServiceImpl.java +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/TerminalTreeServiceImpl.java @@ -96,24 +96,23 @@ public class TerminalTreeServiceImpl implements TerminalTreeService { //用户侧线路 List subvUserList = subvList.stream().filter(it->devIds.contains(it.getPid())).collect(Collectors.toList()); - + List subvUserIds = subvUserList.stream().map(TerminalTree::getId).distinct().collect(Collectors.toList()); //电网侧测点 List otherLineList = newLineList.stream().filter(it->StrUtil.isBlank(it.getObjId())).collect(Collectors.toList()); + List devOtherIds = otherLineList.stream().map(it->it.getPids().split(StrUtil.COMMA)[LineBaseEnum.DEVICE_LEVEL.getCode()]).distinct().collect(Collectors.toList()); //电网侧装置 - List devOtherIds = otherLineList.stream().map(it->it.getPids().split(StrUtil.COMMA)[LineBaseEnum.DEVICE_LEVEL.getCode()]).distinct().collect(Collectors.toList()); List devOtherList = devList.stream().filter(it->devOtherIds.contains(it.getId())).collect(Collectors.toList()); - + List noBindDevList = devList.stream().filter(it->!devOtherIds.contains(it.getId()) && !devIds.contains(it.getId())).collect(Collectors.toList()); + devOtherList.addAll(noBindDevList); //电网侧线路 List subvOtherList = subvList.stream().filter(it->devOtherIds.contains(it.getPid())).collect(Collectors.toList()); + List otherBusBarIds = subvOtherList.stream().map(TerminalTree::getId).distinct().collect(Collectors.toList()); + List noBindList = subvList.stream().filter(it->!subvUserIds.contains(it.getId()) && !otherBusBarIds.contains(it.getId())).collect(Collectors.toList()); + subvOtherList.addAll(noBindList); - //其他的台账默认时电网侧台账 - /* List subvOtherList = subvList.stream().filter(it->!busBarIds.contains(it.getId())).collect(Collectors.toList()); - List devOtherList = devList.stream().filter(it->!devIds.contains(it.getId())).collect(Collectors.toList()); - -*/ UserReportParam userReportParam = new UserReportParam(); List userReportPOList = userLedgerFeignClient.selectUserList(userReportParam).getData(); userReportPOList = userReportPOList.stream().filter(it->StrUtil.isNotBlank(it.getStationId())).collect(Collectors.toList());