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);