From 4e6eafa75d9f14077aa39da352cedd8a215c3161 Mon Sep 17 00:00:00 2001
From: zhangbin <460190368@qq.com>
Date: Fri, 4 Jul 2025 09:57:44 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B3=A8=E5=86=8C=E9=A3=9E=E8=A1=8C=E5=99=A8?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ServiceApp/AirportMaintenanceApp.cs         | 17 +++++++++++++++++
 OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs | 11 ++++++++---
 2 files changed, 25 insertions(+), 3 deletions(-)

diff --git a/OpenAuth.App/ServiceApp/AirportMaintenanceApp.cs b/OpenAuth.App/ServiceApp/AirportMaintenanceApp.cs
index f20d9c8..4bbf4b2 100644
--- a/OpenAuth.App/ServiceApp/AirportMaintenanceApp.cs
+++ b/OpenAuth.App/ServiceApp/AirportMaintenanceApp.cs
@@ -180,6 +180,23 @@ namespace OpenAuth.App.ServiceApp
                 }
             }
         }
+        public async Task<List<string>> GetUavSn()
+        {
+            using (var db = UnitWork.CreateContext())
+            {
+                var uavinfo = await db.LasaUav.AsQueryable().Where(r => r.IsDelete == false).Select(r => r.Sn).ToListAsync();
+                var dockinfo = await db.LasaDronePort.AsQueryable().Where(r => r.IsDelete == false).Select(r => r.Sn).ToListAsync();
+                
+                if (dockinfo != null)
+                {
+                    return dockinfo.Union(uavinfo).ToList();
+                }
+                else
+                {
+                    return new List<string>();
+                }
+            }
+        }
 
         #region 固件版本管理
         public async Task<Response<bool>> AddFirmware(LasaFirmware info)
diff --git a/OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs b/OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs
index 24d3524..5476411 100644
--- a/OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs
+++ b/OpenAuth.WebApi/Model/mqtt/MqttHostedService.cs
@@ -49,10 +49,15 @@ namespace OpenAuth.WebApi.Model.mqtt
                     $"sys/product/{gateway}/status"
                 });
             }
-            topics.AddRange(new[]
+            var snList = await _app.GetUavSn();
+
+            foreach (var sn in snList)
             {
-                $"thing/product/1581F8HGX254V00A0BUY/osd"
-            });
+                topics.AddRange(new[]
+                {
+                    $"thing/product/{sn}/osd"
+                });
+            }
             await _mqttCenter.ConnectAndSubscribeAsync(topics.ToArray());
         }