断点信息保存

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
                         {

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