From a29f26c4f2857322527860672ec1673a4d1fc4ea Mon Sep 17 00:00:00 2001 From: chendaofei <857448963@qq.com> Date: Tue, 22 Jul 2025 18:49:50 +0800 Subject: [PATCH] =?UTF-8?q?bug=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/TerminalBaseServiceImpl.java | 27 +------------------ 1 file changed, 1 insertion(+), 26 deletions(-) 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 2a140f20c..73c501419 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 @@ -1442,22 +1442,6 @@ public class TerminalBaseServiceImpl extends ServiceImpl imple .map(Line::getId) .collect(Collectors.toList()); - this.removeByIds(deviceIds); - deviceMapper.deleteBatchIds(deviceIds); - devFuctionMapper.deleteBatchIds(deviceIds); - - Map devMap = devices.stream().collect(Collectors.toMap(Line::getId,Function.identity())); - List deviceList = deviceMapper.selectList(new LambdaQueryWrapper().select(Device::getId,Device::getNodeId).in(Device::getId,deviceIds)); - String userName= RequestUtil.getUserNickname(); - Map dictDataMap = dicDataFeignClient.getDicDataByTypeCode(DicDataTypeEnum.DEV_TYPE.getCode()).getData().stream().collect(Collectors.toMap(DictData::getId, Function.identity())); - DictData dicDataByCode = dicDataFeignClient.getDicDataByCode(DicDataEnum.DEV_PARAMETER.getCode()).getData(); - // - /* List pqsTerminalLogsList = new ArrayList<>(); - deviceList.forEach(dev->{ - Line devicePO = devMap.get(dev.getId()); - devLogsCat(Param.DEL_ZN,null,devicePO,ledgerList.get(0),dev,pqsTerminalLogsList,dictDataMap,dicDataByCode,userName); - });*/ - // 2. 对每个装置删除其下级 deviceIds.forEach(it-> deleteDeviceAndChildren(it,ledgerList,logsList,nodeMap)); } @@ -1469,19 +1453,16 @@ public class TerminalBaseServiceImpl extends ServiceImpl imple this.removeById(deviceId); deviceMapper.deleteById(deviceId); - - + devFuctionMapper.delete(new LambdaQueryWrapper().eq(DevFuction::getLineId,deviceId)); // 1. 查询并删除所有母线 List busbars = findChildren(deviceId); if (CollectionUtil.isEmpty(busbars)) { return; } - List busbarIds = busbars.stream() .map(Line::getId) .collect(Collectors.toList()); - this.removeByIds(busbarIds); voltageMapper.deleteBatchIds(busbarIds); @@ -1495,9 +1476,6 @@ public class TerminalBaseServiceImpl extends ServiceImpl imple voltageMapper.deleteById(busbarId); // 1. 查询并删除所有监测点 List monitoringPoints = findChildren(busbarId); - - - if (CollectionUtil.isEmpty(monitoringPoints)) { return; } @@ -1506,9 +1484,7 @@ public class TerminalBaseServiceImpl extends ServiceImpl imple List pointIds = monitoringPoints.stream() .map(Line::getId) .collect(Collectors.toList()); - deleteMonitoringPoints(pointIds); - } private void deleteMonitoringPoints(List pointIds) { @@ -1583,7 +1559,6 @@ public class TerminalBaseServiceImpl extends ServiceImpl imple default: throw new BusinessException(CommonResponseEnum.FAIL); } - if(CollUtil.isNotEmpty(logsLedger)){ terminalLogsCat(logsLedger,Param.DEL,allLogs,nodeMap); for(PqsTerminalLogs pqsTerminalLogs: allLogs){