usi
  
ng Quartz;
using Quartz.Impl;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace MPC.AFE.Controller.Service;

public static class QuartzHelper
{
    private static ISchedulerFactory scheduleFactory = null;
    private static IScheduler _scheduler = null;

    public static async Task InitAsync()
    {
        scheduleFactory = new StdSchedulerFactory();
        _scheduler = await scheduleFactory.GetScheduler();
    }


    public static async Task AddSimpleJobOfSecondAsync<T>(string jobName, string groupName, int second, Dictionary
    <string, object>param = null) where T : IJob
    {
        await AddSimpleJobAsync
        <T>(jobName, groupName, (x) => { x.WithIntervalInSeconds(second).RepeatForever(); }, param);
    }

    public static async Task AddSimpleJobOfMinuteAsync
            <T>(string jobName, string groupName, int minute, Dictionary
                <string, object>param = null) where T : IJob
    {
        await AddSimpleJobAsync
                    <T>(jobName, groupName, (x) => { x.WithIntervalInMinutes(minute).RepeatForever(); }, param);
    }

    public static async Task AddSimpleJobAsync
                        <T>(string jobName, string groupName, Action
                            <SimpleScheduleBuilder>action, Dictionary
                                <string, object>param = null) where T : IJob
    {
        var jobKey = new JobKey(jobName, groupName);

        if (await _scheduler.CheckExists(jobKey))
        {
            return;
        }

        var job = JobBuilder.Create
                                    <T>()
            .WithIdentity(jobKey)
            .Build();

        if (param != null && param.Count > 0)
        {
            foreach (string key in param.Keys)
            {
                job.JobDataMap.Put(key, param[key]);
            }
        }

        var trigger = TriggerBuilder.Create()

            .WithIdentity($"{jobName}Trigger", groupName)
            .WithSimpleSchedule(action)
            .Build();

        await _scheduler.ScheduleJob(job, trigger);
    }


    public static async Task AddJob
                                        <T>(string jobName, string groupName, string cronExpression) where T : IJob
    {
        var jobKey = new JobKey(jobName, groupName);

        if (await _scheduler.CheckExists(jobKey))
        {
            return;
        }

        var job = JobBuilder.Create
                                            <T>()
            .WithIdentity(jobKey)
            .Build();

        var trigger = TriggerBuilder.Create()
            .WithIdentity($"{jobName}Trigger", groupName)
            .WithCronSchedule(cronExpression)
            .Build();

        await _scheduler.ScheduleJob(job, trigger);
    }

    public static async Task DeleteJob(string jobName, string groupName)
    {
        var jobKey = new JobKey(jobName, groupName);

        if (!await _scheduler.CheckExists(jobKey))
        {
            return;
        }

        await _scheduler.DeleteJob(jobKey);
    }

    public static async Task PauseJob(string jobName, string groupName)
    {
        var jobKey = new JobKey(jobName, groupName);

        if (!await _scheduler.CheckExists(jobKey))
        {
            return;
        }

        await _scheduler.PauseJob(jobKey);
    }

    public static async Task ResumeJob(string jobName, string groupName)
    {
        var jobKey = new JobKey(jobName, groupName);

        if (!await _scheduler.CheckExists(jobKey))
        {
            return;
        }

        await _scheduler.ResumeJob(jobKey);
    }

    public static async Task StartAllJob()
    {
        await _scheduler.Start();
    }
}