wenyongda/ZrAdminNetCore
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

✨测试任务新增访问数据库示例

Browse Source
This commit is contained in:
不做码农 2023-12-07 12:24:54 +08:00
parent c7e6e322bc
commit eed3ffa650
3 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
ZR.Tasks/ITaskSchedulerServer.cs
View File

@ -1,13 +1,10 @@
using Infrastructure.Model; using Infrastructure.Model;
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks; using System.Threading.Tasks;
using ZR.Model.System; using ZR.Model.System;
namespace ZR.Tasks namespace ZR.Tasks
{ {
public interface ITaskSchedulerServer public interface ITaskSchedulerServer
{ {
Task<ApiResult> StartTaskScheduleAsync(); Task<ApiResult> StartTaskScheduleAsync();

8
ZR.Tasks/TaskScheduler/Job_HttpRequest.cs
View File

@ -31,11 +31,9 @@ namespace ZR.Tasks.TaskScheduler
{ {
AbstractTrigger trigger = (context as JobExecutionContextImpl).Trigger as AbstractTrigger; AbstractTrigger trigger = (context as JobExecutionContextImpl).Trigger as AbstractTrigger;
//var info = await tasksQzService.CopyNew().GetByIdAsync(trigger.JobName); //var info = await tasksQzService.CopyNew().GetByIdAsync(trigger.JobName);
var info = await DbScoped.SugarScope.CopyNew().Queryable<SysTasks>().FirstAsync(f => f.ID == trigger.JobName); var info = await DbScoped.SugarScope.CopyNew()
if (info == null) .Queryable<SysTasks>()
{ .FirstAsync(f => f.ID == trigger.JobName) ?? throw new CustomException($"任务{trigger?.JobName}网络请求执行失败，任务不存在");
throw new CustomException($"任务{trigger?.JobName}网络请求执行失败，任务不存在");
}
string result; string result;
if (info.RequestMethod != null && info.RequestMethod.Equals("POST", StringComparison.OrdinalIgnoreCase)) if (info.RequestMethod != null && info.RequestMethod.Equals("POST", StringComparison.OrdinalIgnoreCase))
{ {

10
ZR.Tasks/TaskScheduler/Job_SyncTest.cs
View File

@ -1,6 +1,8 @@
using Infrastructure.Attribute; using Infrastructure.Attribute;
using Quartz; using Quartz;
using SqlSugar.IOC;
using System.Threading.Tasks; using System.Threading.Tasks;
using ZR.Model.System;
namespace ZR.Tasks.TaskScheduler namespace ZR.Tasks.TaskScheduler
{ {
@ -18,11 +20,19 @@ namespace ZR.Tasks.TaskScheduler
await ExecuteJob(context, Run); await ExecuteJob(context, Run);
} }
/// <summary>
/// 任务使用中注意：所有方法都需要使用异步，并且不能少了await
/// </summary>
/// <returns></returns>
public async Task Run() public async Task Run()
{ {
await Task.Delay(1); await Task.Delay(1);
//TODO 业务逻辑 //TODO 业务逻辑
var db = DbScoped.SugarScope;
var info = await db.Queryable<SysDept>().FirstAsync();
//其他库操作
//var db2 = DbScoped.SugarScope.GetConnectionScope(2);
System.Console.WriteLine("job test"); System.Console.WriteLine("job test");
} }
} }