suguo
/
jetlinks-community
mirror of https://gitee.com/jetlinks/jetlinks-community.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

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

This commit is contained in:
zhouhao 2024-03-12 12:32:33 +08:00
parent 330930c2e1
commit 121c065d27
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/message/DeviceMessageConnector.java
View File

@ -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");