From 0325eaddbf8a0df08158e30950e7904d45ebfaa6 Mon Sep 17 00:00:00 2001 From: zhouhao Date: Wed, 26 Mar 2025 14:46:10 +0800 Subject: [PATCH] =?UTF-8?q?refactor:=20=E4=BC=98=E5=8C=96=E8=AE=BE?= =?UTF-8?q?=E5=A4=87=E6=B3=A8=E5=86=8C=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../device/service/DeviceMessageBusinessHandler.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/service/DeviceMessageBusinessHandler.java b/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/service/DeviceMessageBusinessHandler.java index b3368f7e..0b19a0ad 100644 --- a/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/service/DeviceMessageBusinessHandler.java +++ b/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/service/DeviceMessageBusinessHandler.java @@ -115,7 +115,8 @@ public class DeviceMessageBusinessHandler { boolean selfManageState = CastUtils .castBoolean(tps.getT5().getOrDefault(DeviceConfigKey.selfManageState.getKey(), false)); - instance.setState(selfManageState ? DeviceState.offline : DeviceState.online); + boolean offline = selfManageState || message.getHeaderOrDefault(Headers.ignoreSession); + instance.setState(offline ? DeviceState.offline : DeviceState.online); //合并配置 instance.mergeConfiguration(tps.getT5()); @@ -123,7 +124,7 @@ public class DeviceMessageBusinessHandler { .save(instance) .then(Mono.defer(() -> registry .register(instance.toDeviceInfo() - .addConfig("state", selfManageState + .addConfig("state", offline ? org.jetlinks.core.device.DeviceState.offline : org.jetlinks.core.device.DeviceState.online)))); });