Quartz定时任务帮助类

using Quartz;
using Quartz.Impl;
using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace CRM.ThirdAPITools.QuartzHelper
{
    /// <summary>
    /// Quartz定时任务帮助类： Quartz表达式设计器：http://cron.qqe2.com/
    /// </summary>
    public class QuartzHelper
    {
        // Fields
        private static object oLock = new object();
        private static Dictionary<string, QuartzKey> quartzCache = new Dictionary<string, QuartzKey>();
        private const string QuartzHelperScheulerName = "QuartzHelperScheulerName";
        private static IScheduler sched = null;
        private static ISchedulerFactory sf = null;
        // Methods
        static QuartzHelper()
        {
            NameValueCollection props = new NameValueCollection();
            props.Add("quartz.scheduler.instanceName", "QuartzHelperScheulerName");
            sf = new StdSchedulerFactory(props);
            sched = sf.GetScheduler();
        }
        /// <summary>
        /// 关闭
        /// </summary>
        public static void Close()
        {
            GetScheduler().Shutdown(true);
        }
        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="jobKey"></param>
        public static void Close(object jobKey)
        {
            if (jobKey is JobKey)
            {
                GetScheduler().DeleteJob(jobKey as JobKey);
            }
        }
        /// <summary>
        /// 指定日期执行
        /// </summary>
        /// <param name="action">调用的方法</param>
        /// <param name="date">指定日期</param>
        /// <param name="dataMap">传输数据映射</param>
        /// <param name="jobName">任务名称</param>
        /// <returns></returns>
        public static QuartzKey ExecuteAtDate(Action<Dictionary<string, object>> action, DateTime date, Dictionary<string, object> dataMap = null, string jobName = null)
        {
            return Start(action, delegate (TriggerBuilder p)
            {
                p.WithCronSchedule(BuilderCronExpression(date));
            }, dataMap, jobName);
        }
        /// <summary>
        /// 按表达式执行：
        /// Quartz表达式设计器：http://cron.qqe2.com/
        /// </summary>
        /// <param name="action">调用的方法</param>
        /// <param name="cronExpression">表达式</param>
        /// <param name="dataMap">传输数据映射</param>
        /// <param name="jobName">任务名称</param>
        /// <returns></returns>
        public static QuartzKey ExecuteAtTime(Action<Dictionary<string, object>> action, string cronExpression, Dictionary<string, object> dataMap = null, string jobName = null)
        {
            return Start(action, delegate (TriggerBuilder p)
            {
                p.WithCronSchedule(cronExpression);
            }, dataMap, jobName);
        }
        /// <summary>
        /// 间隔执行
        /// </summary>
        /// <param name="action">调用的方法</param>
        /// <param name="interval">时间间隔</param>
        /// <param name="dataMap">传输数据映射</param>
        public static void ExecuteInterval(Action<Dictionary<string, object>> action, TimeSpan interval, Dictionary<string, object> dataMap = null)
        {
            Action<TriggerBuilder> action2 = null;
            lock (oLock)
            {
                if (action2 == null)
                {
                    action2 = p => p.WithSimpleSchedule(p1 => p1.WithInterval(interval));
                }
                Start(action, action2, dataMap, null);
            }
        }
        /// <summary>
        /// 获取调度名称
        /// </summary>
        /// <returns></returns>
        public static IScheduler GetScheduler()
        {
            ISchedulerFactory factory = new StdSchedulerFactory();
            return factory.GetScheduler("QuartzHelperScheulerName");
        }
        /// <summary>
        /// 任务调度是否开始
        /// </summary>
        /// <returns></returns>
        public static bool IsStart()
        {
            return ((GetScheduler() != null) && GetScheduler().IsStarted);
        }
        /// <summary>
        /// DateTime转为Quartz表达式
        /// </summary>
        /// <param name="date"></param>
        /// <returns></returns>
        public static string BuilderCronExpression(DateTime date)
        {
            string cron = string.Empty;
            cron = string.Format("{0} {1} {2} {3} {4} ?", date.Second, date.Minute, date.Hour, date.Day, date.Month);
            return cron;
        }
        /// <summary>
        /// 启用调度任务
        /// </summary>
        /// <param name="action">方法</param>
        /// <param name="action2">构建的出发实例</param>
        /// <param name="dataMap">传输数据映射</param>
        /// <param name="jobName">任务名称</param>
        /// <returns></returns>
        private static QuartzKey Start(Action<Dictionary<string, object>> action, Action<TriggerBuilder> action2, Dictionary<string, object> dataMap, string jobName)
        {
            QuartzKey key = new QuartzKey();
            if (jobName != null)
            {
                if (quartzCache.ContainsKey(jobName))
                {
                    key = quartzCache[jobName];
                }
                else
                {
                    quartzCache.Add(jobName, key);
                }
            }
            jobName = jobName ?? Guid.NewGuid().ToString("D");
            string group = "group_" + jobName;
            string name = "trigger_" + jobName;
            IJobDetail jobDetail = JobBuilder.Create(typeof(QuartzJob)).WithIdentity(jobName, group).Build();
            TriggerBuilder builder = TriggerBuilder.Create().WithIdentity(name, group);
            action2(builder);
            ITrigger trigger = builder.Build();
            if (quartzCache.ContainsKey(jobName))
            {
                quartzCache[jobName].JobKey = jobDetail.Key;
                quartzCache[jobName].TriggerKey = trigger.Key;
                quartzCache[jobName].Logs.Add(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + " 调度任务已经启动。");
            }
            jobDetail.JobDataMap.Add("dataMap", dataMap);
            jobDetail.JobDataMap.Add("action", action);
            jobDetail.JobDataMap.Add("jobName", jobName);
            jobDetail.JobDataMap.Add("quartzCache", quartzCache);
            sched.ScheduleJob(jobDetail, new Quartz.Collection.HashSet<ITrigger> { trigger }, true);
            sched.Start();
            return key;
        }
    }
    public class QuartzJob : IJob
    {
        // Methods
        public void Execute(IJobExecutionContext context)
        {
            Dictionary<string, object> dictionary = context.JobDetail.JobDataMap["dataMap"] as Dictionary<string, object>;
            string key = context.JobDetail.JobDataMap["jobName"] as string;
            Dictionary<string, QuartzKey> dictionary2 = context.JobDetail.JobDataMap["quartzCache"] as Dictionary<string, QuartzKey>;
            try
            {
                (context.JobDetail.JobDataMap["action"] as Action<Dictionary<string, object>>)(dictionary);
                if (dictionary2.ContainsKey(key))
                {
                    dictionary2[key].Logs.Add(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + " 任务执行成功。");
                }
            }
            catch (Exception exception)
            {
                if (dictionary2.ContainsKey(key))
                {
                    dictionary2[key].Logs.Add(exception.Message);
                }
            }
        }
    }
    public class QuartzKey
    {
        // Methods
        public QuartzKey()
        {
            this.Logs = new List<string>();
        }

        // Properties
        public JobKey JobKey { get; set; }

        public List<string> Logs { get; set; }

        public TriggerKey TriggerKey { get; set; }
    }
}