AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP.Tests/S5/MaterialWarehouse/IqcDocumentIdentityContractTests.cs

using Xunit;

namespace Admin.NET.Plugin.AiDOP.Tests.S5.MaterialWarehouse;

/// <summary>
/// S5 IQC 报检分录「采购单号」文档级身份的生产契约（1.0.540）。
///
/// <para>背景：<c>qms_qcp_insappnentry</c> 是 165 侧报检分录的本地镜像。热关注登记的是
/// <c>BizType='PUR_ORDER'</c> + <c>BizKey=&lt;采购单号&gt;</c>，取数 SQL 也写着
/// <c>WHERE d.OrdNbr=@k</c> —— 也就是说采购单号在镜像那一刻就是确定的，
/// 但历史实现只 <c>SELECT e.*</c>，采购单号在 QUERY 层被丢弃。</para>
///
/// <para>本文件守住修好之后的形状，尤其守住三条容易被"顺手优化"破坏的边界：
/// ① 采购单号取<b>标量</b> purOrd，不从 JOIN 行取（否则受扇出与行序影响）；
/// ② <c>FSRCORDERNUM</c> 仍是<b>收货单号</b>，不得被改写成采购单号；
/// ③ 不得借机补 PO <b>行号</b> —— 上游 <c>FSRCBILLID</c>/<c>FSRCBILLENTRYSEQ</c> 实测全空，
///    属 SOURCE CONTRACT GAP，任何本地推导都是弱关联。</para>
/// </summary>
public class IqcDocumentIdentityContractTests
{
    private static string Source(params string[] parts)
    {
        var dir = new DirectoryInfo(AppContext.BaseDirectory);
        while (dir != null && !Directory.Exists(Path.Combine(dir.FullName, "Admin.NET.Plugin.AiDOP")))
            dir = dir.Parent;
        Assert.NotNull(dir);

        var full = Path.Combine(new[] { dir!.FullName, "Admin.NET.Plugin.AiDOP" }.Concat(parts).ToArray());
        Assert.True(File.Exists(full), $"源码文件不存在，路径需同步更新：{full}");
        return File.ReadAllText(full);
    }

    private static string HotWatch() => Source("DataPlatform", "HotWatch", "MdpHotWatchService.cs");

    private static int At(string code, string anchor)
    {
        var i = code.IndexOf(anchor, StringComparison.Ordinal);
        Assert.True(i >= 0, $"未找到锚点：{anchor}");
        return i;
    }

    /// <summary>取 <c>qms_qcp_insappnentry</c> 那一条 UPSERT 的完整区间（含参数绑定）。</summary>
    private static string EntryUpsertBlock()
    {
        var code = HotWatch();
        var start = At(code, "INSERT INTO qms_qcp_insappnentry");
        var end = At(code, "INSERT INTO qms_qcp_inspbill");
        Assert.True(end > start, "分录 UPSERT 应出现在检验单 UPSERT 之前");
        return code[start..end];
    }

    // ── ① 采购单号确实被写入，且来自 watch.BizKey ──────────────────────────────────

    [Fact]
    public void 分录UPSERT_必须写入采购单号列()
    {
        var block = EntryUpsertBlock();
        Assert.Contains("purchase_order_no", block, StringComparison.Ordinal);
        Assert.Contains("@PurchaseOrderNo", block, StringComparison.Ordinal);
    }

    [Fact]
    public void 采购单号必须取标量purOrd_不得从JOIN行取()
    {
        var block = EntryUpsertBlock();

        // 必须绑定局部标量 poNo（由 purOrd 归一而来）
        Assert.Contains("new SugarParameter(\"@PurchaseOrderNo\", poNo", block, StringComparison.Ordinal);

        // 绝不允许从 row 字典里取 —— 那会把 JOIN 扇出与行序引入身份值
        Assert.DoesNotContain("\"@PurchaseOrderNo\", GetString(row", block, StringComparison.Ordinal);
        Assert.DoesNotContain("GetString(row, \"OrdNbr\")", block, StringComparison.Ordinal);
    }

    [Fact]
    public void poNo必须由purOrd归一而来_空值不伪造()
    {
        var code = HotWatch();
        Assert.Contains(
            "var poNo = string.IsNullOrWhiteSpace(purOrd) ? null : purOrd.Trim();",
            code,
            StringComparison.Ordinal);
    }

    // ── ② 既有语义不被破坏 ────────────────────────────────────────────────────────

    [Fact]
    public void FSRCORDERNUM必须仍绑定源行的收货单号()
    {
        var block = EntryUpsertBlock();
        Assert.Contains(
            "new SugarParameter(\"@FSRCORDERNUM\", GetString(row, \"FSRCORDERNUM\")",
            block,
            StringComparison.Ordinal);

        // 不得把采购单号灌进收货号列
        Assert.DoesNotContain("\"@FSRCORDERNUM\", poNo", block, StringComparison.Ordinal);
    }

    [Fact]
    public void 取数SQL不得为了带PO号而改成取JOIN列()
    {
        var code = HotWatch();
        var start = At(code, "case \"QMS_QCP_INSAPPNENTRY\":");
        var end = At(code, "case \"QMS_QCP_INSPECAPPLYN\":");
        var sql = code[start..end];

        // 仍只取 e.*：这是"免疫扇出"的设计前提，改成 e.*, d.* 会让一行分录因多个 PO 行而重复
        Assert.Contains("SELECT TOP 200 e.*", sql, StringComparison.Ordinal);
        Assert.DoesNotContain("d.OrdNbr AS", sql, StringComparison.Ordinal);

        // 作用域键必须仍是 d.OrdNbr=@k —— 这是 poNo 与每行 d.OrdNbr 恒等的依据
        Assert.Contains("d.OrdNbr = @k", sql, StringComparison.Ordinal);
    }

    // ── ③ 不得借机补行级身份 ──────────────────────────────────────────────────────

    [Fact]
    public void 禁止写入PO行号_行级身份属源契约缺口()
    {
        var block = EntryUpsertBlock();

        // FSRCBILLENTRYSEQ / FSRCBILLID 上游实测全空，任何本地推导都是弱关联
        Assert.DoesNotContain("FSRCBILLENTRYSEQ", block, StringComparison.Ordinal);
        Assert.DoesNotContain("FSRCBILLID", block, StringComparison.Ordinal);
        Assert.DoesNotContain("purchase_order_line", block, StringComparison.Ordinal);
        Assert.DoesNotContain("OrdLine", block, StringComparison.Ordinal);
    }

    // ── ④ 幂等与租户 ─────────────────────────────────────────────────────────────

    [Fact]
    public void 分录UPSERT必须按主键幂等_不因扇出重复建行()
    {
        var block = EntryUpsertBlock();
        Assert.Contains("ON DUPLICATE KEY UPDATE", block, StringComparison.Ordinal);
        // 主键沿用 165 的 id：同一分录被多次镜像只会更新，不会新增
        Assert.Contains("new SugarParameter(\"@Id\", id)", block, StringComparison.Ordinal);
    }

    [Fact]
    public void 采购单号为空时不得把已有权威值打回NULL()
    {
        var block = EntryUpsertBlock();
        Assert.Contains(
            "purchase_order_no = IF(IFNULL(VALUES(purchase_order_no),'')='',",
            block,
            StringComparison.Ordinal);
    }

    [Fact]
    public void 租户必须来自参数而非远端Domain()
    {
        var block = EntryUpsertBlock();
        Assert.Contains("new SugarParameter(\"@TenantId\", tenantId)", block, StringComparison.Ordinal);
        // 既有的"租户只在为空时写入"守卫不得丢
        Assert.Contains(
            "tenant_id = IF(IFNULL(tenant_id,0)=0, VALUES(tenant_id), tenant_id)",
            block,
            StringComparison.Ordinal);
    }

    [Fact]
    public void 无法解析租户时必须整体跳过_不得落无主数据()
    {
        var code = HotWatch();
        var start = At(code, "private async Task ApplyIqcAsync");
        var body = code[start..(start + 1200)];
        Assert.Contains("if (tenantId <= 0)", body, StringComparison.Ordinal);
        Assert.Contains("return;", body, StringComparison.Ordinal);
    }

    // ── ⑤ 身份与质量正交 ─────────────────────────────────────────────────────────

    [Fact]
    public void 镜像不得按检验判定过滤_身份与质量是正交维度()
    {
        var code = HotWatch();
        var start = At(code, "private async Task ApplyIqcAsync");
        var end = At(code, "private async Task ApplyPurchaseReceiptAsync");
        var body = code[start..end];

        // pd=0/pd=1 都必须照常镜像，否则不合格单将拿不到采购单身份
        Assert.DoesNotContain("pd = 0", body, StringComparison.Ordinal);
        Assert.DoesNotContain("pd=0", body, StringComparison.Ordinal);
    }

    // ── ⑥ 检验单经 FK 回到分录的链路不得断 ────────────────────────────────────────

    [Fact]
    public void 检验单必须保留回到分录的外键()
    {
        var code = HotWatch();
        var start = At(code, "INSERT INTO qms_qcp_inspbill");
        var block = code[start..(start + 2600)];

        // hid → insappnentry.id，lydjbh → inspecapplyn.FBILLNO：
        // 有这两把 FK，检验单就不需要重复存采购单号
        Assert.Contains("hid", block, StringComparison.Ordinal);
        Assert.Contains("lydjbh", block, StringComparison.Ordinal);
    }

    // ── ⑦ 1.0.536 采购身份桥不得回归 ──────────────────────────────────────────────

    [Fact]
    public void S3身份桥的采购申请投影不得被移除()
    {
        var s3 = Source("Supply", "S3MdpSyncTransformService.cs");
        Assert.Contains("purchase_request_no", s3, StringComparison.Ordinal);
        Assert.Contains("sales_order_entry_id", s3, StringComparison.Ordinal);
    }
}