using Masuit.Tools;
using NewPdaSqlServer.DB;
using NewPdaSqlServer.Dto.service;
using NewPdaSqlServer.entity;
using NewPdaSqlServer.entity.Base;
using NewPdaSqlServer.util;
using SqlSugar;
using System.Data;
using System.Data.SqlClient;
using System.Security.Cryptography;

namespace NewPdaSqlServer.service.Warehouse;

/// <summary>
///     MES物料表管理类
/// </summary>
public class MesItemTblManager : Repository<MesItemTbl>
{
    /// <summary>
    ///     获取生产退料单号列表
    /// </summary>
    /// <returns>退料单号列表</returns>
    public List<string> GetSCTLBillNo(WarehouseQuery query)
    {
        var list = Db.Queryable<MesItemTbl>()
            .Where(s => (s.Tbl013 ?? 0) == 1 // 审核通过
                        && (s.Tbl020 ?? 0) == 0
                        && s.Tbl008 == query.Type)
            .Select(s => s.BillNo).ToList();

        return list;
    }

    /// <summary>
    ///     根据单号获取MES物料表明细
    /// </summary>
    /// <param name="query">仓库查询参数</param>
    /// <returns>物料明细列表</returns>
    public ProductionPickDto GetMesItemTblDetailByBillNo(
        WarehouseQuery query)
    {
        // 关联查询物料表、物料明细表和物料基础信息表
        var mesItemTblDetails = Db
            .Queryable<MesItemTbl, MesItemTblDetail, MesItems>(
                (a, b, c) => new JoinQueryInfos(
                    JoinType.Left,
                    a.Id == b.Tlmid,
                    JoinType.Left,
                    b.Tld009 == c.Id)
            ).Where((a, b, c) => a.BillNo == query.billNo && (a.Tbl013 ?? 0) == 1)
            .Select<ItemDetailModel>((a, b, c) => new ItemDetailModel
            {
                FQty = b.Tld005 ?? 0, // 待退数量
                SQty = b.Tld006 ?? 0, // 已退数量
                DSQty = (b.Tld005 ?? 0) - (b.Tld006 ?? 0),
                ItemNo = c.ItemNo, // 物料编号
                ItemName = c.ItemName, // 物料名称
                ItemModel = c.ItemModel // 物料型号
            }).ToList();


        if (mesItemTblDetails.Count<1)
            throw new Exception("该申请单【" + query.billNo + "】 明细不存在，请确认！");

        var DS_list = mesItemTblDetails.Where(s => s.DSQty > 0).ToList();

        var YS_list = mesItemTblDetails.Where(s => s.SQty > 0).ToList();

        var itemTblDetails = new ProductionPickDto
        {
            items = DS_list,
            Ysitems = YS_list
            // yisao = mesInvItemOutCDetailsList
        };


        return itemTblDetails;
    }

    /// <summary>
    ///     生产退料扫描库位
    /// </summary>
    /// <param name="query">仓库查询参数</param>
    /// <returns>库位信息</returns>
    public WarehouseQuery SctlScanDepots(WarehouseQuery query)
    {
        if (query.DepotCode.IsNullOrEmpty())
            throw new NullReferenceException("请扫库位条码");

        // 关联查询库位分区和库位信息
        var warehouseQuery = Db.Queryable<MesDepotSections, MesDepots>((a, b) =>
                new JoinQueryInfos(JoinType.Inner, a.DepotGuid == b.Guid))
            .Where((a, b) => a.DepotSectionCode == query.DepotCode)
            .Select<WarehouseQuery>((a, b) => new WarehouseQuery
            {
                DepotSectionName = a.DepotSectionName,
                DepotName = b.DepotName,
                DepotCode = b.DepotCode
            }).First();

        if (warehouseQuery == null)
            throw new Exception("库位编码" + query.DepotCode + " 不存在，请确认！");

        return warehouseQuery;
    }

    /// <summary>
    ///     生产退料扫描条码
    /// </summary>
    /// <param name="query">仓库查询参数</param>
    /// <returns>处理结果</returns>
    public WarehouseQuery SctlScanBarcode(WarehouseQuery query)
    {

        // 2. 验证条码信息
        var barcode = Db.Queryable<MesInvItemBarcodes>()
            .Where(x => x.ItemBarcode == query.barcode)
            .First();
        if (barcode == null)
            throw new Exception($"无此条码，请核对！{query.barcode}");

        // 3. 验证物料信息
        var item = Db.Queryable<MesItems>()
            .Where(x => x.Id == barcode.ItemId)
            .First();
        if (item == null)
            throw new Exception($"无此物料，请核对！{query.barcode}");

        // 4. 验证退料单信息
        var returnOrder = Db.Queryable<MesItemTbl>()
            .Where(x => x.BillNo == query.billNo && (x.Tbl013 ?? 0) == 1)
            .First();
        if (returnOrder == null)
            throw new Exception("申请单已撤回,无法扫码!");

        if (returnOrder.Tbl020 == 1)
            throw new Exception("扫码完成,申请单已完结!");

        // 5. 使用存储过程处理生产退料
        var parameters = new SqlParameter[]
        {
    new SqlParameter("@pi_user", query.userName),
    new SqlParameter("@pi_barcode", query.barcode),
    new SqlParameter("@pi_bill_no", query.billNo),
    new SqlParameter("@pi_section_code", query.DepotCode),
    new SqlParameter("@PI_INP1", DBNull.Value),  // 备用参数1
    new SqlParameter("@PI_INP2", DBNull.Value),  // 备用参数2
    new SqlParameter("@PO_OUT_MSG", SqlDbType.NVarChar, 2000) { Direction = ParameterDirection.Output },
    new SqlParameter("@PO_OUT_SUM", SqlDbType.Int) { Direction = ParameterDirection.Output },
    new SqlParameter("@PO_ITEM_NO", SqlDbType.NVarChar, 100) { Direction = ParameterDirection.Output },
    new SqlParameter("@PO_QUANTITY", SqlDbType.Decimal) { Direction = ParameterDirection.Output }
        };

        string procedureName = "PRC_PDA_SCTL";
        int res = DbHelperSQL.RunProcedure_NonQuery(procedureName, parameters);

        // 获取输出参数
        var outMsg = parameters[6].Value?.ToString() ?? string.Empty;
        var outSum = parameters[7].Value != DBNull.Value ? Convert.ToInt32(parameters[7].Value) : -1;
        var itemNo = parameters[8].Value?.ToString() ?? string.Empty;
        var quantity = parameters[9].Value != DBNull.Value ? Convert.ToDecimal(parameters[9].Value) : 0m;

        // 检查存储过程执行结果
        if (outSum == -1)
        {
            throw new Exception(outMsg);
        }

        query.itemNo = itemNo;
        query.Num = quantity;
        return query;


        //var p_item_barcode = query.barcode; // 物料条码
        //var p_bill_no = query.billNo; // 单据号
        //var p_section_code = query.DepotCode; // 库位编码
        //var c_user = query.userName; // 用户名

        //var p_bill_type_id = 100; // 单据类型ID
        //var p_transction_no = 104; // 交易编号

        //// 验证库位条码
        //if (p_section_code.IsNullOrEmpty()) throw new Exception("请扫库位条码！");

        //// 获取库位信息
        //var c_depot_code = Db.Queryable<MesDepotSections, MesDepots>((a, b) =>
        //        new JoinQueryInfos(JoinType.Inner, a.DepotGuid == b.Guid))
        //    .Where((a, b) => a.DepotSectionCode == p_section_code)
        //    .Select((a, b) => b.DepotId).First();

        //if (!c_depot_code.HasValue)
        //    throw new Exception("库位编码" + p_section_code + " 不存在，请确认！");

        //// 获取库位分区信息
        //var mesDepotSections = Db.Queryable<MesDepotSections>()
        //    .Where(a => a.DepotSectionCode == p_section_code).First();

        //if (mesDepotSections == null)
        //    throw new Exception("库位编码" + p_section_code + " 不存在，请确认！");

        //// 获取库位基础信息
        //var c_mes_depots = Db.Queryable<MesDepots>()
        //    .Where(b => b.Guid == mesDepotSections.DepotGuid).First();

        //if (c_mes_depots == null)
        //    throw new Exception("库位编码" + p_section_code + " 不存在，请确认！");

        //// 检查条码是否已入库
        //var c_num = Db.Queryable<MesInvItemIns, MesInvItemInCDetails>((a, b) =>
        //        new JoinQueryInfos(JoinType.Inner, a.Guid == b.ItemInId))
        //    .Where((a, b) => b.ItemBarcode == p_item_barcode
        //                     && a.BillTypeId == p_bill_type_id &&
        //                     a.TransctionNo == p_transction_no.ToString())
        //    .Count();

        //if (c_num > 0) throw new Exception("此条码已扫入库，勿重复扫描！");

        //c_num = Db.Queryable<MesInvItemStocks>()
        //    .Where(t => t.ItemBarcode == p_item_barcode).Count();

        //if (c_num > 0) throw new Exception("此条码已扫入库，勿重复扫描！");

        //// 获取条码信息
        //var c_mes_inv_item_barcodes = Db.Queryable<MesInvItemBarcodes>()
        //    .Where(t => t.ItemBarcode == p_item_barcode).First();

        //if (c_mes_inv_item_barcodes == null)
        //    throw new Exception("此条码不属于该退料单，请核对！");

        //if (c_mes_inv_item_barcodes.Memo != "生产退料")
        //    throw new Exception("此条码不是生产退料条码，不可使用生产退料模块！");

        //// 使用 String.Equals 方法进行字符串比较，指定比较规则为忽略大小写，提高比较的灵活性
        //if (!string.Equals(c_mes_inv_item_barcodes.BillNo, p_bill_no, StringComparison.OrdinalIgnoreCase))
        //    throw new Exception($"该条码对应的申请号【{c_mes_inv_item_barcodes.BillNo}】与 当前申请单号【{p_bill_no}】不一致，请核对！");
        //// 获取退料单信息
        //var C_MES_ITEM_TBL = Db.Queryable<MesItemTbl>()
        //    .Where(a => a.BillNo == p_bill_no
        //                && (a.Tbl013 ?? 0) == 1).First();



        //// 获取退料单信息
        //var tbWOMDAA = Db.Queryable<Womdaa>()
        //    .Where(a => a.Guid.ToString() == C_MES_ITEM_TBL.Tbl002).First();



        //if (C_MES_ITEM_TBL == null) throw new Exception("申请单已撤回,无法扫码!");

        //if (C_MES_ITEM_TBL.Tbl020 == 1) throw new Exception("扫码完成,申请单已完结!");

        //// 获取退料单明细
        //var C_MES_ITEM_TBL_DETAIL = Db.Queryable<MesItemTblDetail>()
        //    .Where(a => a.Tlid == c_mes_inv_item_barcodes.AboutGuid)
        //    .First();

        //if (C_MES_ITEM_TBL_DETAIL == null)
        //    throw new Exception("条码不属于该申请单明细,无法扫码!");

        //var CABerpid = Db.Queryable<Womdab>().Where(womdab => womdab.Guid.ToString() == C_MES_ITEM_TBL_DETAIL.Tld013).Select(womdab => womdab.Erpid).First();

        //var ownerId = Db.Queryable<Womcab>().Where(womcab => womcab.Erpid == CABerpid.Value).Select(womcab => womcab.OwnerId).First();

        //if (ownerId == null) throw new Exception("用料清单货主信息不存在,无法扫码，请联系管理员!");

        //var owner_type = "";
        //if (Db.Queryable<SysOrganization>().Any(x => x.Fid == ownerId))
        //{
        //    owner_type = "BD_OwnerOrg";
        //}
        //else
        //{
        //    // 第二层判断：检查 MES_CUSTOMER
        //    if (Db.Queryable<MesCustomer>().Any(x => x.Id == Convert.ToInt32(ownerId)))
        //    {
        //        owner_type = "BD_Customer";
        //    }
        //    else
        //    {
        //        // 第三层判断：检查 MES_SUPPLIER
        //        if (Db.Queryable<MesSupplier>().Any(x => x.Id == Convert.ToInt32(ownerId)))
        //        {
        //            owner_type = "BD_Supplier";
        //        }
        //        else
        //        {
        //            throw new Exception("入库失败,用料清单货主信息存在问题，请联系管理员解决！");
        //        }
        //    }
        //}


        //var c_quantity = c_mes_inv_item_barcodes.Quantity;

        //var c_bill_no = "";
        //var c_id = Guid.Empty;

        //// 使用事务处理数据更新
        //UseTransaction(db =>
        //{
        //    // 查询入库单
        //    var mesInvItemIns = db.Queryable<MesInvItemIns>()
        //        .Where(d =>
        //            d.Status == 0 && d.TransctionNo ==
        //                          p_transction_no.ToString()
        //                          && d.TaskNo == c_mes_inv_item_barcodes.BillNo
        //                          && d.DepotsId == c_depot_code
        //                          && d.InsDate.Value.ToString("yyyyMMdd") ==
        //                          DateTime.Now.ToString("yyyyMMdd")).First();

        //    var totalResult = 0;

        //    // 如果入库单不存在则创建新的入库单
        //    if (mesInvItemIns == null)
        //    {
        //        c_bill_no = BillNo.GetBillNo("SCTL(生产退料)");

        //        c_id = Guid.NewGuid();

        //        totalResult += db.Insertable(new MesInvItemIns
        //        {
        //            Guid = c_id,
        //            BillNo = c_bill_no,
        //            BillTypeId = p_bill_type_id,
        //            InsDate = DateTime.Now,
        //            DepotsId = c_depot_code,
        //            UserNoBack = c_user,
        //            Reason = C_MES_ITEM_TBL.Tbl005,
        //            Remark = C_MES_ITEM_TBL.Tbl006,
        //            //InsDate = DateTime.Now,
        //            DepotsCode = c_mes_depots.DepotCode,
        //            TaskNo = c_mes_inv_item_barcodes.BillNo,
        //            //DepotsId = c_depot_code,
        //            TransctionNo = p_transction_no.ToString(),
        //            CreateBy = c_user,
        //            CreateDate = DateTime.Now,
        //            LastupdateBy = c_user,
        //            LastupdateDate = DateTime.Now,
        //            CbillNo = tbWOMDAA.Daa001,
        //            InType = "生产退料",
        //            ReceiveOrgId = c_mes_depots.FSubsidiary,
        //            Fstatus = 0,
        //            Status = 0,
        //            WorkNo = tbWOMDAA.Daa021
        //        }).IgnoreColumns(true).ExecuteCommand();
        //    }
        //    else
        //    {
        //        c_id = mesInvItemIns.Guid;
        //        c_bill_no = mesInvItemIns.BillNo;
        //    }

        //    // 检查是否为合并打印条码
        //    var hbdy = c_mes_inv_item_barcodes.Hbdy ?? 0;
        //    if (hbdy == 1) throw new Exception("不支持合并打印的条码:" + p_item_barcode);


        //    // 检查是否存在于 MES_INV_ITEM_IN_C_ITEMS 表
        //    var existingCount = db.Queryable<MesInvItemInCItems>()
        //    .Where(it =>
        //        it.ItemInId == c_id &&
        //                        it.ItemId == C_MES_ITEM_TBL_DETAIL.Tld009 &&
        //                        it.DepotId == c_depot_code.ToString())
        //        .Count();

        //    if (existingCount == 0)
        //        // 不存在时插入新记录
        //        db.Insertable(new MesInvItemInCItems
        //        {
        //            ItemInId = c_id,
        //            Quantity = c_mes_inv_item_barcodes.Quantity,
        //            CreateBy = c_user,
        //            CreateDate = DateTime.Now,
        //            ItemNo = c_mes_inv_item_barcodes.ItemNo,
        //            //DepotCode = mesDepost.DepotCode,
        //            ItemSname = c_mes_inv_item_barcodes.ItemSname,
        //            Unit = c_mes_inv_item_barcodes.Unit,
        //            Ebeln = c_mes_inv_item_barcodes.WorkNo,
        //            BillNo = c_bill_no,
        //            WorkNo = c_mes_inv_item_barcodes.WorkNo,
        //            EbelnLineNo = c_mes_inv_item_barcodes.WorkLine,
        //            CbillNo = c_mes_inv_item_barcodes.BillNo,
        //            WorkLine = c_mes_inv_item_barcodes.WorkLine,
        //            SuppId = c_mes_inv_item_barcodes.SuppId,
        //            SuppNo = c_mes_inv_item_barcodes.SuppNo,
        //            Remark = c_mes_inv_item_barcodes.Memo,
        //            EbelnK3id = c_mes_inv_item_barcodes.EbelnK3id,
        //            LineK3id = c_mes_inv_item_barcodes.LineK3id,
        //            ItemId = c_mes_inv_item_barcodes.ItemId,
        //            DepotCode = c_mes_depots.DepotCode,
        //            DepotId = c_depot_code.ToString(),
        //            itemDabid = C_MES_ITEM_TBL_DETAIL.Tlid.ToString()
        //        }).IgnoreColumns(true).ExecuteCommand();
        //    else
        //        // 存在时更新数量
        //        db.Updateable<MesInvItemInCItems>()
        //            .SetColumns(it => new MesInvItemInCItems
        //            {
        //                Quantity = SqlFunc.IsNull(it.Quantity, 0) + c_mes_inv_item_barcodes.Quantity // 确保 Quantity 不为 null
        //            })
        //        .Where(it =>
        //               it.ItemInId == c_id &&
        //                        it.ItemId == C_MES_ITEM_TBL_DETAIL.Tld009 &&
        //                        it.DepotId == c_depot_code.ToString())
        //            //.IgnoreColumns(true) // 保留 IgnoreColumns
        //            .ExecuteCommand();


        //    // 插入 mes_inv_item_in_c_details 表
        //    totalResult += db.Insertable(new MesInvItemInCDetails
        //    {
        //        ItemInId = c_id,
        //        BillNo = c_bill_no,
        //        ItemBarcode = p_item_barcode,
        //        Quantity = c_mes_inv_item_barcodes.Quantity,
        //        BarcodeFlag = true,
        //        EpFlag = true,
        //        WorkType = 1,
        //        ItemNo = c_mes_inv_item_barcodes.ItemNo,
        //        //LotNo = cgddDetails.BatchNumber,--批号，退料不设置批号
        //        SuppId = c_mes_inv_item_barcodes.SuppId,
        //        SuppNo = c_mes_inv_item_barcodes.SuppNo,
        //        //DepotCode = mesDepost.DepotCode,
        //        DepotSectionCode = p_section_code,
        //        ItemSname = c_mes_inv_item_barcodes.ItemSname,
        //        Unit = c_mes_inv_item_barcodes.Unit,
        //        CreateBy = c_user,
        //        CreateDate = DateTime.Now,
        //        LastupdateBy = c_user,
        //        LastupdateDate = DateTime.Now,
        //        Remark = c_mes_inv_item_barcodes.Memo,
        //        Ebeln = c_mes_inv_item_barcodes.Mblnr,
        //        EbelnLineNo = c_mes_inv_item_barcodes.Zeile,
        //        WorkNo = c_mes_inv_item_barcodes.WorkNo,
        //        WorkLine = c_mes_inv_item_barcodes.WorkLine,
        //        CbillNo = c_mes_inv_item_barcodes.BillNo,
        //        UrgentFlag = c_mes_inv_item_barcodes.UrgentFlag,
        //        BoardStyle = c_mes_inv_item_barcodes.BoardStyle,
        //        TaskNo = c_mes_inv_item_barcodes.TaskNo,
        //        EbelnK3id = c_mes_inv_item_barcodes.EbelnK3id,
        //        LineK3id = c_mes_inv_item_barcodes.LineK3id,
        //        ItemId = c_mes_inv_item_barcodes.ItemId,
        //        Ischeck = true,
        //        //CheckDate = C_MES_ITEM_TBL_DETAIL.CheckDate,
        //        //CheckRes = C_MES_ITEM_TBL_DETAIL.CheckRes,
        //        //CheckStates = C_MES_ITEM_TBL_DETAIL.CheckStates,--检验信息
        //        ReceiveOrgId = c_mes_depots.FSubsidiary,
        //        DepotCode = c_mes_depots.DepotCode,
        //        DepotId = Convert.ToInt64(c_depot_code)
        //    }).IgnoreColumns(true).ExecuteCommand();

        //    // 插入业务记录
        //    totalResult += db.Insertable(new MesInvBusiness2
        //    {
        //        Guid = Guid.NewGuid(),
        //        Status = 1,
        //        BillTypeId = p_bill_type_id,
        //        TransactionCode = p_transction_no.ToString(),
        //        BusinessType = 1,
        //        ItemBarcode = p_item_barcode,
        //        ItemNo = c_mes_inv_item_barcodes.ItemNo,
        //        LotNo = c_mes_inv_item_barcodes.LotNo,
        //        EpFlag = true,
        //        Quantity = c_mes_inv_item_barcodes.Quantity,
        //        ToInvDepotsCode = c_mes_depots.DepotCode,
        //        InvDepotId = c_depot_code,
        //        ToInvDepotSectionsCode = p_section_code,
        //        Description = "生产退料",
        //        CreateBy = c_user,
        //        CreateDate = DateTime.Now,
        //        LastupdateBy = c_user,
        //        LastupdateDate = DateTime.Now,
        //        TaskNo = c_mes_inv_item_barcodes.TaskNo,
        //        BillNo = c_bill_no,
        //        WorkNo = c_mes_inv_item_barcodes.WorkNo,
        //        WorkLine = c_mes_inv_item_barcodes.WorkLine,
        //        SuppId = c_mes_inv_item_barcodes.SuppId,
        //        SuppNo = c_mes_inv_item_barcodes.SuppNo,
        //        ItemId = c_mes_inv_item_barcodes.ItemId
        //    }).IgnoreColumns(true).ExecuteCommand();

        //    // 插入库存记录
        //    totalResult += db.Insertable(new MesInvItemStocks
        //    {
        //        Guid = Guid.NewGuid(),
        //        TaskNo = c_mes_inv_item_barcodes.TaskNo,
        //        ItemBarcode = p_item_barcode,
        //        ItemNo = c_mes_inv_item_barcodes.ItemNo,
        //        LotNo = c_mes_inv_item_barcodes.LotNo,
        //        Quantity = c_mes_inv_item_barcodes.Quantity,
        //        //EpFlag = c_mes_inv_item_barcodes.EpFlag.Value
        //        //    ? (byte)1
        //        //    : (byte)0,
        //        DepotId = c_mes_depots.DepotId,
        //        DepotsCode = c_mes_depots.DepotCode,
        //        DepotSectionsCode = p_section_code,
        //        CheckDate = c_mes_inv_item_barcodes.CreateDate,
        //        IndepDate = DateTime.Now,
        //        BoardStyle = c_mes_inv_item_barcodes.BoardStyle,
        //        WorkNo = c_mes_inv_item_barcodes.WorkNo,
        //        WorkLine = c_mes_inv_item_barcodes.WorkLine,
        //        SuppNo = c_mes_inv_item_barcodes.SuppNo,
        //        ItemId = c_mes_inv_item_barcodes.ItemId,
        //        BillNo = c_mes_inv_item_barcodes.BillNo,
        //        //DepotId = Convert.ToInt32(c_depot_code),
        //        OwnerId = ownerId,
        //        OwnerType = owner_type,
        //        StockOrgId = c_mes_depots.FSubsidiary,
        //        IndepUserCode = c_user
        //    }).IgnoreColumns(true).ExecuteCommand();

        //    // 根据退料类型(良品退料、来料不良退料、作业不良退料)更新相关数据
        //    if (C_MES_ITEM_TBL.Tbl005 is "良品退料" or "来料不良退料")
        //    {
        //        // 良品退料 - 更新工单表(WOMDAB)相关数量
        //        if (C_MES_ITEM_TBL.Tbl005 == "良品退料")
        //            totalResult += Db.Updateable<Womdab>()
        //                .SetColumns(it => new Womdab
        //                {
        //                    Dab007 = it.Dab007 -
        //                             c_mes_inv_item_barcodes.Quantity, // 减少工单数量
        //                    Dab022 = (it.Dab022 ?? 0) +
        //                             c_mes_inv_item_barcodes.Quantity, // 增加退料数量
        //                    LpTl = (it.LpTl ?? 0) +
        //                           (int)c_mes_inv_item_barcodes
        //                               .Quantity, // 增加良品退料数量
        //                    Dab020 = (it.Dab020 ?? 0) -
        //                             c_mes_inv_item_barcodes.Quantity // 减少已发料数量
        //                })
        //                .Where(it => it.Dab001 == c_mes_inv_item_barcodes.WorkNo
        //                             && it.Dab002 == c_mes_inv_item_barcodes
        //                                 .WorkLine
        //                             && it.Dab003 == c_mes_inv_item_barcodes
        //                                 .ItemId.ToString())
        //                .ExecuteCommand();
        //        // 来料不良退料 - 更新工单表(WOMDAB)相关数量
        //        else if (C_MES_ITEM_TBL.Tbl005 == "来料不良退料")
        //            totalResult += Db.Updateable<Womdab>()
        //                .SetColumns(it => new Womdab
        //                {
        //                    Dab007 = it.Dab007 -
        //                             c_mes_inv_item_barcodes.Quantity, // 减少工单数量
        //                    Dab022 = (it.Dab022 ?? 0) +
        //                             c_mes_inv_item_barcodes.Quantity, // 增加退料数量
        //                    LlBl = (it.LlBl ?? 0) +
        //                           (int)c_mes_inv_item_barcodes
        //                               .Quantity, // 增加来料不良数量
        //                    Dab020 = (it.Dab020 ?? 0) -
        //                             c_mes_inv_item_barcodes.Quantity // 减少已发料数量
        //                })
        //                .Where(it => it.Dab001 == c_mes_inv_item_barcodes.WorkNo
        //                             && it.Dab002 == c_mes_inv_item_barcodes
        //                                 .WorkLine
        //                             && it.Dab003 == c_mes_inv_item_barcodes
        //                                 .ItemId.ToString())
        //                .ExecuteCommand();

        //        // 更新退料单明细表已退数量
        //        totalResult += Db.Updateable<MesItemTblDetail>()
        //            .SetColumns(it => new MesItemTblDetail
        //            {
        //                Tld006 = (it.Tld006 ?? 0) +
        //                         (int)c_mes_inv_item_barcodes.Quantity // 增加已退数量
        //            })
        //            .Where(it => it.Tlmid == C_MES_ITEM_TBL.Id &&
        //                         it.Tlid == c_mes_inv_item_barcodes.AboutGuid)
        //            .ExecuteCommand();
        //    }
        //    // 作业不良退料 - 更新工单表和退料单明细表
        //    else if (C_MES_ITEM_TBL.Tbl005 == "作业不良退料")
        //    {
        //        totalResult += Db.Updateable<Womdab>()
        //            .SetColumns(it => new Womdab
        //            {
        //                Dab022 = (it.Dab022 ?? 0) +
        //                         c_mes_inv_item_barcodes.Quantity, // 增加退料数量
        //                ZyBl = (it.ZyBl ?? 0) +
        //                       (int)c_mes_inv_item_barcodes
        //                           .Quantity, // 增加作业不良数量
        //                Dab020 = (it.Dab020 ?? 0) -
        //                         c_mes_inv_item_barcodes.Quantity // 减少已发料数量
        //            })
        //            .Where(it => it.Dab001 == c_mes_inv_item_barcodes.WorkNo
        //                         && it.Dab002 ==
        //                         c_mes_inv_item_barcodes.WorkLine
        //                         && it.Dab003 == c_mes_inv_item_barcodes.ItemId
        //                             .ToString())
        //            .ExecuteCommand();

        //        // 更新退料单明细表已退数量
        //        totalResult += Db.Updateable<MesItemTblDetail>()
        //            .SetColumns(it => new MesItemTblDetail
        //            {
        //                Tld006 = (it.Tld006 ?? 0) +
        //                         (int)c_mes_inv_item_barcodes.Quantity // 增加已退数量
        //            })
        //            .Where(it => it.Tlmid == C_MES_ITEM_TBL.Id &&
        //                         it.Tlid == c_mes_inv_item_barcodes.AboutGuid)
        //            .ExecuteCommand();
        //    }

        //    // 如果待退数量等于本次退料数量，则更新明细完成状态
        //    if ((C_MES_ITEM_TBL_DETAIL.Tld005 ?? 0) -
        //        (C_MES_ITEM_TBL_DETAIL.Tld006 ?? 0) ==
        //        c_mes_inv_item_barcodes.Quantity)
        //        totalResult += Db.Updateable<MesItemTblDetail>()
        //            .SetColumns(it => new MesItemTblDetail
        //            { Tld008 = 1 }) // 设置完成标志
        //            .Where(it => it.Tlid == C_MES_ITEM_TBL_DETAIL.Tlid)
        //            .ExecuteCommand();

        //    // 检查退料单是否所有明细都已完成
        //    var remainingCount = Db.Queryable<MesItemTbl, MesItemTblDetail>(
        //            (a, b) =>
        //                new JoinQueryInfos(JoinType.Left, a.Id == b.Tlmid))
        //        .Where((a, b) =>
        //            a.BillNo == p_bill_no &&
        //            (b.Tld005 ?? 0) - (b.Tld006 ?? 0) > 0)
        //        .Count();

        //    // 如果所有明细都已完成，则更新退料单状态为已完成
        //    if (remainingCount < 1)
        //        totalResult += Db.Updateable<MesItemTbl>()
        //            .SetColumns(it => it.Tbl020 == 1) // 设置完成标志
        //            .Where(it => it.BillNo == p_bill_no)
        //            .ExecuteCommand();

        //    // 检查必要的插入操作是否都成功执行
        //    var minimumExpectedOperations = 3; // 至少需要执行的插入操作数
        //    if (totalResult < minimumExpectedOperations)
        //        throw new Exception(
        //            $"关键数据插入失败，预期至少{minimumExpectedOperations}个操作，实际执行{totalResult}个操作");

        //    // 创建 插入日志
        //    var logService = new LogService();
        //    var LogMsg = "[PDA]生产退料。条码【" + query.barcode + "】 退料单号【" + c_bill_no + "】";
        //    logService.CreateLog(db, query.userName, tbWOMDAA.Guid.ToString(), "WOMDAA", LogMsg, tbWOMDAA.Daa001);

        //    return totalResult;
        //});

        //query.itemNo = itemNo;
        //query.Num = quantity;
        //return query;
    }
}