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

修改计划任务关闭后再启动不会被执行

Browse Source
This commit is contained in:
不做码农 2022-03-25 13:40:34 +08:00
parent ed0404590f
commit 494ccdbb88
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
ZR.Tasks/TaskSchedulerServer.cs
View File

@ -123,6 +123,10 @@ namespace ZR.Tasks
{ {
return ApiResult.Error(500, $"该计划任务已经在执行:【{tasksQz.Name}】,请勿重复添加！"); return ApiResult.Error(500, $"该计划任务已经在执行:【{tasksQz.Name}】,请勿重复添加！");
} }
if (tasksQz?.EndTime <= DateTime.Now)
{
return ApiResult.Error(500, $"结束时间小于当前时间计划将不会被执行");
}
#region 设置开始时间和结束时间 #region 设置开始时间和结束时间
tasksQz.BeginTime = tasksQz.BeginTime == null ? DateTime.Now : tasksQz.BeginTime; tasksQz.BeginTime = tasksQz.BeginTime == null ? DateTime.Now : tasksQz.BeginTime;
@ -166,10 +170,12 @@ namespace ZR.Tasks
// 5、将触发器和任务器绑定到调度器中 // 5、将触发器和任务器绑定到调度器中
await _scheduler.Result.ScheduleJob(job, trigger); await _scheduler.Result.ScheduleJob(job, trigger);
//任务没有启动、暂停任务 //任务没有启动、暂停任务
if (!tasksQz.IsStart) //if (!tasksQz.IsStart)
{ //{
_scheduler.Result.PauseJob(jobKey).Wait(); // _scheduler.Result.PauseJob(jobKey).Wait();
} //}
//按新的trigger重新设置job执行
await _scheduler.Result.ResumeTrigger(trigger.Key);
return ApiResult.Success($"启动计划任务:【{tasksQz.Name}】成功！"); return ApiResult.Success($"启动计划任务:【{tasksQz.Name}】成功！");
} }
catch (Exception ex) catch (Exception ex)