Compare commits
No commits in common. "2df7cbd1ea7152000770b63559cea04f18b9e648" and "d394b565e2be0d5206844ce97405fb491fe33001" have entirely different histories.
2df7cbd1ea
...
d394b565e2
@ -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 {
|
||||||
|
@ -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 {
|
||||||
|
@ -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;
|
|
||||||
}
|
|
@ -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;
|
|
||||||
|
|
||||||
}
|
|
@ -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);
|
||||||
|
|
||||||
/**********************************
|
/**********************************
|
||||||
* 用途说明: 根据系统编号查询设备
|
* 用途说明: 根据系统编号查询设备
|
||||||
|
@ -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);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user