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

namespace IStation.Server
{
    /// <summary>
    /// 能效分析计划服务任务
    /// </summary>
    [DisallowConcurrentExecution]
    public class EtaAnalyCronServiceJob : IJob 
    {
        private static readonly List<EtaAnalyCronJobHelper> _jobHelpers = new List<EtaAnalyCronJobHelper>();

        /// <summary>
        /// 
        /// </summary>
        public Task Execute(IJobExecutionContext context)
        {
            return Task.Run(async () =>
           {
               try
               {
                   #region 加载目标客户

                   var corpIds = CorpHelper.GetCorpIds();
                   if (corpIds == null || corpIds.Count < 1)
                   {
                       LogHelper.Error("能效分析计划服务任务中，未检索到目标客户信息");
                       CancelJobs();
                       return;
                   }

                   #endregion

                   #region 加载配置

                   var service_configure = new Service.EtaAnalyConfigure();
                   var configure_list = service_configure.GetByCorpIds(corpIds);
                   if (configure_list == null || configure_list.Count < 1)
                   {
                       LogHelper.Error("能效分析计划服务任务中，未检索到能效分析配置信息！");
                       CancelJobs();
                       return;
                   }
                   configure_list = configure_list.Where(x => x.UseStatus == Model.eUseStatus.Enable).ToList();
                   if (configure_list.Count < 1)
                   {
                       LogHelper.Error("能效分析计划服务任务中，未检索到有效能效分析配置信息！");
                       CancelJobs();
                       return;
                   }

                   #endregion

                   #region 开启任务

                   foreach (var configure in configure_list)
                   {
                       var jobHelper = _jobHelpers.Find(x => x.CorpID == configure.CorpID && x.Frequency == configure.Frequency);
                       if (jobHelper == null)
                       {
                           jobHelper = new EtaAnalyCronJobHelper();
                           await jobHelper.StartJob(configure.CorpID, configure.Frequency);
                           _jobHelpers.Add(jobHelper);
                           LogHelper.Info($"能效分析计划服务任务中，客户标识：{configure.CorpID}，分析频率：{configure.Frequency},计划任务开启！");
                       }
                   }

                   #endregion

                   #region 关闭任务

                   foreach (var jobHelper in _jobHelpers.ToList())
                   {
                       var configure = configure_list.Find(x => x.CorpID == jobHelper.CorpID && x.Frequency == jobHelper.Frequency);
                       if (configure == null)
                       {
                           await jobHelper.CancelJob();
                           _jobHelpers.Remove(jobHelper);
                           LogHelper.Info($"能效分析计划服务任务中，客户标识：{jobHelper.CorpID}，分析频率：{jobHelper.Frequency},计划任务关闭！");
                       }
                   }

                   #endregion


                   LogHelper.Info($"能效分析计划服务任务中，开启任务数量为{_jobHelpers.Count}！");
               }
               catch (Exception ex)
               {
                   LogHelper.Error("能效分析计划服务任务中，执行出错！", ex);
                   var e = new JobExecutionException(ex);
                   throw e;
               }
           });


        }

        /// <summary>
        /// 取消任务
        /// </summary>
        public static void CancelJobs()
        {
            if (_jobHelpers != null && _jobHelpers.Count > 0)
            {
                _jobHelpers.ForEach(async x => await x.CancelJob());
                _jobHelpers.Clear();
            }
        }



    }
}