OA2023/OASystem/OASystem.Api/OAMethodLib/Quartz/QuartzFactory.cs

using OASystem.API.OAMethodLib.Quartz.Jobs;
using Quartz;
using Quartz.Spi;

namespace QuzrtzJob.Factory
{
    public class QuartzFactory
    {
        //1、声明一个调度工厂
        private ISchedulerFactory _schedulerFactory;
        private IScheduler _scheduler;
        private IJobFactory _IOCjobFactory;
        public QuartzFactory(ISchedulerFactory schedulerFactory, IJobFactory jobFactory)
        {
            _schedulerFactory = schedulerFactory;
            _IOCjobFactory = jobFactory;
        }
        public async Task<string> Start()
        {
            //2、通过调度工厂获得调度器
            _scheduler = await _schedulerFactory.GetScheduler();

            //这里是指定容器仓库
            _scheduler.JobFactory = _IOCjobFactory;
            //3、开启调度器
            await _scheduler.Start();

            //4、创建一个触发器
            var trigger = TriggerBuilder.Create()
                //.WithSimpleSchedule(x => x.WithIntervalInSeconds(2).RepeatForever())//每两秒执行一次
                .WithCronSchedule("0 15 9 * * ?")
                .Build();

            var taskTrigger = TriggerBuilder.Create()
                //.WithSimpleSchedule(x => x.WithIntervalInSeconds(60).RepeatForever())//每六十秒执行一次
                .WithCronSchedule("0 0 9,18 * * ?") //每天早上九点和下午六点触发
                .Build();

            var taskMsgTrigger = TriggerBuilder.Create()
                //.WithSimpleSchedule(x => x.WithIntervalInSeconds(60).RepeatForever())//每六十秒执行一次
                .WithCronSchedule("0 0 9,18 * * ?") //每天早上九点和下午六点触发
                .Build();

            var teamCurrencyTrigger = TriggerBuilder.Create()
                 //.WithSimpleSchedule(x => x.WithIntervalInSeconds(60).RepeatForever())//每六十秒执行一次
                 .WithCronSchedule("0 0 0 * * ? ") //每天零点零分点触发
                 .Build();

            var performanceTrigger = TriggerBuilder.Create()
                .WithCronSchedule("0 0 5 1 * ?") // 每月1号5点执行
                .Build();

            //5、创建任务
            var jobDetail = JobBuilder.Create<ALiYunPostMessageJob>().WithIdentity("job1", "group").Build();
            var taskJobDetail = JobBuilder.Create<TaskJob>().WithIdentity("job2", "group").Build();
            var taskMsgJobDetail = JobBuilder.Create<TaskNewsFeedJob>().WithIdentity("job3", "group").Build();
            var performanceJobDetail = JobBuilder.Create<PerformanceJob>().WithIdentity("job5", "group").Build();

            //6、将触发器和任务器绑定到调度器中
            await _scheduler.ScheduleJob(jobDetail, trigger);
            await _scheduler.ScheduleJob(taskJobDetail, taskTrigger);
            await _scheduler.ScheduleJob(taskMsgJobDetail, taskMsgTrigger);
            await _scheduler.ScheduleJob(performanceJobDetail, performanceTrigger);

            // 币种信息 每天 凌晨零点更新
            await CreateAndScheduleJob<GroupTeamCurrencyJob>("job4", "group", CreateTrigger("0 0 0 * * ?"));

            // 团组流程提示、预警 企业微信消息通知 每天早上九点触发
            await CreateAndScheduleJob<GroupProcessNodeJob>("job6", "group", CreateTrigger("0 0 9 * * ?"));

            // 每周五下午4点执行
            await CreateAndScheduleJob<WeeklyFridayJob>("job7", "group", CreateTrigger("0 0 16 ? * FRI"));

            return await Task.FromResult("将触发器和任务器绑定到调度器中完成");
        }

        private async Task CreateAndScheduleJob<T>(string jobName, string groupName, ITrigger trigger) where T : IJob
        {
            var jobDetail = JobBuilder.Create<T>()
              .WithIdentity(jobName, groupName)
              .Build();
            await _scheduler.ScheduleJob(jobDetail, trigger);
        }

        private ITrigger CreateTrigger(string cronExpression)
        {
            return TriggerBuilder.Create()
              .WithCronSchedule(cronExpression)
              .Build();
        }

        /// <summary>
        /// 立即触发指定任务（用于手动执行）
        /// </summary>
        /// <param name="jobName">任务名称，如 job7</param>
        /// <param name="groupName">分组名称，默认 group</param>
        public async Task TriggerJobNow(string jobName, string groupName = "group")
        {
            if (_scheduler == null) return;
            var jobKey = new JobKey(jobName, groupName);
            await _scheduler.TriggerJob(jobKey);
        }
    }
}