HC_YFZX
/
LASAPlatform
11
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: HC_YFZX:69a4457a27649a00d0fb0a3edaa684c888b602de
Branches Tags
HC_YFZX:feature-flyModify
HC_YFZX:main
...
compare: HC_YFZX:872b71253aa527ec65444b6d73e0462a4c317fce
Branches Tags
HC_YFZX:feature-flyModify
HC_YFZX:main

2 Commits
69a4457a27 ... 872b71253a

Author SHA1 Message Date
zhangbin 872b71253a Merge branch 'main' of http://123.132.248.154:10000/HC_YFZX/LASAPlatform 2025-06-23 15:13:59 +08:00
zhangbin 801c93c078 调试 2025-06-23 15:13:54 +08:00
3 changed files with 4 additions and 4 deletions
Show Stats Expand all files Collapse all files

2
OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs
View File

@ -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());

2
OpenAuth.WebApi/Model/mqtt/ThingRequestHandler.cs
View File

@ -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)
{

4
OpenAuth.WebApi/Startup.cs
View File

@ -328,8 +328,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>();