根据设备sn读取实时数据

OpenAuth.App/ServiceApp/AirportMaintenanceApp.cs

@@ -186,7 +186,7 @@ namespace OpenAuth.App.ServiceApp
             {
                 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();
@@ -296,6 +296,32 @@ namespace OpenAuth.App.ServiceApp
                     return false;
             }
         }
+        /// <summary>
+        /// 获取日志
+        /// </summary>
+        /// <param name="sn"></param>
+        /// <param name="startTime"></param>
+        /// <param name="endTime"></param>
+        /// <param name="page"></param>
+        /// <param name="limit"></param>
+        /// <returns></returns>
+        public async Task<Response<PageInfo<List<LasaLog>>>> GetLogList(string sn, DateTime startTime, DateTime endTime, int page, int limit)
+        {
+            RefAsync<int> totalCount = 0;
+            using (var db = UnitWork.CreateContext())
+            {
+                var topic = $"thing/product/{sn}/osd";
+                var list = await db.LasaLog.AsQueryable()
+                    .Where(x => x.CreateTime >= startTime && x.CreateTime <= endTime)
+                    .Where(x => x.Topic == topic)
+                    .OrderBy(x => x.CreateTime, OrderByType.Asc) 
+                    .ToPageListAsync(page, limit, totalCount);
+                return new Response<PageInfo<List<LasaLog>>>
+                {
+                    Result = new PageInfo<List<LasaLog>> { Items = list, Total = totalCount }
+                };
+            }
+        }
         #endregion
     }
 }

OpenAuth.Repository/Domain/LasaLog.cs

@@ -45,6 +45,6 @@ namespace OpenAuth.Repository.Domain
         /// Nullable:True
         /// </summary>         
         [SugarColumn(IsJson = true)]
-        public JsonObject Data { get; set; }
+        public string Data { get; set; }
     }
 }

OpenAuth.WebApi/Controllers/ServiceControllers/AirportMaintenanceController.cs

@@ -362,25 +362,27 @@ namespace OpenAuth.WebApi.Controllers.ServiceControllers
                     timestamp = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
                     data = new
                     {
-                        output = new {
-                            bucket= "test",
-			                credentials= new {
-                            access_key_id= "minioadmin",
-			                access_key_secret = "minioadmin",
-				            expire= 3600,
-				            security_token= "security_token"
-
-                    },
-			        endpoint = "175.27.168.120:6013",
-			        object_key_prefix= "",
-			        provider = "ali",
-			        region= "hz"
-  
-                     },
-		            result= 0
+                        output = new
+                        {
+                            bucket = "test",
+                            credentials = new
+                            {
+                                access_key_id = "minioadmin",
+                                access_key_secret = "minioadmin",
+                                expire = 3600,
+                                security_token = "security_token"
+
+                            },
+                            endpoint = "175.27.168.120:6013",
+                            object_key_prefix = "",
+                            provider = "ali",
+                            region = "hz"
+
+                        },
+                        result = 0
                     }
                 };
-             
+
 
                 response.Result = 0;
 
@@ -592,5 +594,32 @@ namespace OpenAuth.WebApi.Controllers.ServiceControllers
             return result;
         }
         #endregion
+
+        #region 日志信息
+        /// <summary>
+        /// 根据设备sn读取实时数据
+        /// </summary>
+        /// <param name="sn">设备sn</param>
+        /// <param name="startTime"></param>
+        /// <param name="endTime"></param>
+        /// <param name="page"></param>
+        /// <param name="limit"></param>
+        /// <returns></returns>
+        [HttpGet]
+        public async Task<Response<PageInfo<List<LasaLog>>>> GetLogList(string sn, DateTime startTime, DateTime endTime, int page, int limit)
+        {
+            var result = new Response<PageInfo<List<LasaLog>>>();
+            try
+            {
+                result = await _app.GetLogList(sn, startTime, endTime, page, limit);
+            }
+            catch (Exception ex)
+            {
+                result.Code = 500;
+                result.Message = ex.Message;
+            }
+            return result;
+        }
+        #endregion
     }
 }

OpenAuth.WebApi/Model/mqtt/ThingOsdHandler.cs

@@ -34,7 +34,7 @@ namespace OpenAuth.WebApi.Model.mqtt
                 Topic = topic,
                 Method = root["method"]?.ToString() ?? "",
                 CreateTime = DateTime.Now,
-                Data = root
+                Data = root.ToString()
             });
             var sub_device = root["data"]?["sub_device"]?.ToString() ?? "";
             if (!string.IsNullOrEmpty(sub_device))