diff --git a/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/controller/DeviceSignalController.java b/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/controller/DeviceSignalController.java index 471ccfe..b3df2e7 100644 --- a/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/controller/DeviceSignalController.java +++ b/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/controller/DeviceSignalController.java @@ -78,11 +78,18 @@ public class DeviceSignalController { ***********************************/ @GetMapping("/queryYxData") @ApiOperation("查询遥信数据") - public ResponseResult queryYxData(Page> page, String areaId, String type) { - Page> mapPage = deviceSignalService.queryYxData(page, areaId, type); + public ResponseResult queryYxData(Page> page, String areaId, String type,String stationId) { + Page> mapPage = deviceSignalService.queryYxData(page, areaId, type,stationId); return ResponseResult.successData(mapPage); } + @GetMapping("/countDeviceTypeStatus") + @ApiOperation("查询遥信数据统计") + public ResponseResult countDeviceTypeStatus(String areaId, String type,String stationId) { + List> mapList = deviceSignalService.countDeviceTypeStatus(areaId, type,stationId); + return ResponseResult.successData(mapList); + } + /********************************** * 用途说明: 查询信号信息 * 参数说明 diff --git a/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/mapper/DeviceSignalMapper.java b/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/mapper/DeviceSignalMapper.java index b6be810..3de0ab2 100644 --- a/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/mapper/DeviceSignalMapper.java +++ b/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/mapper/DeviceSignalMapper.java @@ -19,16 +19,24 @@ import java.util.Map; public interface DeviceSignalMapper extends BaseMapper { DeviceSignal selectOneDeviceSignal(String slaveIp, String type, String address); - Map selectDeviceSignalMap(String slaveIp, String type, String address); + + Map selectDeviceSignalMap(String slaveIp, String type, String address); + List> getDeviceSignalMaps(String stationCode, String signalName); List selectDeviceSignalByIp(String ip); - @Update("UPDATE fk_device_signal SET yc_value = #{value}, lastmodifydate = #{datetime} WHERE yc_addr = #{node_addr}") - boolean updateDeviceSignalValue_yc(String node_addr,String value,String datetime); - @Update("UPDATE fk_device_signal SET yx_value = #{value}, lastmodifydate = #{datetime} WHERE yx_addr = #{node_addr}") - boolean updateDeviceSignalValue_yx(String node_addr,String value,String datetime); + + @Update("UPDATE fk_device_signal SET yc_value = #{value}, lastmodifydate = #{datetime} WHERE yc_addr = " + + "#{node_addr}") + boolean updateDeviceSignalValue_yc(String node_addr, String value, String datetime); + + @Update("UPDATE fk_device_signal SET yx_value = #{value}, lastmodifydate = #{datetime} WHERE yx_addr = " + + "#{node_addr}") + boolean updateDeviceSignalValue_yx(String node_addr, String value, String datetime); Map querySignalDataById(String signalId); - Page> queryYxData(Page> page, String areaId, String type); + Page> queryYxData(Page> page, String areaId, String type, String stationId); + + List> countDeviceTypeStatus(String areaId, String type, String stationId); } diff --git a/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/IDeviceSignalService.java b/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/IDeviceSignalService.java index 4c08ce5..8427bf3 100644 --- a/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/IDeviceSignalService.java +++ b/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/IDeviceSignalService.java @@ -69,5 +69,8 @@ public interface IDeviceSignalService extends IService { ***********************************/ Map querySignalDataById(String signalId); - Page> queryYxData(Page> page, String areaId, String type); + Page> queryYxData(Page> page, String areaId, String type,String stationId); + + List> countDeviceTypeStatus(String areaId, String type, String stationId); + } diff --git a/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/impl/DeviceSignalServiceImpl.java b/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/impl/DeviceSignalServiceImpl.java index 9201489..4048a88 100644 --- a/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/impl/DeviceSignalServiceImpl.java +++ b/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/impl/DeviceSignalServiceImpl.java @@ -20,6 +20,7 @@ import javax.annotation.Resource; import java.sql.Timestamp; import java.text.ParseException; import java.text.SimpleDateFormat; +import java.util.Collections; import java.util.Date; import java.util.List; import java.util.Map; @@ -58,7 +59,7 @@ public class DeviceSignalServiceImpl extends ServiceImpl ***********************************/ @Override - public Page getDeviceSignalPage(String systemcode,String meterDeviceId,String mainDeviceId, String componentId, String signalName, + public Page getDeviceSignalPage(String systemcode, String meterDeviceId, String mainDeviceId, + String componentId, String signalName, Page page) { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); if (StrUtil.isNotBlank(systemcode)) { @@ -210,7 +212,13 @@ public class DeviceSignalServiceImpl extends ServiceImpl> queryYxData(Page> page, String areaId, String type) { - return deviceSignalMapper.queryYxData(page, areaId, type); + public Page> queryYxData(Page> page, String areaId, String type, + String stationId) { + return deviceSignalMapper.queryYxData(page, areaId, type, stationId); + } + + @Override + public List> countDeviceTypeStatus(String areaId, String type, String stationId) { + return deviceSignalMapper.countDeviceTypeStatus(areaId, type, stationId); } } diff --git a/riis-system/src/main/java/com/yfd/platform/modules/basedata/controller/SubstationMaindeviceController.java b/riis-system/src/main/java/com/yfd/platform/modules/basedata/controller/SubstationMaindeviceController.java index a74a942..ea3f6d0 100644 --- a/riis-system/src/main/java/com/yfd/platform/modules/basedata/controller/SubstationMaindeviceController.java +++ b/riis-system/src/main/java/com/yfd/platform/modules/basedata/controller/SubstationMaindeviceController.java @@ -115,9 +115,11 @@ public class SubstationMaindeviceController { } LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(StrUtil.isNotBlank(stationCode), SubstationMaindevice::getStationCode, stationCode); - queryWrapper.in(StrUtil.isNotBlank(deviceTypeList), SubstationMaindevice::getDeviceType, StrUtil.split(deviceTypeList - , ",")); - queryWrapper.select(SubstationMaindevice::getMainDeviceId,SubstationMaindevice::getAreaId,SubstationMaindevice::getAreaName, SubstationMaindevice::getMainDeviceName, + queryWrapper.in(StrUtil.isNotBlank(deviceTypeList), SubstationMaindevice::getDeviceType, + StrUtil.split(deviceTypeList + , ",")); + queryWrapper.select(SubstationMaindevice::getMainDeviceId, SubstationMaindevice::getAreaId, + SubstationMaindevice::getAreaName, SubstationMaindevice::getMainDeviceName, SubstationMaindevice::getDeviceType, SubstationMaindevice::getFileUrl); queryWrapper.eq(SubstationMaindevice::getDatastatus, "1"); List> maps = substationMaindeviceService.listMaps(queryWrapper); @@ -321,11 +323,15 @@ public class SubstationMaindeviceController { if (count > 0) { return ResponseResult.error("当前间隔下已经存在该主设备"); } - int count2 = - substationDeviceService.count(new LambdaQueryWrapper().eq(SubstationDevice::getMainDeviceId, mainDeviceId)); - if (count2 > 0) { - return ResponseResult.error("当前主设备有点位关联不能修改"); + if (StrUtil.isNotBlank(mainDeviceId) && StrUtil.isNotBlank(mainDeviceName)) { + int count2 = + substationDeviceService.count(new LambdaQueryWrapper().eq + (SubstationDevice::getMainDeviceId, mainDeviceId).ne(SubstationDevice::getMainDeviceName,mainDeviceName)); + if (count2 > 0 && file == null) { + return ResponseResult.error("当前主设备有点位关联不能修改名称"); + } } + substationMaindevice.setLastmodifier(SecurityUtils.getCurrentUsername()); substationMaindevice.setLastmodifydate(LocalDateTime.now()); // 文件上传逻辑 diff --git a/riis-system/src/main/resources/mapper/algorithm/AlgorithmClassComponentMapper.xml b/riis-system/src/main/resources/mapper/algorithm/AlgorithmClassComponentMapper.xml index f1b1ba5..f05983c 100644 --- a/riis-system/src/main/resources/mapper/algorithm/AlgorithmClassComponentMapper.xml +++ b/riis-system/src/main/resources/mapper/algorithm/AlgorithmClassComponentMapper.xml @@ -22,7 +22,14 @@ +