code-image-backup-public/fastbee
1
0
Fork 0
mirror of https://gitee.com/beecue/fastbee.git synced 2025-12-17 16:36:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

更新设备时，发布设备状态，解决设备取消禁用的状态同步问题

Browse Source
This commit is contained in:
kerwincui
2022-07-05 01:42:29 +08:00
parent 37630007c2
commit f685093eca
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
springboot/wumei-iot/src/main/java/com/ruoyi/iot/service/impl/DeviceServiceImpl.java
View File

@@ -14,6 +14,7 @@ import com.ruoyi.iot.domain.Device;
import com.ruoyi.iot.domain.DeviceLog; import com.ruoyi.iot.domain.DeviceLog;
import com.ruoyi.iot.domain.DeviceUser; import com.ruoyi.iot.domain.DeviceUser;
import com.ruoyi.iot.domain.Product; import com.ruoyi.iot.domain.Product;
import com.ruoyi.iot.mqtt.EmqxService;
import com.ruoyi.iot.tdengine.service.ILogService; import com.ruoyi.iot.tdengine.service.ILogService;
import com.ruoyi.iot.mapper.DeviceLogMapper; import com.ruoyi.iot.mapper.DeviceLogMapper;
import com.ruoyi.iot.mapper.DeviceMapper; import com.ruoyi.iot.mapper.DeviceMapper;
@@ -30,6 +31,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
@@ -79,6 +81,10 @@ public class DeviceServiceImpl implements IDeviceService {
@Autowired @Autowired
private ILogService logService; private ILogService logService;
@Autowired
@Lazy
private EmqxService emqxService;
/** /**
* 查询设备 * 查询设备
* *
@@ -703,6 +709,11 @@ public class DeviceServiceImpl implements IDeviceService {
device.setProductName(null); device.setProductName(null);
} }
deviceMapper.updateDevice(device); deviceMapper.updateDevice(device);
// 设备取消禁用
if(oldDevice.getStatus()==2 && device.getStatus()==4){
// 发布设备信息
emqxService.publishInfo(oldDevice.getProductId(),oldDevice.getSerialNumber());
}
return AjaxResult.success("修改成功",1); return AjaxResult.success("修改成功",1);
} }