using Newtonsoft.Json;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Information;
using Org.BouncyCastle.Tls;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_Core;
using WIDESEA_Core.BaseRepository;
using WIDESEA_Core.BaseServices;
using WIDESEA_Core.Caches;
using WIDESEA_Core.DB;
using WIDESEA_Core.Enums;
using WIDESEA_Core.Helper;
using WIDESEA_Core.Log;
using WIDESEA_DTO.System;
using WIDESEA_ISystemRepository;
using WIDESEA_ISystemService;
using WIDESEA_Model.Models;
using WIDESEA_SystemService.Scheduler;

namespace WIDESEA_SystemService
{
    public class Sys_JobService : ServiceBase<Sys_Job, ISys_JobRepository>, ISys_JobService
    {
        private readonly IUnitOfWorkManage _unitOfWorkManage;
        private readonly ICacheService _cacheService;
        SchedulerCenter scheduler = new SchedulerCenter();

        public Sys_JobService(ISys_JobRepository BaseDal, IUnitOfWorkManage unitOfWorkManage, ICacheService cacheService) : base(BaseDal)
        {
            _unitOfWorkManage = unitOfWorkManage;
            _cacheService = cacheService;
        }


        public WebResponseContent StartServe()
        {
            WebResponseContent webResponse = new WebResponseContent();
            try
            {
                if (!scheduler.IsRun())
                {
                    var startRes = SrartScheduler();
                    if (startRes.Status)
                    {   
                       return webResponse.OK("服务启动成功！");              
                    }
                    else
                    {
                        //调度启动失败，关闭全部
                        WriteLog.Write_Log("服务", "服务", "启动服务\n[调度异常]" + startRes.Message);
                        return startRes;
                    }
                }
                else
                {
                    return webResponse.Error("请勿重复启动！");
                }
            }
            catch (Exception ex)
            {
                WriteLog.Write_Log("服务", "服务", "启动服务\n[异常]" + ex.Message);
                return webResponse.Error($"异常，{ex.Message}");
            }

        }

        /// <summary>
        /// 启动调度
        /// </summary>
        private WebResponseContent SrartScheduler()
        {
            WebResponseContent webResponse = new WebResponseContent();
            var jobs = BaseDal.QueryData();
            try
            {
                foreach (var job in jobs)
                {
                    scheduler.AddJob(job);
                }
                scheduler.Start();
            }
            catch (Exception ex)
            {
                return webResponse.Error(ex.Message);
            }
            Console.WriteLine("服务启动成功！");
            return webResponse.OK();
        }

        public WebResponseContent CloseServe()
        {
            WebResponseContent webResponse = new WebResponseContent();
            try
            {
               
                scheduler.Shutdown();
                Console.WriteLine("服务关闭成功！");
                WriteLog.Write_Log("服务", "服务", "服务关闭成功!");
            }
            catch (Exception ex)
            {
                WriteLog.Write_Log("服务", "服务", "关闭服务\n[异常]" + ex.Message);
            }
            return webResponse.OK("服务关闭成功！");
        }
    }
}