AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP.Tests/S6/Manufacturing/S6ProcessInspectionReviewContractTests.cs

using Xunit;

namespace Admin.NET.Plugin.AiDOP.Tests.S6.Manufacturing;

/// <summary>
/// S6 Phase 1D 桥接契约测试：Phase 1C bill 接入 ApprovalFlow（BizType=S6_PROCESS_INSPECTION）。
/// 覆盖：独立 BizType 绑 bill.id、提交门槛 COMPLETED、FAIL→disposition_required、质量结果不改写、tenant/幂等/N1=Initiator。
/// </summary>
public class S6ProcessInspectionReviewContractTests
{
    private static string Svc() => File.ReadAllText(FindFile("server", "Plugins", "Admin.NET.Plugin.AiDOP", "Manufacturing", "S6ProcessInspectionReviewService.cs"));
    private static string Handler() => File.ReadAllText(FindFile("server", "Plugins", "Admin.NET.Plugin.AiDOP", "Manufacturing", "S6ProcessInspectionFlowBizHandler.cs"));
    private static string Const() => File.ReadAllText(FindFile("server", "Plugins", "Admin.NET.Plugin.AiDOP", "Manufacturing", "S6ProcessInspectionFlowConst.cs"));
    private static string Seed() => File.ReadAllText(FindFile("server", "Plugins", "Admin.NET.Plugin.AiDOP", "Infrastructure", "S6ProcessInspectionFlowSeed.cs"));

    [Fact]
    public void BizType_IsIndependent_BoundToProcessInspectionBill()
    {
        Assert.Contains("\"S6_PROCESS_INSPECTION\"", Const());
        var s = Svc();
        // business_id = process_inspection_bill.id（StartFlow BizId=input.BillId），不绑 qms_gcjyd
        Assert.Contains("BizId = input.BillId", s);
        Assert.Contains("FROM ado_s6_process_inspection_bill", s);
        Assert.DoesNotContain("qms_gcjyd", s);
    }

    [Fact]
    public void Submit_Gate_RequiresCompleted()
    {
        var s = Svc();
        Assert.Contains("INSPECTION_NOT_COMPLETED", s);
        Assert.Contains("StatusCompleted", s);
    }

    [Fact]
    public void Gateway_FailDrivesDisposition_FromOverallResult()
    {
        // 网关判据 disposition_required 由 overall_result=FAIL 决定，只读、不改写质量结果
        var h = Handler();
        Assert.Contains("overall_result", h);
        Assert.Contains("ResultFail", h);
        Assert.Contains("[\"disposition_required\"]", h);
        // Handler 不 UPDATE 质量结果
        Assert.DoesNotContain("UPDATE ado_s6_process_inspection_result", h);
    }

    [Fact]
    public void Disposition_DoesNotOverwrite_QualityResult()
    {
        var s = Svc();
        // 处置落 ado_s6_ipqc_quality_disposition，绝不 UPDATE overall_result（§20 硬门）
        Assert.Contains("AdoS6IpqcQualityDisposition", s);
        Assert.DoesNotContain("UPDATE ado_s6_process_inspection_result SET overall_result", s);
        Assert.DoesNotContain("SET overall_result", s);
    }

    [Fact]
    public void Idempotent_And_TenantSafe_And_Transactional()
    {
        var s = Svc();
        // S6-PI-RESUBMIT-1：「一单一 active flow」这一原意不变，但不再由「Running 就拒绝」这句话承担
        // ——那句会连主管退回后的合法重提一起挡死。现在改由两条共同保证：
        //   ① 已在 N2/N3 的重复提交被节点判定拒绝；② 重提沿用同一实例，只有 taskId==null 才 StartFlow。
        Assert.Contains("当前流程节点不允许提交审核", s);
        Assert.Contains("if (taskId == null)", s);
        Assert.Contains("ResolveTenantOrThrow", s);
        Assert.Contains("UseTranAsync", s);
        Assert.DoesNotContain("tenant_id IS NULL", s);
    }

    [Fact]
    public void N1_IsInitiator_ReuseSupervisorAndQeRoles()
    {
        var seed = Seed();
        Assert.Contains("nameof(ApproverTypeEnum.Initiator)", seed);      // N1=发起人
        // S6-TENANT-AUTHORITY-1：审批权威由物理 RoleId 改为 RoleCode（原断言锁的是已被本批修复的
        // 「FlowJson 写死默认租户 RoleId」实现细节）。「N2/N3 复用 IPQC 角色」这一原意不变，只是改按 Code 表达。
        Assert.Contains("RoleSupervisorCode", seed);                      // N2 复用 IPQC 主管角色
        Assert.Contains("RoleQualityEngineerCode", seed);                 // N3 复用 IPQC QE 角色
        // 复用 IPQC 角色定义（不新造角色码）
        Assert.Contains("IpqcInspectionFlowConst.RoleSupervisorCode", Const());
    }

    private static string FindFile(params string[] parts)
    {
        var dir = new DirectoryInfo(AppContext.BaseDirectory);
        while (dir != null)
        {
            var candidate = Path.Combine(new[] { dir.FullName }.Concat(parts).ToArray());
            if (File.Exists(candidate)) return candidate;
            dir = dir.Parent;
        }
        throw new FileNotFoundException(string.Join("/", parts));
    }
}