yangjun
/
hldy_yunwei_java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

电表、水表、温湿度计抄表、拉合闸时，将数值和状态同步到业务系统

This commit is contained in:
曹磊 2025-08-21 10:56:29 +08:00
parent bddd08eacb
commit 329eaa82aa
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/impl/ElectricityMeterServiceImpl.java
View File

@ -398,7 +398,7 @@ public class ElectricityMeterServiceImpl extends ServiceImpl<ElectricityMeterMap
log.setServerType("电表");
bizLogService.addLog(log);
iem.setLogId(logId);
rabbitMQUtil.sendToExchange("hldy.iotDeviceValues", entity.getDepartServerUrl() + ".iotElectricity.eleValue.async", iem);
rabbitMQUtil.sendToExchange("hldy.iotDeviceValues", entity.getDepartServerUrl() + ".ywIotElectricity.eleValue.async", iem);
}
}
@ -484,7 +484,7 @@ public class ElectricityMeterServiceImpl extends ServiceImpl<ElectricityMeterMap
log.setServerType("电表");
bizLogService.addLog(log);
iem.setLogId(logId);
rabbitMQUtil.sendToExchange("hldy.iotDeviceValues", entity.getDepartServerUrl() + ".iotElectricity.eleControl.async", iem);
rabbitMQUtil.sendToExchange("hldy.iotDeviceValues", entity.getDepartServerUrl() + ".ywIotElectricity.eleControl.async", iem);
}
}

4
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/impl/WaterMeterServiceImpl.java
View File

@ -401,7 +401,7 @@ public class WaterMeterServiceImpl extends ServiceImpl<WaterMeterMapper, WaterMe
log.setServerType("水表");
bizLogService.addLog(log);
iwm.setLogId(logId);
rabbitMQUtil.sendToExchange("hldy.iotDeviceValues", entity.getDepartServerUrl() + ".iotWater.waterValue.async", iwm);
rabbitMQUtil.sendToExchange("hldy.iotDeviceValues", entity.getDepartServerUrl() + ".ywIotWater.waterValue.async", iwm);
}
}
@ -487,7 +487,7 @@ public class WaterMeterServiceImpl extends ServiceImpl<WaterMeterMapper, WaterMe
log.setServerType("水表");
bizLogService.addLog(log);
iwm.setLogId(logId);
rabbitMQUtil.sendToExchange("hldy.iotDeviceValues", entity.getDepartServerUrl() + ".iotWater.waterControl.async", iwm);
rabbitMQUtil.sendToExchange("hldy.iotDeviceValues", entity.getDepartServerUrl() + ".ywIotWater.waterControl.async", iwm);
}
}