WMSPrjInstance/HH-0126_HeNanPingGao.git

			@@ -30,11 +30,11 @@
			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;

			namespace HH.WCS.Mobox3.pinggao.api
			{
			@@ -45,6 +45,34 @@

			}

			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>
			@@ -770,10 +798,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)
			{
			@@ -793,8 +821,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
			{
			@@ -810,6 +839,7 @@
			iTEM.MSGDESP = $"成功";
			tEMs.Add(iTEM);
			}
			db.Insertable<TN_GENERATE_ORDER>(tN_GENERATE_ORDERs).ExecuteCommand();
			orderResponse.ROOT.ITEM = tEMs;
			db.CommitTran();
			}
			@@ -1133,9 +1163,9 @@

			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}物料主数据不存在该物料")*/
			;
			@@ -1185,9 +1215,10 @@
			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
			{
			S_IO_NO = itemwlpz.HEAD.WLPZH,
			@@ -1209,7 +1240,7 @@
			});
			//}

			});
			}
			db.Insertable<TN_Inbound_Order>(po).ExecuteCommand();
			db.Insertable<TN_Inbound_Detail>(po.Details).ExecuteCommand();
			db.CommitTran();
			@@ -1223,7 +1254,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)
			{
			@@ -1253,19 +1284,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();
			}
			}
			@@ -1304,6 +1336,9 @@

			try
			{
			var itemlist = db.Queryable<TN_Material>().ToList();
			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)
			{

			@@ -1331,8 +1366,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)//判断序列号是否为多个
			//{
			@@ -1384,7 +1421,7 @@
			});
			//}

			});
			}
			db.Insertable<TN_Inbound_Order>(po).ExecuteCommand();
			db.Insertable<TN_Inbound_Detail>(po.Details).ExecuteCommand();
			db.CommitTran();
			@@ -1396,14 +1433,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
			{
			@@ -1431,7 +1469,7 @@
			});
			}

			});
			}
			db.Insertable<TN_Inbound_Detail>(Details).ExecuteCommand();
			db.CommitTran();

			@@ -1526,7 +1564,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();
			@@ -1577,7 +1615,7 @@
			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();
			@@ -1609,7 +1647,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 //返回失败
			{
			@@ -1650,7 +1689,7 @@
			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();
			@@ -1680,7 +1719,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();
			}
			//}
			}
			@@ -1701,8 +1741,15 @@
			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();

			}
			@@ -1731,11 +1778,21 @@
			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())
			{
			var locinfo = db.Queryable<Location>().Where(a => a.S_CODE == model.start).First();

			if (locinfo?.N_LOCK_STATE != 0)
			{
			result.resultCode = 3;
			@@ -1754,7 +1811,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


			@@ -1823,7 +1880,224 @@
			}

			}
			/// <summary>
			/// 分拣
			/// </summary>
			/// <param name="model"></param>
			/// <returns></returns>
			internal static async Task<SimpleResult> KtSorting(KtSorting model)
			{

			var result = new SimpleResult();

			// var db = new SqlHelper<object>().GetInstance();

			using (var db = new SqlHelper<object>().GetInstance())
			{
			try
			{


			result.resultMsg = "成功";
			result.resultCode = 0;
			var locinfo = db.Queryable<Location>().Where(a => a.S_CODE == model.start).First();

			if (locinfo?.N_LOCK_STATE != 0)
			{
			result.resultCode = 3;
			result.resultMsg = $"起始库位已锁/不存在";
			return result;
			}
			//判断托盘是否已经生成任务，如果没有则生成
			if (!string.IsNullOrEmpty(model.cntr_code))
			{
			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)
			{
			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)
			{
			LogHelper.Info($"容器{model.cntr_code}找不到对应货位");
			result.resultMsg = $"容器{model.cntr_code}找不到对应货位";
			result.resultCode = 1;
			return result;
			}
			else
			{
			start= db.Queryable<Location>().Where(it => it.S_CODE == loc.S_LOC_CODE).First();
			}
			}
			else if (!string.IsNullOrEmpty(model.item_code))
			{
			start = db.Queryable<LocCntrRel>()
			.LeftJoin<CntrItemRel>((lcr, cir) => lcr.S_CNTR_CODE == cir.S_CNTR_CODE&&cir.S_CNTR_TYPE=="半托")
			.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")
			.OrderBy((lcr, cir) => cir.T_CREATE)
			.Select((lcr, cir, loc) => loc).ToList() // 返回 Location 对象
			.FirstOrDefault(); // 或者 Take(1).ToList()[0]
			}
			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();


			#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)
			{
			LogHelper.Info($"{model.cntr_code}未找到可用货位");
			result.resultMsg = $"{model.cntr_code}未找到可用货位";
			result.resultCode = 1;
			return result;
			}
			//库位信息

			var endinfo = db.Queryable<Location>().Where(it => it.S_CODE == model.start).First();
			var wmsTask = new WMSTask
			{
			S_CNTR_CODE = model.cntr_code,
			S_CODE = WMSHelper.GenerateTaskNo(),
			S_START_LOC = start.S_CODE,
			S_START_AREA = start.S_AREA_CODE,
			S_START_WH = start.S_WH_CODE,
			S_END_LOC = endinfo.S_CODE,
			S_END_AREA = endinfo.S_AREA_CODE,
			S_END_WH = endinfo.S_WH_CODE,

			N_TYPE = 2,
			// S_TYPE = WMSTask.GetTypeStr(1),
			S_TYPE = "出库空托盘",
			S_OP_DEF_CODE = "",
			S_OP_DEF_NAME = "pda出库"
			};
			if (WMSHelper.CreateWmsTask(wmsTask))
			{
			LocationHelper.LockLoc(start.S_CODE, 2);
			result.resultMsg = $"创建作业成功，作业号{wmsTask.S_CODE}";
			}


			}
			else //入库
			{
			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();
			//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>()
			.Select(s => s.S_LOC_CODE)
			.ToList();

			// 获取第一个可用货位（如果没有则返回null）
			end = db.Queryable<Location>()
			.Where(it => !availableLocationCodes.Contains(it.S_CODE)&&it.S_AREA_CODE== "HJQ")
			.ToList().FirstOrDefault();


			#endregion
			}
			else
			{
			LogHelper.Info($"入库容器{model.cntr_code}不能为空");
			result.resultMsg = $"入库容器{model.cntr_code}不能为空";
			result.resultCode = 1;
			return result;

			}
			if (end==null)
			{
			LogHelper.Info($"{model.cntr_code}未找到可用货位");
			result.resultMsg = $"{model.cntr_code}未找到可用货位";
			result.resultCode = 1;
			return result;
			}
			var sart = db.Queryable<Location>().Where(it => it.S_CODE == model.start).First();
			var wmsTask = new WMSTask
			{
			S_CNTR_CODE = model.cntr_code,
			S_CODE = WMSHelper.GenerateTaskNo(),
			S_START_LOC = sart.S_CODE,
			S_START_AREA = sart.S_AREA_CODE,
			S_START_WH = sart.S_WH_CODE,
			S_END_LOC = end.S_CODE,
			S_END_AREA = end.S_AREA_CODE,
			S_END_WH = end.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(end.S_CODE, 1);
			result.resultMsg = $"创建作业成功，作业号{wmsTask.S_CODE}";
			}

			}
			//通用接口对容器货品的删减和生成回库单都要用的接口

			return result;

			}
			catch (Exception e)
			{
			result.resultMsg = e.Message;
			db.RollbackTran();
			return result;
			throw;
			}
			}

			}
			/// <summary>
			/// 分拣
			/// </summary>
			@@ -1861,7 +2135,7 @@
			return result;

			}

			LogHelper.Info($"S_OUT_TYPE{po.S_OUT_TYPE}");
			//根据不同出库类型回调sap
			if (po.S_OUT_TYPE == "冲销出库")
			{
			@@ -1870,7 +2144,7 @@
			else
			if (po.S_OUT_TYPE == "出库")//普通出库
			{

			LogHelper.Info($"S_OUT_TYPE{po.S_OUT_TYPE}");
			result = await AddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start);
			}
			else if (po.S_OUT_TYPE == "计划外发料出库")
			@@ -1883,7 +2157,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;
			@@ -1901,32 +2179,40 @@
			if (string.IsNullOrEmpty(po.S_WH_CODE))
			{
			S_WH_CODE = util.Settings.WHCode;
			}
			}
			else
			{
			S_WH_CODE = po.S_WH_CODE;
			}
			if (string.IsNullOrEmpty(po.S_AREA_CODE))
			{
			S_AREA_CODE = util.Settings.AREACode;
			}
			model.MaterList.ForEach(a =>
			else
			{
			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
			S_AREA_CODE = po.S_AREA_CODE;
			}
			model.MaterList.ForEach(a =>
			{
			wh_code = S_WH_CODE,
			item_code = a.item_code,
			item_name = "",
			qty = a.qty
			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
			});
			});
			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;
			@@ -1972,7 +2258,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}无需要升降量的物料");
			@@ -1983,6 +2269,7 @@
			}
			catch (Exception e)
			{
			LogHelper.Info($"报错{e.Message}");
			result.resultMsg = e.Message;
			db.RollbackTran();
			return result;
			@@ -1991,7 +2278,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())
			@@ -2022,6 +2309,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)
			@@ -2030,10 +2318,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
			@@ -2044,31 +2330,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;
			@@ -2088,14 +2350,65 @@
			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();
			}
			catch (Exception ex)
			{
			//db.RollbackTran();
			LogHelper.Info("物料信息绑定到满容器上" + ex.Message);
			result.resultCode = 1;
			result.resultMsg += ex.Message;
			Console.WriteLine(ex.Message);

			throw;
			@@ -2677,15 +2990,15 @@
			var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First();
			string GZRQ = "";
			string PZZDRQ = "";
			if (po.BUDAT != null)
			{
			GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd");
			}
			if (po.BLDAT != null)
			{
			PZZDRQ = DateTime.Parse(po.BLDAT.ToString()).ToString("yyyyMMdd");
			//if (po.Details[0].S_CJRQ != null)
			//{
			// GZRQ = DateTime.Parse(po.Details[0].S_CJRQ.ToString()).ToString("yyyyMMdd");
			//}
			//if (po.Details[0].S_XQRQ != null)
			//{
			// PZZDRQ = DateTime.Parse(po.Details[0].S_XQRQ.ToString()).ToString("yyyyMMdd");

			}
			//}
			CkBcakDto.Root myRoot = new CkBcakDto.Root
			{
			ROOT = new CkBcakDto.ROOT
			@@ -2693,10 +3006,10 @@
			WLPZ = new CkBcakDto.WLPZ
			{
			KEY = po.S_NO,
			ZYWLX = "业务类型值",
			PZRQ = PZZDRQ,
			GZRQ = GZRQ, // 假设日期格式为"年-月-日"
			GZRY = po.UNAME,
			ZYWLX = "2",
			PZRQ = DateTime.Now.ToString("yyyyMMdd"),
			GZRQ =DateTime.Now.ToString("yyyyMMdd"), // 假设日期格式为"年-月-日"
			GZRY = po.S_CREATOR_NAME,
			ITEM = new List<CkBcakDto.ITEM>
			{
			}
			@@ -2730,7 +3043,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.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 };
			@@ -2740,6 +3053,10 @@
			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)
			{
			myRoot.ROOT.WLPZ.ZYWLX = "2";
			}
			//db.Insertable<OutboundRecord>(records).ExecuteCommand();
			#region wms-sap回调
			//类转json
			@@ -2839,9 +3156,9 @@
			/// <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 result = new SimpleResult();
			// var db = new SqlHelper<object>().GetInstance();
			using (var db = new SqlHelper<object>().GetInstance())
			{
			@@ -2884,12 +3201,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);
			@@ -2948,7 +3266,7 @@
			}
			};
			List<LLDReturnRoot.ITEM> iTEMs = new List<LLDReturnRoot.ITEM>();


			var result = new WeiLiResult();

			using (var db = new SqlHelper<object>().GetInstance())
			@@ -2957,15 +3275,25 @@
			//创建领料单
			try
			{
			var itemlist = db.Queryable<TN_Material>().ToList();

			//删除的集合
			List<TN_Ll_detail> tN_Ll_Details = new List<TN_Ll_detail>();
			List<TN_Ll_detail> iuptN_Ll_Details = new List<TN_Ll_detail>();
			foreach (var itemscddll in model.ROOT.SCDDLL)
			{
			LLDReturnRoot.ITEM lLDReturnRoots = new LLDReturnRoot.ITEM();

			db.BeginTran();

			// 预先缓存物料数据（优化点1：批量查询减少数据库访问）

			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();
			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);
			if (po == null)
			@@ -2976,12 +3304,9 @@
			{
			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;
			@@ -2996,16 +3321,44 @@
			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,
			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;
			db.Insertable<TN_Ll_detail>(po.Details).ExecuteCommand();
			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();
			}
			else
			{
			LLDReturnRoot.ITEM lLDReturnRoot1 = new LLDReturnRoot.ITEM();
			lLDReturnRoot1.GC = itemscddll.GC;
			lLDReturnRoot1.LLDH = itemscddll.LLDH;
			lLDReturnRoot1.MSGCODE = 0;
			lLDReturnRoot1.MSGDESP = $"成功,无数据添加";
			iTEMs.Add(lLDReturnRoot1);
			}

			}
			}
			@@ -3032,7 +3385,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;
			@@ -3053,6 +3406,17 @@
			S_ITEM_CODE = a.WLBM,
			S_ITEM_NAME = item.S_ITEM_NAME,
			F_QTY = a.XQSL,
			S_ZJBM = a.ZJBM,
			S_YLBH = a.YLBH,
			S_YLXMH = a.YLHXM,
			S_ZJWLTH = a.ZJWLTH,
			S_ZJWLMS = a.ZJWLMS,
			S_ZHFHBS = a.ZHFHBS,
			S_CJRQ = a.CJRQ,
			S_LLDSCBS = a.LLDSCBS,
			S_GXH = a.GXH,
			S_XQRQ = a.XQRQ,
			S_SCGLY = a.SCGLY,
			S_BATCH_NO = "无",
			S_ERP_WH_CODE = a.KCDD,
			N_ITEM_STATE = 1
			@@ -3064,7 +3428,8 @@
			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 //返回失败
			{
			@@ -3091,7 +3456,8 @@
			var po1 = po.Details.Where(s => a.WLBM == s.S_ITEM_CODE).ToList();
			if (po1.Count() > 0) //无则新增物料明细
			{
			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.AddRange(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
			{
			@@ -3101,7 +3467,7 @@
			lLDReturnRoots.GC = itemscddll.GC;
			lLDReturnRoots.LLDH = itemscddll.LLDH;
			lLDReturnRoots.MSGCODE = 1;
			lLDReturnRoots.MSGDESP = $"物料{a.WLBM}物料数据不存在无法删除";
			lLDReturnRoots.MSGDESP = $"删除的物料{a.WLBM}物料数据不存在无法删除";
			iTEMs.Add(lLDReturnRoots);
			continue;
			}
			@@ -3111,7 +3477,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;
			@@ -3132,6 +3498,17 @@
			S_ITEM_CODE = a.WLBM,
			S_ITEM_NAME = item.S_ITEM_NAME,
			F_QTY = a.XQSL,
			S_ZJBM = a.ZJBM,
			S_YLBH = a.YLBH,
			S_YLXMH = a.YLHXM,
			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,
			S_BATCH_NO = "无",
			S_ERP_WH_CODE = a.KCDD,
			N_ITEM_STATE = 1
			@@ -3141,18 +3518,47 @@
			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();

			}

			;
			}
			//添加数据
			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);
			}
			}


			db.CommitTran();
			}

			@@ -3219,7 +3625,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)
			{
			@@ -3240,12 +3646,24 @@
			S_BATCH_NO = a.S_BATCH_NO,
			S_SERIAL_NO = a.S_SERIAL_NO,
			S_CGPZH = a.S_CGPZH,
			S_ZJBM = a.S_ZJBM,
			S_YLBH = a.S_YLBH,
			S_ZJWLTH = a.S_ZJWLTH,
			S_ZJWLMS = a.S_ZJWLMS,
			S_ZHFHBS = a.S_ZHFHBS,
			S_CJRQ = a.S_CJRQ,
			S_LLDSCBS = a.S_LLDSCBS,
			S_SCGLY = a.S_SCGLY,
			S_GXH = a.S_GXH,
			S_XQRQ = a.S_XQRQ,
			S_YLXMH = a.S_YLXMH,
			S_CGPZXMBH = a.S_CGPZXMBH,
			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
			{
			@@ -3255,6 +3673,9 @@
			}

			}


			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;
			@@ -3699,6 +4120,10 @@
			result.resultMsg = "数据不存在";
			return result;
			}
			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>();
			@@ -3802,7 +4227,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);

			@@ -3820,22 +4245,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;
			@@ -3960,13 +4402,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

			@@ -4091,15 +4545,34 @@
			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();
			//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
			//{
			@@ -4312,17 +4785,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).First();

			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;