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 14:34:01 +08:00
parent 329eaa82aa
commit 8aca289d72
2 changed files with 2 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/mq/tq/listener/IotSyncElectricityMQListener.java
View File

@ -2,12 +2,9 @@ package com.nu.mq.tq.listener;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.nu.dto.IotElectricityMeterMQDto;
import com.nu.dto.IotHumidDeviceMQDto;
import com.nu.dto.StatusMQDto;
import com.nu.modules.tq.electricity.entity.ElectricityMeter;
import com.nu.modules.tq.electricity.service.IElectricityMeterService;
import com.nu.modules.yiweilian.humid.entity.HumidDevice;
import com.nu.modules.yiweilian.humid.service.IHumidDeviceService;
import com.nu.utils.RabbitMQUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.ExchangeTypes;

9
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/mq/tq/listener/IotSyncWaterMQListener.java
View File

@ -1,15 +1,10 @@
package com.nu.mq.tq.listener;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.nu.dto.IotElectricityMeterMQDto;
import com.nu.dto.IotHumidDeviceMQDto;
import com.nu.dto.IotWaterMeterMQDto;
import com.nu.dto.StatusMQDto;
import com.nu.modules.tq.electricity.entity.ElectricityMeter;
import com.nu.modules.tq.water.entity.WaterMeter;
import com.nu.modules.tq.water.service.IWaterMeterService;
import com.nu.modules.yiweilian.humid.entity.HumidDevice;
import com.nu.modules.yiweilian.humid.service.IHumidDeviceService;
import com.nu.utils.RabbitMQUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.ExchangeTypes;
@ -77,11 +72,11 @@ public class IotSyncWaterMQListener {
),
errorHandler = "iotDeviceMQErrorHandler"
)
public void handleWaterControl_unify(IotElectricityMeterMQDto dto) {
public void handleWaterControl_unify(IotWaterMeterMQDto dto) {
saveSyncWaterControl(dto);
}
private void saveSyncWaterControl(IotElectricityMeterMQDto dto) {
private void saveSyncWaterControl(IotWaterMeterMQDto dto) {
StatusMQDto statusMQDto = new StatusMQDto();
try {
statusMQDto.setAsyncId(dto.getId().toString());