AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/Job/MdpOutboxPushJob.cs

using Admin.NET.Plugin.AiDOP.DataPlatform.Executors;
using Furion.Schedule;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;

namespace Admin.NET.Plugin.AiDOP.Job;

/// <summary>
/// 出站 Outbox 兜底扫描：每 60 秒捡漏（进程重启期间入队、触发失败、重试到期）。
/// 主路径为入队后 <see cref="MdpOutboxWakeSignal"/> 事件驱动推送。
/// </summary>
[JobDetail("job_mdp_outbox_push", Description = "MDP Outbox 出站推送（兜底）", GroupName = "default", Concurrent = false)]
[PeriodSeconds(60, TriggerId = "trigger_mdp_outbox_push", Description = "每 60 秒兜底扫描 Outbox", RunOnStart = true)]
public class MdpOutboxPushJob : IJob
{
    private readonly IServiceScopeFactory _scopeFactory;
    private readonly ILogger _logger;

    public MdpOutboxPushJob(IServiceScopeFactory scopeFactory, ILoggerFactory loggerFactory)
    {
        _scopeFactory = scopeFactory;
        _logger = loggerFactory.CreateLogger(nameof(MdpOutboxPushJob));
    }

    public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
    {
        using var scope = _scopeFactory.CreateScope();
        var dispatcher = scope.ServiceProvider.GetRequiredService<MdpTargetPushDispatcher>();
        var (success, failed, skipped) = await dispatcher.PushPendingAsync(
            MdpTargetPushDispatcher.DefaultTake, stoppingToken);
        if (success + failed + skipped > 0)
            _logger.LogInformation("[MdpOutboxPushJob] success={Success} failed={Failed} retrying={Skipped}", success, failed, skipped);
    }
}