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

fix定时任务执行api请求问题

Browse Source
This commit is contained in:
不做码农 2022-05-10 11:18:12 +08:00
parent d7ee352f3a
commit ac277c9230
2 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ZR.Admin.WebApi/Controllers/System/TasksController.cs
View File

@ -111,7 +111,7 @@ namespace ZR.Admin.WebApi.Controllers
if (parm.ApiUrl.IfNotEmpty() && parm.TaskType == 2) if (parm.ApiUrl.IfNotEmpty() && parm.TaskType == 2)
{ {
tasksQz.AssemblyName = "ZR.Tasks"; tasksQz.AssemblyName = "ZR.Tasks";
tasksQz.ClassName = "TaskScheduler.HttpResultfulJob"; tasksQz.ClassName = "TaskScheduler.Job_HttpRequest";
} }
return SUCCESS(_tasksQzService.Add(tasksQz)); return SUCCESS(_tasksQzService.Add(tasksQz));
} }
@ -146,7 +146,7 @@ namespace ZR.Admin.WebApi.Controllers
if (parm.ApiUrl.IfNotEmpty() && parm.TaskType == 2) if (parm.ApiUrl.IfNotEmpty() && parm.TaskType == 2)
{ {
parm.AssemblyName = "ZR.Tasks"; parm.AssemblyName = "ZR.Tasks";
parm.ClassName = "TaskScheduler.HttpResultfulJob"; parm.ClassName = "TaskScheduler.Job_HttpRequest";
} }
if (tasksQz.IsStart) if (tasksQz.IsStart)
{ {

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

@ -3,11 +3,15 @@ using Infrastructure.Attribute;
using Quartz; using Quartz;
using Quartz.Impl; using Quartz.Impl;
using Quartz.Impl.Triggers; using Quartz.Impl.Triggers;
using System;
using System.Threading.Tasks; using System.Threading.Tasks;
using ZR.Service.System.IService; using ZR.Service.System.IService;
namespace ZR.Tasks.TaskScheduler namespace ZR.Tasks.TaskScheduler
{ {
/// <summary>
/// 定时任务http请求
/// </summary>
[AppService(ServiceType = typeof(Job_HttpRequest), ServiceLifetime = LifeTime.Scoped)] [AppService(ServiceType = typeof(Job_HttpRequest), ServiceLifetime = LifeTime.Scoped)]
internal class Job_HttpRequest : JobBase, IJob internal class Job_HttpRequest : JobBase, IJob
{ {
@ -25,9 +29,11 @@ namespace ZR.Tasks.TaskScheduler
{ {
AbstractTrigger trigger = (context as JobExecutionContextImpl).Trigger as AbstractTrigger; AbstractTrigger trigger = (context as JobExecutionContextImpl).Trigger as AbstractTrigger;
var info = await tasksQzService.GetByIdAsync(trigger.Name); var info = await tasksQzService.GetByIdAsync(trigger.Name);
if (info != null)
var result = await HttpHelper.HttpPostAsync("http://" + info.ApiUrl, info.JobParams); {
//Console.WriteLine(result); var result = await HttpHelper.HttpGetAsync("http://" + info.ApiUrl);
Console.WriteLine(result);
}
} }
} }
} }