文件上传对接

OpenAuth.App/ServiceApp/DroneDocking/DroneDockApp.cs

@@ -16,6 +16,7 @@ using OpenAuth.App.ServiceApp.DroneDocking.Response;
 using DocumentFormat.OpenXml.Math;
 using static Microsoft.Extensions.Logging.EventSource.LoggingEventSource;
 using DocumentFormat.OpenXml.Drawing.Charts;
+using Org.BouncyCastle.Ocsp;
 
 
 namespace OpenAuth.App.ServiceApp.DroneDocking
@@ -759,6 +760,116 @@ namespace OpenAuth.App.ServiceApp.DroneDocking
             return Response;
         }
 
+
+        /// <summary>
+        /// 获取临时上传地址
+        /// </summary>
+        /// <param name="req"></param>
+        /// <returns></returns>
+        public async Task<Response<string>> getUploadFilePath(AirPortUploadReq req)
+        {
+            Response<string> Response = new Response<string>();
+
+            var handler = new HttpClientHandler();
+            // 如果需要忽略服务器证书错误（仅测试环境）
+            handler.ServerCertificateCustomValidationCallback = (sender, cert, chain, sslPolicyErrors) => true;
+            using (var client = new HttpClient())
+            {
+                try
+                {
+                    string url = configuration.GetSection("DroneDocking:Url").Value + "/DataExchange/getUploadFilePath";
+                    string x_lc_secret = _helper.getxseret();
+                    string centercode = "UAV32_LJY2FPMYDE6UDES3P3ZD7V3IKQ";
+                    string x_token = _helper.GetToken(centercode);
+
+                    // 序列化为 JSON 字符串
+                    string json = JsonSerializer.Serialize(req);
+
+                    // 转换为字节数组
+                    byte[] bytes = Encoding.UTF8.GetBytes(json);
+
+                    var encryptedData = _helper.Encrypt(bytes);
+                    // 创建请求体
+                    var httpContent = new StringContent(encryptedData, Encoding.UTF8, "application/json");
+
+                    // 添加请求头
+                    client.DefaultRequestHeaders.Add("x-lc-secret", x_lc_secret);
+                    client.DefaultRequestHeaders.Add("x-lc-token", x_token);
+                    client.DefaultRequestHeaders.Add("x-lc-datacode", "AirportData");
+
+                    //发送请求
+                    HttpResponseMessage response = await client.PostAsync(url, httpContent);
+                    response.EnsureSuccessStatusCode();
+
+                    // 获取响应头中的 x_cl_screte 参数
+                    string resx_cl_screte = GetHeaderValue(response, "x-lc-secret");
+
+                    // 读取响应内容并反序列化
+                    string responseBody = await response.Content.ReadAsStringAsync();
+                    var result = JsonSerializer.Deserialize<ReciveData<string>>(responseBody);
+
+                    //解密数据
+                    byte[] resbytesx = Convert.FromBase64String(resx_cl_screte);
+                    byte[] resdatabytes = Convert.FromBase64String(result?.data);
+                    string data = _helper.Decrypt(resbytesx, resdatabytes);
+
+                    Response.Result = data;
+                    Response.Message = result.message;
+                    Response.Code = result.code;
+                }
+                catch (HttpRequestException e)
+                {
+                    Console.WriteLine("\nException Caught!");
+                    Console.WriteLine("Message :{0} ", e.Message);
+                    Response.Result = "连接错误";
+                }
+            }
+
+            return Response;
+        }
+
+
+        /// <summary>
+        /// 无人机状态获取
+        /// </summary>
+        /// <param name="req"></param>
+        /// <returns></returns>
+        public async Task<ResData> getResult(string taskid)
+        {
+            ResData Response = new ResData();
+            using (var uow = base.UnitWork.CreateContext())
+            {
+                //查询数据  检查是否有重复数据
+                var info = uow.DbfineInfo.AsQueryable().Where(r => r.taskid == taskid).First();
+       
+                if (true)
+                {
+                    string json = JsonSerializer.Serialize(info);
+                    string x_lc_secret = _helper.getxseret();
+                    // 转换为字节数组
+                    byte[] bytes = Encoding.UTF8.GetBytes(json);
+                    var encryptedResData = _helper.Encrypt(bytes);
+                    Response.Result = encryptedResData;
+                    Response.Message = "获取无人机机场状态成功！";
+                    Response.Code = 200;
+                    Response.Secret = x_lc_secret;
+                    return Response;
+                }
+                else
+                {
+                    string x_lc_secret = _helper.getxseret();
+                    // 转换为字节数组
+                    byte[] bytes = Encoding.UTF8.GetBytes(" ");
+
+                    var encryptedResData = _helper.Encrypt(bytes);
+                    Response.Result = encryptedResData;
+                    Response.Message = "获取无人机机场状态失败！";
+                    Response.Code = 500;
+                    Response.Secret = x_lc_secret;
+                    return Response;
+                }
+            }
+        }
         // 安全获取响应头值的方法
         private static string GetHeaderValue(HttpResponseMessage response, string headerName)
         {

OpenAuth.App/ServiceApp/DroneDocking/Request/AirPortStatusApply.cs

@@ -6,27 +6,14 @@ using System.Threading.Tasks;
 
 namespace OpenAuth.App.ServiceApp.DroneDocking.Request
 {
-    public class AirPortStatusApply
+    public class AirPortUploadReq
     {
-        public string deviceid { get; set; }
+        public string code { get; set; }
 
-        public string onlinestate { get; set; }
+        public string regioncode { get; set; }
 
-        public double longitude { get; set; }
+        public List<string> filenames { get; set; }
 
-        public double latitude { get; set; }
-
-        public double height { get; set; }
-
-        public double elevation { get; set; }
-
-        public double gimbal_pitch { get; set; }
-
-        public double gimbal_ya { get; set; }
-
-        public int battery_capacity_percent { get; set; }
-
-        public int gps_state { get; set; }
        
         
     }

OpenAuth.App/ServiceApp/DroneDocking/Request/AirPortUploadReq.cs

@@ -0,0 +1,33 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OpenAuth.App.ServiceApp.DroneDocking.Request
+{
+    public class AirPortStatusApply
+    {
+        public string deviceid { get; set; }
+
+        public string onlinestate { get; set; }
+
+        public double longitude { get; set; }
+
+        public double latitude { get; set; }
+
+        public double height { get; set; }
+
+        public double elevation { get; set; }
+
+        public double gimbal_pitch { get; set; }
+
+        public double gimbal_ya { get; set; }
+
+        public int battery_capacity_percent { get; set; }
+
+        public int gps_state { get; set; }
+
+        
+    }
+}

OpenAuth.Repository/Domain/DbfileInfo.cs

@@ -0,0 +1,59 @@
+using SqlSugar;
+
+namespace OpenAuth.Repository.Domain;
+
+using System;
+
+/// <summary>
+/// 媒体文件实体类
+/// </summary>
+[SugarTable("dbfile_info")]
+public class DbfineInfo
+{
+    /// <summary>
+    /// 主键ID
+    /// </summary>
+    [SugarColumn(IsPrimaryKey = true, ColumnName = "id")]
+    public string id { get; set; }
+
+    /// <summary>
+    /// 计划ID
+    /// </summary>
+    public string taskid { get; set; }
+
+    /// <summary>
+    /// 飞行器产品枚举
+    /// </summary>
+    public string regioncode { get; set; }
+
+    /// <summary>
+    /// 是否是原图 0否1是
+    /// </summary>
+    public int size { get; set; }
+
+    /// <summary>
+    /// 文件索引
+    /// </summary>
+    public int count { get; set; }
+
+    /// <summary>
+    /// 负载产品枚举
+    /// </summary>
+    public int attachment_count { get; set; }
+
+    /// <summary>
+    /// 拍摄绝对高度
+    /// </summary>
+    public string extension { get; set; }
+
+    /// <summary>
+    /// 云台偏航角
+    /// </summary>
+    public string hashcode { get; set; }
+
+    /// <summary>
+    /// 拍摄相对高度
+    /// </summary>
+    public string url { get; set; }
+
+}

OpenAuth.Repository/SugarDbContext.cs

@@ -82,6 +82,8 @@ namespace OpenAuth.Repository
 
         public SugarRepositiry<LasaMediaFile> LasaMediaFile { get; set; }
 
+
+        public SugarRepositiry<DbfineInfo> DbfineInfo { get; set; }
         public SugarRepositiry<SysOpenJob> SysOpenJob { get; set; }
         #endregion
     }

OpenAuth.WebApi/Controllers/ServiceControllers/DroneDockController.cs

@@ -467,5 +467,69 @@ namespace OpenAuth.WebApi.Controllers.ServiceControllers
             return await _app.GetDroneDockflightInfos(taskid);
         }
 
+
+        /// <summary>
+        /// 获取临时上传地址
+        /// </summary>
+        /// <returns></returns>
+        [Route("/zhcfzx/DataExchange/getUploadFilePath")]
+        [HttpPost]
+        [AllowAnonymous]
+        public async Task<Response<string>> getUploadFilePath([FromBody] AirPortUploadReq req)
+        {
+            var result = new Response<string>();
+            try
+            {
+                result = await _app.getUploadFilePath(req);
+            }
+            catch (Exception ex)
+            {
+                result.Code = 500;
+                result.Message = ex.Message;
+            }
+            return result;
+        }
+
+        [HttpGet]
+        [AllowAnonymous]
+        [Route("/zhcfzx/droneAirport/getResult")]
+        public async Task<ReciveData<string>> getResult(string taskid)
+        {
+            var result = new ReciveData<string>();
+            if (Request.Headers.TryGetValue("x-lc-token", out var tokenValue))
+            {
+                var tokenflag = _helper.Verify(tokenValue);
+                if (tokenflag)
+                {
+                    try
+                    {
+                        var data = await _app.getResult(taskid);
+                        result.data = data.Result;
+                        result.code = data.Code;
+                        result.message = data.Message;
+                        Request.Headers.TryGetValue("traceid", out var traceid);
+                        result.traceid = traceid;
+                        Response.Headers.Add("x-lc-secret", data.Secret);
+                    }
+                    catch (Exception ex)
+                    {
+                        result.code = 200;
+                        result.message = "error";
+                        Request.Headers.TryGetValue("traceid", out var traceid);
+                        result.traceid = traceid;
+                    }
+                    return result;
+                }
+                else
+                {
+                    throw new Exception("unauthorized");
+                }
+            }
+            else
+            {
+                throw new Exception("Missing required header: x-lc-token");
+            }
+
+        }
     }
 }