diff --git a/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/impl/MeterDeviceServiceImpl.java b/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/impl/MeterDeviceServiceImpl.java index 1d0411e..4c872d7 100644 --- a/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/impl/MeterDeviceServiceImpl.java +++ b/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/impl/MeterDeviceServiceImpl.java @@ -4,6 +4,7 @@ import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.yfd.platform.modules.auxcontrol.domain.GatewayDevice; import com.yfd.platform.modules.auxcontrol.domain.MeterDevice; import com.yfd.platform.modules.auxcontrol.mapper.MeterDeviceMapper; import com.yfd.platform.modules.auxcontrol.service.IMeterDeviceService; @@ -30,7 +31,12 @@ public class MeterDeviceServiceImpl extends ServiceImpl getDevicePage(String deviceName, String deviceModel, String deviceType, String status, String systemcode, Page page) { - return null; + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.like(StrUtil.isNotBlank(deviceName), MeterDevice::getDeviceName, deviceName); + queryWrapper.like(StrUtil.isNotBlank(deviceModel), MeterDevice::getDeviceModel, deviceModel); + queryWrapper.eq(StrUtil.isNotBlank(deviceType), MeterDevice::getDeviceType, deviceType); + queryWrapper.eq(StrUtil.isNotBlank(systemcode), MeterDevice::getSystemcode, systemcode).orderByAsc(MeterDevice::getDeviceCode); + return this.page(page, queryWrapper); } /********************************** @@ -40,6 +46,14 @@ public class MeterDeviceServiceImpl extends ServiceImpl queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.eq(MeterDevice::getIpAddr, meterDevice.getIpAddr()); + int count = this.count(queryWrapper); + if (count > 0) { + throw new RuntimeException("当前ip已经有设备绑定"); + } + } meterDevice.setLastmodifier(SecurityUtils.getCurrentUsername()); //当前操作时间 最近修改时间 meterDevice.setLastmodifydate(new Timestamp(System.currentTimeMillis())); @@ -53,6 +67,15 @@ public class MeterDeviceServiceImpl extends ServiceImpl queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.ne(MeterDevice::getDeviceId, meterDevice.getDeviceId()).eq(MeterDevice::getIpAddr, + meterDevice.getIpAddr()); + int count = this.count(queryWrapper); + if (count > 0) { + throw new RuntimeException("当前ip已经有设备绑定"); + } + } meterDevice.setLastmodifier(SecurityUtils.getCurrentUsername()); //当前操作时间 最近修改时间 meterDevice.setLastmodifydate(new Timestamp(System.currentTimeMillis())); @@ -82,7 +105,7 @@ public class MeterDeviceServiceImpl extends ServiceImpl> getMeterDeviceByCode(String stationId, String systemCode) { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); - queryWrapper.eq(StrUtil.isNotBlank(stationId), MeterDevice::getStationId, stationId).eq(StrUtil.isNotBlank(systemCode), MeterDevice::getSystemcode, systemCode).select(MeterDevice::getDeviceId, MeterDevice::getDeviceName); + queryWrapper.eq(StrUtil.isNotBlank(stationId), MeterDevice::getStationId, stationId).eq(StrUtil.isNotBlank(systemCode), MeterDevice::getSystemcode, systemCode).select(MeterDevice::getDeviceId, MeterDevice::getDeviceName).orderByAsc(MeterDevice::getDeviceCode); return this.listMaps(queryWrapper); } }