EVCB_OCPP.TaskScheduler/EVCB_OCPP.TaskScheduler/Jobs/JobScheduler.cs

using Microsoft.Extensions.DependencyInjection;
using Quartz;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace EVCB_OCPP.TaskScheduler.Jobs
{
    public static class JobScheduler
    {
        public static void AddTaskSchedulerQuartz(this IServiceCollection services)
        {
            services.AddQuartz(q => {

                var CheckEVSEOnlineJobKey = new JobKey("job1", "group1");
                q.AddJob<CheckEVSEOnlineJob>(opts => { opts.WithIdentity(CheckEVSEOnlineJobKey); });

                var StartTransacionReportJobKey = new JobKey("job2", "group1");
                q.AddJob<StartTransacionReportJob>(opts => { opts.WithIdentity(StartTransacionReportJobKey); });

                var StopTransacionReportJobKey = new JobKey("job3", "group1");
                q.AddJob<StopTransacionReportJob>(opts => { opts.WithIdentity(StopTransacionReportJobKey); });

                var CheckExecutionCmdJobKey = new JobKey("job4", "group1");
                q.AddJob<CheckExecutionCmdJob>(opts => { opts.WithIdentity(CheckExecutionCmdJobKey); });

                var ExecutionCmdReportJobKey = new JobKey("job5", "group1");
                q.AddJob<ExecutionCmdReportJob>(opts => { opts.WithIdentity(ExecutionCmdReportJobKey); });

                q.AddTrigger(opts =>
                {
                    opts
                    .ForJob(CheckEVSEOnlineJobKey)
                    .WithIdentity("trigger1", "group1")
                    .StartNow()
                    .WithSimpleSchedule(x => x
                        .WithIntervalInSeconds(10)
                        .RepeatForever());
                });

                q.AddTrigger(opts =>
                {
                    opts
                    .ForJob(StartTransacionReportJobKey)
                    .WithIdentity("trigger2", "group1")
                    .StartNow()
                    .WithSimpleSchedule(x => x
                        .WithIntervalInSeconds(10)
                        .RepeatForever());
                });

                q.AddTrigger(opts =>
                {
                    opts
                    .ForJob(StopTransacionReportJobKey)
                    .WithIdentity("trigger3", "group1")
                    .StartNow()
                    .WithSimpleSchedule(x => x
                        .WithIntervalInSeconds(10)
                        .RepeatForever());
                });

                q.AddTrigger(opts =>
                {
                    opts
                    .ForJob(CheckExecutionCmdJobKey)
                    .WithIdentity("trigger4", "group1")
                    .StartNow()
                    .WithSimpleSchedule(x => x
                        .WithIntervalInSeconds(10)
                        .RepeatForever());
                });

                q.AddTrigger(opts =>
                {
                    opts
                    .ForJob(ExecutionCmdReportJobKey)
                    .WithIdentity("trigger5", "group1")
                    .StartNow()
                    .WithSimpleSchedule(x => x
                        .WithIntervalInSeconds(10)
                        .RepeatForever());
                });
            });
        }
    }
}