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

namespace IStation.Server
{
    /// <summary>
    /// 自定义计划重复任务
    /// </summary>
    public class CustomCronRepeatJob : Quartz.IJob
    {
        //自定义计划任务字典
        private static Dictionary<long,CustomCronJobHelper> _dict=new Dictionary<long, CustomCronJobHelper>();

        /// <summary>
        /// 任务id 
        /// </summary>
        public long JobID { get; set; }

        /// <summary>
        /// 
        /// </summary>
        public Task Execute(IJobExecutionContext context)
        {
            return Task.Run(async () =>
            {
                try
                {
                    //获取任务
                    var model = new Service.CustomCronJob().GetByID(JobID);

                    //获取任务失败后，停止任务并移除任务辅助类
                    if (model == null)
                    {
                        if (_dict.ContainsKey(JobID))
                        {
                            await _dict[JobID].CancelJob();
                            _dict.Remove(JobID);
                        }
                        return;
                    }

                    //尚未创建计划任务时，创建计划任务辅助类
                    if (!_dict.ContainsKey(JobID))
                    {
                        var jobHelper = new CustomCronJobHelper();
                        await jobHelper.StartJob(model);
                        _dict.Add(JobID, jobHelper);
                        return;
                    }

                    //任务已存在，检查任务执行间隔是否发生变化，若发生变化，重置任务
                    if (_dict[JobID].Instance.Expression != model.Expression)
                    {
                        await _dict[JobID].CancelJob();
                        var jobHelper = new CustomCronJobHelper();
                        await jobHelper.StartJob(model);
                        _dict[JobID] = jobHelper;
                    }

                }
                catch (Exception ex)
                {
                    LogHelper.Error("自定义计划重复任务，执行出错", ex);
                    var e = new JobExecutionException(ex);
                    throw e;
                }
            });


        }

        /// <summary>
        /// 取消任务
        /// </summary>
        /// <returns></returns>
        public async Task CancelJob()
        {
            await CancelJob(JobID);
        }

        /// <summary>
        /// 取消任务
        /// </summary>
        /// <param name="jobId">任务id</param>
        public static async Task CancelJob(long jobId)
        {
            if (_dict.ContainsKey(jobId))
            {
                await _dict[jobId].CancelJob();
                _dict.Remove(jobId);
            }

        }

        /// <summary>
        /// 取下任务
        /// </summary>
        public static async Task CancelJobs()
        {
            foreach (var key in _dict.Keys)
            {
                await CancelJob(key);
            }
        }

    }

}