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

using Admin.NET.Plugin.AiDOP.Service.S8;
using Furion.Schedule;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;

namespace Admin.NET.Plugin.AiDOP.Job;

/// <summary>
/// 定期扫描挂有 ActiveFlow 且长时间未更新的 S8 异常，输出告警日志和通知记录。
/// </summary>
[JobDetail("job_s8_active_flow_stuck_scan", Description = "S8 ActiveFlow 卡死扫描",
    GroupName = "default", Concurrent = false)]
[Period(300000, TriggerId = "trigger_s8_active_flow_stuck_scan", Description = "每5分钟执行", RunOnStart = true)]
public class S8ActiveFlowStuckScanJob : IJob
{
    private readonly IServiceScopeFactory _scopeFactory;
    private readonly IConfiguration _configuration;
    private readonly ILogger _logger;

    // S8-SCHEDULER-P0-BLEEDING-STOP-CONFIG-1：禁用日志单进程内只输出一次，避免每 tick 刷日志。
    // _firstParseFailLogged 控制 AIDOP_* env 解析失败 warn 单进程内只输出一次（首个失败 env 名）。
    private static int _firstDisabledLogged;
    private static int _firstParseFailLogged;

    // S8-SCHEDULER-CONFIG-ORDER-FIX（合入 P0）：AIDOP_* env override 名称。
    // Furion 4.9.8.24 JSON 装配链后置导致 ASP.NET Core env vars 被 JSON 覆盖，
    // 故此处用 Environment.GetEnvironmentVariable 做 S8 调度开关专项 override。
    private const string EnvSchedulerEnabled = "AIDOP_SCHEDULER_ENABLED";
    private const string EnvS8SchedulerEnabled = "AIDOP_S8_SCHEDULER_ENABLED";

    // S8-ACTIVE-FLOW-TENANT-FILTER-P2-4：当前部署仅租户 1 / 工厂 1 投产，
    // stuck 候选与 dedup 查询补 tenant/factory 过滤；orphan 路径保持 global 0/0 不变。
    private const long DefaultTenantId = 1;
    private const long DefaultFactoryId = 1;

    public S8ActiveFlowStuckScanJob(IServiceScopeFactory scopeFactory, IConfiguration configuration, ILoggerFactory loggerFactory)
    {
        _scopeFactory = scopeFactory;
        _configuration = configuration;
        _logger = loggerFactory.CreateLogger(nameof(S8ActiveFlowStuckScanJob));
    }

    public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
    {
        // S8-SCHEDULER-P0-BLEEDING-STOP-CONFIG-1：环境级 + S8 业务级双开关 gate。
        // 任一为 false 时直接早退；早退前不访问任何业务 service / DB。
        // 注意：[Period(... RunOnStart = true)] 在启动期会立即触发一次，此处 gate 同样生效，
        // 确保 dev/未授权环境启动时不会立刻进入 ScanAsync。
        // env override（合入 CONFIG-ORDER-FIX）：env 不存在/空白 → 沿用 JSON；
        // 存在但 bool.TryParse 失败 → 保留 JSON 值 + 单次 warn（首个失败 env 名，不输出 value）。
        var schedulerEnabled = _configuration.GetValue("Scheduler:Enabled", true);
        var s8SchedulerEnabled = _configuration.GetValue("S8:Scheduler:Enabled", false);
        string? parseFailEnvName = null;
        var envSchedulerRaw = Environment.GetEnvironmentVariable(EnvSchedulerEnabled);
        if (!string.IsNullOrWhiteSpace(envSchedulerRaw))
        {
            if (bool.TryParse(envSchedulerRaw, out var v)) schedulerEnabled = v;
            else parseFailEnvName ??= EnvSchedulerEnabled;
        }
        var envS8SchedulerRaw = Environment.GetEnvironmentVariable(EnvS8SchedulerEnabled);
        if (!string.IsNullOrWhiteSpace(envS8SchedulerRaw))
        {
            if (bool.TryParse(envS8SchedulerRaw, out var v)) s8SchedulerEnabled = v;
            else parseFailEnvName ??= EnvS8SchedulerEnabled;
        }
        if (parseFailEnvName != null && Interlocked.Exchange(ref _firstParseFailLogged, 1) == 0)
        {
            _logger.LogWarning(
                "S8ActiveFlowStuckScanJob env override 解析失败：{EnvName}，已沿用配置值",
                parseFailEnvName);
        }
        if (!schedulerEnabled || !s8SchedulerEnabled)
        {
            if (Interlocked.Exchange(ref _firstDisabledLogged, 1) == 0)
            {
                _logger.LogInformation(
                    "S8ActiveFlowStuckScanJob 被配置禁用：Scheduler:Enabled={Scheduler} S8:Scheduler:Enabled={S8Scheduler}",
                    schedulerEnabled, s8SchedulerEnabled);
            }
            return;
        }

        using var scope = _scopeFactory.CreateScope();
        var watchService = scope.ServiceProvider.GetRequiredService<S8ActiveFlowWatchService>();

        try
        {
            var alertCount = await watchService.ScanAsync(DefaultTenantId, DefaultFactoryId, stoppingToken);
            if (alertCount > 0)
                _logger.LogInformation("S8ActiveFlowStuckScanJob 本轮新增 {Count} 条卡死告警", alertCount);
        }
        catch (OperationCanceledException) when (stoppingToken.IsCancellationRequested)
        {
            _logger.LogInformation("S8ActiveFlowStuckScanJob 收到停止信号，结束本轮扫描");
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "S8ActiveFlowStuckScanJob 扫描失败");
        }
    }
}