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 ad8935c50..05ecd7e59 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 @@ -1897,11 +1897,14 @@ public class TerminalBaseServiceImpl extends ServiceImpl imple deviceBakLambdaQueryWrapper.eq(DeviceBak::getDevId, oracleTerminalExcel.getDeviceId()); List deviceBaks = deviceBakService.list(deviceBakLambdaQueryWrapper); List devIds = deviceBaks.stream().map(DeviceBak::getId).collect(Collectors.toList()); - LambdaQueryWrapper devLambda = new LambdaQueryWrapper<>(); - devLambda.in(Line::getId, devIds) - .orderByAsc(Line::getCreateTime) - .eq(Line::getState, DataStateEnum.ENABLE.getCode()); - List devList = lineMapper.selectList(devLambda); + List devList = new ArrayList<>(); + if(!CollectionUtil.isEmpty(devIds)){ + LambdaQueryWrapper devLambda = new LambdaQueryWrapper<>(); + devLambda.in(Line::getId, devIds) + .orderByAsc(Line::getCreateTime) + .eq(Line::getState, DataStateEnum.ENABLE.getCode()); + devList = lineMapper.selectList(devLambda); + } if (CollectionUtil.isEmpty(deviceBaks) || CollectionUtil.isEmpty(devList)) { temp = assembleLine(deviceName, LineBaseEnum.DEVICE_LEVEL.getCode(), pids.get(LineBaseEnum.SUB_LEVEL.getCode()), pids); this.baseMapper.insert(temp); @@ -2040,11 +2043,14 @@ public class TerminalBaseServiceImpl extends ServiceImpl imple lineBakLambdaQueryWrapper.eq(LineBak::getLineId, oracleTerminalExcel.getId()); List lineBaks = lineBakService.list(lineBakLambdaQueryWrapper); List lineIds = lineBaks.stream().map(LineBak::getId).collect(Collectors.toList()); - LambdaQueryWrapper devLambda = new LambdaQueryWrapper<>(); - devLambda.in(Line::getId, lineIds) - .orderByAsc(Line::getCreateTime) - .eq(Line::getState, DataStateEnum.ENABLE.getCode()); - List lineList = lineMapper.selectList(devLambda); + List lineList = new ArrayList<>(); + if(CollectionUtil.isNotEmpty(lineIds)){ + LambdaQueryWrapper devLambda = new LambdaQueryWrapper<>(); + devLambda.in(Line::getId, lineIds) + .orderByAsc(Line::getCreateTime) + .eq(Line::getState, DataStateEnum.ENABLE.getCode()); + lineList = lineMapper.selectList(devLambda); + } if (CollectionUtil.isEmpty(lineBaks) || CollectionUtil.isEmpty(lineList)) { temp = assembleLine(lineName, LineBaseEnum.LINE_LEVEL.getCode(), pids.get(LineBaseEnum.SUB_V_LEVEL.getCode()), pids); this.baseMapper.insert(temp);