From b4dadf6c51c22ff1d49825497ce2e8a868f5609d Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: Tue, 20 Jun 2023 13:02:18 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=88=A0=E9=99=A4=E7=9A=84?= =?UTF-8?q?=E8=AE=BE=E5=A4=87=E6=97=A0=E6=B3=95=E9=87=8D=E6=96=B0=E6=B3=A8?= =?UTF-8?q?=E5=86=8C=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../genersoft/iot/vmp/service/impl/DeviceServiceImpl.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/genersoft/iot/vmp/service/impl/DeviceServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/service/impl/DeviceServiceImpl.java index bb480895..0adbf9df 100644 --- a/src/main/java/com/genersoft/iot/vmp/service/impl/DeviceServiceImpl.java +++ b/src/main/java/com/genersoft/iot/vmp/service/impl/DeviceServiceImpl.java @@ -117,9 +117,10 @@ public class DeviceServiceImpl implements IDeviceService { } // 第一次上线 或则设备之前是离线状态--进行通道同步和设备信息查询 - if (device.getCreateTime() == null) { + if (deviceInDb == null) { device.setOnLine(true); device.setCreateTime(now); + device.setUpdateTime(now); logger.info("[设备上线,首次注册]: {},查询设备信息以及通道信息", device.getDeviceId()); deviceMapper.add(device); redisCatchStorage.updateDevice(device); @@ -525,6 +526,9 @@ public class DeviceServiceImpl implements IDeviceService { }catch (Exception e) { dataSourceTransactionManager.rollback(transactionStatus); } + if (result) { + redisCatchStorage.removeDevice(deviceId); + } return result; }