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 a630d77..0d13d93 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 @@ -16,8 +16,6 @@ import java.util.Map; */ public interface DeviceSignalMapper extends BaseMapper { - List selectDeviceSignalYx(String slave_ip, String address); - List selectDeviceSignalYc(String slave_ip, String address); - List> selectDeviceSignal_Map(String slave_ip, String type, String address); - List> selectDeviceSignal_Map2(String type,String address); + DeviceSignal selectOneDeviceSignal(String slaveIp, String type, String address); + Map selectDeviceSignalMap(String slaveIp, String type, String address); } diff --git a/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/impl/DeviceAlarmRecordServiceImpl.java b/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/impl/DeviceAlarmRecordServiceImpl.java index ea5eec2..daa2bd4 100644 --- a/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/impl/DeviceAlarmRecordServiceImpl.java +++ b/riis-system/src/main/java/com/yfd/platform/modules/auxcontrol/service/impl/DeviceAlarmRecordServiceImpl.java @@ -71,16 +71,16 @@ public class DeviceAlarmRecordServiceImpl extends ServiceImpl> list = new ArrayList<>(); + String sinnalType = type; if ("IEC104".equals(from)) { - list = deviceSignalMapper.selectDeviceSignal_Map(slaveIp, "yc", address); + sinnalType = "yc"; } else if ("IEC61850".equals(from)) { - list = deviceSignalMapper.selectDeviceSignal_Map2(type, address); + slaveIp = null; } - if (list.size() == 0) { + Map map = deviceSignalMapper.selectDeviceSignalMap(slaveIp, sinnalType, address); + if (map == null || ObjUtil.isEmpty(map)) { return; } - Map map = list.get(0); //如果是yx 遥信 (设备自身报警记录) if ("yx".equals(type)) { //如果信号类型是1 设备告警 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 be9c5e9..3604383 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 @@ -1,6 +1,7 @@ package com.yfd.platform.modules.auxcontrol.service.impl; import cn.hutool.core.convert.Convert; +import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import com.yfd.platform.modules.auxcontrol.domain.DeviceSignal; import com.yfd.platform.modules.auxcontrol.mapper.DeviceSignalMapper; @@ -37,19 +38,9 @@ public class DeviceSignalServiceImpl extends ServiceImpl list = null; - - if ("yx".equals(type)) { - // 遥信 - list = deviceSignalMapper.selectDeviceSignalYx(slaveIp, address); - } else if ("yc".equals(type)) { - // 遥测 - list = deviceSignalMapper.selectDeviceSignalYc(slaveIp, address); - } - - if (list != null && !list.isEmpty()) { - DeviceSignal deviceSignal = list.get(0); + DeviceSignal deviceSignal = deviceSignalMapper.selectOneDeviceSignal(slaveIp, type, address); + if (deviceSignal != null && ObjectUtil.isNotEmpty(deviceSignal)) { try { if ("yx".equals(type)) { // 遥信 @@ -64,7 +55,6 @@ public class DeviceSignalServiceImpl extends ServiceImpl> list = new ArrayList<>(); - if ("IEC104".equals(from)) { - list = deviceSignalMapper.selectDeviceSignal_Map(slaveIp, "yc", address); - } else if ("IEC61850".equals(from)) { - list = deviceSignalMapper.selectDeviceSignal_Map2("yc", address); + if ("IEC61850".equals(from)) { + slaveIp = null; } - if (list.size() > 0) { - Map map = list.get(0); - workdata.setId(IdUtil.fastSimpleUUID()); - workdata.setSystemcode(map.get("systemcode").toString()); - workdata.setStationId(map.get("station_id").toString()); - workdata.setDeviceId(map.get("device_id").toString()); - workdata.setDeviceName(map.get("device_name").toString()); - workdata.setSignalId(map.get("signal_id").toString()); - workdata.setSignalName(map.get("signal_name").toString()); - workdata.setUnit(ObjUtil.isNotEmpty(map.get("signal_unit")) ? map.get("signal_unit").toString() : ""); + Map map = deviceSignalMapper.selectDeviceSignalMap(slaveIp, "yc", address); + if (map == null || ObjUtil.isEmpty(map)) { + return; + } + workdata.setId(IdUtil.fastSimpleUUID()); + workdata.setSystemcode(map.get("systemcode").toString()); + workdata.setStationId(map.get("station_id").toString()); + workdata.setDeviceId(map.get("device_id").toString()); + workdata.setDeviceName(map.get("device_name").toString()); + workdata.setSignalId(map.get("signal_id").toString()); + workdata.setSignalName(map.get("signal_name").toString()); + workdata.setUnit(ObjUtil.isNotEmpty(map.get("signal_unit")) ? map.get("signal_unit").toString() : ""); workdata.setValue(new BigDecimal(value)); if (StrUtil.isEmpty(dateTimeString) || "null".equals(dateTimeString)) { workdata.setStartTime(LocalDateTime.now()); @@ -66,7 +65,6 @@ public class DeviceWorkDataServiceImpl extends ServiceImpl - - - - - - SELECT a.station_id, a.systemcode, @@ -38,10 +11,13 @@ b.* FROM fk_meter_device a - JOIN fk_device_signal b ON ( a.device_id = b.device_id ) + JOIN fk_device_signal b ON ( a.device_id = b.meter_device_id ) JOIN fk_gateway_device c ON ( a.netdevice_ip = c.ip_addr ) WHERE - c.ip_addr = #{slave_ip} + 1 =1 + + and c.ip_addr = #{slaveIp} + and b.yx_addr = #{address} @@ -52,22 +28,24 @@ - SELECT - a.station_id, - a.systemcode, - a.device_name, b.* - FROM + FROM fk_meter_device a - JOIN fk_device_signal b ON ( a.device_id = b.device_id ) - WHERE - 1 =1 + JOIN fk_device_signal b ON ( a.device_id = b.meter_device_id ) + JOIN fk_gateway_device c ON ( a.netdevice_ip = c.ip_addr ) + WHERE + + c.ip_addr = #{slaveIp} + and b.yx_addr = #{address} and b.yc_addr = #{address} + limit 1 +