From 6eb98971bd7d126703eedc95c3015259ab214533 Mon Sep 17 00:00:00 2001 From: zhouhao Date: Fri, 21 Feb 2020 12:06:28 +0800 Subject: [PATCH] =?UTF-8?q?=E8=AE=BE=E7=BD=AE=E7=88=B6=E7=BA=A7=E8=AE=BE?= =?UTF-8?q?=E5=A4=87ID?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../standalone/configuration/DefaultDeviceSessionManager.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/configuration/DefaultDeviceSessionManager.java b/jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/configuration/DefaultDeviceSessionManager.java index c38f6e3d..889227b0 100644 --- a/jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/configuration/DefaultDeviceSessionManager.java +++ b/jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/configuration/DefaultDeviceSessionManager.java @@ -2,6 +2,7 @@ package org.jetlinks.community.standalone.configuration; import lombok.Getter; import lombok.Setter; +import org.jetlinks.core.device.DeviceConfigKey; import org.jetlinks.core.device.DeviceRegistry; import org.jetlinks.core.message.codec.Transport; import org.jetlinks.core.server.monitor.GatewayServerMonitor; @@ -231,6 +232,7 @@ public class DefaultDeviceSessionManager implements DeviceSessionManager { .switchIfEmpty(Mono.fromRunnable(() -> log.warn("children device [{}] not fond in registry", childrenDeviceId))) .flatMap(deviceOperator -> deviceOperator .online(session.getServerId().orElse(serverId), session.getId()) + .then(deviceOperator.setConfig(DeviceConfigKey.parentMeshDeviceId, deviceId)) .thenReturn(new ChildrenDeviceSession(childrenDeviceId, session, deviceOperator))) .doOnSuccess(s -> children.computeIfAbsent(deviceId, __ -> new ConcurrentHashMap<>()).put(childrenDeviceId, s)); });