api/WmsSpaHelper.cs
@@ -30,12 +30,17 @@
using System.Security.Policy;
using HH.WCS.Mobox3.pinggao.models;
using static HH.WCS.Mobox3.pinggao.wms.WMSHelper;
using WHTest;
using System.Net;
using SqlSugar;
using static HH.WCS.Mobox3.pinggao.models.SapRoot.GYSDto;
using System.Web.Services.Protocols;
using System.Web.Http.ValueProviders;
using System.Diagnostics;
using System.Data.SqlClient;
using System.Data.Common;
using System.Data;
using System.Runtime.ConstrainedExecution;
using HH.WCS.Mobox3.pinggao.core;
namespace HH.WCS.Mobox3.pinggao.api
{
@@ -46,6 +51,35 @@
        }
        public static bool MaterPanduan(string ItemCode, double count)
        {
            bool panduan = true;
            var db = new SqlHelper<object>().GetInstance();
            var po = db.Queryable<TN_Material_KC>().Where(a => a.S_ITEM_CODE == ItemCode).First();
            var po1 = db.Queryable<CntrItemRel>().Where(a => a.S_ITEM_CODE == ItemCode).First();
            if (po != null)
            {
                if (po1 != null)
                {
                    double sl = po1.F_QTY + count;
                    if (sl > po.N_COUNT)
                    {
                        panduan = false;
                    }
                }
                if (count > po.N_COUNT)
                {
                    panduan = false;
                }
            }
            else
            {
                panduan = false;
            }
            return panduan;
        }
        /// <summary>
        /// 数据
        /// </summary>
@@ -569,7 +603,8 @@
                            }
                        }
                    }else
                    }
                    else
                    {
                        //冲销凭证单号
@@ -686,15 +721,21 @@
                    //创建入库单主子表
                   // var po = WMSHelper.GetGYSBMOrder(item.JBXX.GYSBM);
                    var po= db.Queryable<TN_Supplier>().Includes(a => a.Details).Where(a => a.S_GYSBM == item.JBXX.GYSBM).First();
                    // var po = WMSHelper.GetGYSBMOrder(item.JBXX.GYSBM);
                    var po = db.Queryable<TN_Supplier>().Includes(a => a.Details).Where(a => a.S_GYSBM == item.JBXX.GYSBM).First();
                    if (po != null)
                    {
                        db.Deleteable<TN_Supplier>().Where(it => it.S_GYSBM == po.S_GYSBM).ExecuteCommand();
                        db.Deleteable<TN_Supplier_detial>().Where(it => it.S_DO_GYSBM == po.S_GYSBM).ExecuteCommand();
                    }
                    po = new TN_Supplier { S_GYSBM = item.JBXX.GYSBM, S_MDMBM = item.JBXX.MDMBM, S_GYSMC=item.JBXX.GYSMC, S_YHGJ=item.JBXX.YHGJ, S_YHDM = item.JBXX.YHDM ,
                    po = new TN_Supplier
                    {
                        S_GYSBM = item.JBXX.GYSBM,
                        S_MDMBM = item.JBXX.MDMBM,
                        S_GYSMC = item.JBXX.GYSMC,
                        S_YHGJ = item.JBXX.YHGJ,
                        S_YHDM = item.JBXX.YHDM,
                        S_KHH = item.JBXX.KHH,
                        S_YHJD = item.JBXX.YHJD,
                        S_YHCS = item.JBXX.YHCS,
@@ -771,10 +812,10 @@
            try
            {
                db.BeginTran();
                List<TN_GENERATE_ORDER> tN_GENERATE_ORDERs = new List<TN_GENERATE_ORDER>();
                foreach (var item in model.ROOT.SCDD)
                {
                    Orderback.ITEM iTEM = new Orderback.ITEM();
                    var materlist = db.Queryable<TN_GENERATE_ORDER>().Where(it => it.S_SCDDH == item.SCDDH).First();
                    if (materlist == null)
                    {
@@ -794,8 +835,9 @@
                        tnorder.S_WBS = item.WBS;
                        tnorder.S_SHF = item.SHF;
                        tnorder.GZLH = item.GZLH;
                        tN_GENERATE_ORDERs.Add(tnorder);
                        //tnorder.S_XLH = string.Join(",", item.ITEM.Select(items => items.XLH));
                        db.Insertable<TN_GENERATE_ORDER>(tnorder).ExecuteCommand();
                    }
                    else
                    {
@@ -811,6 +853,7 @@
                    iTEM.MSGDESP = $"成功";
                    tEMs.Add(iTEM);
                }
                db.Insertable<TN_GENERATE_ORDER>(tN_GENERATE_ORDERs).ExecuteCommand();
                orderResponse.ROOT.ITEM = tEMs;
                db.CommitTran();
            }
@@ -850,6 +893,13 @@
            };
            db.BeginTran();
            List<WLReturnRoot.ITEM> list = new List<WLReturnRoot.ITEM>();
            var itemCodes = model.ROOT.ITEM.Select(item => item.WLBM).ToList();
            var itemlist = db.Queryable<TN_Material>()
            .Where(it => itemCodes.Contains(it.S_ITEM_CODE))
            .ToList();
            foreach (var item in model.ROOT.ITEM)
            {
                try
@@ -857,7 +907,7 @@
                    var result = new WLReturnRoot.ITEM();
                    var materlist = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == item.WLBM).First();
                    var materlist = itemlist.Where(it => it.S_ITEM_CODE == item.WLBM).First();
                    if (materlist == null)
                    {
                        TN_Material tN_Material = new TN_Material();
@@ -991,14 +1041,21 @@
                        #region 创建领料单
                        if (po == null)
                        {
                        {
                            po = new TN_Ll_Order { S_NO = itemwlpz.HEAD.WLPZH, S_FACTORY = itemwlpz.ITEM[0].FHGC, S_OUT_TYPE = "内采出库", S_BS_TYPE = itemwlpz.HEAD.YDLX, S_AREA_CODE = "HJQ", S_BS_NO = itemwlpz.HEAD.WLPZH };
                            po.Details = new List<TN_Ll_detail>();
                            if (itemwlpz.ITEM.Count() > 0)
                            {
                                var itemCodes = itemwlpz.ITEM.Select(items => items.WLBM).ToList();
                                var itemlist = db.Queryable<TN_Material>()
                                .Where(it => itemCodes.Contains(it.S_ITEM_CODE))
                                .ToList();
                                foreach (var a in itemwlpz.ITEM)
                                {
                                    var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.WLBM).First();
                                    var item = itemlist.Where(it => it.S_ITEM_CODE == a.WLBM).First();
                                    if (item == null)
                                    {
@@ -1040,8 +1097,15 @@
                            List<TN_Ll_detail> listtn = new List<TN_Ll_detail>();
                            if (po.N_B_STATE != 0)
                            {
                                var itemCodes = itemwlpz.ITEM.Select(items => items.WLBM).ToList();
                                var itemlist = db.Queryable<TN_Material>()
                                .Where(it => itemCodes.Contains(it.S_ITEM_CODE))
                                .ToList();
                                foreach (var a in itemwlpz.ITEM)
                                {
                                    //if (a.LLDSCBS == "Y")//如果是删除标识则删除当前所属出库单明细 不是删除标记 则进行增改判断
                                    //{
                                    //    result.resultCode = 1;
@@ -1051,7 +1115,7 @@
                                    var po1 = po.Details.Where(s => a.WLBM == s.S_ITEM_CODE).ToList();
                                    if (po1.Count() == 0)  //无则新增物料明细
                                    {
                                        var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.WLBM).First();
                                        var item = itemlist.Where(it => it.S_ITEM_CODE == a.WLBM).First();
                                        if (item == null)
                                        {
@@ -1107,36 +1171,24 @@
                            }//执行中订单
                            else if (po.N_B_STATE == 0)//未执行 执行增删改操作
                            {
                                var itemCodes = itemwlpz.ITEM.Select(items => items.WLBM).ToList();
                                var itemlist = db.Queryable<TN_Material>()
                                .Where(it => itemCodes.Contains(it.S_ITEM_CODE))
                                .ToList();
                                foreach (var a in itemwlpz.ITEM)
                                {
                                    //if (a.LLDSCBS == "Y")//如果是删除标识则删除当前所属出库单明细 不是删除标记 则进行增改判断
                                    //{
                                    //    var po1 = po.Details.Where(s => a.WLH == s.S_ITEM_CODE).ToList();
                                    //    if (po1.Count() > 0)  //无则新增物料明细
                                    //    {
                                    //        db.Deleteable<TN_Ll_detail>().Where(it => it.S_ITEM_CODE == a.WLH && it.S_DO_NO == po1.First().S_DO_NO).ExecuteCommand();
                                    //    }
                                    //    else
                                    //    {
                                    //        result.resultCode = 1;
                                    //        result.resultMsg = $"物料{a.WLH}物料数据不存在 无法删除";
                                    //        throw new Exception($"物料{a.WLH}物料数据不存在 无法删除");
                                    //    }
                                    //}
                                    //else
                                    //{
                                    var po1 = po.Details.Where(s => a.WLBM == s.S_ITEM_CODE).ToList();
                                    if (po1.Count() == 0)  //无则新增物料明细
                                    {
                                        var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.WLBM).First();
                                        var item = itemlist.Where(it => it.S_ITEM_CODE == a.WLBM).First();
                                        if (item == null)
                                        {
                                            result.resultCode = 1;
                                            result.resultMsg = $"物料{a.WLBM}物料主数据不存在该物料";
                                            result.resultMsg = "失败";
                                            result.WLPZBH = itemwlpz.HEAD.WLPZH;
                                            result.WLPZND = itemwlpz.HEAD.ND;
                                            simpleResults.Add(result);
                                            continue;
                                            /*  throw new Exception($"物料{a.WLH}物料主数据不存在该物料")*/
                                            ;
@@ -1186,7 +1238,8 @@
                            po.Details = new List<TN_Inbound_Detail>();
                            if (itemwlpz.ITEM.Count > 0)
                            {
                                itemwlpz.ITEM.ForEach(a =>
                                foreach (var a in itemwlpz.ITEM)
                                {
                                    po.Details.Add(new TN_Inbound_Detail
@@ -1210,7 +1263,7 @@
                                    });
                                    //}
                                });
                                }
                                db.Insertable<TN_Inbound_Order>(po).ExecuteCommand();
                                db.Insertable<TN_Inbound_Detail>(po.Details).ExecuteCommand();
                                db.CommitTran();
@@ -1224,7 +1277,7 @@
                            var Details = new List<TN_Inbound_Detail>();
                            if (itemwlpz.ITEM.Count > 0)
                            {
                                itemwlpz.ITEM.ForEach(a =>
                                foreach (var a in itemwlpz.ITEM)
                                {
                                    if (po.Details.Where(s => s.S_ITEM_CODE == a.WLBM).Count() > 0)
                                    {
@@ -1254,19 +1307,20 @@
                                        });
                                    }
                                });
                                }
                                db.Insertable<TN_Inbound_Detail>(Details).ExecuteCommand();
                                db.CommitTran();
                            }
                        }
                    }
                    result.resultMsg = "成功";
                    result.WLPZBH = itemwlpz.HEAD.WLPZH;
                    result.WLPZND = itemwlpz.HEAD.ND;
                    result.resultCode = 0;
                    result.resultMsg = "";
                    simpleResults.Add(result);
                    var result2 = new SimpleResult();
                    result2.resultMsg = "成功";
                    result2.WLPZBH = itemwlpz.HEAD.WLPZH;
                    result2.WLPZND = itemwlpz.HEAD.ND;
                    result2.resultCode = 0;
                    simpleResults.Add(result2);
                    db.CommitTran();
                }
            }
@@ -1298,6 +1352,8 @@
        /// <returns></returns>
        internal static List<SimpleResult> Otherbound_Order_In(otherDto.Root model)
        {
            Stopwatch sw = new Stopwatch();
            sw.Start();
            LogHelper.Info($"其他出入库调试");
            List<SimpleResult> simples = new List<SimpleResult>();
            using (var db = new SqlHelper<object>().GetInstance())
@@ -1305,9 +1361,15 @@
                try
                {
                    List<TN_Inbound_Detail> tN_Inbound_Details = new List<TN_Inbound_Detail>();
                    List<TN_Ll_detail> tN_Ll_Details = new List<TN_Ll_detail>();
                    foreach (var itemwlpz in model.ROOT.WLPZ)
                    {
                        var itemCodes = itemwlpz.ITEM.Select(item => item.WLBH).ToList();
                        var itemlist = db.Queryable<TN_Material>()
                        .Where(it => itemCodes.Contains(it.S_ITEM_CODE))
                        .ToList();
                        var result = new SimpleResult();
                        db.BeginTran();
@@ -1332,32 +1394,10 @@
                                po.Details = new List<TN_Inbound_Detail>();
                                if (itemwlpz.ITEM.Count > 0)
                                {
                                    itemwlpz.ITEM.ForEach(a =>
                                    foreach (var a in itemwlpz.ITEM)
                                    {
                                        #region 不需要
                                        //if (a.ITEM1.Select(s => s.XLH).Count() > 0)//判断序列号是否为多个
                                        //{
                                        //    foreach (var item in a.ITEM1.Select(s => s.XLH))
                                        //    {
                                        //        po.Details.Add(new TN_Inbound_Detail
                                        //        {
                                        //            S_IO_NO = model.ROOT.WLPZ.HEAD.WLPZBH,
                                        //            N_ROW_NO = po.Details.Count + 1,
                                        //            S_ITEM_CODE = a.WLH,
                                        //            F_QTY = a.SL,
                                        //            S_ITEM_STATE = "物料",
                                        //            S_ITEM_NAME = "物料",
                                        //            F_ACC_B_QTY = 0,
                                        //            S_KCDD = a.KCDD,
                                        //            S_UOM = a.JBJLDW,//计量单位
                                        //            S_SERIAL_NO = item,
                                        //            S_BATCH_NO = a.PC,
                                        //        });
                                        //    }
                                        //}
                                        //else
                                        //{
                                        #endregion
                                        LogHelper.Info($"效验{a.ITEM1}");
                                        po.Details.Add(new TN_Inbound_Detail
                                        {
@@ -1385,7 +1425,7 @@
                                        });
                                        //}
                                    });
                                    }
                                    db.Insertable<TN_Inbound_Order>(po).ExecuteCommand();
                                    db.Insertable<TN_Inbound_Detail>(po.Details).ExecuteCommand();
                                    db.CommitTran();
@@ -1397,14 +1437,15 @@
                                var Details = new List<TN_Inbound_Detail>();
                                if (itemwlpz.ITEM.Count > 0)
                                {
                                    itemwlpz.ITEM.ForEach(a =>
                                    foreach (var a in itemwlpz.ITEM)
                                    {
                                        if (po.Details.Where(s => s.S_ITEM_CODE == a.WLBH).Count() > 0)
                                        {
                                            var poq = po.Details.Where(s => s.S_ITEM_CODE == a.WLBH).FirstOrDefault();
                                            poq.F_QTY = a.SL;
                                            db.Updateable(poq).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();
                                            tN_Inbound_Details.Add(poq);
                                            // db.Updateable(poq).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();
                                        }
                                        else
                                        {
@@ -1432,7 +1473,7 @@
                                            });
                                        }
                                    });
                                    }
                                    db.Insertable<TN_Inbound_Detail>(Details).ExecuteCommand();
                                    db.CommitTran();
@@ -1449,72 +1490,9 @@
                        }
                        else
                        {
                            #region
                            ////创建入库单主子表
                            //var po = WMSHelper.GetOutboundOrder(model.ROOT.WLPZ.HEAD.WLPZBH);
                            //if (po == null)
                            //{
                            //    po = new TN_Outbound_Order { S_NO = model.ROOT.WLPZ.HEAD.WLPZBH, S_AREA_CODE = "HJQ", S_BS_NO = model.ROOT.WLPZ.HEAD.WLPZBH, S_WLPZNF = model.ROOT.WLPZ.HEAD.WLPZNF, S_FACTORY = model.ROOT.WLPZ.ITEM[0].GC, S_OUT_TYPE = "其他出库", S_BS_TYPE = model.ROOT.WLPZ.ITEM[0].YDLX };
                            //    po.Details = new List<TN_Outbound_Detail>();
                            //    if (model.ROOT.WLPZ.ITEM.Count > 0)
                            //    {
                            //        model.ROOT.WLPZ.ITEM.ForEach(a =>
                            //        {
                            //            //if (a.ITEM1.Select(s => s.XLH).Count() > 0)//判断序列号是否为多个
                            //            //{
                            //            //    foreach (var item in a.ITEM1.Select(s => s.XLH))
                            //            //    {
                            //            //        po.Details.Add(new TN_Inbound_Detail
                            //            //        {
                            //            //            S_IO_NO = model.ROOT.WLPZ.HEAD.WLPZBH,
                            //            //            N_ROW_NO = po.Details.Count + 1,
                            //            //            S_ITEM_CODE = a.WLH,
                            //            //            F_QTY = a.SL,
                            //            //            S_ITEM_STATE = "物料",
                            //            //            S_ITEM_NAME = "物料",
                            //            //            F_ACC_B_QTY = 0,
                            //            //            S_KCDD = a.KCDD,
                            //            //            S_UOM = a.JBJLDW,//计量单位
                            //            //            S_SERIAL_NO = item,
                            //            //            S_BATCH_NO = a.PC,
                            //            //        });
                            //            //    }
                            //            //}
                            //            //else
                            //            //{
                            //            po.Details.Add(new TN_Outbound_Detail
                            //            {
                            //                S_DO_NO = model.ROOT.WLPZ.HEAD.WLPZBH,
                            //                N_ROW_NO = a.WLPZHXM,
                            //                S_ITEM_CODE = a.WLBH,
                            //                F_QTY = a.SL,
                            //                S_AREA_CODE = "测试",
                            //                S_ITEM_NAME = "物料",
                            //                S_KCDD = a.KCDD,
                            //                S_UOM = a.JLDW,//计量单位
                            //                S_SERIAL_NO = string.Join(",", a.ITEM1.Select(item => item.XLH)),
                            //                S_BATCH_NO = a.PC,
                            //                S_ERP_WH_CODE = a.KCDD,
                            //                N_ITEM_STATE = 1
                            //            });
                            //            //}
                            //        });
                            //        db.Insertable<TN_Outbound_Order>(po).ExecuteCommand();
                            //        db.Insertable<TN_Outbound_Detail>(po.Details).ExecuteCommand();
                            //        db.CommitTran();
                            //    }
                            //}
                            //else
                            //{
                            //    result.resultCode = 1;
                            //    result.resultMsg = "已经有重复单号,不可重复传输";
                            //    return result;
                            //}
                            #endregion
                            sw.Stop();
                           LogHelper.Info("第一次" + sw.ElapsedMilliseconds);
                            #region 创建领料单
                            var po = db.Queryable<TN_Ll_Order>().Includes(a => a.Details).Where(s => s.S_NO == itemwlpz.HEAD.WLPZBH).First();
@@ -1527,7 +1505,7 @@
                                    po.S_FACTORY = itemwlpz.ITEM[0].GC;
                                    foreach (var a in itemwlpz.ITEM)
                                    {
                                        var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.WLBH).First();
                                        var item = itemlist.Where(it => it.S_ITEM_CODE == a.WLBH).FirstOrDefault();
                                        if (item == null)
                                        {
                                            var result12 = new SimpleResult();
@@ -1546,7 +1524,7 @@
                                            N_ROW_NO = a.WLPZHXM,
                                            S_JDBS = a.JDBS,
                                            S_ITEM_CODE = a.WLBH,
                                            S_ITEM_NAME = item.S_ITEM_NAME,
                                            S_ITEM_NAME = item?.S_ITEM_NAME,
                                            F_QTY = a.SL,
                                            S_BATCH_NO = a.PC,
                                            S_ERP_WH_CODE = a.KCDD,
@@ -1557,7 +1535,20 @@
                                    }
                                    var result1 = db.Insertable<TN_Ll_Order>(po).ExecuteCommand() > 0;
                                    db.Insertable<TN_Ll_detail>(po.Details).ExecuteCommand();
                                    using (var bulkCopy = new SqlBulkCopy(util.Settings.SqlServer))
                                    {
                                        bulkCopy.DestinationTableName = "TN_Picking_Detail";
                                        bulkCopy.BatchSize = 500;
                                        var dataTable = new DataTable();
                                        dataTable = po.Details.ToDataTable();
                                        // 添加列映射(确保名称匹配)
                                        foreach (DataColumn col in dataTable.Columns)
                                        {
                                            bulkCopy.ColumnMappings.Add(col.ColumnName, col.ColumnName);
                                        }
                                        bulkCopy.WriteToServer(po.Details.ToDataTable());
                                    }
                                    //db.Insertable<TN_Ll_detail>(po.Details).ExecuteCommand();
                                }
                            }
@@ -1569,16 +1560,11 @@
                                {
                                    foreach (var a in itemwlpz.ITEM)
                                    {
                                        //if (a.LLDSCBS == "Y")//如果是删除标识则删除当前所属出库单明细 不是删除标记 则进行增改判断
                                        //{
                                        //    result.resultCode = 1;
                                        //    result.resultMsg = $"执行中领料单,物料{a.WLH}物料不允许删除";
                                        //    throw new Exception($"执行中领料单,物料{a.WLH}物料不允许删除");
                                        //}
                                        var po1 = po.Details.Where(s => a.WLBH == s.S_ITEM_CODE).ToList();
                                        if (po1.Count() == 0)  //无则新增物料明细
                                        {
                                            var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.WLBH).First();
                                            var item = itemlist.Where(it => it.S_ITEM_CODE == a.WLBH).FirstOrDefault();
                                            if (item == null)
                                            {
                                                var result12 = new SimpleResult();
@@ -1610,7 +1596,8 @@
                                            if (po1.Where(s => s.F_ACC_D_QTY < a.SL).Count() > 0)//更新数量大于当前物料 数量 更新出库单
                                            {
                                                po1.First().F_QTY = a.SL;
                                                db.Updateable(po1).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();
                                                tN_Ll_Details.Add(po1.First());
                                                //db.Updateable(po1).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();
                                            }
                                            else //返回失败
                                            {
@@ -1632,26 +1619,11 @@
                                {
                                    foreach (var a in itemwlpz.ITEM)
                                    {
                                        //if (a.LLDSCBS == "Y")//如果是删除标识则删除当前所属出库单明细 不是删除标记 则进行增改判断
                                        //{
                                        //    var po1 = po.Details.Where(s => a.WLH == s.S_ITEM_CODE).ToList();
                                        //    if (po1.Count() > 0)  //无则新增物料明细
                                        //    {
                                        //        db.Deleteable<TN_Ll_detail>().Where(it => it.S_ITEM_CODE == a.WLH && it.S_DO_NO == po1.First().S_DO_NO).ExecuteCommand();
                                        //    }
                                        //    else
                                        //    {
                                        //        result.resultCode = 1;
                                        //        result.resultMsg = $"物料{a.WLH}物料数据不存在 无法删除";
                                        //        throw new Exception($"物料{a.WLH}物料数据不存在 无法删除");
                                        //    }
                                        //}
                                        //else
                                        //{
                                        var po1 = po.Details.Where(s => a.WLBH == s.S_ITEM_CODE).ToList();
                                        if (po1.Count() == 0)  //无则新增物料明细
                                        {
                                            var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.WLBH).First();
                                            var item = itemlist.Where(it => it.S_ITEM_CODE == a.WLBH).FirstOrDefault();
                                            if (item == null)
                                            {
                                                var result12 = new SimpleResult();
@@ -1681,7 +1653,8 @@
                                        else
                                        {//更新数量 未执行时 直接更新数量
                                            po1.First().F_QTY = a.SL;
                                            db.Updateable(po1).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();
                                            tN_Ll_Details.Add(po1.First());
                                            //db.Updateable(po1).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();
                                        }
                                        //}
                                    }
@@ -1693,7 +1666,9 @@
                                    db.Insertable<TN_Ll_detail>(listtn).ExecuteCommand();
                                }
                            }
                            sw.Restart();
                            sw.Stop();
                            LogHelper.Info("第二次" + sw.ElapsedMilliseconds);
                            #endregion
                        }
                        result.WLPZBH = itemwlpz.HEAD.WLPZBH;
@@ -1702,10 +1677,19 @@
                        result.resultCode = 0;
                        simples.Add(result);
                    }
                    if (tN_Ll_Details.Count() > 0)
                    {
                        db.Updateable(tN_Ll_Details).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();
                    }
                    if (tN_Inbound_Details.Count() > 0)
                    {
                        db.Updateable(tN_Inbound_Details).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();
                    }
                    db.CommitTran();
                    sw.Restart();
                    sw.Stop();
                    LogHelper.Info("第三次" + sw.ElapsedMilliseconds);
                }
                catch (Exception e)
                {
@@ -1732,6 +1716,15 @@
        internal static SimpleResult InboundOrderSorting(MPSorting model)
        {
            var result = new SimpleResult();
            foreach (var a in model.MaterList)
            {
                bool v = MaterPanduan(a.item_code, a.qty);
                if (v)
                {
                    result.resultMsg = $"物料{a.item_code}数量超过 库存总数";
                    return result;
                }
            }
            //判断起始库位是否锁定
            // var db = new SqlHelper<object>().GetInstance();
            using (var db = new SqlHelper<object>().GetInstance())
@@ -1756,7 +1749,7 @@
                result.resultMsg = "成功";
                result.resultCode = 0;
                //校验入库单数量,不可以超,成功后插入托盘物料表,更新入库单累计数量
                result = AddInboundOrder(model.MaterList, model.cntr_code);
                result = AddInboundOrder(model.MaterList, model.cntr_code, model.cntr_type);
                #region MyRegion
@@ -1854,23 +1847,25 @@
                        return result;
                    }
                    //判断托盘是否已经生成任务,如果没有则生成
                    var wmsTaskcs = WMSHelper.GetWmsTaskByCntr(model.cntr_code);
                    if (wmsTaskcs != null)
                    if (!string.IsNullOrEmpty(model.cntr_code))
                    {
                        result.resultCode = 3;
                        result.resultMsg = $"起点{model.start} 托盘{model.cntr_code}已经创建任务,请勿重复申请";
                        return result;
                        var wmsTaskcs = WMSHelper.GetWmsTaskByCntr(model.cntr_code);
                        if (wmsTaskcs != null)
                        {
                            result.resultCode = 3;
                            result.resultMsg = $"起点{model.start} 托盘{model.cntr_code}已经创建任务,请勿重复申请";
                            return result;
                        }
                    }
                    //出库
                    if (model.Type==2)
                    if (model.Type == 2)
                    {
                        Location start = new Location();
                        if (!string.IsNullOrEmpty(model.cntr_code))
                        {
                           var loc= db.Queryable<LocCntrRel>().Where(it => it.S_CNTR_CODE == model.cntr_code).First();
                            if (loc==null)
                            var loc = db.Queryable<LocCntrRel>().Where(it => it.S_CNTR_CODE == model.cntr_code).First();
                            if (loc == null)
                            {
                                LogHelper.Info($"容器{model.cntr_code}找不到对应货位");
                                result.resultMsg = $"容器{model.cntr_code}找不到对应货位";
@@ -1879,40 +1874,37 @@
                            }
                            else
                            {
                                start= db.Queryable<Location>().Where(it => it.S_CODE == loc.S_LOC_CODE).First();
                                start = db.Queryable<Location>().Where(it => it.S_CODE == loc.S_LOC_CODE).First();
                            }
                        }
                        else if (!string.IsNullOrEmpty(model.item_code))
                        {
                            var starts = db.Queryable<CntrItemRel>().Where(cir => cir.S_CNTR_TYPE == "半托" && cir.S_ITEM_CODE == model.item_code).OrderBy(cir => cir.T_CREATE).ToList().FirstOrDefault();
                            LogHelper.Info($"starts{starts}");
                            var starts12 = db.Queryable<LocCntrRel>().Where(lcr => lcr.S_CNTR_CODE== starts.S_CNTR_CODE).ToList().FirstOrDefault();
                            LogHelper.Info($"starts1{starts12}");
                            start = db.Queryable<Location>().Where(loc => loc.S_AREA_CODE == "HJQ" && loc.S_CODE== starts12.S_LOC_CODE).ToList().FirstOrDefault();
                            LogHelper.Info($"starts2{start}");
                            model.cntr_code = starts12?.S_CNTR_CODE;
                        }
                        else
                        {
                            #region MyRegion
                            //var list = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToArray();
                            //var S_LOC_CODElist =   db.Queryable<LocCntrRel>().Where(s=>!list.Contains(s.S_CNTR_CODE)).Select(s=>s.S_LOC_CODE).ToArray();
                            //start = db.Queryable<Location>().Where(it => S_LOC_CODElist.Contains(it.S_CODE)).First();
                            //// 获取所有被占用的容器编码
                            //var usedContainerCodes = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToList();
                            //// 获取未被占用的容器对应的货位编码
                            //var availableLocationCodes = db.Queryable<LocCntrRel>()
                            //    .Where(s => !usedContainerCodes.Contains(s.S_CNTR_CODE))
                            //    .Select(s => s.S_LOC_CODE)
                            //    .ToList();
                            //// 获取第一个可用货位(如果没有则返回null)
                            //var startLocation = db.Queryable<Location>()
                            //    .Where(it => availableLocationCodes.Contains(it.S_CODE))
                            //    .ToList().FirstOrDefault();
                            var list = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToArray();
                            var S_LOC_CODElist = db.Queryable<LocCntrRel>().Where(s => !list.Contains(s.S_CNTR_CODE)).Select(s => s.S_LOC_CODE).ToArray();
                            start = db.Queryable<Location>().Where(it => S_LOC_CODElist.Contains(it.S_CODE)).ToList().FirstOrDefault();
                            var starts12 = db.Queryable<LocCntrRel>().Where(lcr => lcr.S_CNTR_CODE == start.S_CODE).ToList().FirstOrDefault();
                            model.cntr_code = starts12?.S_CNTR_CODE;
                            #endregion
                            start = db.Queryable<LocCntrRel>()
                                    .LeftJoin<CntrItemRel>((lcr, cir) => lcr.S_CNTR_CODE == cir.S_CNTR_CODE)
                                    .Where((lcr, cir) => cir.S_CNTR_CODE == null)  // 找出未被占用的容器
                                    .LeftJoin<Location>((lcr, cir, loc) => lcr.S_LOC_CODE == loc.S_CODE&&loc.S_AREA_CODE== "HJQ")
                                    .Select((lcr, cir, loc) => loc).ToList()  // 返回 Location 对象
                                    .FirstOrDefault();  // 或者 Take(1).ToList()[0]
                        }
                        if (start==null)
                        if (start == null)
                        {
                            LogHelper.Info($"{model.cntr_code}未找到可用货位");
                            result.resultMsg = $"{model.cntr_code}未找到可用货位";
@@ -1952,6 +1944,7 @@
                        Location end = new Location();
                        if (!string.IsNullOrEmpty(model.cntr_code))
                        {
                            #region MyRegion
                            //var list = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToArray();
                            //var S_LOC_CODElist =   db.Queryable<LocCntrRel>().Where(s=>!list.Contains(s.S_CNTR_CODE)).Select(s=>s.S_LOC_CODE).ToArray();
@@ -1967,7 +1960,7 @@
                            // 获取第一个可用货位(如果没有则返回null)
                            end = db.Queryable<Location>()
                               .Where(it => !availableLocationCodes.Contains(it.S_CODE)&&it.S_AREA_CODE== "HJQ")
                               .Where(it => !availableLocationCodes.Contains(it.S_CODE) && it.S_AREA_CODE == "HJQ")
                               .ToList().FirstOrDefault();
@@ -1981,7 +1974,7 @@
                            return result;
                        }
                        if (end==null)
                        if (end == null)
                        {
                            LogHelper.Info($"{model.cntr_code}未找到可用货位");
                            result.resultMsg = $"{model.cntr_code}未找到可用货位";
@@ -2035,7 +2028,7 @@
        /// <returns></returns>
        internal static async Task<SimpleResult> OutboundOrderSorting(FJSorting model)
        {
            var result = new SimpleResult();
            // var db = new SqlHelper<object>().GetInstance();
@@ -2087,7 +2080,11 @@
                    }
                    //通用接口 对容器货品的删减 和生成回库单 都要用的接口
                    result = await TYAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.IsHK, model.start, po.S_OUT_TYPE);
                    result = await TYAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.IsHK, model.start, po.S_OUT_TYPE, model.cntr_type);
                    if (result.resultCode == 1)
                    {
                        return result;
                    }
                    #region 升降量
                    bool adds = true;
@@ -2118,27 +2115,27 @@
                        {
                            S_AREA_CODE = po.S_AREA_CODE;
                        }
                            model.MaterList.ForEach(a =>
                        model.MaterList.ForEach(a =>
                        {
                            LogHelper.Info($"填充数据{util.Settings.WHCode}");
                            LogHelper.Info($"减仓库量{util.Settings.AREACode}表数据 仓库{po.S_WH_CODE} 物料编码{a.item_code} 物料名称 数量{a.qty}");
                            req.item_info.Add(new AddChangeModel.itemModel
                            {
                                LogHelper.Info($"填充数据{util.Settings.WHCode}");
                                LogHelper.Info($"减仓库量{util.Settings.AREACode}表数据 仓库{po.S_WH_CODE} 物料编码{a.item_code} 物料名称 数量{a.qty}");
                                req.item_info.Add(new AddChangeModel.itemModel
                                {
                                    wh_code = S_WH_CODE,
                                    item_code = a.item_code,
                                    item_name = "",
                                    qty = a.qty
                                });
                                LogHelper.Info($"减库区量表数据 库区{po.S_AREA_CODE} 物料编码{a.item_code} 物料名称 数量{a.qty}");
                                req2.item_info.Add(new AddChangeModel.itemModel
                                {
                                    wh_code = S_WH_CODE,
                                    area_code = S_AREA_CODE,
                                    item_code = a.item_code,
                                    item_name = "",
                                    qty = a.qty
                                });
                                wh_code = S_WH_CODE,
                                item_code = a.item_code,
                                item_name = "",
                                qty = a.qty
                            });
                            LogHelper.Info($"减库区量表数据 库区{po.S_AREA_CODE} 物料编码{a.item_code} 物料名称 数量{a.qty}");
                            req2.item_info.Add(new AddChangeModel.itemModel
                            {
                                wh_code = S_WH_CODE,
                                area_code = S_AREA_CODE,
                                item_code = a.item_code,
                                item_name = "",
                                qty = a.qty
                            });
                        });
                        var reqData = JsonConvert.SerializeObject(req);
                        var AppKey = Settings.AppKey;
                        var AppSecret = Settings.AppSecret;
@@ -2184,7 +2181,7 @@
                            LogHelper.Info($"mobox 库区降量接口返回为空");
                        }
                        if (adds) addOnShelves(po, model.cntr_code, 2);
                        //if (adds) addOnShelves(po, model.cntr_code, 2);
                    }
                    else LogHelper.Info($"托盘{model.cntr_code}无需要升降量的物料");
@@ -2195,6 +2192,7 @@
                }
                catch (Exception e)
                {
                    LogHelper.Info($"报错{e.Message}");
                    result.resultMsg = e.Message;
                    db.RollbackTran();
                    return result;
@@ -2203,7 +2201,7 @@
            }
        }
        public static async Task<SimpleResult> TYAddOutboundOrder(SqlSugarClient db, List<Mater> MaterList, string arrival_no, string cntr_code, bool isHK, string start, string S_OUT_TYPE)
        public static async Task<SimpleResult> TYAddOutboundOrder(SqlSugarClient db, List<Mater> MaterList, string arrival_no, string cntr_code, bool isHK, string start, string S_OUT_TYPE, string cntr_type)
        {
            // var db = new SqlHelper<object>().GetInstance();
            //using (var db = new SqlHelper<object>().GetInstance())
@@ -2234,6 +2232,7 @@
                        if (cir != null)
                        {
                            cir.F_QTY -= item.qty;
                            cir.S_CNTR_TYPE = cntr_type;
                            cir.F_ALLOC_QTY -= item.qty;
                            cir.T_MODIFY = DateTime.Now;
                            if (cir.F_QTY == 0)
@@ -2242,10 +2241,8 @@
                            }
                            else
                            {
                                db.Updateable(cir).UpdateColumns(it => new { it.F_QTY, it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();
                                db.Updateable(cir).UpdateColumns(it => new { it.F_QTY, it.S_CNTR_TYPE, it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();
                                //添加回库作业
                            }
                        }
                        else
@@ -2256,31 +2253,7 @@
                            LogHelper.Info($"物料不存在{item.item_code}");
                            return result;
                        }
                        if (isHK)
                        {
                            var wmsTask = new WMSTask
                            {
                                S_CNTR_CODE = cntr_code,
                                S_CODE = WMSHelper.GenerateTaskNo(),
                                S_START_LOC = start,
                                S_START_AREA = startinfo.S_AREA_CODE,
                                S_START_WH = startinfo.S_WH_CODE,
                                S_END_LOC = startinfo.S_CODE,
                                S_END_AREA = startinfo.S_AREA_CODE,
                                S_END_WH = startinfo.S_WH_CODE,
                                N_TYPE = 1,
                                // S_TYPE = WMSTask.GetTypeStr(1),
                                S_TYPE = "回库",
                                S_OP_DEF_CODE = "",
                                S_OP_DEF_NAME = "pda入库"
                            };
                            if (WMSHelper.CreateWmsTask(wmsTask))
                            {
                                LocationHelper.LockLoc(start, 1);
                                result.resultMsg = $"创建作业成功,作业号{wmsTask.S_CODE}";
                            }
                        }
                        OutboundRecord outboundRecord = new OutboundRecord();
                        outboundRecord.S_WLPZBH = pz?.S_WLPZBH;
                        outboundRecord.S_WLPZND = pz?.S_WLPZND;
@@ -2300,7 +2273,56 @@
                        return result;
                    }
                }
                db.Insertable<OutboundRecord>(records).ExecuteCommand();
                if (isHK)
                {
                    var locs = db.Queryable<WCSTask>().Where(a => a.S_TYPE.Contains("出库") && a.S_CNTR_CODE == cntr_code && a.N_B_STATE == 3).OrderByDescending(s => s.T_END_TIME).First();
                    if (locs != null)
                    {
                        var cntr = db.Queryable<TN_Distribution_CNTR>().Where(a => a.S_DC_NO == locs.S_BS_NO).First();
                        if (cntr != null)
                        {
                            cntr.S_SORT_TYPE = "已分拣";
                            db.Updateable(cntr).UpdateColumns(it => new { it.S_SORT_TYPE }).ExecuteCommand();
                        }
                        else
                        {
                            result.resultCode = 1;
                            result.resultMsg += $"任务{locs.S_CODE}来源号{locs.S_BS_NO}找不到配盘信息";
                            return result;
                        }
                        //var location = db.Queryable<Location>().Where(a => a.S_CODE == locs.S_LOC_CODE).First();
                        var wmsTask = new WMSTask
                        {
                            S_CNTR_CODE = cntr_code,
                            S_CODE = WMSHelper.GenerateTaskNo(),
                            S_START_LOC = start,
                            S_START_AREA = startinfo.S_AREA_CODE,
                            S_START_WH = startinfo.S_WH_CODE,
                            S_END_LOC = locs?.S_START_LOC,
                            S_END_AREA = locs?.S_START_AREA,
                            S_END_WH = locs?.S_START_WH,
                            N_TYPE = 1,
                            // S_TYPE = WMSTask.GetTypeStr(1),
                            S_TYPE = "回库",
                            S_OP_DEF_CODE = "",
                            S_OP_DEF_NAME = "pda入库"
                        };
                        if (WMSHelper.CreateWmsTask(wmsTask))
                        {
                            LocationHelper.LockLoc(start, 1);
                            result.resultMsg = $"创建作业成功,作业号{wmsTask.S_CODE}";
                        }
                    }
                    else
                    {
                        result.resultCode = 1;
                        result.resultMsg += $"找不到容器对应任务信息{cntr_code}";
                        return result;
                    }
                }
                var sss = db.Insertable<OutboundRecord>(records).ExecuteCommand();
                //db.CommitTran();
            }
@@ -2308,6 +2330,8 @@
            {
                //db.RollbackTran();
                LogHelper.Info("物料信息绑定到满容器上" + ex.Message);
                result.resultCode = 1;
                result.resultMsg += ex.Message;
                Console.WriteLine(ex.Message);
                throw;
@@ -2742,7 +2766,7 @@
                };
                List<CXCkBackDto.HEAD> listhead = new List<CXCkBackDto.HEAD>();
                //出库单详情
                var porecord = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == po.S_BS_NO&&a.STATUS==0).ToList();
                var porecord = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == po.S_BS_NO && a.STATUS == 0).ToList();
                foreach (var item in MaterList)
                {
                    CXCkBackDto.HEAD hEAD = new CXCkBackDto.HEAD();
@@ -2821,7 +2845,7 @@
                            materialVoucher.S_GZRQ = po.BUDAT;
                            materialVoucher.UNAME = po.UNAME;
                            materialVoucher.S_AREA_CODE = po.S_AREA_CODE;
                            materialVoucher.F_QTY = onr == null ? 0 : onr.qty;
                            //materialVoucher.STATUS = 0;
                            resmeg += item?.MSGDESP;
@@ -2907,7 +2931,7 @@
                            KEY = po.S_NO,
                            ZYWLX = "2",
                            PZRQ = DateTime.Now.ToString("yyyyMMdd"),
                            GZRQ =DateTime.Now.ToString("yyyyMMdd"), // 假设日期格式为"年-月-日"
                            GZRQ = DateTime.Now.ToString("yyyyMMdd"), // 假设日期格式为"年-月-日"
                            GZRY = po.S_CREATOR_NAME,
                            ITEM = new List<CkBcakDto.ITEM>
                            {
@@ -2942,7 +2966,7 @@
                    //var serialNos = string.Join(",", CntrItemRels
                    //                    .Where(s => s.S_ITEM_CODE == item.item_code)
                    //                    .Select(s => s.S_SERIAL_NO));
                    listitem1.XLH = podetail?.S_SERIAL_NO==null?null: podetail?.S_SERIAL_NO.Split(',').ToList();
                    listitem1.XLH = podetail?.S_SERIAL_NO == null ? null : podetail?.S_SERIAL_NO.Split(',').ToList();
                    //foreach (var xlhValue in xlhValues)
                    //{
                    //    CkBcakDto.ITEM1 newItem = new CkBcakDto.ITEM1 { XLH = xlhValue };
@@ -2952,7 +2976,7 @@
                    iTEMs.Add(ckbitem);
                }
                myRoot.ROOT.WLPZ.ITEM = iTEMs;
                if (myRoot.ROOT.WLPZ.ITEM.Where(s=>!string.IsNullOrEmpty(s.SCDD) && !string.IsNullOrEmpty(s.YLBH) && !string.IsNullOrEmpty(s.YLXMH)).Count()==0)
                if (myRoot.ROOT.WLPZ.ITEM.Where(s => !string.IsNullOrEmpty(s.SCDD) && !string.IsNullOrEmpty(s.YLBH) && !string.IsNullOrEmpty(s.YLXMH)).Count() == 0)
                {
                    myRoot.ROOT.WLPZ.ZYWLX = "2";
                }
@@ -3009,7 +3033,7 @@
                        materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND;
                        materialVoucher.S_WH_CODE = po.S_WH_CODE;
                        materialVoucher.S_AREA_CODE = po.S_AREA_CODE;
                        materialVoucher.F_QTY = item.qty;
                        materialVoucher.F_QTY = item.qty;
                        materialVoucher.S_GZRQ = po.BUDAT;
                        materialVoucher.UNAME = po.UNAME;
                        materialVoucher.STATUS = 0;
@@ -3055,7 +3079,7 @@
        /// <param name="cntr_code"></param>
        /// <returns></returns>
        [ApiExplorerSettings(IgnoreApi = true)]
        public static SimpleResult AddInboundOrder(List<Mater> MaterList, string cntr_code)
        public static SimpleResult AddInboundOrder(List<Mater> MaterList, string cntr_code, string S_CNTR_TYPE)
        {
            var result = new SimpleResult();
            //  var db = new SqlHelper<object>().GetInstance();
@@ -3100,12 +3124,13 @@
                                    if (cir != null)
                                    {
                                        cir.F_QTY += item.qty;
                                        db.Updateable(cir).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();
                                        cir.S_CNTR_TYPE = S_CNTR_TYPE;
                                        db.Updateable(cir).UpdateColumns(it => new { it.F_QTY, it.S_CNTR_TYPE }).ExecuteCommand();
                                    }
                                    else
                                    {
                                        //2.插入新的容器物料信息(容器号不变S_SERIAL_NO = item.S_SERIAL_NO,)
                                        cir = new CntrItemRel { S_CNTR_CODE = cntr.S_CODE.Trim(), S_UOM = info.S_UOM, S_BATCH_NO = item.S_BATCH_NO, N_BS_ROW_NO = item.N_ROW_NO, F_QTY = item.qty, S_ITEM_CODE = item.item_code, S_BS_NO = item.arrival_no };
                                        cir = new CntrItemRel { S_CNTR_TYPE = S_CNTR_TYPE, S_CNTR_CODE = cntr.S_CODE.Trim(), S_UOM = info.S_UOM, S_BATCH_NO = item.S_BATCH_NO, N_BS_ROW_NO = item.N_ROW_NO, F_QTY = item.qty, S_ITEM_CODE = item.item_code, S_BS_NO = item.arrival_no };
                                        db.Insertable<CntrItemRel>(cir).ExecuteCommand();
                                    }
                                    var count = db.Queryable<CntrItemRel>().Count(a => a.S_CNTR_CODE == cntr.S_CODE);
@@ -3146,6 +3171,130 @@
                return result;
            }
        }
        /// <summary>
        /// 创建领料单
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public static LLDReturnRoot.Root Out_Order_In1s(CKDdto.Root model)
        {
            LLDReturnRoot.Root finalRoot = new LLDReturnRoot.Root
            {
                ROOT = new LLDReturnRoot.ROOT
                {
                    ITEM = new List<LLDReturnRoot.ITEM>
                    {
                    }
                }
            };
            List<LLDReturnRoot.ITEM> iTEMs = new List<LLDReturnRoot.ITEM>();
            var result = new WeiLiResult();
            using (var db = new SqlHelper<object>().GetInstance())
            {
                //创建领料单
                try
                {
                    List<WcReturnRoot.ITEM> wcReturnRoots = new List<WcReturnRoot.ITEM>();
                    //删除的集合
                    List<TN_Ll_detail> tN_Ll_Details = new List<TN_Ll_detail>();
                    List<TN_Ll_detail> iuptN_Ll_Details = new List<TN_Ll_detail>();
                    //db.BeginTran();
                    foreach (var itemscddll in model.ROOT.SCDDLL)
                    {
                        LLDReturnRoot.ITEM lLDReturnRoots = new LLDReturnRoot.ITEM();
                        #region
                        var po = db.Queryable<TN_Ll_Order>()
                          .Includes(a => a.Details)
                          .Where(s => s.S_NO == itemscddll.LLDH)
                          .First();
                        #endregion
                        if (po == null)
                        {
                            po = new TN_Ll_Order { S_NO = itemscddll.LLDH, S_FACTORY = itemscddll.GC, S_OUT_TYPE = "出库", S_BS_TYPE = "出库", S_AREA_CODE = "HJQ", S_BS_NO = itemscddll.LLDH };
                            po.Details = new List<TN_Ll_detail>();
                            if (itemscddll.ITEM.Count() > 0)
                            {
                                Stopwatch sw = new Stopwatch();
                                sw.Start();
                                foreach (var a in itemscddll.ITEM)
                                {
                                    po.Details.Add(new TN_Ll_detail
                                    {
                                        S_DO_NO = itemscddll.LLDH,
                                        S_AREA_CODE = "HJQ",
                                        N_ROW_NO = "",
                                        S_ITEM_CODE = a.WLBM,
                                        S_ITEM_NAME = "",
                                        F_QTY = a.XQSL,
                                        S_ZJBM = a.ZJBM,
                                        S_YLBH = a.YLBH,
                                        S_YLXMH = a.YLHXM,
                                        S_BATCH_NO = "",
                                        S_ERP_WH_CODE = a.KCDD,
                                        S_ZJWLTH = a.ZJWLTH,
                                        S_ZJWLMS = a.ZJWLMS,
                                        S_ZHFHBS = a.ZHFHBS,
                                        S_CJRQ = a.CJRQ,
                                        S_LLDSCBS = a.LLDSCBS,
                                        S_SCGLY = a.SCGLY,
                                        S_GXH = a.GXH,
                                        S_XQRQ = a.XQRQ,
                                        N_ITEM_STATE = 1
                                    });
                                }
                                var result1 = db.Insertable<TN_Ll_Order>(po).ExecuteCommand() > 0;
                                if (po.Details.Count() > 0)
                                {
                                    using (var bulkCopy = new SqlBulkCopy(util.Settings.SqlServer))
                                    {
                                        bulkCopy.DestinationTableName = "TN_Picking_Detail";
                                        bulkCopy.BatchSize = 500;
                                        var dataTable = new DataTable();
                                        dataTable = po.Details.ToDataTable();
                                        // 添加列映射(确保名称匹配)
                                        foreach (DataColumn col in dataTable.Columns)
                                        {
                                            bulkCopy.ColumnMappings.Add(col.ColumnName, col.ColumnName);
                                        }
                                        bulkCopy.WriteToServer(po.Details.ToDataTable());
                                    }
                                }
                                sw.Stop();
                                long elapsedMilliseconds = sw.ElapsedMilliseconds;
                                LogHelper.Info($"生产订单领料单无数据{po.Details.Count()}(生成领料单)添加数据返回时长:" + elapsedMilliseconds);
                            }
                        }
                    }
                    //db.CommitTran();
                    return finalRoot;
                }
                catch (Exception ex)
                {
                    LLDReturnRoot.ITEM lLDReturnRoots = new LLDReturnRoot.ITEM();
                    lLDReturnRoots.GC = "";
                    lLDReturnRoots.LLDH = "";
                    lLDReturnRoots.MSGCODE = 1;
                    lLDReturnRoots.MSGDESP = ex.Message;
                    iTEMs.Add(lLDReturnRoots);
                    finalRoot.ROOT.ITEM = iTEMs;
                    db.RollbackTran();
                    return finalRoot;
                }
            }
        }
        /// <summary>
        /// 创建领料单
        /// </summary>
@@ -3164,23 +3313,35 @@
                }
            };
            List<LLDReturnRoot.ITEM> iTEMs = new List<LLDReturnRoot.ITEM>();
            var result = new WeiLiResult();
            using (var db = new SqlHelper<object>().GetInstance())
            {
                //创建领料单
                try
                {
                    Stopwatch s1w = new Stopwatch();
                    s1w.Start();
                    List<WcReturnRoot.ITEM> wcReturnRoots = new List<WcReturnRoot.ITEM>();
                    //删除的集合
                    List<TN_Ll_detail> tN_Ll_Details = new List<TN_Ll_detail>();
                    List<TN_Ll_detail> iuptN_Ll_Details = new List<TN_Ll_detail>();
                    db.BeginTran();
                    foreach (var itemscddll in model.ROOT.SCDDLL)
                    {
                        var wlbmList = itemscddll.ITEM.Select(x => x.WLBM).Distinct().ToList();
                        var itemlist = db.Queryable<TN_Material>()
                        .Where(it => wlbmList.Contains(it.S_ITEM_CODE))  // 使用 IN 查询
                        .ToList();
                        LLDReturnRoot.ITEM lLDReturnRoots = new LLDReturnRoot.ITEM();
                        db.BeginTran();
                        var materialCache = new Dictionary<string, TN_Material>();
                        #region 创建领料单
                        var po = db.Queryable<TN_Ll_Order>().Includes(a => a.Details).Where(s => s.S_NO == itemscddll.LLDH).First();
                        var po = db.Queryable<TN_Ll_Order>()
                          .Includes(a => a.Details)
                          .Where(s => s.S_NO == itemscddll.LLDH)
                          .First();
                        #endregion
                        //var po = WMSHelper.GetOutboundOrder(model.ROOT.SCDDLL.LLDH);
@@ -3192,19 +3353,16 @@
                            {
                                foreach (var a in itemscddll.ITEM)
                                {
                                    var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.WLBM).First();
                                    var item = itemlist.Where(it => it.S_ITEM_CODE == a.WLBM).FirstOrDefault();
                                    if (item == null)
                                    {
                                        //result.code = 1;
                                        //result.msg = $"物料{a.WLBM}物料主数据不存在该物料";
                                        //throw new Exception($"物料{a.WLBM}物料主数据不存在该物料");
                                        lLDReturnRoots.GC = itemscddll.GC;
                                        lLDReturnRoots.LLDH = itemscddll.LLDH;
                                        lLDReturnRoots.MSGCODE = 1;
                                        lLDReturnRoots.MSGDESP = $"物料{a.WLBM}物料主数据不存在该物料";
                                        iTEMs.Add(lLDReturnRoots);
                                        break ;
                                        continue;
                                    }
                                    po.Details.Add(new TN_Ll_detail
                                    {
@@ -3212,7 +3370,7 @@
                                        S_AREA_CODE = "HJQ",
                                        N_ROW_NO = "",
                                        S_ITEM_CODE = a.WLBM,
                                        S_ITEM_NAME = item.S_ITEM_NAME,
                                        S_ITEM_NAME = item?.S_ITEM_NAME,
                                        F_QTY = a.XQSL,
                                        S_ZJBM = a.ZJBM,
                                        S_YLBH = a.YLBH,
@@ -3229,13 +3387,48 @@
                                        S_XQRQ = a.XQRQ,
                                        N_ITEM_STATE = 1
                                    });
                                }
                                if (po.Details.Count()>0)
                                {
                                    var result1 = db.Insertable<TN_Ll_Order>(po).ExecuteCommand() > 0;
                                    db.Insertable<TN_Ll_detail>(po.Details).ExecuteCommand();
                                }
                                Stopwatch sw = new Stopwatch();
                                sw.Start();
                                if (po.Details.Count() > 0)
                                {
                                    LLDReturnRoot.ITEM lLDReturnRoot1 = new LLDReturnRoot.ITEM();
                                    lLDReturnRoot1.GC = itemscddll.GC;
                                    lLDReturnRoot1.LLDH = itemscddll.LLDH;
                                    lLDReturnRoot1.MSGCODE = 0;
                                    lLDReturnRoot1.MSGDESP = $"成功";
                                    iTEMs.Add(lLDReturnRoot1);
                                    var result1 = db.Insertable<TN_Ll_Order>(po).ExecuteCommand() > 0;
                                    //db.Insertable<TN_Ll_detail>(po.Details).ExecuteCommand();
                                    using (var bulkCopy = new SqlBulkCopy(util.Settings.SqlServer))
                                    {
                                        bulkCopy.DestinationTableName = "TN_Picking_Detail";
                                        bulkCopy.BatchSize = 500;
                                        var dataTable = new DataTable();
                                        dataTable = po.Details.ToDataTable();
                                        // 添加列映射(确保名称匹配)
                                        foreach (DataColumn col in dataTable.Columns)
                                        {
                                            bulkCopy.ColumnMappings.Add(col.ColumnName, col.ColumnName);
                                        }
                                        bulkCopy.WriteToServer(po.Details.ToDataTable());
                                    }
                                }
                                else
                                {
                                    LLDReturnRoot.ITEM lLDReturnRoot1 = new LLDReturnRoot.ITEM();
                                    lLDReturnRoot1.GC = itemscddll.GC;
                                    lLDReturnRoot1.LLDH = itemscddll.LLDH;
                                    lLDReturnRoot1.MSGCODE = 0;
                                    lLDReturnRoot1.MSGDESP = $"成功,无数据添加";
                                    iTEMs.Add(lLDReturnRoot1);
                                }
                                sw.Stop();
                                long elapsedMilliseconds = sw.ElapsedMilliseconds;
                                LogHelper.Info($"生产订单领料单无数据{po.Details.Count()}(生成领料单)添加数据返回时长:" + elapsedMilliseconds);
                            }
                        }
                        else
@@ -3248,31 +3441,26 @@
                                {
                                    if (a.LLDSCBS == "Y")//如果是删除标识则删除当前所属出库单明细 不是删除标记 则进行增改判断
                                    {
                                        //result.code = 1;
                                        //result.msg = $"执行中领料单,物料{a.WLBM}物料不允许删除";
                                        //throw new Exception($"执行中领料单,物料{a.WLBM}物料不允许删除");
                                        lLDReturnRoots.GC = itemscddll.GC;
                                        lLDReturnRoots.LLDH = itemscddll.LLDH;
                                        lLDReturnRoots.MSGCODE = 1;
                                        lLDReturnRoots.MSGDESP = $"执行中领料单,物料{a.WLBM}物料不允许删除";
                                        iTEMs.Add(lLDReturnRoots);
                                        break;
                                        continue;
                                    }
                                    var po1 = po.Details.Where(s => a.WLBM == s.S_ITEM_CODE).ToList();
                                    if (po1.Count() == 0)  //无则新增物料明细
                                    {
                                        var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.WLBM).First();
                                        var item = itemlist.Where(it => it.S_ITEM_CODE == a.WLBM).FirstOrDefault();
                                        if (item == null)
                                        {
                                            //result.code = 1;
                                            //result.msg = $"物料{a.WLBM}物料主数据不存在该物料";
                                            //throw new Exception($"物料{a.WLBM}物料主数据不存在该物料");
                                            ;
                                            lLDReturnRoots.GC = itemscddll.GC;
                                            lLDReturnRoots.LLDH = itemscddll.LLDH;
                                            lLDReturnRoots.MSGCODE = 1;
                                            lLDReturnRoots.MSGDESP = $"物料{a.WLBM}物料主数据不存在该物料";
                                            iTEMs.Add(lLDReturnRoots);
                                            break;
                                            continue;
                                        }
                                        TN_Ll_detail tN_Outbound_Detail = new TN_Ll_detail
                                        {
@@ -3304,19 +3492,17 @@
                                        if (po1.Where(s => s.F_ACC_D_QTY < a.XQSL).Count() > 0)//更新数量大于当前物料 数量 更新出库单
                                        {
                                            po1.First().F_QTY = a.XQSL;
                                            db.Updateable(po1).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();
                                            iuptN_Ll_Details.Add(po1.First());
                                            //db.Updateable(po1).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();
                                        }
                                        else //返回失败
                                        {
                                            //result.code = 1;
                                            //result.msg = $"更新失败,更新数量必须大于当前物料数量{a.WLBM}";
                                            //throw new Exception($"更新失败,更新数量必须大于当前物料数量{a.WLBM}");
                                            lLDReturnRoots.GC = itemscddll.GC;
                                            lLDReturnRoots.LLDH = itemscddll.LLDH;
                                            lLDReturnRoots.MSGCODE = 1;
                                            lLDReturnRoots.MSGDESP = $"更新失败,更新数量必须大于当前物料数量{a.WLBM}";
                                            iTEMs.Add(lLDReturnRoots);
                                            break;
                                            continue;
                                        }
                                    }
                                }
@@ -3328,10 +3514,11 @@
                                {
                                    if (a.LLDSCBS == "Y")//如果是删除标识则删除当前所属出库单明细 不是删除标记 则进行增改判断
                                    {
                                        var po1 = po.Details.Where(s => a.WLBM == s.S_ITEM_CODE).ToList();
                                        if (po1.Count() > 0)  //无则新增物料明细
                                        var po1 = po.Details.Where(s => a.WLBM == s.S_ITEM_CODE).FirstOrDefault();
                                        if (po1 != null)  //无则新增物料明细
                                        {
                                            db.Deleteable<TN_Ll_detail>().Where(it => it.S_ITEM_CODE == a.WLBM && it.S_DO_NO == po1.First().S_DO_NO).ExecuteCommand();
                                            tN_Ll_Details.Add(po1);
                                            //   db.Deleteable<TN_Ll_detail>().Where(it => it.S_ITEM_CODE == a.WLBM && it.S_DO_NO == po1.First().S_DO_NO).ExecuteCommand();
                                        }
                                        else
                                        {
@@ -3341,9 +3528,9 @@
                                            lLDReturnRoots.GC = itemscddll.GC;
                                            lLDReturnRoots.LLDH = itemscddll.LLDH;
                                            lLDReturnRoots.MSGCODE = 1;
                                            lLDReturnRoots.MSGDESP = $"物料{a.WLBM}物料数据不存在 无法删除";
                                            lLDReturnRoots.MSGDESP = $"删除的物料{a.WLBM}物料数据不存在 无法删除";
                                            iTEMs.Add(lLDReturnRoots);
                                            break;
                                            continue;
                                        }
                                    }
                                    else
@@ -3351,7 +3538,7 @@
                                        var po1 = po.Details.Where(s => a.WLBM == s.S_ITEM_CODE).ToList();
                                        if (po1.Count() == 0)  //无则新增物料明细
                                        {
                                            var item = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == a.WLBM).First();
                                            var item = itemlist.Where(it => it.S_ITEM_CODE == a.WLBM).FirstOrDefault();
                                            if (item == null)
                                            {
                                                //result.code = 1;
@@ -3362,7 +3549,7 @@
                                                lLDReturnRoots.MSGCODE = 1;
                                                lLDReturnRoots.MSGDESP = $"物料{a.WLBM}物料主数据不存在该物料";
                                                iTEMs.Add(lLDReturnRoots);
                                                break;
                                                continue;
                                            }
                                            TN_Ll_detail tN_Outbound_Detail = new TN_Ll_detail
                                            {
@@ -3392,30 +3579,62 @@
                                        else
                                        {//更新数量 未执行时 直接更新数量
                                            po1.First().F_QTY = a.XQSL;
                                            db.Updateable(po1).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();
                                            iuptN_Ll_Details.Add(po1.First());
                                            //db.Updateable(po1).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();
                                        }
                                    }
                                }
                                ;
                                if (tN_Ll_Details.Count() > 0)
                                {
                                    db.Deleteable<TN_Ll_detail>(tN_Ll_Details).ExecuteCommand();
                                }
                                if (iuptN_Ll_Details.Count() > 0)
                                {
                                    db.Updateable(iuptN_Ll_Details).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();
                                }
                            }
                            Stopwatch sw1 = new Stopwatch();
                            sw1.Start();
                            //添加数据
                            if (listtn.Count() > 0)
                            {
                                LLDReturnRoot.ITEM lLDReturnRoot1 = new LLDReturnRoot.ITEM();
                                lLDReturnRoot1.GC = itemscddll.GC;
                                lLDReturnRoot1.LLDH = itemscddll.LLDH;
                                lLDReturnRoot1.MSGCODE = 0;
                                lLDReturnRoot1.MSGDESP = $"成功";
                                iTEMs.Add(lLDReturnRoot1);
                                db.Insertable<TN_Ll_detail>(listtn).ExecuteCommand();
                            }
                            else
                            {
                                LLDReturnRoot.ITEM lLDReturnRoot1 = new LLDReturnRoot.ITEM();
                                lLDReturnRoot1.GC = itemscddll.GC;
                                lLDReturnRoot1.LLDH = itemscddll.LLDH;
                                lLDReturnRoot1.MSGCODE = 0;
                                lLDReturnRoot1.MSGDESP = $"成功,无数据添加";
                                iTEMs.Add(lLDReturnRoot1);
                            }
                            sw1.Stop();
                            long elapsedMilliseconds2 = sw1.ElapsedMilliseconds;
                            LogHelper.Info("生产订单领料单有数据(生成领料单)添加数据返回时长:" + elapsedMilliseconds2);
                        }
                        lLDReturnRoots.GC = itemscddll.GC;
                        lLDReturnRoots.LLDH = itemscddll.LLDH;
                        lLDReturnRoots.MSGCODE = 0;
                        lLDReturnRoots.MSGDESP = $"成功";
                        iTEMs.Add(lLDReturnRoots);
                        db.CommitTran();
                    }
                    db.CommitTran();
                    finalRoot.ROOT.ITEM = iTEMs;
                    s1w.Stop();
                    long elapsedMillisecond1s = s1w.ElapsedMilliseconds;
                    LogHelper.Info("生产订单finalRoot.ROOT.ITEM" + elapsedMillisecond1s);
                }
                catch (Exception ex)
                {
@@ -3428,21 +3647,10 @@
                    finalRoot.ROOT.ITEM = iTEMs;
                    db.RollbackTran();
                    //result.msg = $"出库单接口异常,异常信息={ex.Message}";
                    //var jsons = CkGetJsonResult(model.ROOT.SCDDLL.LLDH, model.ROOT.SCDDLL.GC, result.code.ToString(), result.msg);
                    return finalRoot;
                }
                //LLDReturnRoot.ITEM lLDReturnRoots = new LLDReturnRoot.ITEM();
                //lLDReturnRoots.GC = model.ROOT.SCDDLL.GC;
                //lLDReturnRoots.LLDH = model.ROOT.SCDDLL.LLDH;
                //lLDReturnRoots.MSGCODE = 0;
                //lLDReturnRoots.MSGDESP = "添加成功";
                //finalRoot.ROOT.ITEM = lLDReturnRoots;
                //var json = CkGetJsonResult(model.ROOT.SCDDLL.LLDH, model.ROOT.SCDDLL.GC, result.code.ToString(), result.msg);
                return finalRoot;
            }
            return finalRoot;
        }
        /// <summary>
@@ -3457,12 +3665,12 @@
            using (var db = new SqlHelper<object>().GetInstance())
            {
                //创建领料单
                //mobox创建出库单
                try
                {
                    db.BeginTran();
                    #region 创建领料单
                    #region mobox创建出库单
                    var po = db.Queryable<TN_Ll_Order>().Includes(a => a.Details).Where(s => s.S_NO == S_NO).First();
                    #endregion
@@ -3477,7 +3685,7 @@
                    {
                        //var az = db.Queryable<AZInventory>().ToList();
                        var po1 = new TN_Outbound_Order { S_NO = WMSHelper.GenerateShippNo(), UNAME = po.UNAME, S_FACTORY = po.S_FACTORY, S_CBZX = po.S_CBZX, S_ZZKM = po.S_ZZKM, S_LRZX = po.S_LRZX, BLDAT = po.BLDAT, BUDAT = po.BUDAT, S_OUT_TYPE = po.S_OUT_TYPE, S_BS_TYPE = po.S_BS_TYPE, S_AREA_CODE = po.S_AREA_CODE, S_BS_NO = po.S_NO };
                        List<TN_Ll_detail> tN_Ll_Details = new List<TN_Ll_detail>();
                        po1.Details = new List<TN_Outbound_Detail>();
                        if (po.Details.Count() > 0)
                        {
@@ -3513,8 +3721,9 @@
                                        S_ERP_WH_CODE = a.S_ERP_WH_CODE,
                                        N_ITEM_STATE = a.N_ITEM_STATE
                                    });
                                    a.F_ACC_D_QTY += a.F_QTY - a.F_ACC_D_QTY;
                                    db.Updateable(a).UpdateColumns(it => new { it.F_ACC_D_QTY }).ExecuteCommand();
                                    double difference = a.F_QTY - a.F_ACC_D_QTY;
                                    a.F_ACC_D_QTY += difference;
                                    tN_Ll_Details.Add(a);
                                }
                                else
                                {
@@ -3524,10 +3733,14 @@
                                }
                            }
                            db.Updateable(tN_Ll_Details).UpdateColumns(it => new { it.F_ACC_D_QTY }).ExecuteCommand();
                            if (po1.Details.Count() > 0)
                            {
                                var result1 = db.Insertable<TN_Outbound_Order>(po1).ExecuteCommand() > 0;
                                db.Insertable<TN_Outbound_Detail>(po1.Details).ExecuteCommand();
                                po1.Details.Clear();
                            }
                            else
                            {
@@ -3968,6 +4181,12 @@
                        result.resultMsg = "数据不存在";
                        return result;
                    }
                    List<TN_Inbound_Detail> tN_Inbound_Details = new List<TN_Inbound_Detail>();
                    po.Details = po.Details.Where(d => model.Wlist.Any(w =>
                                w.S_ITEM_CODE == d.S_ITEM_CODE &&
                                w.N_ROW_NO == d.N_ROW_NO))
                            .ToList();
                    if (po.S_IN_TYPE == "内采入库")
                    {
                        List<NcRkDto.ITEM> listitem = new List<NcRkDto.ITEM>();
@@ -4002,6 +4221,8 @@
                            //}
                            //wcbkbcitem.ITEM1 = listitem1;
                            listitem.Add(wcbkbcitem);
                            item.N_B_STATE = 1;
                            tN_Inbound_Details.Add(item);
                        }
                        NcRkDto.Root roots = new NcRkDto.Root
@@ -4071,7 +4292,7 @@
                        // 准备请求参数
                        ZscmNc request = new ZscmNc();
                        request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml;
                        LogHelper.Info($"内采SAP回调");
                        LogHelper.Info($"内采SAP回调{service.Url}");
                        // 调用Web Service
                        ZscmNcResponse responses = service.ZscmNc(request);
@@ -4089,22 +4310,39 @@
                        //添加凭证记录表
                        result.resultMsg = data.ROOT.ITEM.MSGDESP;
                        result.resultCode = data.ROOT.ITEM.MSGCODE;
                        MaterialVoucher materialVoucher = new MaterialVoucher();
                        //MaterialVoucher materialVoucher = new MaterialVoucher();
                        if (data.ROOT.ITEM.MSGCODE == 0)
                        {
                            materialVoucher.S_NO = model.S_NO;
                            materialVoucher.S_TYPE = po.S_IN_TYPE;
                            materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH;
                            materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND;
                            materialVoucher.STATUS = 0;
                            db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand();
                            //materialVoucher.S_NO = model.S_NO;
                            //materialVoucher.S_TYPE = po.S_IN_TYPE;
                            //materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH;
                            //materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND;
                            //materialVoucher.STATUS = 0;
                            //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand();
                            List<MaterialVoucher> materials = new List<MaterialVoucher>();
                            foreach (var item in model.Wlist)
                            {
                                MaterialVoucher materialVoucher = new MaterialVoucher();
                                materialVoucher.S_NO = po.S_NO;
                                materialVoucher.S_WLBM = item.S_ITEM_CODE;
                                materialVoucher.S_WLH = item.N_ROW_NO;
                                materialVoucher.S_TYPE = po.S_IN_TYPE;
                                materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH;
                                materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND;
                                materialVoucher.STATUS = 0;
                                materials.Add(materialVoucher);
                            }
                            if (materials.Count() > 0)
                            {
                                db.Insertable<MaterialVoucher>(materials).ExecuteCommand();
                            }
                        }
                    }
                    else
                    if (po.S_IN_TYPE == "计划外退料入库")
                    else if (po.S_IN_TYPE == "计划外退料入库")
                    {
                        DateTime dateTime;
                        DateTime dateTime1;
@@ -4178,7 +4416,8 @@
                            iTEMs.Add(ckbitem);
                            item.N_B_STATE = 1;
                            tN_Inbound_Details.Add(item);
                        }
                        myRoot.ROOT.HEAD.ITEM = iTEMs;
                        #region wms-sap回调
@@ -4229,13 +4468,25 @@
                        result.resultCode = data.ROOT.ITEM.MSGCODE;
                        if (data.ROOT.ITEM.MSGCODE == 0)
                        {
                            MaterialVoucher materialVoucher = new MaterialVoucher();
                            materialVoucher.S_NO = po.S_NO;
                            materialVoucher.S_TYPE = po.S_IN_TYPE;
                            materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH;
                            materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND;
                            materialVoucher.STATUS = 0;
                            db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand();
                            List<MaterialVoucher> materials = new List<MaterialVoucher>();
                            foreach (var item in model.Wlist)
                            {
                                MaterialVoucher materialVoucher = new MaterialVoucher();
                                materialVoucher.S_NO = po.S_NO;
                                materialVoucher.S_WLBM = item.S_ITEM_CODE;
                                materialVoucher.S_WLH = item.N_ROW_NO;
                                materialVoucher.S_TYPE = po.S_IN_TYPE;
                                materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH;
                                materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND;
                                materialVoucher.STATUS = 0;
                                materials.Add(materialVoucher);
                            }
                            if (materials.Count() > 0)
                            {
                                db.Insertable<MaterialVoucher>(materials).ExecuteCommand();
                            }
                        }
                        #endregion
@@ -4274,6 +4525,8 @@
                            }
                            wcbkbcitem.ITEM1 = listitem1;
                            listitem.Add(wcbkbcitem);
                            item.N_B_STATE = 1;
                            tN_Inbound_Details.Add(item);
                        }
                        WcRkBc.Root roots = new WcRkBc.Root
@@ -4360,25 +4613,27 @@
                        result.resultCode = data.ROOT.ITEM.MSGCODE;
                        if (data.ROOT.ITEM.MSGCODE == 0)
                        {
                            MaterialVoucher materialVoucher = new MaterialVoucher();
                            materialVoucher.S_NO = model.S_NO;
                            materialVoucher.S_TYPE = po.S_IN_TYPE;
                            materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZH;
                            LogHelper.Info("值1: " + data.ROOT.ITEM?.WLPZH);
                            LogHelper.Info("值2: " + materialVoucher.S_WLPZBH);
                            materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND;
                            materialVoucher.STATUS = 0;
                            db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand();
                            ;
                            List<MaterialVoucher> materials = new List<MaterialVoucher>();
                            foreach (var item in model.Wlist)
                            {
                                MaterialVoucher materialVoucher = new MaterialVoucher();
                                materialVoucher.S_NO = po.S_NO;
                                materialVoucher.S_WLBM = item.S_ITEM_CODE;
                                materialVoucher.S_WLH = item.N_ROW_NO;
                                materialVoucher.S_TYPE = po.S_IN_TYPE;
                                materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH;
                                materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND;
                                materialVoucher.STATUS = 0;
                                materials.Add(materialVoucher);
                            }
                            if (materials.Count() > 0)
                            {
                                db.Insertable<MaterialVoucher>(materials).ExecuteCommand();
                            }
                        }
                        //else
                        //{
                        //    SapReturn sapReturn = new SapReturn();
                        //    sapReturn.N_STATUS = 0;
                        //    sapReturn.S_NO = model.S_NO;
                        //    sapReturn.S_TYPE = po.S_IN_TYPE;
                        //    sapReturn.S_JSON = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>"+ xml;
                        //    db.Insertable<SapReturn>(sapReturn).ExecuteCommand();
                        //}
                    }
@@ -4428,6 +4683,8 @@
                            hEAD.WLPZXM = item.N_ROW_NO;
                            hEAD.GZRY = po.UNAME;
                            listhead.Add(hEAD);
                            item.N_B_STATE = 1;
                            tN_Inbound_Details.Add(item);
                        }
                        roots.ROOT.HEAD = listhead;
@@ -4547,6 +4804,18 @@
                        //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand();
                    }
                    if (tN_Inbound_Details.Count() > 0)
                    {
                        db.Updateable(tN_Inbound_Details).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
                    }
                    var newpodetai= db.Queryable<TN_Inbound_Detail>().Where(a => a.S_IO_NO == model.S_NO).ToList();
                    int cout = newpodetai.Where(s => s.N_B_STATE != 1).Count();
                    if (cout==0)
                    {
                        po.N_B_STATE = 1;
                        db.Updateable(po).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
                    }
                    db.CommitTran();
                }
                catch (Exception ex)
@@ -4581,17 +4850,18 @@
                    var po = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == S_CNTR_CODE && a.S_BS_NO == taskno).ToList();
                    LogHelper.Info("添加入库记录表po" + po.Count());
                    var pz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == taskno).First();
                    var ass = pz == null;
                    var pzs = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == taskno).ToList();
                    var ass = pzs == null;
                    LogHelper.Info("添加入库记录表pz" + ass);
                    List<OutboundRecord> records = new List<OutboundRecord>();
                    foreach (var item in po)
                    {
                        var pz = pzs.Where(s => s.S_WLBM == item.S_ITEM_CODE && s.S_WLH == item.N_BS_ROW_NO).ToList().FirstOrDefault();
                        OutboundRecord outboundRecord = new OutboundRecord();
                        outboundRecord.S_NO = item.S_BS_NO;
                        outboundRecord.S_TYPE = pz?.S_TYPE;
                        outboundRecord.S_WLPZBH = pz?.S_WLPZBH;
                        outboundRecord.S_WLPZBH = pz?.S_WLBM;
                        outboundRecord.S_WLPZND = pz?.S_WLPZND;
                        outboundRecord.S_WLBM = item.S_ITEM_CODE;
                        outboundRecord.S_SL = item.F_QTY;
@@ -5325,9 +5595,15 @@
            {
                db.BeginTran();
                List<TN_Material> list = new List<TN_Material>();
                var itemCodes = model.ITEM.Select(item => item.WLBM).ToList();
                var itemlist = db.Queryable<TN_Material>()
                .Where(it => itemCodes.Contains(it.S_ITEM_CODE))
                .ToList();
                foreach (var item in model.ITEM)
                {
                    var materlist = db.Queryable<TN_Material>().Where(it => it.S_ITEM_CODE == item.WLBM).First();
                    var materlist = itemlist.Where(it => it.S_ITEM_CODE == item.WLBM).First();
                    if (materlist == null)
                    {
                        TN_Material tN_Material = new TN_Material();