Yuebon.NetCore/Yuebon.Quartz.Jobs/SchedulerCenter.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using Quartz.Spi;
using System.Collections.Specialized;
using System.Reflection;
using Yuebon.Security.Dtos;

namespace Yuebon.Quartz.Jobs
{
    /// <summary>
    /// 任务调度管理中心
    /// </summary>
    public class SchedulerCenter : ISchedulerCenter
    {
        /// <summary>
        /// 调度器
        /// </summary>
        private Task<IScheduler> _scheduler;
        private readonly IJobFactory _iocjobFactory;
        public SchedulerCenter(IJobFactory jobFactory)
        {
            _iocjobFactory = jobFactory;
            _scheduler = GetSchedulerAsync();
        }
        private Task<IScheduler> GetSchedulerAsync()
        {
            if (_scheduler != null)
                return this._scheduler;
            else
            {
                // 从Factory中获取Scheduler实例
                NameValueCollection collection = new NameValueCollection
                {
                    { "quartz.serializer.type", "binary" },
                };
                StdSchedulerFactory factory = new StdSchedulerFactory(collection);
                return _scheduler = factory.GetScheduler();
            }
        }

        /// <summary>
        /// 开启任务调度
        /// </summary>
        /// <returns></returns>
        public async Task<CommonResult> StartScheduleAsync()
        {
            var result = new CommonResult();
            try
            {
                this._scheduler.Result.JobFactory = this._iocjobFactory;
                if (!this._scheduler.Result.IsStarted)
                {
                    //等待任务运行完成
                    await this._scheduler.Result.Start();
                    await Console.Out.WriteLineAsync("任务调度开启！");
                    result.Success = true;
                    result.ErrMsg = $"任务调度开启成功";
                    return result;
                }
                else
                {
                    result.Success = false;