AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/Service/S8/Rules/DataAccess/S8DatasetEnableGate.cs

using Admin.NET.Plugin.AiDOP.Entity.S8;

namespace Admin.NET.Plugin.AiDOP.Service.S8.Rules.DataAccess;

/// <summary>Enable Gate 的检查结果。失败时带明确 reason code，便于前端与运维定位。</summary>
public sealed class S8DatasetEnableCheck
{
    private S8DatasetEnableCheck(bool ok, string? reasonCode, string? message)
    {
        Ok = ok;
        ReasonCode = reasonCode;
        Message = message;
    }

    public bool Ok { get; }
    public string? ReasonCode { get; }
    public string? Message { get; }

    public static S8DatasetEnableCheck Pass() => new(true, null, null);
    public static S8DatasetEnableCheck Fail(string reasonCode, string message) => new(false, reasonCode, message);
}

/// <summary>
/// STANDARD_DATASET 规则的统一启用前校验。
///
/// 校验顺序：<b>先查目录层可判定的问题，再查实现层问题</b>。
/// 理由——"这个数据集做不了 TIMEOUT"是定义问题，等 Provider 上线也不会变好；
/// 若先报 provider_not_registered 会误导配置方以为等实现即可。
///
///   1. dataset_code 是否填写      → dataset_code_missing
///   2. Catalog 中是否定义         → dataset_not_defined
///   3. 定义是否停用               → dataset_not_ready
///   4. 规则类型是否已知           → dataset_unknown_rule_type
///   5. 目录机制能力是否支持       → dataset_capability_mismatch
///   6. 目录 canonical 字段是否齐备 → dataset_missing_required_field
///   7. Provider 是否注册          → dataset_provider_not_registered
///   8. Provider 编码是否一致      → dataset_provider_code_mismatch
///   9. Provider 能力是否同样满足   → dataset_capability_mismatch / dataset_missing_required_field
///  10. 租户 / 工厂作用域          → invalid_tenant_scope / invalid_factory_scope
///
/// LEGACY_SQL 规则不经过本 Gate（其校验由既有数据源 / expression 检查承担）。
/// </summary>
public class S8DatasetEnableGate : ITransient
{
    private readonly IS8DatasetCatalog _catalog;
    private readonly S8MonitoringDataProviderRegistry _registry;

    public S8DatasetEnableGate(IS8DatasetCatalog catalog, S8MonitoringDataProviderRegistry registry)
    {
        _catalog = catalog;
        _registry = registry;
    }

    /// <summary>检查规则是否具备启用条件。LEGACY_SQL 直接通过。</summary>
    public S8DatasetEnableCheck Check(AdoS8WatchRule rule, long tenantId, long factoryId)
    {
        if (!S8DataAccessMode.IsAcceptable(rule.DataAccessMode))
            return S8DatasetEnableCheck.Fail(
                "data_access_mode_invalid",
                $"未知的取数模式 {rule.DataAccessMode}");

        if (S8DataAccessMode.Resolve(rule.DataAccessMode) == S8DataAccessMode.LegacySql)
            return S8DatasetEnableCheck.Pass();

        // ① dataset_code
        if (string.IsNullOrWhiteSpace(rule.DatasetCode))
            return S8DatasetEnableCheck.Fail(
                S8DatasetReasonCode.CodeMissing,
                "STANDARD_DATASET 模式的规则必须提供 dataset_code");

        // ② Catalog 定义
        var definition = _catalog.Find(rule.DatasetCode);
        if (definition == null)
            return S8DatasetEnableCheck.Fail(
                S8DatasetReasonCode.NotDefined,
                $"数据集 {rule.DatasetCode} 未在目录中定义");

        // ③ 定义是否停用
        if (!definition.IsActive)
            return S8DatasetEnableCheck.Fail(
                S8DatasetReasonCode.NotReady,
                $"数据集 {definition.DatasetCode} 已停用，不能用于规则执行");

        // ④ 规则类型已知
        if (!S8RuleTypeFieldRequirements.IsKnown(rule.RuleType))
            return S8DatasetEnableCheck.Fail(
                S8DatasetReasonCode.UnknownRuleType,
                $"规则类型 {rule.RuleType} 不在 canonical 词表内，无法校验数据集能力");

        // ⑤ 目录机制能力（定义层问题，先于 Provider 报出）
        if (!definition.Capabilities.Supports(rule.RuleType))
            return S8DatasetEnableCheck.Fail(
                S8DatasetReasonCode.CapabilityMismatch,
                $"数据集 {definition.DatasetCode} 不支持 {rule.RuleType} 类规则");

        // ⑥ 目录 canonical 字段齐备（防"声明支持某机制但拿不出必需字段"的自相矛盾配置）
        var missing = definition.Capabilities.MissingFieldsFor(rule.RuleType);
        if (missing is { Count: > 0 })
            return S8DatasetEnableCheck.Fail(
                S8DatasetReasonCode.MissingRequiredField,
                $"数据集 {definition.DatasetCode} 缺少 {rule.RuleType} 必需字段：{string.Join(", ", missing)}");

        // ⑦ Provider 注册
        if (!_registry.IsRegistered(definition.DatasetCode))
            return S8DatasetEnableCheck.Fail(
                S8DatasetReasonCode.ProviderNotRegistered,
                $"数据集 {definition.DatasetCode} 已定义但尚无 Provider 实现，可保存配置但不能启用");

        // ⑧ Provider 自报编码与目录一致
        var provider = _registry.Resolve(definition.DatasetCode);
        if (!string.Equals(provider.DatasetCode?.Trim(), definition.DatasetCode, StringComparison.OrdinalIgnoreCase))
            return S8DatasetEnableCheck.Fail(
                S8DatasetReasonCode.ProviderCodeMismatch,
                $"Provider 自报数据集编码 {provider.DatasetCode} 与目录定义 {definition.DatasetCode} 不一致");

        // ⑨ Provider 实际能力必须与目录声明同样满足（不一致时按更严格的一方拒绝）
        if (!provider.Capabilities.Supports(rule.RuleType))
            return S8DatasetEnableCheck.Fail(
                S8DatasetReasonCode.CapabilityMismatch,
                $"Provider 实现不支持 {rule.RuleType} 类规则（数据集 {definition.DatasetCode}）");

        var providerMissing = provider.Capabilities.MissingFieldsFor(rule.RuleType);
        if (providerMissing is { Count: > 0 })
            return S8DatasetEnableCheck.Fail(
                S8DatasetReasonCode.MissingRequiredField,
                $"Provider 实现缺少 {rule.RuleType} 必需字段：{string.Join(", ", providerMissing)}");

        // ⑩ 作用域
        if (tenantId <= 0)
            return S8DatasetEnableCheck.Fail(S8DatasetReasonCode.InvalidTenantScope, "租户作用域非法");
        if (factoryId <= 0)
            return S8DatasetEnableCheck.Fail(S8DatasetReasonCode.InvalidFactoryScope, "工厂作用域非法");

        return S8DatasetEnableCheck.Pass();
    }

    /// <summary>检查并在失败时抛 <see cref="S8BizException"/>（配置类错误，API 层直接回给调用方）。</summary>
    public void EnsureCanEnable(AdoS8WatchRule rule, long tenantId, long factoryId)
    {
        var result = Check(rule, tenantId, factoryId);
        if (!result.Ok)
            throw new S8BizException($"[{result.ReasonCode}] {result.Message}");
    }
}