namespace Admin.NET.Plugin.AiDOP.DataPlatform.S0Dim;
/// 业务键集合三层等价的差集计数。全部为 0 才算通过。
public sealed class S0DimBizKeyDiff
{
/// source 有而 stg 没有。
public int SourceMinusStaging { get; set; }
/// stg 有而 source 没有。
public int StagingMinusSource { get; set; }
/// stg 有而 dim 没有。
public int StagingMinusDim { get; set; }
/// dim 有而 stg 没有。
public int DimMinusStaging { get; set; }
/// 四个方向是否全为 0。
public bool IsEqual => SourceMinusStaging == 0 && StagingMinusSource == 0
&& StagingMinusDim == 0 && DimMinusStaging == 0;
}
/// 某一层业务键的质量（重复 / 空值）。
public sealed class S0DimBizKeyQuality
{
/// 层名：source / staging / dim。
public string Layer { get; set; } = "";
/// 总行数。
public int Total { get; set; }
/// 去重后行数。
public int Distinct { get; set; }
/// 空业务键行数（stg 侧出现即意味着 biz_key_expr 回落到了 source_row_id）。
public int Blank { get; set; }
/// 无重复且无空值。
public bool IsClean => Total == Distinct && Blank == 0;
}
/// 单个维度的对账结果。
public sealed class S0DimReconcileResult
{
/// 维度 Key。
public string Key { get; set; } = "";
/// 租户。
public long TenantId { get; set; }
/// 本轮批次（只读对账时可能为 null）。
public string? BatchId { get; set; }
/// 源表行数（按租户）。
public int SourceCount { get; set; }
/// staging 行数（四段谓词）。
public int StagingCount { get; set; }
/// dim 行数（按租户）。
public int DimCount { get; set; }
/// 源表中无法归属租户的行（整条链路不可见，WARN）。
public int SourceUntenanted { get; set; }
/// dim 中不属于本批的残留行（FULL Replace 后必须为 0）。
public int DimBatchImpurity { get; set; }
/// 业务键集合差集。
public S0DimBizKeyDiff BizKeyDiff { get; set; } = new();
/// 三层业务键质量。
public List BizKeyQuality { get; set; } = [];
/// 源侧属性校验和。
public string SourceChecksum { get; set; } = "0";
/// dim 侧属性校验和。
public string DimChecksum { get; set; } = "0";
/// dim 业务键重复组数。
public int DimDuplicateBizKeys { get; set; }
/// 镜像唯一性违例组数（未声明时为 -1 表示不适用）。
public int MirrorUniqueViolations { get; set; } = -1;
///
/// 孤儿子行**真实总数**（WARN，不阻断；未声明父维度时为 0）。
/// 与 不同：后者受 OrphanSampleLimit 截断，只是样本。
///
public int OrphanChildCount { get; set; }
/// 孤儿子行业务键**样本**（最多 OrphanSampleLimit 条）。总数看 。
public List OrphanChildren { get; set; } = [];
/// 阻断级失败原因（为空表示通过）。
public List Failures { get; set; } = [];
/// 告警（不阻断）。
public List Warnings { get; set; } = [];
/// 无阻断级失败。
public bool IsPass => Failures.Count == 0;
}
/// 单个维度的物化结果。
public sealed class S0DimMaterializeResult
{
/// 维度 Key。
public string Key { get; set; } = "";
/// 租户。
public long TenantId { get; set; }
/// 批次。
public string BatchId { get; set; } = "";
/// purge 掉的 staging 行数。
public int StagingPurged { get; set; }
/// 本批拉取到的源行数。
public int SourcePulled { get; set; }
/// 本批写入 staging 的行数。
public int StagingWritten { get; set; }
/// 写入 dim 的行数。
public int DimRows { get; set; }
/// 对账结果。
public S0DimReconcileResult? Reconcile { get; set; }
/// SUCCESS / FAILED。
public string Status { get; set; } = "SUCCESS";
/// 失败信息。
public string? Error { get; set; }
}
/// 一次刷新（可含多个维度）的整体结果。
public sealed class S0DimRefreshResult
{
/// 批次（同时是 stg/dim 的 sync_batch_id 与 run log 的 batch_id）。
public string BatchId { get; set; } = "";
/// 租户。
public long TenantId { get; set; }
/// SUCCESS / SUCCESS_WITH_WARNING / FAILED。
public string Status { get; set; } = "SUCCESS";
/// 逐维度结果。
public List Items { get; set; } = [];
/// 耗时（毫秒）。
public int DurationMs { get; set; }
/// run log 主键。
public long RunLogId { get; set; }
}