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 CustomCronJob : Quartz.IJob
    {
        internal const string Instance = "Instance";

        /// <summary>
        /// 
        /// </summary>
        public Task Execute(IJobExecutionContext context)
        {
            return Task.Run(() =>
            {
                try
                {
                    var dataMap = context.MergedJobDataMap;
                    var jobModel = (Model.CustomCronJob)dataMap[Instance];
                    if (jobModel == null)
                        return;
                    var jobExecuter = JobFactory.CreateJob(jobModel.Execution);
                    if (jobExecuter == null)
                    {
                        LogHelper.Error($"自定义计划任务,ID:{jobModel.ID},NO:{jobModel.NO},Name:{jobModel.Name},Execution:{jobModel.Execution},创建任务执行对象失败！");
                        return;
                    }
                    jobExecuter.Execute();
                }
                catch (Exception ex)
                {
                    LogHelper.Error("自定义计划任务，执行出错", ex);
                    var e = new JobExecutionException(ex);
                    throw e;
                }

            });


        }
    }
}