From 121c065d27a72e41a534a905268a964f39b41d94 Mon Sep 17 00:00:00 2001 From: zhouhao Date: Tue, 12 Mar 2024 12:32:33 +0800 Subject: [PATCH] =?UTF-8?q?refactor:=20=E4=BC=98=E5=8C=96=E8=AE=BE?= =?UTF-8?q?=E5=A4=87=E4=B8=8A=E7=BA=BF=E7=A6=BB=E7=BA=BF=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E6=97=B6=E9=97=B4=E6=88=B3=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../community/device/message/DeviceMessageConnector.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/message/DeviceMessageConnector.java b/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/message/DeviceMessageConnector.java index 9665d38a..9790f58a 100644 --- a/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/message/DeviceMessageConnector.java +++ b/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/message/DeviceMessageConnector.java @@ -148,11 +148,11 @@ public class DeviceMessageConnector implements DecodedClientMessageHandler { } //从会话管理器里监听会话注销,转发为设备离线消息 if (event.getType() == DeviceSessionEvent.Type.unregister) { - return handleSessionMessage(new DeviceOfflineMessage(),event.getSession()); + return handleSessionMessage(new DeviceOfflineMessage().timestamp(event.getTimestamp()),event.getSession()); } //从会话管理器里监听会话注册,转发为设备上线消息 if (event.getType() == DeviceSessionEvent.Type.register) { - return handleSessionMessage(new DeviceOnlineMessage(),event.getSession()); + return handleSessionMessage(new DeviceOnlineMessage().timestamp(event.getSession().connectTime()),event.getSession()); } return Mono.empty(); }); @@ -172,7 +172,6 @@ public class DeviceMessageConnector implements DecodedClientMessageHandler { }); message.setDeviceId(session.getDeviceId()); - message.setTimestamp(System.currentTimeMillis()); message.addHeader("connectTime", session.connectTime()); message.addHeader("from", "session");