Compare commits

..

No commits in common. "2df7cbd1ea7152000770b63559cea04f18b9e648" and "d394b565e2be0d5206844ce97405fb491fe33001" have entirely different histories.

6 changed files with 14 additions and 68 deletions

View File

@ -6,7 +6,6 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.annotation.Log; import com.yfd.platform.annotation.Log;
import com.yfd.platform.config.ResponseResult; import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.modules.auxcontrol.domain.GatewayDevice; import com.yfd.platform.modules.auxcontrol.domain.GatewayDevice;
import com.yfd.platform.modules.auxcontrol.domain.GatewayDeviceRequest;
import com.yfd.platform.modules.auxcontrol.service.IGatewayDeviceService; import com.yfd.platform.modules.auxcontrol.service.IGatewayDeviceService;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
@ -133,11 +132,11 @@ public class GatewayDeviceController {
@Log(module = "数据变电站系统设备", value = "根据ID删除变电站网关设备", type = "1") @Log(module = "数据变电站系统设备", value = "根据ID删除变电站网关设备", type = "1")
@PostMapping("/batchDeleteGateway") @PostMapping("/batchDeleteGateway")
@ApiOperation("根据ID批量删除变电站网关设备") @ApiOperation("根据ID批量删除变电站网关设备")
public ResponseResult batchDeleteGateway(@RequestBody GatewayDeviceRequest gatewayDeviceRequest) { public ResponseResult batchDeleteGateway(@RequestBody List<String> ids) {
if (gatewayDeviceRequest.getIds() == null || gatewayDeviceRequest.getIds().size() <= 0) { if (ids.size() <= 0) {
return ResponseResult.error("参数为空"); return ResponseResult.error("参数为空");
} }
boolean isOk = gatewayDeviceService.removeByIds(gatewayDeviceRequest.getIds()); boolean isOk = gatewayDeviceService.removeByIds(ids);
if (isOk) { if (isOk) {
return ResponseResult.success(); return ResponseResult.success();
} else { } else {

View File

@ -5,14 +5,15 @@ import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.annotation.Log; import com.yfd.platform.annotation.Log;
import com.yfd.platform.config.ResponseResult; import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.modules.auxcontrol.domain.MeterDeviceRequest;
import com.yfd.platform.modules.auxcontrol.domain.MeterDevice; import com.yfd.platform.modules.auxcontrol.domain.MeterDevice;
import com.yfd.platform.modules.auxcontrol.service.IMeterDeviceService; import com.yfd.platform.modules.auxcontrol.service.IMeterDeviceService;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@ -118,15 +119,12 @@ public class MeterDeviceController {
@Log(module = "数据变电站辅控设备", value = "批量修改变电站辅控设备信息", type = "1") @Log(module = "数据变电站辅控设备", value = "批量修改变电站辅控设备信息", type = "1")
@PostMapping("/batchUpdateMeterDeviceIp") @PostMapping("/batchUpdateMeterDeviceIp")
@ApiOperation("批量修改变电站辅控设备信息") @ApiOperation("批量修改变电站辅控设备信息")
public ResponseResult batchUpdateMeterDeviceIp(@RequestBody MeterDeviceRequest batchUpdateIpRequest) { public ResponseResult batchUpdateMeterDeviceIp(@RequestParam String ids, @RequestParam String ip) {
if (batchUpdateIpRequest.getIds() == null || batchUpdateIpRequest.getIds().size() <= 0) { if (StrUtil.isBlank(ids) || StrUtil.isBlank(ip)) {
return ResponseResult.error("参数为空"); return ResponseResult.error("参数为空");
} }
if (StrUtil.isBlank(batchUpdateIpRequest.getIp())) { boolean isOk = meterDeviceService.batchUpdateDeviceIp(ids, ip);
return ResponseResult.error("参数为空");
}
boolean isOk = meterDeviceService.batchUpdateDeviceIp(batchUpdateIpRequest.getIds(), batchUpdateIpRequest.getIp());
if (isOk) { if (isOk) {
return ResponseResult.success(); return ResponseResult.success();
} else { } else {

View File

@ -1,15 +0,0 @@
package com.yfd.platform.modules.auxcontrol.domain;
import lombok.Data;
import java.util.List;
/**
* @Date: 2025/4/29 14:26
* @Description:
*/
@Data
public class GatewayDeviceRequest {
private List<String> ids;
}

View File

@ -1,14 +0,0 @@
package com.yfd.platform.modules.auxcontrol.domain;
import lombok.Data;
import java.util.List;
@Data
public class MeterDeviceRequest {
private String ip;
private List<String> ids;
}

View File

@ -49,7 +49,7 @@ public interface IMeterDeviceService extends IService<MeterDevice> {
* 参数说明 ip 设备ip * 参数说明 ip 设备ip
* 返回值说明: boolean * 返回值说明: boolean
***********************************/ ***********************************/
boolean batchUpdateDeviceIp(List<String> ids, String ip); boolean batchUpdateDeviceIp(String ids, String ip);
/********************************** /**********************************
* 用途说明: 根据系统编号查询设备 * 用途说明: 根据系统编号查询设备

View File

@ -4,7 +4,6 @@ import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; 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.domain.MeterDevice;
import com.yfd.platform.modules.auxcontrol.mapper.MeterDeviceMapper; import com.yfd.platform.modules.auxcontrol.mapper.MeterDeviceMapper;
import com.yfd.platform.modules.auxcontrol.service.IMeterDeviceService; import com.yfd.platform.modules.auxcontrol.service.IMeterDeviceService;
@ -31,12 +30,7 @@ public class MeterDeviceServiceImpl extends ServiceImpl<MeterDeviceMapper, Meter
@Override @Override
public Page<MeterDevice> getDevicePage(String deviceName, String deviceModel, String deviceType, String status, public Page<MeterDevice> getDevicePage(String deviceName, String deviceModel, String deviceType, String status,
String systemcode, Page<MeterDevice> page) { String systemcode, Page<MeterDevice> page) {
LambdaQueryWrapper<MeterDevice> queryWrapper = new LambdaQueryWrapper<>(); return null;
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);
} }
/********************************** /**********************************
@ -46,14 +40,6 @@ public class MeterDeviceServiceImpl extends ServiceImpl<MeterDeviceMapper, Meter
***********************************/ ***********************************/
@Override @Override
public boolean addMeterDevice(MeterDevice meterDevice) { public boolean addMeterDevice(MeterDevice meterDevice) {
if (StrUtil.isNotBlank(meterDevice.getIpAddr())) {
LambdaQueryWrapper<MeterDevice> 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.setLastmodifier(SecurityUtils.getCurrentUsername());
//当前操作时间 最近修改时间 //当前操作时间 最近修改时间
meterDevice.setLastmodifydate(new Timestamp(System.currentTimeMillis())); meterDevice.setLastmodifydate(new Timestamp(System.currentTimeMillis()));
@ -67,15 +53,6 @@ public class MeterDeviceServiceImpl extends ServiceImpl<MeterDeviceMapper, Meter
***********************************/ ***********************************/
@Override @Override
public boolean updateMeterDevice(MeterDevice meterDevice) { public boolean updateMeterDevice(MeterDevice meterDevice) {
if (StrUtil.isNotBlank(meterDevice.getIpAddr())) {
LambdaQueryWrapper<MeterDevice> 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.setLastmodifier(SecurityUtils.getCurrentUsername());
//当前操作时间 最近修改时间 //当前操作时间 最近修改时间
meterDevice.setLastmodifydate(new Timestamp(System.currentTimeMillis())); meterDevice.setLastmodifydate(new Timestamp(System.currentTimeMillis()));
@ -89,9 +66,10 @@ public class MeterDeviceServiceImpl extends ServiceImpl<MeterDeviceMapper, Meter
* 返回值说明: boolean * 返回值说明: boolean
***********************************/ ***********************************/
@Override @Override
public boolean batchUpdateDeviceIp(List<String> ids, String ip) { public boolean batchUpdateDeviceIp(String ids, String ip) {
List<String> idList = StrUtil.split(ids, ",");
LambdaUpdateWrapper<MeterDevice> updateWrapper = new LambdaUpdateWrapper<>(); LambdaUpdateWrapper<MeterDevice> updateWrapper = new LambdaUpdateWrapper<>();
updateWrapper.in(MeterDevice::getDeviceId, ids).set(MeterDevice::getNetdeviceIp, ip); updateWrapper.in(MeterDevice::getDeviceId, idList).set(MeterDevice::getNetdeviceIp, ip);
return this.update(updateWrapper); return this.update(updateWrapper);
} }
@ -104,7 +82,7 @@ public class MeterDeviceServiceImpl extends ServiceImpl<MeterDeviceMapper, Meter
@Override @Override
public List<Map<String, Object>> getMeterDeviceByCode(String stationId, String systemCode) { public List<Map<String, Object>> getMeterDeviceByCode(String stationId, String systemCode) {
LambdaQueryWrapper<MeterDevice> queryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<MeterDevice> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(StrUtil.isNotBlank(stationId), MeterDevice::getStationId, stationId).eq(StrUtil.isNotBlank(systemCode), MeterDevice::getSystemcode, systemCode).select(MeterDevice::getDeviceId, MeterDevice::getDeviceName).orderByAsc(MeterDevice::getDeviceCode); queryWrapper.eq(StrUtil.isNotBlank(stationId), MeterDevice::getStationId, stationId).eq(StrUtil.isNotBlank(systemCode), MeterDevice::getSystemcode, systemCode).select(MeterDevice::getDeviceId, MeterDevice::getDeviceName);
return this.listMaps(queryWrapper); return this.listMaps(queryWrapper);
} }
} }