// 3.x 的 Job 定義
public class MyJob : IJob
{
    public async Task Execute(IJobExecutionContext context)
    {
        // 異步操作示例
        await Task.Delay(1);
    }
}

# 核心包
dotnet add package Quartz
# ASP.NET Core 托管集成
dotnet add package Quartz.Extensions.Hosting
# 如需持久化支持（例如 SQL Server）
dotnet add package Quartz.Plugins
dotnet add package Quartz.Serialization.Json

using Quartz;
public class HelloJob : IJob
{
    private readonly ILogger<HelloJob> _logger;
    public HelloJob(ILogger<HelloJob> logger)
    {
        _logger = logger;
    }
    public Task Execute(IJobExecutionContext context)
    {
        _logger.LogInformation("Hello! 當(dāng)前時(shí)間: {Time}", DateTime.Now);
        return Task.CompletedTask;
    }
}

var builder = WebApplication.CreateBuilder(args);
builder.Services.AddQuartz(q =>
{
    // 注冊(cè) Job
    var jobKey = new JobKey("HelloJob");
    q.AddJob<HelloJob>(opts => opts.WithIdentity(jobKey));
    // 注冊(cè)觸發(fā)器 - SimpleSchedule 方式
    q.AddTrigger(opts => opts
        .ForJob(jobKey)
        .WithIdentity("HelloJob-trigger")
        .WithSimpleSchedule(x => x.WithIntervalInSeconds(10).RepeatForever()));
});
// 添加 Quartz 托管服務(wù)，隨應(yīng)用生命周期啟停
builder.Services.AddQuartzHostedService(q => q.WaitForJobsToComplete = true);
var app = builder.Build();
app.Run();

q.AddTrigger(opts => opts
    .ForJob("HelloJob")
    .WithIdentity("simple-trigger")
    .WithSimpleSchedule(x => x
        .WithIntervalInMinutes(30)  // 每 30 分鐘執(zhí)行
        .RepeatForever()));         // 無(wú)限重復(fù)

q.AddTrigger(opts => opts
    .ForJob("HelloJob")
    .WithIdentity("cron-trigger")
    .WithCronSchedule("0 0 9 ? * MON-FRI")); // 工作日早上9點(diǎn)

0 0/5 * * * ?              # 每 5 分鐘執(zhí)行一次
0 0 2 * * ?                # 每天凌晨 2 點(diǎn)執(zhí)行
0 15 10 ? * MON-FRI        # 周一至周五上午 10:15 執(zhí)行
0 0 9 ? * 6L               # 每月最后一個(gè)周五上午 9 點(diǎn)
0 0/30 9-17 ? * MON-FRI    # 工作日 9:00-17:00 內(nèi)每 30 分鐘執(zhí)行

var trigger = TriggerBuilder.Create()
    .WithIdentity("officeHoursTrigger")
    .WithSchedule(DailyTimeIntervalScheduleBuilder.Create()
        .OnMondayThroughFriday()
        .StartingDailyAt(TimeOfDay.HourAndMinuteOfDay(9, 0))
        .EndingDailyAt(TimeOfDay.HourAndMinuteOfDay(17, 0))
        .WithIntervalInHours(2))
    .Build();

// 定義有依賴注入的 Job
public class EmailJob : IJob
{
    private readonly IEmailService _emailService;
    public EmailJob(IEmailService emailService)
    {
        _emailService = emailService;
    }
    public async Task Execute(IJobExecutionContext context)
    {
        await _emailService.SendAsync("定時(shí)郵件", "來(lái)自 Quartz.NET 的問候");
    }
}
// 注冊(cè)服務(wù)和 Job
builder.Services.AddTransient<IEmailService, EmailService>();
builder.Services.AddQuartz(q =>
{
    q.UseMicrosoftDependencyInjectionJobFactory(); // 啟用 DI 工廠
    q.AddJob<EmailJob>(opts => opts.WithIdentity("EmailJob"));
});

{
  "Quartz": {
    "Scheduler": {
      "InstanceName": "My Scheduler",
      "InstanceId": "AUTO"
    },
    "ThreadPool": {
      "MaxConcurrency": 10
    },
    "JobStore": {
      "Type": "Quartz.Impl.AdoJobStore.JobStoreTX, Quartz",
      "DataSource": "default",
      "TablePrefix": "QRTZ_"
    },
    "DataSource": {
      "default": {
        "Provider": "SqlServer",
        "ConnectionString": "Server=localhost;Database=quartznet"
      }
    }
  }
}

builder.Services.AddQuartz(Configuration.GetSection("Quartz"), q =>
{
    // 代碼配置可與 JSON 配置并存
});

public class LoggingJobListener : JobListenerSupport
{
    public override string Name => "LoggingJobListener";
    public override ValueTask JobToBeExecuted(IJobExecutionContext context)
    {
        Console.WriteLine($"Job [{context.JobDetail.Key}] 即將執(zhí)行...");
        return ValueTask.CompletedTask;
    }
    public override ValueTask JobWasExecuted(IJobExecutionContext context,
        JobExecutionException? jobException)
    {
        if (jobException == null)
            Console.WriteLine($"Job [{context.JobDetail.Key}] 執(zhí)行成功");
        else
            Console.WriteLine($"Job [{context.JobDetail.Key}] 執(zhí)行失敗: {jobException.Message}");
        return ValueTask.CompletedTask;
    }
}

public class MetricsTriggerListener : TriggerListenerSupport
{
    public override string Name => "MetricsTriggerListener";
    public override ValueTask TriggerFired(ITrigger trigger, IJobExecutionContext context)
    {
        // 觸發(fā)器觸發(fā)時(shí)記錄指標(biāo)
        return ValueTask.CompletedTask;
    }
    public override ValueTask TriggerMisfired(ITrigger trigger)
    {
        // 處理錯(cuò)過觸發(fā)的情況
        Console.WriteLine($"Trigger [{trigger.Key}] 錯(cuò)過觸發(fā)!");
        return ValueTask.CompletedTask;
    }
}

scheduler.ListenerManager.AddJobListener(
    myJobListener,
    KeyMatcher<JobKey>.KeyEquals(new JobKey("myJobName", "myJobGroup")));
// 監(jiān)聽特定組的所有 Job
scheduler.ListenerManager.AddJobListener(
    myJobListener,
    GroupMatcher<JobKey>.GroupEquals("myJobGroup"));
// 監(jiān)聽所有 Job
scheduler.ListenerManager.AddJobListener(
    myJobListener,
    GroupMatcher<JobKey>.AnyGroup());

// 快速的內(nèi)存調(diào)度器（用于高頻輕量任務(wù)）
builder.Services.AddQuartz("FastScheduler", q =>
{
    q.UseInMemoryStore();
    q.UseDefaultThreadPool(tp => tp.MaxConcurrency = 5);
    q.ScheduleJob<NotificationJob>(trigger => trigger
        .WithSimpleSchedule(x => x.WithIntervalInSeconds(30).RepeatForever()));
});
// 持久化的數(shù)據(jù)庫(kù)調(diào)度器（用于關(guān)鍵業(yè)務(wù)任務(wù)）
builder.Services.AddQuartz("DurableScheduler", q =>
{
    q.UsePersistentStore(s =>
    {
        s.UseSqlServer(sql => sql.ConnectionString = "your connection string");
    });
    q.ScheduleJob<ReportJob>(trigger => trigger
        .WithCronSchedule("0 0 2 * * ?"));
});
// 單次調(diào)用啟動(dòng)所有命名調(diào)度器
builder.Services.AddQuartzHostedService(options =>
{
    options.WaitForJobsToComplete = true;
});

// 動(dòng)態(tài)添加作業(yè)
await scheduler.ScheduleJob(jobDetail, trigger);
// 暫停作業(yè)
await scheduler.PauseJob(jobKey);
// 恢復(fù)作業(yè)
await scheduler.ResumeJob(jobKey);
// 刪除作業(yè)
await scheduler.DeleteJob(jobKey);
// 檢查作業(yè)是否存在
bool exists = await scheduler.CheckExists(jobKey);

// 在 Trigger 定義時(shí)傳遞參數(shù)（示例）
q.AddTrigger(opts => opts
    .ForJob("HelloJob")
    .UsingJobData("RetryCount", "3")
    .UsingJobData("TimeoutSeconds", "30")
    .WithCronSchedule("0 0/10 * * * ?"));