EmailBill/WebApi/Expand.cs

using Quartz;
using Service.Jobs;

namespace WebApi;

public static class Expand
{
    public static void AddScheduler(this WebApplicationBuilder builder)
    {
        builder.Services.AddQuartz(q =>
        {
            // 配置调度器
            q.SchedulerId = "EmailBillScheduler";

            // 配置邮件同步任务 - 每10分钟执行一次
            var emailJobKey = new JobKey("EmailSyncJob");
            q.AddJob<EmailSyncJob>(opts => opts
                .WithIdentity(emailJobKey)
                .WithDescription("邮件同步任务"));
            q.AddTrigger(opts => opts
                .ForJob(emailJobKey)
                .WithIdentity("EmailSyncTrigger")
                .WithCronSchedule("0 0/30 * * * ?") // 每30分钟执行
                .WithDescription("每30分钟同步一次邮件"));

            // 配置周期性账单任务 - 每天早上6点执行
            var periodicBillJobKey = new JobKey("PeriodicBillJob");
            q.AddJob<PeriodicBillJob>(opts => opts
                .WithIdentity(periodicBillJobKey)
                .WithDescription("周期性账单任务"));
            q.AddTrigger(opts => opts
                .ForJob(periodicBillJobKey)
                .WithIdentity("PeriodicBillTrigger")
                .WithCronSchedule("0 0 6 * * ?") // 每天早上6点执行
                .WithDescription("每天早上6点执行周期性账单任务"));

            // 配置预算归档任务 - 每个月1号晚11点执行
            var budgetArchiveJobKey = new JobKey("BudgetArchiveJob");
            q.AddJob<BudgetArchiveJob>(opts => opts
                .WithIdentity(budgetArchiveJobKey)
                .WithDescription("预算归档任务"));
            q.AddTrigger(opts => opts
                .ForJob(budgetArchiveJobKey)
                .WithIdentity("BudgetArchiveTrigger")
                .WithCronSchedule("0 0 23 1 * ?") // 每个月1号晚11点执行
                .WithDescription("每个月1号晚11点执行预算归档"));

            // 配置数据库备份任务 - 每天早上6点执行
            var dbBackupJobKey = new JobKey("DbBackupJob");
            q.AddJob<DbBackupJob>(opts => opts
                .WithIdentity(dbBackupJobKey)
                .WithDescription("数据库备份任务"));
            q.AddTrigger(opts => opts
                .ForJob(dbBackupJobKey)
                .WithIdentity("DbBackupTrigger")
                .WithCronSchedule("0 0 6 * * ?") // 每天早上6点执行
                .WithDescription("每天早上6点执行数据库备份"));

            // 配置日志清理任务 - 每天凌晨2点执行
            var logCleanupJobKey = new JobKey("LogCleanupJob");
            q.AddJob<LogCleanupJob>(opts => opts
                .WithIdentity(logCleanupJobKey)
                .WithDescription("日志清理任务"));
            q.AddTrigger(opts => opts
                .ForJob(logCleanupJobKey)
                .WithIdentity("LogCleanupTrigger")
                .WithCronSchedule("0 0 2 * * ?") // 每天凌晨2点执行
                .WithDescription("每天凌晨2点执行日志清理(保留30天)"));

            // 配置分类图标生成任务 - 每24小时执行一次
            var categoryIconJobKey = new JobKey("CategoryIconGenerationJob");
            q.AddJob<CategoryIconGenerationJob>(opts => opts
                .WithIdentity(categoryIconJobKey)
                .WithDescription("分类图标生成任务"));
            q.AddTrigger(opts => opts
                .ForJob(categoryIconJobKey)
                .WithIdentity("CategoryIconGenerationTrigger")
                .WithCronSchedule("0 0 0 * * ?") // 每24小时执行一次
                .WithDescription("每24小时扫描并为无图标分类生成SVG图标"));

            // 配置节假日同步任务 - 每10天凌晨3点执行
            var holidaySyncJobKey = new JobKey("HolidaySyncJob");
            q.AddJob<HolidaySyncJob>(opts => opts
                .WithIdentity(holidaySyncJobKey)
                .WithDescription("节假日同步任务"));
            q.AddTrigger(opts => opts
                .ForJob(holidaySyncJobKey)
                .WithIdentity("HolidaySyncTrigger")
                .WithCronSchedule("0 0 3 */10 * ?") // 每10天凌晨3点执行
                .WithDescription("每10天同步节假日数据"));
        });

        // 添加 Quartz Hosted Service
        builder.Services.AddQuartzHostedService(options =>
        {
            // 等待任务完成后再关闭
            options.WaitForJobsToComplete = true;
        });
    }
}