feat:添加执行一次接口
This commit is contained in:
@@ -38,7 +38,7 @@ namespace Yi.Furion.Application.Rbac.Services.Impl
|
||||
[HttpGet("")]
|
||||
public PagedResultDto<SchedulerModel> GetList([FromQuery] TaskGetListInput input)
|
||||
{
|
||||
var data = _schedulerFactory.GetJobsOfModels().Skip(input.PageNum * input.PageSize).Take(input.PageSize).OrderByDescending(x => x.JobDetail.UpdatedTime).ToList();
|
||||
var data = _schedulerFactory.GetJobsOfModels().Skip((input.PageNum-1) * input.PageSize).Take(input.PageSize).OrderByDescending(x => x.JobDetail.UpdatedTime).ToList();
|
||||
return new PagedResultDto<SchedulerModel>(data.Count(), data);
|
||||
}
|
||||
|
||||
@@ -148,5 +148,16 @@ namespace Yi.Furion.Application.Rbac.Services.Impl
|
||||
var result = _schedulerFactory.TryUpdateJob(schedulerBuilder, out var scheduler);
|
||||
return result;
|
||||
}
|
||||
|
||||
[HttpPost]
|
||||
public bool RunOnce(string jobId)
|
||||
{
|
||||
var result = _schedulerFactory.TryGetJob(jobId, out var scheduler);
|
||||
|
||||
var triggerBuilder = Triggers.Period(100).SetRunOnStart(true).SetMaxNumberOfRuns(1);
|
||||
scheduler.AddTrigger(triggerBuilder);
|
||||
//设置启动时执行一次,然后最大只执行一次
|
||||
return true;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -38,6 +38,7 @@ public class Startup : AppStartup
|
||||
// 注册作业,并配置作业触发器
|
||||
// options.AddJob<SystemDataJob>(Triggers.Period(10000)); // 表示每秒执行
|
||||
options.AddJob<SystemDataJob>(Triggers.Cron("0 0 0,12 ? * ?",CronStringFormat.WithSeconds)); // 表示每天凌晨与12点
|
||||
options.AddJob<TestJob>(Triggers.Period(1000000)); // 表示每天凌晨与12点
|
||||
});
|
||||
services.AddFileLogging("application-{0:yyyy}-{0:MM}-{0:dd}.log", options =>
|
||||
{
|
||||
|
||||
Reference in New Issue
Block a user