From a797381a7daf8d3f8007ec550af0737ca578204e Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Tue, 18 Mar 2025 14:22:02 +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 --- .../device/pq/service/impl/TerminalBaseServiceImpl.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) 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 9f1c029f3..895f52ced 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 @@ -302,6 +302,8 @@ public class TerminalBaseServiceImpl extends ServiceImpl imple processCountMap.put(processNum, processCount); } + }else{ + processCountMap = new HashMap<>(); } //获取数量最少的线程号 @@ -1532,7 +1534,9 @@ public class TerminalBaseServiceImpl extends ServiceImpl imple LambdaQueryWrapper lineLambdaQueryWrapper = new LambdaQueryWrapper<>(); lineLambdaQueryWrapper.in(DeptLine::getLineId, lineIndexList); deptLineMapper.delete(lineLambdaQueryWrapper); - + //通知前置删除监测点 + String[] split = obj.getPids().split(","); + this.askRestartDevice(split[4],DeviceRebootType.LEDGER_MODIFY); } @@ -1542,6 +1546,7 @@ public class TerminalBaseServiceImpl extends ServiceImpl imple lineDetailMapper.deleteById(obj.getId()); overlimitMapper.deleteById(obj.getId()); deptLineMapper.deleteById(obj.getId()); + //通知前置删除监测点 String[] split = obj.getPids().split(","); this.askRestartDevice(split[4],DeviceRebootType.LEDGER_MODIFY);