From 566f5a12b718beb1c94b0f18234e7351623ad95f Mon Sep 17 00:00:00 2001 From: YunaiV Date: Sat, 14 Feb 2026 16:33:27 +0800 Subject: [PATCH] feat(iot): add j2mod dependency and refactor connection info method --- yudao-dependencies/pom.xml | 8 ++++++++ yudao-module-iot/yudao-module-iot-gateway/pom.xml | 1 - .../protocol/mqtt/manager/IotMqttConnectionManager.java | 2 +- 3 files changed, 9 insertions(+), 2 deletions(-) diff --git a/yudao-dependencies/pom.xml b/yudao-dependencies/pom.xml index 2e8c26e2b2..fa180b4c7c 100644 --- a/yudao-dependencies/pom.xml +++ b/yudao-dependencies/pom.xml @@ -70,6 +70,7 @@ 4.5.22 4.12.0 3.12.0 + 3.2.1 2.40.15 1.16.7 @@ -601,6 +602,13 @@ ${californium.version} + + + com.ghgande + j2mod + ${j2mod.version} + + software.amazon.awssdk diff --git a/yudao-module-iot/yudao-module-iot-gateway/pom.xml b/yudao-module-iot/yudao-module-iot-gateway/pom.xml index 0731198fd7..51e55c3246 100644 --- a/yudao-module-iot/yudao-module-iot-gateway/pom.xml +++ b/yudao-module-iot/yudao-module-iot-gateway/pom.xml @@ -52,7 +52,6 @@ com.ghgande j2mod - 3.2.1 diff --git a/yudao-module-iot/yudao-module-iot-gateway/src/main/java/cn/iocoder/yudao/module/iot/gateway/protocol/mqtt/manager/IotMqttConnectionManager.java b/yudao-module-iot/yudao-module-iot-gateway/src/main/java/cn/iocoder/yudao/module/iot/gateway/protocol/mqtt/manager/IotMqttConnectionManager.java index 9bd3ec4934..3d187c847e 100644 --- a/yudao-module-iot/yudao-module-iot-gateway/src/main/java/cn/iocoder/yudao/module/iot/gateway/protocol/mqtt/manager/IotMqttConnectionManager.java +++ b/yudao-module-iot/yudao-module-iot-gateway/src/main/java/cn/iocoder/yudao/module/iot/gateway/protocol/mqtt/manager/IotMqttConnectionManager.java @@ -124,7 +124,7 @@ public class IotMqttConnectionManager { * @param deviceId 设备 ID * @return 连接信息 */ - public IotMqttConnectionManager.ConnectionInfo getConnectionInfoByDeviceId(Long deviceId) { + public ConnectionInfo getConnectionInfoByDeviceId(Long deviceId) { // 通过设备 ID 获取连接端点 MqttEndpoint endpoint = getDeviceEndpoint(deviceId); if (endpoint == null) {