From e657741094596c3cc38d26ef87cec8538b5f7601 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E4=BC=9F?= <421281095@qq.com>
Date: Fri, 11 Jul 2025 16:33:39 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AE=9A=E6=97=B6=E5=8F=8A?=
 =?UTF-8?q?=E5=91=A8=E6=9C=9F=E4=BB=BB=E5=8A=A1Job?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 OpenAuth.App/ServiceApp/FlyTaskJob.cs | 28 +++++++++++++++++++++++++++
 1 file changed, 28 insertions(+)
 create mode 100644 OpenAuth.App/ServiceApp/FlyTaskJob.cs

diff --git a/OpenAuth.App/ServiceApp/FlyTaskJob.cs b/OpenAuth.App/ServiceApp/FlyTaskJob.cs
new file mode 100644
index 0000000..c7fcca9
--- /dev/null
+++ b/OpenAuth.App/ServiceApp/FlyTaskJob.cs
@@ -0,0 +1,28 @@
+using Infrastructure;
+using Newtonsoft.Json;
+using Quartz;
+
+namespace OpenAuth.App.ServiceApp;
+
+public class FlyTaskJob : IJob
+{
+    private readonly ManageApp _manageApp;
+    private readonly OpenJobApp _openJobApp;
+
+    public FlyTaskJob(ManageApp manageApp, OpenJobApp openJobApp)
+    {
+        _manageApp = manageApp;
+        _openJobApp = openJobApp;
+    }
+
+    public Task Execute(IJobExecutionContext context)
+    {
+        var jobId = context.MergedJobDataMap.GetString(Define.JOBMAPKEY);
+        var job = _openJobApp.Get(jobId);
+        if (job == null) return Task.CompletedTask;
+        var param = JsonConvert.DeserializeObject<dynamic>(job.JobCallParams);
+        var taskId = param.taskId;
+        _manageApp.ExecuteFlyTask(taskId);
+        return Task.CompletedTask;
+    }
+}
\ No newline at end of file