From 801c93c0788265c42223ee98ef5a75efa7a9f021 Mon Sep 17 00:00:00 2001
From: zhangbin <460190368@qq.com>
Date: Mon, 23 Jun 2025 15:13:54 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs   | 2 +-
 OpenAuth.WebApi/Model/mqtt/ThingRequestHandler.cs | 2 +-
 OpenAuth.WebApi/Startup.cs                        | 4 ++--
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs b/OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs
index a47f4b3..0688d3e 100644
--- a/OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs
+++ b/OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs
@@ -41,7 +41,7 @@ namespace OpenAuth.WebApi.Model.mqtt
                     $"thing/product/{gateway}/osd", 
                     $"thing/product/{gateway}/events",
                     $"thing/product/{gateway}/requests",
-                    $"thing/product/{gateway}/services"
+                    $"thing/product/{gateway}/services_reply"
                 });
             }
             await _mqttCenter.ConnectAndSubscribeAsync(topics.ToArray());
diff --git a/OpenAuth.WebApi/Model/mqtt/ThingRequestHandler.cs b/OpenAuth.WebApi/Model/mqtt/ThingRequestHandler.cs
index 9ef6a32..8056764 100644
--- a/OpenAuth.WebApi/Model/mqtt/ThingRequestHandler.cs
+++ b/OpenAuth.WebApi/Model/mqtt/ThingRequestHandler.cs
@@ -68,7 +68,7 @@ namespace OpenAuth.WebApi.Model.mqtt
             }
             if (payload.Contains("airport_bind_status"))
             {
-                //解析返回的设备sn  先不解析，先测试绑定
+                //解析返回的设备sn
                 var root = JsonNode.Parse(payload)?.AsObject();
                 if (root == null)
                 {
diff --git a/OpenAuth.WebApi/Startup.cs b/OpenAuth.WebApi/Startup.cs
index 8a2b210..f3a067d 100644
--- a/OpenAuth.WebApi/Startup.cs
+++ b/OpenAuth.WebApi/Startup.cs
@@ -335,8 +335,8 @@ namespace OpenAuth.WebApi
             #region mqtt
             services.AddSingleton<MqttMessageCenter>();
             //services.AddSingleton<IMqttMessageHandler, ThingRequestHandler>();
-            //services.AddSingleton<IMqttMessageHandler, ThingServiceHandler>();
-            services.AddSingleton<IMqttMessageHandler, ThingOsdHandler>();
+            services.AddSingleton<IMqttMessageHandler, ThingServiceHandler>();
+            //services.AddSingleton<IMqttMessageHandler, ThingOsdHandler>();
             //services.AddSingleton<IMqttMessageHandler, ThingEventHandler>();
             
             services.AddHostedService<MqttHostedService>();