任务更新状态及失败原因

OpenAuth.App/BaseApp/Subscribe/ConfigSubscribe.cs

@@ -263,6 +263,12 @@ 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 填充错误信息
                         }
                         else
                         {
@@ -347,6 +353,13 @@ public class ConfigSubscribe : IJob
                                     Status = 2
                                 };
                                 _sqlSugarClient.Updateable(taskAssignRecord).IgnoreNullColumns().ExecuteCommand();
+                                var taskUpdate = new LasaTask
+                                {
+                                    Id = taskAssign.TaskId,
+                                    Status = 2, // todo 状态待定
+                                    Reason = errorMsg //失败原因
+                                };
+                                 _sqlSugarClient.Updateable(taskUpdate).IgnoreNullColumns().ExecuteCommand();
                             }
                         }
 

OpenAuth.Repository/Domain/LasaTask.cs

@@ -130,5 +130,7 @@ namespace OpenAuth.Repository.Domain
         public int UploadedFileCount { get; set; }
         
         public string FlightId { get; set; }
+        
+        public string Reason { get; set; }
     }
 }