32 lines
1020 B
C#
32 lines
1020 B
C#
|
using Microsoft.Extensions.DependencyInjection;
|
|||
|
|
using Quartz;
|
|||
|
|
using Quartz.Spi;
|
|||
|
|
using System;
|
|||
|
|
|
|||
|
|
namespace HT.Cloud.Service.AutoJob
|
|||
|
|
{
|
|||
|
|
/// <summary>
|
|||
|
|
/// 依赖注入必须，代替原本的SimpleJobFactory
|
|||
|
|
/// </summary>
|
|||
|
|
public class IOCJobFactory : IJobFactory
|
|||
|
|
{
|
|||
|
|
private readonly IServiceProvider _serviceProvider;
|
|||
|
|
|
|||
|
|
public IOCJobFactory(IServiceProvider serviceProvider)
|
|||
|
|
{
|
|||
|
|
_serviceProvider = serviceProvider;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public IJob NewJob(TriggerFiredBundle bundle, IScheduler scheduler)
|
|||
|
|
{
|
|||
|
|
var serviceScope = _serviceProvider.CreateScope(); // 获得一个ioc对象，指定创建scope级别的实例（在job里面需要依赖注入ef，但是startup里面配置的ef是scope级别的，必须指定为scope，不然报错）。不写的话，默认是单例。
|
|||
|
|
return serviceScope.ServiceProvider.GetService(bundle.JobDetail.JobType) as IJob; // 依赖注入一个 job 然后返回
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public void ReturnJob(IJob job)
|
|||
|
|
{
|
|||
|
|
var disposable = job as IDisposable;
|
|||
|
|
disposable?.Dispose();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|