From 54f504e610b6967df2757d4771636781f2e4ba28 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E4=BC=9F?= <421281095@qq.com>
Date: Fri, 25 Jul 2025 15:21:37 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=AD=E7=82=B9=E4=BF=A1=E6=81=AF=E4=BF=9D?=
 =?UTF-8?q?=E5=AD=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ServiceApp/Subscribe/ConfigSubscribe.cs       | 15 ++++++++++-----
 OpenAuth.Repository/Domain/LasaTask.cs            |  2 ++
 2 files changed, 12 insertions(+), 5 deletions(-)

diff --git a/OpenAuth.App/ServiceApp/Subscribe/ConfigSubscribe.cs b/OpenAuth.App/ServiceApp/Subscribe/ConfigSubscribe.cs
index 85dc6d9..423006b 100644
--- a/OpenAuth.App/ServiceApp/Subscribe/ConfigSubscribe.cs
+++ b/OpenAuth.App/ServiceApp/Subscribe/ConfigSubscribe.cs
@@ -427,13 +427,18 @@ public class ConfigSubscribe : IJob
                             };
                             await _mqttClientManager.PublishAsync(cancelTaskTopic,
                                 JsonConvert.SerializeObject(cancelTaskRequest));
-                            // todo  更新任务状态及失败原因？
+                            //更新任务状态及失败原因？
                             string flightId1 = data.output.ext.flight_id;
                             var taskId1 = _manageApp.GetTaskAssignByFlightId(flightId1).TaskId;
-
-                            // todo 获取任务信息
-                            // todo 改变任务状态
-                            // todo 填充错误信息
+                            // 添加断点信息
+                            var taskRecord1 = new LasaTask()
+                            {
+                                Id = taskId1,
+                                Status = 2,
+                                BreakPoint = JsonConvert.SerializeObject(data.output.ext.break_point)
+                            };
+                            await _sqlSugarClient.Updateable(taskRecord1)
+                                .IgnoreNullColumns().ExecuteCommandAsync();
                         }
                         else
                         {
diff --git a/OpenAuth.Repository/Domain/LasaTask.cs b/OpenAuth.Repository/Domain/LasaTask.cs
index 68bbe3d..6b053dd 100644
--- a/OpenAuth.Repository/Domain/LasaTask.cs
+++ b/OpenAuth.Repository/Domain/LasaTask.cs
@@ -138,5 +138,7 @@ namespace OpenAuth.Repository.Domain
         public int? FlightTaskType { get; set; }
         
         public string ExternalTaskId { get; set; }
+        
+        public string BreakPoint { get; set; }
     }
 }
\ No newline at end of file