Yi.Framework.Net6/Yi.Framework.Core/Quartz/QuartzInvoker.cs

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

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

using Microsoft.Extensions.Logging;
using Quartz;
using Quartz.Impl.Matchers;
using Quartz.Spi;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Yi.Framework.Common.Helper;
using Yi.Framework.Job;

namespace Yi.Framework.Core
{
    public class QuartzInvoker
    {
        private readonly ISchedulerFactory _schedulerFactory;
        private IScheduler _scheduler;
        private ILogger<QuartzInvoker> _logger;
        private IJobFactory _jobFactory;

        private const string JobDllName = "Yi.Framework.Job";
        public QuartzInvoker(ISchedulerFactory schedulerFactory, ILogger<QuartzInvoker> logger, IJobFactory jobFactory)
        {
            _schedulerFactory = schedulerFactory;
            _logger = logger;
            _jobFactory = jobFactory;
        }

        /// <summary>
        /// 开始任务
        /// </summary>
        /// <param name="cron"></param>
        /// <param name="jobClass"></param>
        /// <param name="jobName"></param>
        /// <param name="jobGroup"></param>
        /// <param name="second"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public async Task StartAsync(string cron, string jobClass, string jobName = "", string jobGroup = "default", long startAtSecondTime = 0, IDictionary<string, object> data = null)
        {
            jobName = jobName == "" ? jobClass : jobName;
            if (data == null)
            {
                data = new Dictionary<string, object>();
            }
            JobKey jobKey = new JobKey(jobName, jobGroup);
            var myClass = AssemblyHelper.GetClass(JobDllName, jobClass).FirstOrDefault();

            _scheduler = await _schedulerFactory.GetScheduler();
            _scheduler.JobFactory = _jobFactory;

            //创建一个触发器
            var trigger = TriggerBuilder.Create()
                             .StartAt(DateTimeOffset.Now.AddSeconds(startAtSecondTime))
                            .WithCronSchedule(cron)
                            .Build();
            //创建任务
            var jobDetail = JobBuilder.Create(myClass)
                            .UsingJobData(new JobDataMap(data))