From 435da925b9d3fb63f2cab9a9a5d380ef85c751ab Mon Sep 17 00:00:00 2001 From: zhangbin <460190368@qq.com> Date: Fri, 4 Jul 2025 10:19:40 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9C=BA=E5=9C=BA=E7=BB=91=E5=AE=9A=E7=BD=91?= =?UTF-8?q?=E5=85=B3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- OpenAuth.Repository/Domain/LasaDronePort‌.cs | 1 + OpenAuth.WebApi/Model/mqtt/ThingRequestHandler.cs | 4 ++-- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/OpenAuth.Repository/Domain/LasaDronePort‌.cs b/OpenAuth.Repository/Domain/LasaDronePort‌.cs index 36a9642..56af641 100644 --- a/OpenAuth.Repository/Domain/LasaDronePort‌.cs +++ b/OpenAuth.Repository/Domain/LasaDronePort‌.cs @@ -26,6 +26,7 @@ namespace OpenAuth.Repository.Domain [SugarColumn(DefaultValue = "false")] public bool IsDelete { get; set; } public string WorkSpaceId { get; set; } + public string GateWay { get; set; } [Navigate(NavigateType.OneToMany, nameof(LasaUav.PId))] public List UavList { get; set; } } diff --git a/OpenAuth.WebApi/Model/mqtt/ThingRequestHandler.cs b/OpenAuth.WebApi/Model/mqtt/ThingRequestHandler.cs index 27d5a7f..459a60b 100644 --- a/OpenAuth.WebApi/Model/mqtt/ThingRequestHandler.cs +++ b/OpenAuth.WebApi/Model/mqtt/ThingRequestHandler.cs @@ -139,7 +139,7 @@ namespace OpenAuth.WebApi.Model.mqtt } if (payload.Contains("airport_organization_bind")) { - + string getway = topic.Split('/')[2]; // 解析 JSON var root = JsonNode.Parse(payload)?.AsObject(); // 获取 bind_devices 数组 @@ -163,6 +163,7 @@ namespace OpenAuth.WebApi.Model.mqtt lasaDronePort.BindStatus = 1; lasaDronePort.Name = "机场"; dronesn = obj["sn"].ToString(); + lasaDronePort.GateWay = getway; } else { @@ -215,7 +216,6 @@ namespace OpenAuth.WebApi.Model.mqtt method = "airport_organization_bind" }; string payloadreq = JsonSerializer.Serialize(requestData); - string getway = topic.Split('/')[2]; await _mqttClientManager.PublishAsync($"thing/product/{getway}/requests_reply", payloadreq); } }