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(); //services.AddSingleton(); - //services.AddSingleton(); - services.AddSingleton(); + services.AddSingleton(); + //services.AddSingleton(); //services.AddSingleton(); services.AddHostedService();