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); } }