AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/MaterialWarehouse/IqcInspBillFlowBizHandler.cs

using Admin.NET.Plugin.ApprovalFlow;
using Admin.NET.Plugin.ApprovalFlow.Service;

namespace Admin.NET.Plugin.AiDOP.MaterialWarehouse;

/// <summary>
/// S5 来料检验单流程常量（BizType / 节点码 / 角色码 / 角色固定 Id / 字典）。集中避免散落字符串。
/// </summary>
public static class IqcInspBillFlowConst
{
    /// <summary>流程业务类型编码</summary>
    public const string BizType = "S5_IQC_INSPBILL";

    /// <summary>N1 检验员检验节点</summary>
    public const string NodeInspect = "N1_INSPECT";

    /// <summary>N2 检验主管审核节点</summary>
    public const string NodeSupervisor = "N2_SUP_REVIEW";

    /// <summary>GW_PD 排他网关（按 pd 分流：pd=1→SQE，否则完成）</summary>
    public const string GatewayPd = "GW_PD";

    /// <summary>N3 SQE 处置节点</summary>
    public const string NodeSqe = "N3_SQE_DISPOSITION";

    /// <summary>检验员角色编码</summary>
    public const string RoleInspectorCode = "ROLE_S5_IQC_INSPECTOR";

    /// <summary>检验主管角色编码</summary>
    public const string RoleSupervisorCode = "ROLE_S5_IQC_SUPERVISOR";

    /// <summary>SQE 角色编码</summary>
    public const string RoleSqeCode = "ROLE_S5_SQE";

    /// <summary>检验员角色固定 Id（种子与流程定义共用）</summary>
    public const long RoleInspectorId = 1329915010001L;

    /// <summary>检验主管角色固定 Id</summary>
    public const long RoleSupervisorId = 1329915010002L;

    /// <summary>SQE 角色固定 Id</summary>
    public const long RoleSqeId = 1329915010003L;

    /// <summary>流程定义版本（升 v2 加入 GW_PD/N3_SQE；seed 幂等升级依据）</summary>
    public const int FlowDefinitionVersion = 2;

    /// <summary>UAT 冒烟绑定账号（同绑两角色，仅 UAT 自审）</summary>
    public const string UatAccount = "superAdmin.NET";

    /// <summary>
    /// 检验单业务状态 qms_qcp_inspbill.FBILLSTATUS 的终态值（P1-A）。
    /// 生成时由 IqcTaskEntryService 写 '检验中'，流程 Approved 终结时由 Handler 写本值。
    /// </summary>
    public const string BillStatusDone = "检验完成";

    // pd 判定：0=合格 1=不合格 ｜ clfs 处理方式：0=让步接收 1=挑选 2=报废
}

/// <summary>
/// S5 来料检验单审批流回调处理器（BizType=S5_IQC_INSPBILL）。
///
/// 本批（检验员+主管最小闭环）Handler 全部 no-op：不写 qms、不写库存、不发额外通知、不转 SQE。
/// 检验结果字段 pd/dhsl/bhgsl/clfs 由 IqcInspBillFlowService.submit-result 在事务内写入；
/// 流程状态由 ApprovalFlowInstance 承载，不回写 qms_qcp_inspbill。GetBizData 仅返回基础信息供流程日志/条件（本批线性流程无网关）。
/// </summary>
public class IqcInspBillFlowBizHandler : IFlowBizHandler, ITransient
{
    public string BizType => IqcInspBillFlowConst.BizType;

    private readonly ISqlSugarClient _db;
    private readonly UserManager _userManager;

    public IqcInspBillFlowBizHandler(ISqlSugarClient db, UserManager userManager)
    {
        _db = db;
        _userManager = userManager;
    }

    /// <summary>流程发起后回调：本批 no-op（不回写 qms）。</summary>
    public Task OnFlowStarted(long bizId, long instanceId) => Task.CompletedTask;

    /// <summary>单节点完成回调：本批 no-op。</summary>
    public Task OnNodeCompleted(long bizId, long instanceId, string nodeId, string nodeName, long? approverUserId) => Task.CompletedTask;

    /// <summary>
    /// 流程结束回调：把检验单业务状态推进到终态（P1-A）。
    ///
    /// 【为什么写在这里而不是 IqcInspBillFlowService】
    /// 本回调由流程引擎在**实例真正终结**时触发且仅触发一次，天然覆盖两条路径：
    ///   · 合格(pd=0)：N2 主管通过 → GW_PD 默认边 → end → 本回调；
    ///   · 不合格(pd=1)：N2 主管通过 → GW_PD 走 N3_SQE_DISPOSITION（实例仍 Running，**不触发本回调**）
    ///                   → SQE 处置完成 → end → 本回调。
    /// 即「NG 单在主管通过时提前写完成」在结构上不可能发生，无需在 Service 里判断网关走向。
    ///
    /// 【事务】FlowEngineService.InvokeHandler 捕获后 rethrow，而 supervisor-approve /
    /// sqe-submit-disposition 均以 _db.AsTenant().UseTranAsync 包住 _flowEngine.Approve，
    /// 故本次 UPDATE 与流程推进落在同一事务：不会出现「流程已完成但业务单状态没写成功」。
    ///
    /// 【取值】'检验完成' 与同一条 INSERT 写入的 '检验中'（IqcTaskEntryService 生成时）同词族，
    /// 也是项目既有 done-word（参见 FqcInspBillFlowBizHandler.InspectStatusDone）。
    /// 库内 FBILLSTATUS 另有 C/A/COMPLETED/CREATED/NG 等历史 seed 值，无代码写入者，不予采用，
    /// 亦不自造新枚举。
    ///
    /// 【边界】只在 Approved（正常走完）时写；Rejected / Cancelled 保持原状态，不写完成。
    /// 不写 FAUDITORID、不碰库存、不改 pd/clfs、不动报检分录 FINSPECTSTATUS
    /// （后者的既定写入者是 IqcWmsResultPushService 的 165 推送路径，语义为「已提交并回写 WMS」，
    ///  与本字段的「审批流走完」不是同一语义轴）。
    /// </summary>
    public async Task OnFlowCompleted(long bizId, long instanceId, FlowInstanceStatusEnum finalStatus, long? lastApproverId)
    {
        if (finalStatus != FlowInstanceStatusEnum.Approved) return;

        // 同库分租户：本回调在请求上下文内同步调用，租户取当前登录用户，绝不跨租户改单。
        await _db.Ado.ExecuteCommandAsync(
            "UPDATE qms_qcp_inspbill SET FBILLSTATUS=@Status WHERE id=@id AND tenant_id=@TenantId",
            new List<SugarParameter>
            {
                new("@Status", IqcInspBillFlowConst.BillStatusDone),
                new("@id", bizId),
                new("@TenantId", _userManager.TenantId),
            });
    }

    /// <summary>返回检验单基础信息（本批线性流程无网关条件，仅供日志/展示）。</summary>
    public async Task<Dictionary<string, object>> GetBizData(long bizId)
    {
        // 同库分租户：GetBizData 由流程引擎在请求上下文内同步调用（Approve/网关求值），用当前用户租户过滤。
        var rows = await _db.Ado.SqlQueryAsync<IqcInspBillFlowBizData>(
            "SELECT FBILLNO AS BillNo, FMATERIALCFG AS MaterialCode, wlmc AS MaterialName, pd AS Pd, clfs AS Clfs FROM qms_qcp_inspbill WHERE id=@id AND tenant_id=@TenantId LIMIT 1",
            new List<SugarParameter> { new("@id", bizId), new("@TenantId", _userManager.TenantId) });
        var r = rows.FirstOrDefault();
        if (r == null) return new Dictionary<string, object>();
        return new Dictionary<string, object>
        {
            ["billNo"] = r.BillNo ?? "",
            ["materialCode"] = r.MaterialCode ?? "",
            ["materialName"] = r.MaterialName ?? "",
            ["pd"] = r.Pd ?? -1,
            ["clfs"] = r.Clfs ?? -1,
        };
    }

    private class IqcInspBillFlowBizData
    {
        public string? BillNo { get; set; }
        public string? MaterialCode { get; set; }
        public string? MaterialName { get; set; }
        public long? Pd { get; set; }
        public long? Clfs { get; set; }
    }
}