AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/Order/OrderDeliveryService.cs

namespace Admin.NET.Plugin.AiDOP.Order;

/// <summary>
/// 订单交付服务 📦
/// 路由前缀：/api/Order/delivery/...
/// </summary>
[ApiDescriptionSettings(Order = 270, Description = "订单交付")]
[Route("api/Order")]
[AllowAnonymous]
[NonUnify]
public class OrderDeliveryService : IDynamicApiController, ITransient
{
    private readonly ISqlSugarClient _db;
    private readonly UserManager _userManager;

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

    // ══════════════════════════════════════════════════════════════
    // 列表 GET /api/Order/delivery/list
    // ══════════════════════════════════════════════════════════════
    /// <summary>获取订单交付分页列表 📦</summary>
    [DisplayName("获取订单交付列表")]
    [HttpGet("delivery/list")]
    public async Task<object> GetDeliveryList([FromQuery] OrderDeliveryListInput input)
    {
        var tenantId = _userManager.TenantId;
        var pars = new List<SugarParameter> { new("@TenantId", tenantId) };
        var innerConditions = new List<string>
        {
            "d.tenant_id = @TenantId",
            "d.order_no IS NOT NULL",
            """
            d.calc_batch_id = (
                SELECT r.batch_id
                FROM mdp_transform_run_log r
                WHERE r.job_code = 'S1_MDP_SYNC_TRANSFORM'
                  AND r.status = 'SUCCESS'
                ORDER BY r.start_time DESC, r.id DESC
                LIMIT 1
            )
            """
        };

        if (!string.IsNullOrWhiteSpace(input.BillNo))
        {
            innerConditions.Add("d.order_no LIKE @BillNo");
            pars.Add(new SugarParameter("@BillNo", $"%{input.BillNo.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.CustomNo))
        {
            innerConditions.Add("d.customer_no LIKE @CustomNo");
            pars.Add(new SugarParameter("@CustomNo", $"%{input.CustomNo.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.ItemNumber))
        {
            innerConditions.Add("d.item_code LIKE @ItemNumber");
            pars.Add(new SugarParameter("@ItemNumber", $"%{input.ItemNumber.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.PlanDateFrom))
        {
            innerConditions.Add("d.plan_delivery_date >= @PlanDateFrom");
            pars.Add(new SugarParameter("@PlanDateFrom", input.PlanDateFrom.Trim()));
        }

        var innerWhere = string.Join(" AND ", innerConditions);
        var baseSql = BuildListBaseSql(innerWhere);

        // progress 是计算列，需包一层过滤
        var outerWhere = "";
        if (!string.IsNullOrWhiteSpace(input.Progress))
        {
            outerWhere = "WHERE t.progress = @Progress";
            pars.Add(new SugarParameter("@Progress", input.Progress.Trim()));
        }

        var offset = (input.Page - 1) * input.PageSize;
        var total = await _db.Ado.GetIntAsync(
            $"SELECT COUNT(*) FROM ({baseSql}) AS t {outerWhere}", pars);
        var list = await _db.Ado.SqlQueryAsync<OrderDeliveryListRow>(
            $"SELECT * FROM ({baseSql}) AS t {outerWhere} ORDER BY t.RDate DESC, t.BillNo ASC, IFNULL(t.EntrySeq, 0) ASC LIMIT {input.PageSize} OFFSET {offset}",
            pars);

        return new { total, page = input.Page, pageSize = input.PageSize, list };
    }

    private static string BuildListBaseSql(string innerWhere) => $"""
        SELECT
            COALESCE(d.order_entry_id, d.id)                            AS Id,
            d.order_id                                                  AS SeOrderId,
            d.order_no                                                  AS BillNo,
            NULL                                                        AS Rstate,
            CAST(NULLIF(d.order_line, '') AS SIGNED)                    AS EntrySeq,
            IFNULL(NULLIF(d.item_code, 'null'), '')                       AS ItemNumber,
            IFNULL(NULLIF(d.item_name, 'null'), '')                     AS ItemName,
            IFNULL(NULLIF(d.item_spec, 'null'), '')                     AS Specification,
            NULL                                                        AS Unit,
            IFNULL(NULLIF(d.customer_no, 'null'), '')                     AS CustomNo,
            NULL                                                        AS CustomOrderBillNo,
            NULL                                                        AS CustomOrderItemNo,
            NULL                                                        AS CustomLevel,
            COALESCE(se.qty, d.order_qty)                               AS Qty,
            d.shipped_qty                                               AS DeliverCount,
            NULL                                                        AS BomNumber,
            NULL                                                        AS EmpName,
            NULL                                                        AS PlannerName,
            d.plan_delivery_date                                        AS PlanDate,
            d.promised_delivery_date                                    AS SysCapacityDate,
            d.promised_delivery_date                                    AS Date,
            d.order_date                                                 AS RDate,
            d.create_time                                               AS CreateTime,
            NULL                                                        AS CreateByName,
            NULL                                                        AS Auditor,
            CASE
                WHEN d.delivery_status = 'COMPLETED' THEN '7'
                WHEN d.planned_ship_qty > 0 THEN '7'
                WHEN d.order_status = 'CLOSED' THEN '7'
                WHEN d.review_status IS NOT NULL THEN '1'
                ELSE '1'
            END                                                         AS Progress,
            NULL                                                        AS ProdLine,
            NULL                                                        AS ProdRange,
            d.actual_ship_date                                          AS ShipDate,
            NULL                                                        AS Recid,
            IF(IFNULL(d.planned_ship_qty, 0) > 0, '是', '否')          AS Spstatus,
            IFNULL(NULLIF(me.mono_list, 'null'), '')                      AS MoentryMono
        FROM dwd_ship_trans d
        LEFT JOIN crm_seorderentry se
               ON se.id = d.order_entry_id
              AND se.tenant_id = d.tenant_id
              AND se.IsDeleted = 0
        LEFT JOIN (
            SELECT soentry_id, tenant_id,
                   GROUP_CONCAT(moentry_mono SEPARATOR ', ') AS mono_list
            FROM mes_moentry
            WHERE IsDeleted = 0
            GROUP BY soentry_id, tenant_id
        ) me ON me.soentry_id = d.order_entry_id
            AND me.tenant_id = d.tenant_id
        WHERE {innerWhere}
        """;

    // ══════════════════════════════════════════════════════════════
    // 价值流 GET /api/Order/delivery/flow/{entryId}
    // ══════════════════════════════════════════════════════════════
    /// <summary>获取订单价值流全量数据（8个Tab）📦</summary>
    [DisplayName("获取订单价值流")]
    [HttpGet("delivery/flow/{entryId}")]
    public async Task<object> GetDeliveryFlow(long entryId)
    {
        // 同一 ISqlSugarClient 底层共用一条连接，不能对 _db.Ado 并发执行多查询（MySqlConnector 会报 Cannot Open when State is Connecting）
        var basic = await QueryBasic(entryId);
        var orderInfo = await QueryOrderInfo(entryId);
        var review = await QueryReview(entryId);
        var changes = await QueryChanges(entryId);
        var schedule = await QuerySchedule(entryId);
        var material = await QueryMaterials(entryId);
        var po = await QueryPo(entryId);
        var pr = await QueryPr(entryId);
        var deliverySchedule = await QueryDeliverySchedule(entryId);
        var nbr = await QueryNbr(entryId);
        var prodReport = await QueryProdReport(entryId);
        var iqc = await QueryIqc(entryId);
        var fqc = await QueryFqc(entryId);
        var receipt = await QueryReceipt(entryId);
        var shipment = await QueryShipment(entryId);

        return new
        {
            basic,
            tab1 = orderInfo,
            tab2 = new { review, changes },
            tab3 = schedule,
            tab4 = material,
            tab5 = new { po, pr, deliverySchedule },
            tab6 = nbr,
            tab7 = new { prodReport, iqc },
            tab8 = new { fqc, receipt, shipment },
        };
    }

    // ── 基础信息 ──
    private async Task<FlowBasicRow?> QueryBasic(long entryId)
    {
        var tenantId = _userManager.TenantId;
        const string sql = """
            SELECT
                IFNULL(NULLIF(d.item_code, 'null'), '')  AS ItemNumber,
                IFNULL(NULLIF(d.item_name, 'null'), '')  AS ItemName,
                IFNULL(NULLIF(d.item_spec, 'null'), '')  AS Specification,
                d.order_qty          AS Qty,
                COALESCE(so.customer_order_no, '') AS BillFrom,
                d.plan_delivery_date AS PlanDate,
                CASE
                    WHEN d.delivery_status = 'COMPLETED' THEN '7'
                    WHEN d.planned_ship_qty > 0 THEN '7'
                    WHEN d.order_status = 'CLOSED' THEN '7'
                    WHEN d.review_status IS NOT NULL THEN '1'
                    ELSE '1'
                END                  AS Progress,
                d.update_time        AS Mrptime
            FROM dwd_ship_trans d
            LEFT JOIN mdp_std_so so
              ON so.tenant_id = d.tenant_id
             AND so.order_entry_id = d.order_entry_id
            WHERE (d.order_entry_id = @Id OR d.id = @Id)
              AND d.tenant_id = @TenantId
              AND d.order_no IS NOT NULL
            ORDER BY d.calc_time DESC, d.id DESC
            LIMIT 1
            """;
        return (await _db.Ado.SqlQueryAsync<FlowBasicRow>(sql, new { Id = entryId, TenantId = tenantId })).FirstOrDefault();
    }

    // ── Tab1 订单信息 ──
    private async Task<FlowOrderInfoRow?> QueryOrderInfo(long entryId)
    {
        var tenantId = _userManager.TenantId;
        const string sql = """
            SELECT
                so.order_no          AS BillNo,
                so.customer_name     AS CustomName,
                NULL                 AS CustomLevel,
                COALESCE(so.flow_state, '')        AS State,
                so.order_date        AS Date,
                ''                 AS CreateByName,
                so.order_type        AS OrderType,
                so.update_time       AS AuditDate,
                ''                 AS Auditor,
                so.customer_order_no AS BillFrom,
                COALESCE(so.planner_name, '')      AS EmpName,
                COALESCE(so.planner_no, '')        AS EmpNo
            FROM mdp_std_so so
            WHERE so.order_entry_id = @Id
              AND so.tenant_id = @TenantId
            ORDER BY so.sync_time DESC, so.id DESC
            LIMIT 1
            """;
        return (await _db.Ado.SqlQueryAsync<FlowOrderInfoRow>(sql, new { Id = entryId, TenantId = tenantId })).FirstOrDefault();
    }

    // ── Tab2 订单评审 ──
    /// <remarks>
    /// 查询最新评审记录（num=1 的首行物料）的预计交期评估信息。
    /// </remarks>
    private async Task<FlowReviewRow?> QueryReview(long entryId)
    {
        var tenantId = _userManager.TenantId;
        const string sql = """
            SELECT
                d.satisfy_time AS SysCapacityDate,
                d.morder_no AS MorderNo,
                d.create_time AS CreateTime,
                d.make_qty AS MakeQty,
                d.use_qty AS UseQty,
                d.mo_qty AS MoQty
            FROM dwd_requirement_examine_detail d
            WHERE d.order_entry_id = @EntryId
              AND d.tenant_id = @TenantId
              AND d.num = '1'
              AND d.calc_batch_id = (
                  SELECT r.batch_id
                  FROM mdp_transform_run_log r
                  WHERE r.job_code = 'S1_MDP_SYNC_TRANSFORM'
                    AND r.status = 'SUCCESS'
                  ORDER BY r.start_time DESC, r.id DESC
                  LIMIT 1
              )
            ORDER BY d.create_time DESC, d.row_id
            LIMIT 1
            """;
        return (await _db.Ado.SqlQueryAsync<FlowReviewRow>(sql, new { EntryId = entryId, TenantId = tenantId })).FirstOrDefault();
    }

    // ── Tab2 变更记录（MySQL：按订单行关联变更单）──
    private async Task<List<FlowChangeRow>> QueryChanges(long entryId)
    {
        var tenantId = _userManager.TenantId;
        const string sql = """
            SELECT
                ROW_NUMBER() OVER (ORDER BY a.id) AS Sno,
                JSON_UNQUOTE(JSON_EXTRACT(a.raw_data, '$.bill_no')) AS BillNo,
                JSON_UNQUOTE(JSON_EXTRACT(a.raw_data, '$.change_Type')) AS ChangeType,
                JSON_UNQUOTE(JSON_EXTRACT(a.raw_data, '$.change_Reason')) AS ChangeReason,
                JSON_UNQUOTE(JSON_EXTRACT(a.raw_data, '$.change_content')) AS ChangeContent,
                a.update_time AS UpdateTime
            FROM mdp_stg_so a
            INNER JOIN mdp_std_so so
                    ON so.order_entry_id = @Id
                   AND so.order_no = JSON_UNQUOTE(JSON_EXTRACT(a.raw_data, '$.bill_no'))
                   AND so.tenant_id = a.tenant_id
            WHERE a.source_table = 'crm_seorder_change'
              AND a.tenant_id = @TenantId
            ORDER BY a.id
            """;
        return await _db.Ado.SqlQueryAsync<FlowChangeRow>(sql, new { Id = entryId, TenantId = tenantId });
    }

    // ── Tab3 计划排程1（MySQL：按分录 Id 关联工单排程 + 物料主档）──
    private async Task<List<FlowScheduleRow>> QuerySchedule(long entryId)
    {
        const string sql = """
            SELECT
                ROW_NUMBER() OVER (ORDER BY sch.PlanDate) AS Sno,
                sch.WorkOrds,
                DATE(sch.PlanDate) AS WorkDate,
                sch.Line,
                sch.Op,
                CAST(sch.OrdQty AS DECIMAL(18, 2)) AS WorkQty,
                sch.ItemNum,
                im.Descr,
                im.Descr1,
                sch.CreateTime
            FROM PeriodSequenceDet sch
            LEFT JOIN ItemMaster im ON sch.ItemNum = im.ItemNum            LEFT JOIN mes_morder mo ON mo.morder_no = sch.WorkOrds            INNER JOIN mes_moentry me ON mo.Id = me.moentry_moid
            LEFT JOIN crm_seorderentry se ON se.Id = me.soentry_id
            WHERE se.id = @EntryId AND mo.IsDeleted = 0
            ORDER BY sch.PlanDate
            """;
        return await _db.Ado.SqlQueryAsync<FlowScheduleRow>(sql, new { EntryId = entryId });
    }

    // ── Tab4 物料需求（MySQL：最新评审结果 + BOM 子件明细，同需求明细核验口径）──
    private async Task<List<FlowMaterialRow>> QueryMaterials(long entryId)
    {
        var tenantId = _userManager.TenantId;
        const string sql = """
            SELECT
                ROW_NUMBER() OVER (ORDER BY d.row_id) AS Sno,
                d.num AS Num,
                IFNULL(NULLIF(d.item_number, 'null'), '') AS ItemNumber,
                IFNULL(NULLIF(d.item_name, 'null'), '') AS ItemName,
                d.bom_number AS BomNumber,
                d.model AS Model,
                DATE_FORMAT(d.kitting_time, '%Y-%m-%d') AS KittingTime,
                d.item_type AS Type,
                NULL AS Unit,
                d.erp_cls_name AS ErpClsName,
                d.qty AS Qty,
                d.need_count AS NeedCount,
                d.sqty AS Sqty,
                d.use_qty AS UseQty,
                d.self_lack_qty AS SelfLackQty,
                d.lack_qty AS LackQty,
                d.mo_qty AS MoQty,
                d.make_qty AS MakeQty,
                d.purchase_qty AS PurchaseQty,
                d.purchase_occupy_qty AS PurchaseOccupyQty,
                NULL AS SubcontractingQty,
                NULL AS Backflush,
                DATE_FORMAT(d.satisfy_time, '%Y-%m-%d') AS SatisfyTime,
                d.have_ic_subs AS HaveIcSubs,
                d.substitute_code AS SubstituteCode
            FROM dwd_requirement_examine_detail d
            WHERE d.order_entry_id = @EntryId
              AND d.tenant_id = @TenantId
              AND d.calc_batch_id = (
                  SELECT r.batch_id
                  FROM mdp_transform_run_log r
                  WHERE r.job_code = 'S1_MDP_SYNC_TRANSFORM'
                    AND r.status = 'SUCCESS'
                  ORDER BY r.start_time DESC, r.id DESC
                  LIMIT 1
              )
            ORDER BY d.row_id ASC
            """;
        return await _db.Ado.SqlQueryAsync<FlowMaterialRow>(sql, new { EntryId = entryId, TenantId = tenantId });
    }

    // ── Tab5 采购订单（MySQL：经占用/工单关联到订单分录）──
    private async Task<List<FlowPoRow>> QueryPo(long entryId)
    {
        const string sql = """
            SELECT
                ROW_NUMBER() OVER (ORDER BY t.PoBillNo) AS Sno,
                t.PoBillNo,
                t.SupplierNo,
                t.SupplierName,
                t.PoTotal,
                t.PoPurchaser,
                t.State,
                t.PoSsendDate,
                t.CreateTime
            FROM (
                SELECT DISTINCT
                    pm.po_billno AS PoBillNo,
                    pm.supplier_no AS SupplierNo,
                    pm.supplier_name AS SupplierName,
                    CAST(pm.po_total AS DECIMAL(18, 2)) AS PoTotal,
                    pm.po_purchaser AS PoPurchaser,
                    pm.create_time AS CreateTime,
                    pm.po_ssend_date AS PoSsendDate,
                    CASE pm.state
                        WHEN 0 THEN '新增'
                        WHEN 1 THEN '审核中'
                        WHEN 2 THEN '同意'
                        WHEN 3 THEN '关闭'
                    END AS State
                FROM srm_po_main pm
                LEFT JOIN srm_po_list pl ON pm.id = pl.po_id
                LEFT JOIN srm_po_occupy occ ON pl.Id = occ.polist_id AND CAST(pm.factory_id AS CHAR(64)) = CAST(occ.factory_id AS CHAR(64))                LEFT JOIN mes_morder mo ON mo.id = occ.morder_id
                LEFT JOIN mes_moentry me ON mo.id = me.moentry_moid
                LEFT JOIN crm_seorderentry se ON me.soentry_id = se.id
                WHERE se.id = @EntryId AND pm.IsDeleted = 0
            ) AS t
            ORDER BY t.PoBillNo
            """;
        return await _db.Ado.SqlQueryAsync<FlowPoRow>(sql, new { EntryId = entryId });
    }

    // ── Tab5 采购申请（MySQL）──
    private async Task<List<FlowPrRow>> QueryPr(long entryId)
    {
        const string sql = """
            SELECT
                ROW_NUMBER() OVER (ORDER BY pm.pr_billno) AS Sno,
                pm.pr_billno AS PrBillNo,
                ic.number AS Number,
                pm.icitem_name AS IcItemName,
                ic.model AS Model,
                pm.pr_purchasenumber AS PrPurchaseNumber,
                pm.pr_purchasename AS PrPurchaseName,
                CAST(pm.pr_aqty AS DECIMAL(18, 2)) AS PrAQty,
                pm.pr_ssend_date AS PrSsendDate,
                pm.pr_sarrive_date AS PrSarriveDate,
                pm.pr_unit AS PrUnit,
                pm.pr_purchaser AS PrPurchaser
            FROM srm_pr_main pm
            LEFT JOIN srm_po_occupy occ ON pm.Id = occ.polist_id AND CAST(pm.factory_id AS CHAR(64)) = CAST(occ.factory_id AS CHAR(64))            LEFT JOIN ic_item ic ON pm.icitem_id = ic.Id
            LEFT JOIN mes_morder mo ON mo.id = occ.morder_id
            LEFT JOIN mes_moentry me ON mo.id = me.moentry_moid
            LEFT JOIN crm_seorderentry se ON me.soentry_id = se.id
            WHERE se.id = @EntryId AND pm.state <> 0 AND pm.IsDeleted = 0
            ORDER BY pm.pr_billno
            """;
        return await _db.Ado.SqlQueryAsync<FlowPrRow>(sql, new { EntryId = entryId });
    }

    // ── Tab5 物料交货单（MySQL：srm_polist_ds）──
    private async Task<List<FlowDeliveryScheduleRow>> QueryDeliverySchedule(long entryId)
    {
        const string sql = """
            SELECT
                ROW_NUMBER() OVER (ORDER BY t.DsNum) AS Sno,
                t.PoNumber,
                t.DsNum,
                t.ItemNum,
                t.Descr,
                t.SupplierCode,
                t.Supplier,
                t.RequestDate,
                t.NeedDate,
                t.SchedQty,
                t.SentQty,
                t.RestQty
            FROM (
                SELECT
                    ds.dsnum AS DsNum,
                    ds.ponumber AS PoNumber,
                    ds.itemnum AS ItemNum,
                    im.Descr AS Descr,
                    ds.suppliercode AS SupplierCode,
                    ds.supplier AS Supplier,
                    ds.requestdate AS RequestDate,
                    ds.needdate AS NeedDate,
                    ds.schedqty AS SchedQty,
                    ds.sentqty AS SentQty,
                    ds.restqty AS RestQty
                FROM srm_po_main pm
                LEFT JOIN srm_po_list pl ON pm.id = pl.po_id
                LEFT JOIN srm_po_occupy occ ON pl.Id = occ.polist_id AND CAST(pm.factory_id AS CHAR(64)) = CAST(occ.factory_id AS CHAR(64))                LEFT JOIN mes_morder mo ON mo.id = occ.morder_id
                LEFT JOIN mes_moentry me ON mo.id = me.moentry_moid
                LEFT JOIN crm_seorderentry se ON me.soentry_id = se.id
                LEFT JOIN srm_polist_ds ds ON pl.po_billno = ds.ponumber AND pl.ItemNum = ds.itemnum                LEFT JOIN ItemMaster im ON ds.itemnum = im.ItemNum                WHERE se.id = @EntryId AND pm.IsDeleted = 0
            ) AS t
            ORDER BY t.DsNum
            """;
        return await _db.Ado.SqlQueryAsync<FlowDeliveryScheduleRow>(sql, new { EntryId = entryId });
    }

    // ── Tab6 生产备料（MySQL：备料明细经工单关联分录）──
    private async Task<List<FlowNbrRow>> QueryNbr(long entryId)
    {
        const string sql = """
            SELECT
                CAST(nd.Line AS CHAR) AS Line,
                nm.Nbr AS Nbr,
                nd.ItemNum,
                im.Descr AS Descr,
                im.Descr1 AS Descr1,
                CAST(nd.QtyFrom AS DECIMAL(18, 2)) AS QtyFrom,
                CAST(nd.QtyOrd AS DECIMAL(18, 2)) AS QtyOrd,
                CAST(nd.CurrQtyOpened AS DECIMAL(18, 2)) AS CurrQtyOpened,
                CAST(nd.QtyRec AS DECIMAL(18, 2)) AS QtyRec,
                nd.UM AS Unit,
                nd.LocationFrom,
                nd.LocationTo,
                nd.UpdateTime AS UpdateTime,
                nd.WorkOrd AS WorkOrd
            FROM NbrDetail nd
            LEFT JOIN NbrMaster nm ON nd.nbr = nm.nbr            LEFT JOIN mes_morder mo ON mo.morder_no = nm.WorkOrd            INNER JOIN mes_moentry me ON mo.Id = me.moentry_moid
            LEFT JOIN crm_seorderentry se ON se.Id = me.soentry_id AND mo.product_code = se.item_number            LEFT JOIN ItemMaster im ON nd.ItemNum = im.ItemNum            WHERE se.id = @EntryId AND mo.IsDeleted = 0 AND nm.Type = 'SM'
            ORDER BY nm.Nbr
            """;
        return await _db.Ado.SqlQueryAsync<FlowNbrRow>(sql, new { EntryId = entryId });
    }

    // ── Tab7 生产报工（OpTransEmployee + 销售订单行）──
    private async Task<List<FlowProdReportRow>> QueryProdReport(long entryId)
    {
        const string sql = """
            SELECT
                ROW_NUMBER() OVER (ORDER BY ote.ProdDate DESC) AS Sno,
                ote.WorkOrd,
                ote.Name AS Name,
                ote.Op,
                ote.ProdDate,
                im.ItemNum,
                im.Descr,
                im.Descr1,
                im.Um,
                CAST(ote.QtyCompleted AS DECIMAL(18,2)) AS QtyCompleted,
                CAST(ote.QtyReject AS DECIMAL(18,2)) AS QtyReject,
                CAST(ote.QtyScrapped AS DECIMAL(18,2)) AS QtyScrapped
            FROM OpTransEmployee ote
            LEFT JOIN mes_morder mo ON mo.morder_no = ote.WorkOrd            INNER JOIN mes_moentry me ON mo.Id = me.moentry_moid
            LEFT JOIN crm_seorderentry se ON se.Id = me.soentry_id
            LEFT JOIN ItemMaster im ON ote.ItemNum = im.ItemNum            WHERE se.id = @EntryId AND mo.IsDeleted = 0
            ORDER BY ote.ProdDate DESC
            """;
        return await _db.Ado.SqlQueryAsync<FlowProdReportRow>(sql, new { EntryId = entryId });
    }

    // ── Tab7 IQC信息（请购/采购/检验链路）──
    private async Task<List<FlowIqcRow>> QueryIqc(long entryId)
    {
        const string sql = """
            SELECT
                ROW_NUMBER() OVER (ORDER BY iqcjy.FAPPLYTIME DESC) AS Line,
                iqcjy.po_bill AS PoBill,
                iqcjy.po_billline AS PoBillLine,
                iqcjy.FBILLNO AS FBillNo,
                iqcjy.FMATERIALCFG AS FMaterialCfg,
                iqcjy.wlmc AS Wlmc,
                iqcjy.ggxh AS Ggxh,
                CAST(iqcjy.FRINSQTY AS DECIMAL(18,2)) AS FRinsQty,
                iqcjy.FAPPLYTIME AS FApplyTime,
                iqcjy.FINSPESTARTDATE AS FInspeStartDate,
                iqcjy.FINSPECTSTATUS AS FInspecStatus
            FROM srm_pr_main pr
            LEFT JOIN PurOrdDetail pod ON pr.pr_billno = pod.Req            LEFT JOIN vscm_cgshrk sh ON pod.PurOrd = sh.OrdNbr AND CAST(pod.Line AS CHAR(32)) = CAST(sh.OrdLine AS CHAR(32))            LEFT JOIN scm_jhjh_jq jq ON pod.PurOrd = jq.cgdd AND CAST(pod.Line AS CHAR(32)) = CAST(jq.ddhh AS CHAR(32))            LEFT JOIN (
                SELECT
                    f.po_bill,
                    f.po_billline,
                    a.FINSPESTARTDATE,
                    b.FAPPLYTIME,
                    b.FBILLNO,
                    a.FMATERIALCFG,
                    a.wlmc,
                    a.ggxh,
                    a.FRINSQTY,
                    c.FINSPECTSTATUS
                FROM qms_qcp_inspbill a
                LEFT JOIN qms_qcp_inspecapplyn b ON a.lydjbh = b.FBILLNO                LEFT JOIN qms_qcp_insappnentry c ON b.id = c.glid
                LEFT JOIN scm_shd cd ON c.shdh = cd.shddh                LEFT JOIN scm_shdzb f ON f.shpc = c.FLOTNUMBER AND f.sh_material_code = c.FMATERIALCFG AND f.glid = cd.id
            ) iqcjy ON pod.PurOrd = iqcjy.po_bill AND CAST(pod.Line AS CHAR(32)) = CAST(iqcjy.po_billline AS CHAR(32))            WHERE jq.flag = '1'
              AND pr.sentry_id IS NOT NULL
              AND pr.sentry_id = @EntryId
            ORDER BY iqcjy.FAPPLYTIME DESC
            """;
        return await _db.Ado.SqlQueryAsync<FlowIqcRow>(sql, new { EntryId = entryId });
    }

    // ── Tab8 FQC信息 ──
    private async Task<List<FlowFqcRow>> QueryFqc(long entryId)
    {
        const string sql = """
            SELECT
                ROW_NUMBER() OVER (ORDER BY a.FBILLNO ASC) AS Sno,
                b.WorkOrd,
                a.sczld,
                a.FBILLNO,
                a.FMATERIALCFG AS FMaterialCfg,
                a.wlmc,
                a.ggxh,
                a.scph,
                CAST(a.FRINSQTY AS DECIMAL(18,2)) AS FRinsQty,
                a.FINSPEENDDATE AS FInspeEndDate
            FROM qms_qcpp_inspbill a
            LEFT JOIN WorkOrdMaster b ON a.sczld = b.Batch            LEFT JOIN mes_moentry c ON b.WorkOrd = c.moentry_mono            WHERE c.soentry_id = @EntryId
            ORDER BY a.FBILLNO
            """;
        return await _db.Ado.SqlQueryAsync<FlowFqcRow>(sql, new { EntryId = entryId });
    }

    // ── Tab8 生产入库 ──
    private async Task<List<FlowReceiptRow>> QueryReceipt(long entryId)
    {
        const string sql = """
            SELECT
                ROW_NUMBER() OVER (ORDER BY mo.morder_no) AS Sno,
                CASE
                    WHEN c.Status = 'r' THEN '下达'
                    WHEN c.Status = 'c' THEN '关闭'
                    WHEN c.Status = 'w' THEN '投产'
                    ELSE '初始'
                END AS Status,
                c.WorkOrd,
                im.Um,
                c.QtyOrded,
                IFNULL(compp.CompQty, 0) AS CompQty,
                NULL AS InspectionNumber,
                NULL AS QualifiedNumber,
                CASE WHEN a.QtyChange > 0 THEN a.QtyChange ELSE 0 END AS QtyChangeAdvance,
                mo.moentry_prdname,
                mo.moentry_wrkcname,
                c.OrdDate,
                c.DueDate,
                a.CreateTime,
                c.itemnum AS ItemNum,
                im.descr AS Descr
            FROM WorkOrdMaster c
            LEFT JOIN InvTransHist a ON a.WorkOrd = c.WorkOrd AND a.TransType = 'rct-wo' AND a.QtyChange > 0
            LEFT JOIN GeneralizedCodeMaster b ON a.TransType = b.Val AND b.FldName = 'TransType' AND b.`Domain` = c.`Domain`            LEFT JOIN ItemMaster im ON c.ItemNum = im.ItemNum AND im.`Domain` = c.`Domain`            LEFT JOIN PeriodSequenceDet det ON det.ItemNum = im.ItemNum AND det.WorkOrds = c.WorkOrd AND det.`Domain` = c.`Domain`            LEFT JOIN (
                SELECT WorkOrds, SUM(IFNULL(CompQty, 0)) AS CompQty
                FROM PeriodSequenceDet
                GROUP BY WorkOrds
            ) compp ON c.WorkOrd = compp.WorkOrds            LEFT JOIN mes_morder mo ON mo.morder_no = c.WorkOrd AND mo.IsDeleted = 0
            LEFT JOIN mes_moentry motry ON motry.moentry_moid = mo.Id AND motry.IsDeleted = 0
            WHERE motry.soentry_id = @EntryId
            ORDER BY mo.morder_no
            """;
        return await _db.Ado.SqlQueryAsync<FlowReceiptRow>(sql, new { EntryId = entryId });
    }

    // ── Tab8 成品发运（与订单行 OrdNbr + 行物料一致）──
    private async Task<List<FlowShipmentRow>> QueryShipment(long entryId)
    {
        var tenantId = _userManager.TenantId;
        const string sql = """
            SELECT
                ROW_NUMBER() OVER (ORDER BY st.actual_ship_date DESC, st.source_row_id DESC) AS Sno,
                COALESCE(st.shipper_no, CAST(st.source_row_id AS CHAR)) AS Id,
                st.site AS Location,
                st.actual_ship_date AS ShipDate,
                CAST(st.qty_to_ship AS DECIMAL(18,2)) AS QtyToShip,
                st.site AS LocationCode,
                st.real_qty AS RealQty
            FROM mdp_std_ship_trans st
            INNER JOIN mdp_std_so so
                    ON so.order_entry_id = @EntryId
                   AND so.tenant_id = st.tenant_id
                   AND so.order_no = st.order_no
                   AND IFNULL(so.order_line, '') = IFNULL(st.order_line, '')
                   AND IFNULL(so.item_code, '') = IFNULL(st.item_code, '')
            WHERE st.trans_type = 'ASN_SHIPPER'
              AND st.tenant_id = @TenantId
            ORDER BY st.actual_ship_date DESC, st.source_row_id DESC
            """;
        return await _db.Ado.SqlQueryAsync<FlowShipmentRow>(sql, new { EntryId = entryId, TenantId = tenantId });
    }
}