refactor: 优化设备上线离线消息时间戳逻辑

jetlinks · Mar 12, 2024 · 121c065 · 121c065
1 parent 330930c
commit 121c065
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...e-manager/src/main/java/org/jetlinks/community/device/message/DeviceMessageConnector.java b/...e-manager/src/main/java/org/jetlinks/community/device/message/DeviceMessageConnector.java
@@ -148,11 +148,11 @@ public DeviceMessageConnector(EventBus eventBus,
             }
             //从会话管理器里监听会话注销,转发为设备离线消息
             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 @@ private Mono<Void> handleSessionMessage(CommonDeviceMessage<?> message, DeviceSe
                });
 
             message.setDeviceId(session.getDeviceId());
-            message.setTimestamp(System.currentTimeMillis());
 
             message.addHeader("connectTime", session.connectTime());
             message.addHeader("from", "session");