using Quartz;
using Quartz.Impl;
using System;
using System.Collections.Specialized;
using System.Reflection;
using System.Threading.Tasks;
using WIDESEA.Core.Utilities;
using WIDESEA.Services.IServices;

namespace WIDESEA.Job
{
    public class SchedulerCenterServer
    {
        private Task<IScheduler> _scheduler;
        private StdSchedulerFactory _jobFactory;


        public SchedulerCenterServer(StdSchedulerFactory jobFactory)
        {
            _jobFactory = jobFactory;
            _scheduler = GetSchedulerAsync();
        }
        private Task<IScheduler> GetSchedulerAsync()
        {
            if (_scheduler != null)
                return this._scheduler;
            else
            {
                // 从Factory中获取Scheduler实例
                NameValueCollection collection = new NameValueCollection
                {
                    { "quartz.serializer.type", "binary" },
                };
                StdSchedulerFactory factory = new StdSchedulerFactory(collection);
                return _scheduler = factory.GetScheduler();
            }
        }
        #region 将任务计划添加到调度中心
        /// <summary>
        /// 添加一个任务
        /// </summary>
        /// <param name="job"></param>
        /// <returns></returns>
        public async Task<WebResponseContent> AddScheduleJobAsync(string jobClassName)
        {
            WebResponseContent content = new WebResponseContent();
            string jobName = jobClassName;
            string jobGroup = "jobGroup";
            string jobAssembName = "WIDESEA.Job";
            string className = jobClassName;
            try
            {
                JobKey jobKey = new JobKey(jobName, jobGroup);
                if (!await this._scheduler.Result.CheckExists(jobKey))
                {
                    Assembly assembly = Assembly.LoadFile(AppDomain.CurrentDomain.BaseDirectory + $"{jobAssembName}.dll");

                    Type jobType = assembly.GetType(jobAssembName + "." + className);

                    //判断任务调度是否已经开启
                    if (!this._scheduler.Result.IsStarted)
                    {
                        await StartScheduleAsync();
                    }

                    //传入反射出来的执行程序集
                    IJobDetail jobDetail = new JobDetailImpl(jobName, jobGroup, jobType);
                    ITrigger trigger = CreateSimpleTrigger(jobName, jobGroup);


                    // 告诉Quartz使用我们的触发器来安排作业
                    await _scheduler.Result.ScheduleJob(jobDetail, trigger);

                }
                await Console.Out.WriteLineAsync($"【{jobName}】任务计划添加成功");
                return content = content.OK(message: $"【{jobName}】添加成功");

            }
            catch (Exception ex)
            {
                Console.Out.WriteLine($"任务计划异常:【{ex.Message}】");
                //this._scheduler.Dispose();
                this._scheduler = null;
                return content = content.Error(message: $"任务计划异常:【{ex.Message}】");
            }
        }
        #endregion
        #region 检测任务是否存在
        /// <summary>
        /// 检测任务是否存在
        /// </summary>
        /// <param name="job"></param>
        /// <returns></returns>
        public async Task<bool> IsExistScheduleJobAsync(string jobName, string jobGroup)
        {
            JobKey jobKey = new JobKey(jobName, jobGroup);
            if (await _scheduler.Result.CheckExists(jobKey))
            {
                return true;
            }
            else
            {
                return false;
            }
        }
        #endregion

        #region 开启任务调度
        /// <summary>
        /// 开启任务调度
        /// </summary>
        /// <returns></returns>
        public async Task<WebResponseContent> StartScheduleAsync()
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                if (!this._scheduler.Result.IsStarted)
                {
                    await this._scheduler.Result.Start();
                    await Console.Out.WriteLineAsync("任务调度开启！");
                    content = content.OK(message: $"任务调度开启成功");

                    //WIDESEA.Helper.GetToken();

                    //调度开启成功后，开启Hsl的websocket，端口号为9111
                    if (!ToWCSService.webServer.IsStarted)
                    {
                        ToWCSService.webServer.ServerStart(9111); ;
                    }

                }
                else
                {
                    await Console.Out.WriteLineAsync($"任务调度已经开启");
                    content = content.Error($"任务调度已经开启");
                }
            }
            catch (Exception ex)
            {
                await Console.Out.WriteLineAsync($"任务调度开启异常:{ex.Message}");
                content = content.Error($"任务调度开启异常:{ex.Message}");
            }
            return content;
        }
        #endregion

        private ITrigger CreateSimpleTrigger(string jobName, string jobGroup)
        {
            ITrigger trigger = TriggerBuilder.Create()
            .WithIdentity(jobName, jobGroup)
            .WithSimpleSchedule(x => x
                .WithIntervalInSeconds(10)
                .RepeatForever()
            )
            .Build();
            return trigger;
        }
    }
}