Koto.Scheduling

Плановые джобы и batch-обработка на Quartz.NET.

Что внутри

Тип	Назначение
`IScheduledJob`	Маркерный интерфейс: `JobId` + `ExecuteAsync`
`ScheduledJobBase`	Обёртка Quartz `IJob` со структурированным логированием и обработкой ошибок
`BatchJobBase<TItem>`	Курсорный batch-процессор: выборка → обработка страницами
`AddKotoScheduling(builder => ...)`	Регистрация в DI одной строкой

Настройка

// Program.cs
builder.Services.AddKotoScheduling(scheduling =>
{
    scheduling.AddJob<SendDailyDigestJob>("0 0 8 * * ?");  // каждый день в 08:00
    scheduling.AddJob<CleanupExpiredTokensJob>("0 */15 * * * ?"); // каждые 15 минут

    // Для HPA / нескольких подов: включаем кластерное хранилище джобов на PostgreSQL
    scheduling.UseJobStore(builder.Configuration.GetConnectionString("QuartzDb")!);
});

Реализация плановой джобы

public class SendDailyDigestJob : ScheduledJobBase
{
    private readonly IUserRepository _users;
    private readonly IEmailService _email;

    public override string JobId => "orders.send-daily-digest";

    public SendDailyDigestJob(
        IUserRepository users,
        IEmailService email,
        ILogger<ScheduledJobBase> logger) : base(logger)
    {
        _users = users;
        _email = email;
    }

    public override async Task ExecuteAsync(CancellationToken ct)
    {
        var users = await _users.GetUsersWithPendingDigestAsync(ct);
        foreach (var user in users)
            await _email.SendDigestAsync(user, ct);
    }
}

Реализация batch-джобы

public class SyncProductsJob : BatchJobBase<ProductDto>
{
    public override string JobId => "catalog.sync-products";

    protected override int BatchSize => 50;

    public SyncProductsJob(ILogger<BatchJobBase<ProductDto>> logger) : base(logger) { }

    protected override Task<IReadOnlyList<ProductDto>> FetchBatchAsync(
        int offset, int batchSize, CancellationToken ct)
        => _api.GetProductsAsync(offset, batchSize, ct);

    protected override Task ProcessItemAsync(ProductDto item, CancellationToken ct)
        => _repo.UpsertAsync(item, ct);
}

Распределённая блокировка (HPA / несколько подов)

Вызовите .UseJobStore(connectionString), чтобы переключить Quartz на кластерный режим на PostgreSQL. Каждый триггер в любой момент выполняет только один под — дополнительная распределённая блокировка не нужна. Требует применения схемы Quartz для PostgreSQL к базе данных.