From 14bab088de8a0474a8e7f51c06ad098449e1bef8 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E4=BC=9F?= <421281095@qq.com>
Date: Wed, 23 Jul 2025 09:44:42 +0800
Subject: [PATCH] =?UTF-8?q?bugfix:=E7=B3=BB=E7=BB=9F=E8=BF=90=E8=A1=8C?=
 =?UTF-8?q?=E6=9C=9F=E9=97=B4=E6=B7=BB=E5=8A=A0=E4=BB=BB=E5=8A=A1=E4=B8=8D?=
 =?UTF-8?q?=E8=BF=90=E8=A1=8C=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 OpenAuth.App/BaseApp/Jobs/OpenJobApp.cs | 13 ++++++++++++-
 OpenAuth.App/ServiceApp/FlyTaskJob.cs   |  2 +-
 OpenAuth.App/ServiceApp/ManageApp.cs    |  6 +++---
 3 files changed, 16 insertions(+), 5 deletions(-)

diff --git a/OpenAuth.App/BaseApp/Jobs/OpenJobApp.cs b/OpenAuth.App/BaseApp/Jobs/OpenJobApp.cs
index 0e73753..f040bd3 100644
--- a/OpenAuth.App/BaseApp/Jobs/OpenJobApp.cs
+++ b/OpenAuth.App/BaseApp/Jobs/OpenJobApp.cs
@@ -72,7 +72,7 @@ namespace OpenAuth.App
             _logger.LogInformation("所有状态为正在运行的任务已启动");
         }
 
-        public void Add(AddOrUpdateOpenJobReq req)
+        public string Add(AddOrUpdateOpenJobReq req)
         {
             var obj = req.MapTo<SysOpenJob>();
             obj.Id = Guid.NewGuid().ToString();
@@ -81,6 +81,7 @@ namespace OpenAuth.App
             obj.CreateUserId = user.Id.ToString();
             obj.CreateUserName = user.Name;
             Repository.Insert(obj);
+            return obj.Id;
         }
 
         public void AddStart(AddOrUpdateOpenJobReq req)
@@ -131,6 +132,16 @@ namespace OpenAuth.App
             return types.Select(u => u.FullName).ToList();
         }
 
+        public void StartJob(string jobId)
+        {
+            var job = Repository.GetFirst(u => u.Id == jobId);
+            if (job == null)
+            {
+                throw new Exception("任务不存在");
+            }
+            job.Start(_scheduler);
+        }
+
         public void ChangeJobStatus(ChangeJobStatusReq req)
         {
             var job = Repository.GetFirst(u => u.Id == req.Id);
diff --git a/OpenAuth.App/ServiceApp/FlyTaskJob.cs b/OpenAuth.App/ServiceApp/FlyTaskJob.cs
index ab9a846..4bbb781 100644
--- a/OpenAuth.App/ServiceApp/FlyTaskJob.cs
+++ b/OpenAuth.App/ServiceApp/FlyTaskJob.cs
@@ -22,7 +22,7 @@ public class FlyTaskJob : IJob
         if (job == null) return Task.CompletedTask;
         var param = JsonConvert.DeserializeObject<dynamic>(job.JobCallParams);
         var taskId = (string)param.taskId;
-        _manageApp.ExecuteFlyTask(taskId);
+        _ = _manageApp.ExecuteFlyTask(taskId);
         return Task.CompletedTask;
     }
 }
\ No newline at end of file
diff --git a/OpenAuth.App/ServiceApp/ManageApp.cs b/OpenAuth.App/ServiceApp/ManageApp.cs
index ca69040..2d3dc28 100644
--- a/OpenAuth.App/ServiceApp/ManageApp.cs
+++ b/OpenAuth.App/ServiceApp/ManageApp.cs
@@ -238,7 +238,7 @@ namespace OpenAuth.App.ServiceApp
             }
         }
 
-        
+
         /// <summary>
         /// 获取机场sn获取无人机列表
         /// </summary>
@@ -397,7 +397,6 @@ namespace OpenAuth.App.ServiceApp
                 task.CreateUserName = user.Name;
                 task.CreateTime = DateTime.Now;
                 //task.FlightId = Guid.NewGuid().ToString();
-                // todo 根据 
                 //  如：执行时长，单次定时的时间
                 // 0-飞行计划 1-指点飞行
                 task.FlightTaskType = 0; //
@@ -416,7 +415,8 @@ namespace OpenAuth.App.ServiceApp
                         Status = 1, // 开启运行 todo 关于修改后关闭问题
                         Remark = "定时任务",
                     };
-                    _openJobApp.Add(record);
+                    var jobId = _openJobApp.Add(record);
+                    _openJobApp.StartJob(jobId);
                 }
                 else if (type.Equals(0))
                 {