AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/Manufacturing/IpqcInspectionFlowBizHandler.cs

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

namespace Admin.NET.Plugin.AiDOP.Manufacturing;

/// <summary>
/// S6 过程检验单审批流回调处理器（BizType=IPQC_INSPECTION）。
///
/// Handler 回调全部 no-op：不回写 qms_gcjyd、不写库存/生产/仓储、不发额外通知。
/// 检验结果字段由 IpqcInspectionFlowService/IpqcInspectionDispositionService 在事务内写入 qms_gcjyd 白名单列 / 处置表；
/// 流程状态由 ApprovalFlowInstance 承载 + 轻量扩展表 ado_s6_ipqc_inspection_flow_state 落审核信息，不回写 qms_gcjyd.status。
/// GetBizData 返回 GW_RESULT 网关判据 disposition_required（主管 N2 整批判定驱动，源自扩展表），
/// 不用 jgpd 枚举做流程分流（枚举未确认）。
/// </summary>
public class IpqcInspectionFlowBizHandler : IFlowBizHandler, ITransient
{
    public string BizType => IpqcInspectionFlowConst.BizType;

    private readonly ISqlSugarClient _db;

    public IpqcInspectionFlowBizHandler(ISqlSugarClient db)
    {
        _db = db;
    }

    /// <summary>流程发起后回调：no-op（不回写 qms_gcjyd）。</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>流程结束回调：no-op（不写 qms_gcjyd.status/库存/生产/仓储）。审核结果由 ApprovalFlowInstance + 扩展表承载。</summary>
    public Task OnFlowCompleted(long bizId, long instanceId, FlowInstanceStatusEnum finalStatus, long? lastApproverId) => Task.CompletedTask;

    /// <summary>返回检验单基础信息 + 网关判据 disposition_required（GW_RESULT 按此分流：==1→N3，否则→end）。</summary>
    public async Task<Dictionary<string, object>> GetBizData(long bizId)
    {
        var rows = await _db.Ado.SqlQueryAsync<IpqcFlowBizData>(
            "SELECT djbh AS BillNo, cplx AS ProductModel, wlbm AS MaterialCode, wlmc AS MaterialName, jgpd AS Jgpd FROM qms_gcjyd WHERE id=@id LIMIT 1",
            new List<SugarParameter> { new("@id", bizId) });
        var r = rows.FirstOrDefault();
        // 网关判据：主管 N2 整批判定写入扩展表 disposition_required（1=不合格转处置 / 0=合格结束）。
        var dispRows = await _db.Ado.SqlQueryAsync<int?>(
            "SELECT disposition_required FROM ado_s6_ipqc_inspection_flow_state WHERE inspection_id=@id AND IsDelete=0 ORDER BY id DESC LIMIT 1",
            new List<SugarParameter> { new("@id", bizId) });
        var dispositionRequired = dispRows.FirstOrDefault() ?? 0;
        if (r == null)
            return new Dictionary<string, object> { ["disposition_required"] = dispositionRequired };
        return new Dictionary<string, object>
        {
            ["billNo"] = r.BillNo ?? "",
            ["productModel"] = r.ProductModel ?? "",
            ["materialCode"] = r.MaterialCode ?? "",
            ["materialName"] = r.MaterialName ?? "",
            ["jgpd"] = r.Jgpd ?? -1,
            ["disposition_required"] = dispositionRequired,
        };
    }

    private class IpqcFlowBizData
    {
        public string? BillNo { get; set; }
        public string? ProductModel { get; set; }
        public string? MaterialCode { get; set; }
        public string? MaterialName { get; set; }
        public long? Jgpd { get; set; }
    }
}