From e49300de2dc08b38f0f829db8078f0f199994314 Mon Sep 17 00:00:00 2001
From: zhangbin <460190368@qq.com>
Date: Mon, 1 Dec 2025 09:54:00 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=8F=90=E7=A4=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 OpenAuth.App/ServiceApp/AirportMaintenanceApp.cs     | 12 ++++++------
 .../AirportMaintenanceController.cs                  |  4 ++--
 OpenAuth.WebApi/Model/mqtt/ThingOperationHandler.cs  |  9 ++++++++-
 3 files changed, 16 insertions(+), 9 deletions(-)

diff --git a/OpenAuth.App/ServiceApp/AirportMaintenanceApp.cs b/OpenAuth.App/ServiceApp/AirportMaintenanceApp.cs
index 176064e..ba4b15d 100644
--- a/OpenAuth.App/ServiceApp/AirportMaintenanceApp.cs
+++ b/OpenAuth.App/ServiceApp/AirportMaintenanceApp.cs
@@ -557,7 +557,7 @@ namespace OpenAuth.App.ServiceApp
 
         #region 天气阻飞
         //天气预报和是否有人在操作
-        public async Task<Response<bool>> IsCanFly(string sn, string dock, string address = "兰山")
+        public async Task<Response<string>> IsCanFly(string sn, string dock, string address = "兰山")
         {
             var rainThreshforecast = 3; // 天气预报雨量
             var windSpeedThresh = 12;// 机场设定雨量
@@ -567,7 +567,7 @@ namespace OpenAuth.App.ServiceApp
             var existingLocked = await _redisCacheContext.SetMembersAsync("locked_devices");
             islock = existingLocked.Any(u => u == sn);
             if (islock)
-                return new Response<bool> { Result = false, Message = "设备已锁定" };
+                return new Response<string> { Code = 500, Result = "设备已锁定", Message = "设备已锁定" };
             switch (dock)
             {
                 case "Dock 1":
@@ -604,17 +604,17 @@ namespace OpenAuth.App.ServiceApp
                 var rainfall = dataObject["data"]?["rainfall"]?.Value<int>();
                 var drone_in_dock = dataObject["data"]?["drone_in_dock"]?.Value<string>();
                 if (drone_in_dock == "0")
-                    return new Response<bool> { Result = false, Message = "执行任务中，请勿重复起飞" };
+                    return new Response<string> { Code = 500, Result = "执行任务中，请勿重复起飞" };
                 if (windSpeedThresh <= windSpeed || rainThreshforecast <= rainfall || weatherWindSpeedThre <= weatherWindSpeedforecast)
                 {
-                    return new Response<bool> { Result = false, Message = "当前天气条件不允许起飞" };
+                    return new Response<string> { Code = 500, Result = "当前天气条件不允许起飞" };
                 }
                 else
                 {
-                    return new Response<bool> { Result = true, Message = "当前天气条件允许起飞" };
+                    return new Response<string> { Code = 200, Result = "当前天气条件允许起飞" };
                 }
             }
-            return new Response<bool> { Result = true, Message = "当前天气条件允许起飞" };
+            return new Response<string> { Code = 500, Result = "当前天气条件允许起飞" };
 
         }
         #endregion
diff --git a/OpenAuth.WebApi/Controllers/ServiceControllers/AirportMaintenanceController.cs b/OpenAuth.WebApi/Controllers/ServiceControllers/AirportMaintenanceController.cs
index 4248dfd..8c13dcd 100644
--- a/OpenAuth.WebApi/Controllers/ServiceControllers/AirportMaintenanceController.cs
+++ b/OpenAuth.WebApi/Controllers/ServiceControllers/AirportMaintenanceController.cs
@@ -748,9 +748,9 @@ namespace OpenAuth.WebApi.Controllers.ServiceControllers
         /// <returns></returns>
         [HttpGet]
         [AllowAnonymous]
-        public async Task<Response<bool>> IsCanFly(string address, string sn, string dock)
+        public async Task<Response<string>> IsCanFly(string address, string sn, string dock)
         {
-            var result = new Response<bool>();
+            var result = new Response<string>();
             try
             {
                 result = await _app.IsCanFly(sn, dock, address);
diff --git a/OpenAuth.WebApi/Model/mqtt/ThingOperationHandler.cs b/OpenAuth.WebApi/Model/mqtt/ThingOperationHandler.cs
index 6bc064d..4dcef4d 100644
--- a/OpenAuth.WebApi/Model/mqtt/ThingOperationHandler.cs
+++ b/OpenAuth.WebApi/Model/mqtt/ThingOperationHandler.cs
@@ -1,5 +1,6 @@
 using Infrastructure.Cache;
 using Infrastructure.CloudSdk.mqttmessagecenter;
+using Newtonsoft.Json;
 using OpenAuth.App.ServiceApp;
 using OpenAuth.Repository.Domain;
 using System.Text.Json.Nodes;
@@ -22,6 +23,11 @@ namespace OpenAuth.WebApi.Model.mqtt
         public async Task HandleAsync(string topic, string payload)
         {
             var root = JsonNode.Parse(payload)?.AsObject();
+
+            string dataJson = JsonConvert.SerializeObject(root["Data"],new JsonSerializerSettings
+            {
+                StringEscapeHandling = StringEscapeHandling.Default
+            });
             await _app.AddOperationLog(new LasaControlOperation
             {
                 Id = Guid.NewGuid().ToString(),
@@ -29,7 +35,8 @@ namespace OpenAuth.WebApi.Model.mqtt
                 TaskId = root["TaskId"]?.ToString() ?? "",
                 CreateTime = DateTime.Now,
                 CreateId = long.Parse((root["CreateId"]?.ToString() ?? "0")),
-                Data = root["Data"]?.ToJsonString() ?? ""
+                //Data = root["Data"]?.ToJsonString() ?? ""
+                Data = dataJson
             });
             //var info = Newtonsoft.Json.JsonConvert.DeserializeObject<LasaControlOperation>(payload);
             //info.Id = Guid.NewGuid().ToString();