From eed3ffa6508595812695270757b6b3b0eab29d3f Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E4=B8=8D=E5=81=9A=E7=A0=81=E5=86=9C?= <599854767@qq.com>
Date: Thu, 7 Dec 2023 12:24:54 +0800
Subject: [PATCH] =?UTF-8?q?:sparkles:=E6=B5=8B=E8=AF=95=E4=BB=BB=E5=8A=A1?=
 =?UTF-8?q?=E6=96=B0=E5=A2=9E=E8=AE=BF=E9=97=AE=E6=95=B0=E6=8D=AE=E5=BA=93?=
 =?UTF-8?q?=E7=A4=BA=E4=BE=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ZR.Tasks/ITaskSchedulerServer.cs          |  5 +----
 ZR.Tasks/TaskScheduler/Job_HttpRequest.cs |  8 +++-----
 ZR.Tasks/TaskScheduler/Job_SyncTest.cs    | 10 ++++++++++
 3 files changed, 14 insertions(+), 9 deletions(-)

diff --git a/ZR.Tasks/ITaskSchedulerServer.cs b/ZR.Tasks/ITaskSchedulerServer.cs
index f8f040e..2e98951 100644
--- a/ZR.Tasks/ITaskSchedulerServer.cs
+++ b/ZR.Tasks/ITaskSchedulerServer.cs
@@ -1,13 +1,10 @@
 using Infrastructure.Model;
-using System;
-using System.Collections.Generic;
-using System.Text;
 using System.Threading.Tasks;
 using ZR.Model.System;
 
 namespace ZR.Tasks
 {
-	public interface ITaskSchedulerServer
+    public interface ITaskSchedulerServer
 	{
 		Task<ApiResult> StartTaskScheduleAsync();
 
diff --git a/ZR.Tasks/TaskScheduler/Job_HttpRequest.cs b/ZR.Tasks/TaskScheduler/Job_HttpRequest.cs
index 1ea38e3..0e302fd 100644
--- a/ZR.Tasks/TaskScheduler/Job_HttpRequest.cs
+++ b/ZR.Tasks/TaskScheduler/Job_HttpRequest.cs
@@ -31,11 +31,9 @@ namespace ZR.Tasks.TaskScheduler
         {
             AbstractTrigger trigger = (context as JobExecutionContextImpl).Trigger as AbstractTrigger;
             //var info = await tasksQzService.CopyNew().GetByIdAsync(trigger.JobName);
-            var info = await DbScoped.SugarScope.CopyNew().Queryable<SysTasks>().FirstAsync(f => f.ID == trigger.JobName);
-            if (info == null)
-            {
-                throw new CustomException($"任务{trigger?.JobName}网络请求执行失败，任务不存在");
-            }
+            var info = await DbScoped.SugarScope.CopyNew()
+                .Queryable<SysTasks>()
+                .FirstAsync(f => f.ID == trigger.JobName) ?? throw new CustomException($"任务{trigger?.JobName}网络请求执行失败，任务不存在");
             string result;
             if (info.RequestMethod != null && info.RequestMethod.Equals("POST", StringComparison.OrdinalIgnoreCase))
             {
diff --git a/ZR.Tasks/TaskScheduler/Job_SyncTest.cs b/ZR.Tasks/TaskScheduler/Job_SyncTest.cs
index 0218743..501dda2 100644
--- a/ZR.Tasks/TaskScheduler/Job_SyncTest.cs
+++ b/ZR.Tasks/TaskScheduler/Job_SyncTest.cs
@@ -1,6 +1,8 @@
 using Infrastructure.Attribute;
 using Quartz;
+using SqlSugar.IOC;
 using System.Threading.Tasks;
+using ZR.Model.System;
 
 namespace ZR.Tasks.TaskScheduler
 {
@@ -18,11 +20,19 @@ namespace ZR.Tasks.TaskScheduler
             await ExecuteJob(context, Run);            
         }
 
+        /// <summary>
+        /// 任务使用中注意：所有方法都需要使用异步，并且不能少了await
+        /// </summary>
+        /// <returns></returns>
         public async Task Run()
         {
             await Task.Delay(1);
             //TODO 业务逻辑
+            var db = DbScoped.SugarScope;
+            var info = await db.Queryable<SysDept>().FirstAsync();
 
+            //其他库操作
+            //var db2 = DbScoped.SugarScope.GetConnectionScope(2);
             System.Console.WriteLine("job test");
         }
     }