注册飞行器数据

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)

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