using CommonUtil;
using Quartz;
using Quartz.Impl;
using ScheduledTasks.Handle;
using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.Text;
using System.Threading.Tasks;

namespace ScheduledTasks
{
    public class Scheduler
    {
        private IScheduler scheduler;

        /// <summary>
        /// 创建调度任务的入口
        /// </summary>
        /// <returns></returns>

        public async Task Start()
        {
            await StartJob();
        }

        /// <summary>
        /// 创建调度任务的公共调用中心
        /// </summary>
        /// <returns></returns>
        public async Task StartJob()
        {
            //创建一个工厂
            NameValueCollection param = new NameValueCollection()
            {
                {  "testJob","test"}
            };

            StdSchedulerFactory factory = new StdSchedulerFactory(param);
            //创建一个调度器
            scheduler = await factory.GetScheduler();
            //开始调度器
            await scheduler.Start();


            //有赞和1688token更新
            string tokenupdate = ConfigUtil.GetValue<string>("job_tokenupdate");
            await CreateJob<TokenUpdateHandle>("token更新", "token更新", tokenupdate);
        }


        /// <summary>
        /// 创建运行的调度器
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="name"></param>
        /// <param name="group"></param>
        /// <param name="cronTime"></param>
        /// <returns></returns>
        public async Task CreateJob<T>(string name, string group, string cronTime) where T : IJob
        {
            //创建一个作业
            var job = JobBuilder.Create<T>()
                .WithIdentity("name" + name, "group" + group)
                .Build();

            //创建一个触发器
            var tigger = (ICronTrigger)TriggerBuilder.Create()
                .WithIdentity("name" + name, "group" + group)
                .StartNow()
                .WithCronSchedule(cronTime)
                .Build();

            //把作业和触发器放入调度器中
            await scheduler.ScheduleJob(job, tigger);
        }
    }
}