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 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().FirstAsync(f => f.ID == trigger.JobName); - if (info == null) - { - throw new CustomException($"任务{trigger?.JobName}网络请求执行失败,任务不存在"); - } + var info = await DbScoped.SugarScope.CopyNew() + .Queryable() + .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); } + /// + /// 任务使用中注意:所有方法都需要使用异步,并且不能少了await + /// + /// public async Task Run() { await Task.Delay(1); //TODO 业务逻辑 + var db = DbScoped.SugarScope; + var info = await db.Queryable().FirstAsync(); + //其他库操作 + //var db2 = DbScoped.SugarScope.GetConnectionScope(2); System.Console.WriteLine("job test"); } }