AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/DataPlatform/S0Dim/S0DimResults.cs

namespace Admin.NET.Plugin.AiDOP.DataPlatform.S0Dim;

/// <summary>业务键集合三层等价的差集计数。全部为 0 才算通过。</summary>
public sealed class S0DimBizKeyDiff
{
    /// <summary>source 有而 stg 没有。</summary>
    public int SourceMinusStaging { get; set; }

    /// <summary>stg 有而 source 没有。</summary>
    public int StagingMinusSource { get; set; }

    /// <summary>stg 有而 dim 没有。</summary>
    public int StagingMinusDim { get; set; }

    /// <summary>dim 有而 stg 没有。</summary>
    public int DimMinusStaging { get; set; }

    /// <summary>四个方向是否全为 0。</summary>
    public bool IsEqual => SourceMinusStaging == 0 && StagingMinusSource == 0
                           && StagingMinusDim == 0 && DimMinusStaging == 0;
}

/// <summary>某一层业务键的质量（重复 / 空值）。</summary>
public sealed class S0DimBizKeyQuality
{
    /// <summary>层名：source / staging / dim。</summary>
    public string Layer { get; set; } = "";

    /// <summary>总行数。</summary>
    public int Total { get; set; }

    /// <summary>去重后行数。</summary>
    public int Distinct { get; set; }

    /// <summary>空业务键行数（stg 侧出现即意味着 biz_key_expr 回落到了 source_row_id）。</summary>
    public int Blank { get; set; }

    /// <summary>无重复且无空值。</summary>
    public bool IsClean => Total == Distinct && Blank == 0;
}

/// <summary>单个维度的对账结果。</summary>
public sealed class S0DimReconcileResult
{
    /// <summary>维度 Key。</summary>
    public string Key { get; set; } = "";

    /// <summary>租户。</summary>
    public long TenantId { get; set; }

    /// <summary>本轮批次（只读对账时可能为 null）。</summary>
    public string? BatchId { get; set; }

    /// <summary>源表行数（按租户）。</summary>
    public int SourceCount { get; set; }

    /// <summary>staging 行数（四段谓词）。</summary>
    public int StagingCount { get; set; }

    /// <summary>dim 行数（按租户）。</summary>
    public int DimCount { get; set; }

    /// <summary>源表中无法归属租户的行（整条链路不可见，WARN）。</summary>
    public int SourceUntenanted { get; set; }

    /// <summary>dim 中不属于本批的残留行（FULL Replace 后必须为 0）。</summary>
    public int DimBatchImpurity { get; set; }

    /// <summary>业务键集合差集。</summary>
    public S0DimBizKeyDiff BizKeyDiff { get; set; } = new();

    /// <summary>三层业务键质量。</summary>
    public List<S0DimBizKeyQuality> BizKeyQuality { get; set; } = [];

    /// <summary>源侧属性校验和。</summary>
    public string SourceChecksum { get; set; } = "0";

    /// <summary>dim 侧属性校验和。</summary>
    public string DimChecksum { get; set; } = "0";

    /// <summary>dim 业务键重复组数。</summary>
    public int DimDuplicateBizKeys { get; set; }

    /// <summary>镜像唯一性违例组数（未声明时为 -1 表示不适用）。</summary>
    public int MirrorUniqueViolations { get; set; } = -1;

    /// <summary>
    /// 孤儿子行**真实总数**（WARN，不阻断；未声明父维度时为 0）。
    /// 与 <see cref="OrphanChildren"/> 不同：后者受 <c>OrphanSampleLimit</c> 截断，只是样本。
    /// </summary>
    public int OrphanChildCount { get; set; }

    /// <summary>孤儿子行业务键**样本**（最多 <c>OrphanSampleLimit</c> 条）。总数看 <see cref="OrphanChildCount"/>。</summary>
    public List<string> OrphanChildren { get; set; } = [];

    /// <summary>阻断级失败原因（为空表示通过）。</summary>
    public List<string> Failures { get; set; } = [];

    /// <summary>告警（不阻断）。</summary>
    public List<string> Warnings { get; set; } = [];

    /// <summary>无阻断级失败。</summary>
    public bool IsPass => Failures.Count == 0;
}

/// <summary>单个维度的物化结果。</summary>
public sealed class S0DimMaterializeResult
{
    /// <summary>维度 Key。</summary>
    public string Key { get; set; } = "";

    /// <summary>租户。</summary>
    public long TenantId { get; set; }

    /// <summary>批次。</summary>
    public string BatchId { get; set; } = "";

    /// <summary>purge 掉的 staging 行数。</summary>
    public int StagingPurged { get; set; }

    /// <summary>本批拉取到的源行数。</summary>
    public int SourcePulled { get; set; }

    /// <summary>本批写入 staging 的行数。</summary>
    public int StagingWritten { get; set; }

    /// <summary>写入 dim 的行数。</summary>
    public int DimRows { get; set; }

    /// <summary>对账结果。</summary>
    public S0DimReconcileResult? Reconcile { get; set; }

    /// <summary>SUCCESS / FAILED。</summary>
    public string Status { get; set; } = "SUCCESS";

    /// <summary>失败信息。</summary>
    public string? Error { get; set; }
}

/// <summary>一次刷新（可含多个维度）的整体结果。</summary>
public sealed class S0DimRefreshResult
{
    /// <summary>批次（同时是 stg/dim 的 sync_batch_id 与 run log 的 batch_id）。</summary>
    public string BatchId { get; set; } = "";

    /// <summary>租户。</summary>
    public long TenantId { get; set; }

    /// <summary>SUCCESS / SUCCESS_WITH_WARNING / FAILED。</summary>
    public string Status { get; set; } = "SUCCESS";

    /// <summary>逐维度结果。</summary>
    public List<S0DimMaterializeResult> Items { get; set; } = [];

    /// <summary>耗时（毫秒）。</summary>
    public int DurationMs { get; set; }

    /// <summary>run log 主键。</summary>
    public long RunLogId { get; set; }
}