refactor: 优化子设备注销消息逻辑

jetlinks · Apr 19, 2024 · 9157c88 · 9157c88
1 parent a83ba95
commit 9157c88
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/...s/gateway-component/src/main/java/org/jetlinks/community/gateway/DeviceGatewayHelper.java b/...s/gateway-component/src/main/java/org/jetlinks/community/gateway/DeviceGatewayHelper.java
@@ -34,13 +34,11 @@
  * @since 1.5
  */
 @AllArgsConstructor
+@Getter
 public class DeviceGatewayHelper {
 
-    @Getter
     private final DeviceRegistry registry;
-    @Getter
     private final DeviceSessionManager sessionManager;
-    @Getter
     private final DecodedClientMessageHandler messageHandler;
 
     public static Consumer<DeviceSession> applySessionKeepaliveTimeout(DeviceMessage msg, Supplier<Duration> timeoutSupplier) {
@@ -112,7 +110,7 @@ private Mono<Void> handleChildrenDeviceMessage(String deviceId, DeviceMessage ch
             return sessionManager
                 .remove(childrenId, removeSessionOnlyLocal(children))
                 .doOnNext(total -> {
-                    if (total > 0) {
+                    if (total > 0 && children instanceof DeviceOfflineMessage) {
                         children.addHeader(Headers.ignore, true);
                     }
                 })