TigerClouds-Tech/Server/TigerApi6_2024.git

			@@ -13,6 +13,14 @@
			using Tiger.Model.Entitys.MES.U9C;
			using System.Security.Policy;
			using Tiger.Model.Entitys.MES.Position;
			using MailKit.Search;
			using IronPython.Runtime.Operations;
			using static IronPython.Modules._ast;
			using System.Diagnostics;
			using Tiger.Model.Minsun;
			using static IronPython.Runtime.Profiler;
			using static Microsoft.CodeAnalysis.CSharp.SyntaxTokenParser;
			using Microsoft.Scripting.Utils;

			namespace Tiger.Business.WMS.Transaction
			{
			@@ -24,17 +32,19 @@
			public IPrint_BIZ_U9_ASN Init(string id, string userCode, string apiHost, string orgCode)
			{
			base.Init(id, userCode, apiHost, orgCode);
			//加载已经清点数据
			LoadData();
			Logger.Console.Info($"Start {this.GetType().Name} Transaction[ID: {TransID}]");
			LoadData();
			return this;
			}

			#region Propertys & Variables
			//private List<WmsOrder<BIZ_U9_ASN>> _OrderList { get; set; } = new();
			private List<string> OrderList = new();
			private BIZ_U9_ASN CurOrder = new();
			private List<BIZ_U9_ASN_SN> CurSn = new();
			private List<BIZ_U9_ASN_SN> ScanList = new();
			List<string> SnList = new();
			private string rcvDocType = "RCV03"; //默认无单
			private string CurReqType = "0";
			#endregion

			#region Functions
			@@ -43,7 +53,8 @@
			/// </summary>
			private void LoadData()
			{
			OrderList = MainDB.Queryable<BIZ_U9_ASN_SN>().Where(q => q.RECEIVER == UserCode && SqlFunc.Subqueryable<BIZ_U9_ASN>().Where(s => s.ORDER_NO == q.ORDER_NO && s.STATUS == BIZ_U9_ASN.STATUSs.Counting.GetValue()).Any()).Select(q => q.ORDER_NO).ToList();
			var _Sns = MainDB.Queryable<BIZ_U9_ASN_SN>().Where(q => q.ORDER_NO == SqlFunc.Subqueryable<BIZ_U9_ASN_DTL>().Where(s => SqlFunc.StartsWith(s.UPDATE_USER, $"GenerateASN_{UserCode}")).Select(s => s.ORDER_NO)).ToList();
			CurSn.AddRange(_Sns);
			}
			/// <summary>
			/// 扫描入口
			@@ -61,24 +72,30 @@
			return SetOutPutMqttMsg(action, input.Locale);
			}
			//如果是未上门户
			else if (input.Data == "0")
			else if (input.Command == "NotOn")
			{
			action = await GetAsnInfoForPrint(input);
			}
			//如果是随单赠品或者样品
			else if (input.Data == "1")
			else if (input.Command == "IsGift")
			{

			action = await GetAsnInfoBySn(input);
			}
			else
			//如果是未上门户提交
			else if (input.Command == "Submit")
			{
			action = await ScanItem(input);
			action = await Submit(input);
			}
			//如果是随单赠品或者样品提交
			else if (input.Command == "GenerateASN")
			{
			action = await GenerateASN(input);
			}
			}
			catch (Exception ex)
			{
			//取消当前操作
			ResetScan();
			ResetTrans();
			//action.CatchExceptionWithLog(ex, $"扫描[{input.SN}]异常");
			action.CatchExceptionWithLog(ex, Biz.L("WMS.Default.Scan.ScanException", input.SN));
			}
			@@ -92,96 +109,300 @@
			/// <returns></returns>
			public async Task<ApiAction<ScanOutput>> GetAsnInfoForPrint(BaseInput input)
			{
			var action = new ApiAction<ScanOutput>(new ScanOutput() );
			var action = new ApiAction<ScanOutput>($"成功获取ASN单[{input.SN}]信息", new ScanOutput());
			try
			{

			CurOrder = await MainDB.Queryable<BIZ_U9_ASN>().Where(q => q.ORDER_NO == input.SN && q.STATUS < BIZ_U9_ASN.STATUSs.Finished.GetValue()).Includes(q => q.Details, d => d._ItemInfos).IncludesAllFirstLayer().FirstAsync();
			if (CurOrder == null)
			{
			action.IsSuccessed = false;
			action.LocaleMsg = Biz.L($"查不到ASN单[{input.SN}]的数据");
			return action;
			}
			action.LocaleMsg = CurOrder.STATUS == BIZ_U9_ASN.STATUSs.Counting.GetValue() ? Biz.L($"ASN单[{input.SN}]状态为[{BIZ_U9_ASN.STATUSs.Counting.GetDesc()}]，请继续未完成的操作") : action.LocaleMsg;
			action.Data.Data = CurOrder;
			}
			catch (Exception ex)
			{
			//取消当前操作
			ResetScan();
			ResetTrans();
			action.CatchExceptionWithLog(ex, Biz.L("WMS.Default.Scan.ScanException", input.SN));
			}
			return SetOutPutMqttMsg(action, input.Locale);
			}

			/// <summary>
			/// 扫描条码分析类型
			/// 随单赠品扫SN获取ASN单信息
			/// </summary>
			public async Task<ApiAction<ScanOutput>> ScanItem(BaseInput input)
			/// <param name="input"></param>
			/// <returns></returns>
			private async Task<ApiAction<ScanOutput>> GetAsnInfoBySn(BaseInput input)
			{
			var action = new ApiAction<ScanOutput>(new ScanOutput() { Command = Command });
			var action = new ApiAction<ScanOutput>(new ScanOutput());
			try
			{
			//解析条码
			Barcode barcode = new Barcode(input.SN);
			if (barcode.IsException)
			{
			throw barcode.AnalyseException;
			}
			//非法条码
			else if (!barcode.IsRegular)
			CurReqType = input.Options["reqType"].ToString();
			rcvDocType = "RCV01";
			if (CurReqType != "1")
			{
			action.IsSuccessed = false;
			//action.LocaleMsg = Biz.L("条码为非法条码");
			action.LocaleMsg = Biz.L("WMS.WmsItem.Barcode.IllegalFailure", input.SN);
			return SetOutPutMqttMsg(action, input.Locale); ;
			action.LocaleMsg = Biz.L($"不是随单赠品，不用扫描条码");
			return action;
			}

			if (barcode.Type == Barcode.Types.OuterPackage)
			var AsnSn = await MainDB.Queryable<BIZ_U9_ASN_SN>().Where(q => q.SN == input.SN).FirstAsync();
			if (AsnSn == null)
			{
			CurSn = MainDB.Queryable<BIZ_U9_ASN_SN>().Where(q => q.CARTON_NO == barcode.SN).ToList();
			action.IsSuccessed = false;
			action.LocaleMsg = Biz.L($"查不到条码[{input.SN}]的数据");
			return action;
			}
			else
			CurOrder = await MainDB.Queryable<BIZ_U9_ASN>().Where(q => q.ORDER_NO == AsnSn.ORDER_NO).Includes(q => q.Details, d => d._ItemInfos).IncludesAllFirstLayer().FirstAsync();
			if (CurOrder == null)
			{
			CurSn = MainDB.Queryable<BIZ_U9_ASN_SN>().Where(q => q.SN == barcode.SN).ToList();
			foreach (var sn in CurSn)
			action.IsSuccessed = false;
			action.LocaleMsg = Biz.L($"查不到ASN单[{input.SN}]的数据");
			return action;
			}
			var _sns = CurSn.Where(q => q.LOTNO == AsnSn.LOTNO && q.STATUS <= WMS_ITEM.STATUSs.Counted.GetValue()).ToList();
			if (CurSn.Count > 0 && _sns.Any())
			{
			action.LocaleMsg = Biz.L($"批次[{AsnSn.LOTNO}]已经提交，请继续下一步操作");
			CurOrder = await MainDB.Queryable<BIZ_U9_ASN>().Where(q => q.ORDER_NO == _sns[0].ORDER_NO).Includes(q => q.Details, d => d._ItemInfos).IncludesAllFirstLayer().FirstAsync();
			if (CurOrder == null)
			{
			sn.META_SN = input.SN;
			action.IsSuccessed = false;
			action.LocaleMsg = Biz.L($"查不到ASN单[{CurOrder.ORDER_NO}]的数据");
			return action;
			}
			CurOrder.Details = CurOrder.Details.Where(q => _sns[0].LINE_NO == q.LINE_NO).ToList();
			SnList.AddRange(_sns.Select(q => q.SN).ToList());
			CurOrder.BarcodeList = SnList;
			action.Data.Data = CurOrder;
			return action;
			}

			if (CurSn.IsNullOrEmpty())
			if (CurSn.Any(q=> q.ORDER_NO == AsnSn.ORDER_NO && q.LINE_NO == AsnSn.LINE_NO))
			{
			action.IsSuccessed = false;
			//action.LocaleMsg = Biz.L("ASN单中不存在条码[{0}]");
			action.LocaleMsg = Biz.L("WMS.Print_BIZ_U9_ASN.SnNotExists", input.SN);
			return SetOutPutMqttMsg(action, input.Locale); ;
			action.LocaleMsg = Biz.L($"扫描的条码的ASN单[{AsnSn.ORDER_NO}]的行号[{AsnSn.LINE_NO}]已经存在，请先完成未完成的操作");
			return action;
			}
			if (CurSn.First().AUTH_ORG != input.AuthOption.CurOrg)
			CurSn.Add(AsnSn);
			if (!CurOrder.ORDER_NO.StartsWith("WASN"))
			{
			CurOrder.ORDER_NO = $"WASN{DateTime.Now.ToString("yyyyMMddHHmmss")}";
			CurOrder.STATUS = BIZ_U9_ASN.STATUSs.Arrived.GetValue();
			}
			CurOrder.Details = CurOrder.Details.Where(q => CurSn.Any(s => s.LINE_NO == q.LINE_NO)).ToList();
			action.LocaleMsg = Biz.L($"成功获取ASN单[{AsnSn.ORDER_NO}]的信息");
			action.Data.Data = CurOrder;
			}
			catch (Exception ex)
			{
			//取消当前操作
			ResetTrans();
			action.CatchExceptionWithLog(ex, Biz.L("WMS.Default.Scan.ScanException", input.SN));
			}
			return SetOutPutMqttMsg(action, input.Locale);
			}

			/// <summary>
			/// 赠品/样品提交，需要生成WMS的ASN单
			/// </summary>
			/// <param name="input"></param>
			/// <returns></returns>
			public async Task<ApiAction<ScanOutput>> GenerateASN(BaseInput input)
			{
			var action = new ApiAction<ScanOutput>(new ScanOutput());
			try
			{
			var reqType = input.Options["reqType"].ToString();
			//如果类型不一样，则清除CurOrder
			if (CurReqType != reqType) {
			CurOrder = null;
			CurReqType = reqType;
			}
			var dtl = input.Options["record"].ToString().JsonToObject<BIZ_U9_ASN_DTL>();
			CurOrder = CurOrder??new() {
			ORDER_NO= $"WASN{DateTime.Now.ToString("yyyyMMddHHmmss")}",
			SUPP_CODE = dtl.SUPP_CODE,
			DELIVERY_DATE = DateTime.Now,
			PLANARRIVED_DATE = DateTime.Now,
			AUTH_ORG = OrgCode,
			};
			if (!CurOrder.ORDER_NO.IsNullOrEmpty() && CurOrder.ORDER_NO.StartsWith("WASN") && CurOrder.STATUS == BIZ_U9_ASN.STATUSs.Counting.GetValue())
			{
			action.IsSuccessed = false;
			//action.LocaleMsg = Biz.L($"条码所属组织[{0}]与当前登录组织[{1}]不一致，请重新选择组织");
			action.LocaleMsg = Biz.L("WMS.Print_BIZ_U9_ASN.OrgNotCorrect", CurSn.First().AUTH_ORG, input.AuthOption.CurOrg);
			return SetOutPutMqttMsg(action, input.Locale); ;
			}
			//验证条码是否正确
			if (CurSn.First().STATUS > WMS_ITEM.STATUSs.Incoming.GetValue())
			{
			action.IsSuccessed = false;
			//action.LocaleMsg = Biz.L("状态[{0}]异常，请重新扫描");
			action.LocaleMsg = Biz.L("WMS.Default.ScanItem.StatusException", CurSn.First().STATUS.GetEnumDesc<WMS_ITEM.STATUSs>());
			return SetOutPutMqttMsg(action, input.Locale); ;
			action.LocaleMsg = Biz.L($"已经生成ASN单[{CurOrder.ORDER_NO}]，请继续下一步操作");
			return action;
			}

			//执行清点数据处理
			foreach (var sn in CurSn)
			dtl.UPDATE_USER = $"GenerateASN_{UserCode}";
			dtl.REMARK = CurSn.Where(q => q.ORDER_NO == dtl.ORDER_NO && q.LINE_NO == dtl.LINE_NO).FirstOrDefault()?.SN;
			dtl.ORDER_NO = CurOrder.ORDER_NO;
			BIZ_U9_ASN Asn = new()
			{
			sn.STATUS = WMS_ITEM.STATUSs.Counted.GetValue();
			sn.RECEIVER = UserCode;
			sn.RECEIVE_DATE = DateTime.Now;
			}

			ID = Guid.NewGuid().ToString("N"),
			ORDER_NO = CurOrder.ORDER_NO,
			STATUS = BIZ_U9_ASN.STATUSs.Counting.GetValue(),
			SUPP_CODE = CurOrder.SUPP_CODE,
			SUPP_NAME = CurOrder.SUPP_NAME,
			DELIVERY_DATE = CurOrder.DELIVERY_DATE,
			PLANARRIVED_DATE = CurOrder.PLANARRIVED_DATE,
			ORDER_DATE = DateTime.Now,
			CREATE_TIME = DateTime.Now,
			CREATE_USER = $"Print_BIZ_U9_ASN_{UserCode}",
			UPDATE_TIME = DateTime.Now,
			UPDATE_USER = $"Print_BIZ_U9_ASN_{UserCode}",
			AUTH_ORG = CurOrder.AUTH_ORG,
			};
			//创建变量克隆对象用于传入DBSubmitAction中保存当前需要暂存的数据值
			var _CurSn = CurSn.Clone();
			AddCommitAction("Counted", () =>
			var _dtl = dtl.Clone();
			_dtl.ID = Guid.NewGuid().ToString("N");
			_dtl.IS_GIFT = reqType == "1" ? "Y" : "N";
			_dtl.AUTH_ORG = CurOrder.AUTH_ORG;
			_dtl.LINE_NO = _dtl.LINE_NO ?? "10";
			input.Options["record"] = _dtl.ToJson();
			var _Asn = Asn.Clone();
			AddCommitAction("GenerateASN", () =>
			{
			//使用统一的事务DB对象
			var db = GetCommitDB();
			//数据保存逻辑
			db.Updateable<BIZ_U9_ASN>(UserCode).SetColumns(q => q.STATUS == BIZ_U9_ASN.STATUSs.Counting.GetValue()).Where(q => q.ORDER_NO == _CurSn.First().ORDER_NO).ExecuteCommand();
			db.Storageable(_CurSn, UserCode).ExecuteCommand();
			db.Insertable(_Asn, UserCode).ExecuteCommand();
			var y = db.Storageable(_dtl).WhereColumns(t => new { t.ORDER_NO, t.LINE_NO, t.GHOST_ROW }).ToStorage();
			y.AsInsertable.ExecuteCommand();
			y.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.ITEM_CODE, q.AUTH_ORG, q.QTY, q.STATUS, q.SUPP_CODE, q.SUPP_LOTNO, q.QTY_PACKING, q.QTY_GIFT, q.IS_GIFT, q.UPDATE_TIME, q.UPDATE_USER, }).ExecuteCommand();
			});
			action = await Submit(input);
			}
			catch (Exception ex)
			{
			//取消当前操作
			ResetTrans();
			action.CatchExceptionWithLog(ex, Biz.L("WMS.Default.Scan.ScanException", input.SN));
			}
			return SetOutPutMqttMsg(action, input.Locale);
			}

			/// <summary>
			/// 提交数据生成SN并清点
			/// </summary>
			/// <param name="input"></param>
			/// <returns></returns>
			public async Task<ApiAction<ScanOutput>> Submit(BaseInput input)
			{
			var action = new ApiAction<ScanOutput>(new ScanOutput());
			try
			{
			var snlist = input.Options["Snlist"].ToString().JsonToObject<List<BIZ_U9_ASN_SN>>();
			var reqType = input.Options["reqType"].ToString();
			var dtl = input.Options["record"].ToString().JsonToObject<BIZ_U9_ASN_DTL>();
			action.LocaleMsg = Biz.L($"成功提交ASN单[{dtl.ORDER_NO}]行数据，请点击打印按钮打印标签");

			var asnSn = MainDB.Queryable<BIZ_U9_ASN_SN>().Where(q => q.ORDER_NO == dtl.ORDER_NO && q.LINE_NO == dtl.LINE_NO && (q.STATUS == WMS_ITEM.STATUSs.Counted.GetValue() \|\| q.STATUS == WMS_ITEM.STATUSs.Rejected.GetValue())).ToList();
			if (asnSn.Count>0 && asnSn.Sum(q => q.QTY) == dtl.QTY)
			{
			action.IsSuccessed = false;
			action.LocaleMsg = dtl.ORDER_NO.IsNullOrEmpty() ? Biz.L($"数据不存在！") : Biz.L($"ASN单[{dtl.ORDER_NO}]行[{dtl.LINE_NO}]数据已全部提交完成，如果未打印标签请点击打印按钮打印标签");
			SnList.AddRange(asnSn.Select(q=>q.SN));
			return action;
			}
			List<BIZ_U9_ASN_SN> sns = new();
			List<WMS_ITEM> items = new();
			List<WMS_ITEM_HIS> hiss = new();
			List<WMS_ITEM_EXT> itemExts = new();
			List<WMS_ITEM_PKG> pkgs = new();
			SnList.Clear();
			foreach (var sn in snlist)
			{
			var strs = sn.SN.Split('/');
			var metaSn = reqType == "2" ? $"{DI.Resolve<ICodeRuleCache>()["SampleBarcode"]?.Generate(strs[0],"/", strs[1], "/").Data.ToString() ?? ""}" : DI.Resolve<ICodeRuleCache>()["NoSourceBarcode"]?.Generate($"{sn.SN}").Data.ToString() ?? "";
			SnList.Add(metaSn);
			var barcode = new Barcode(metaSn);
			BIZ_U9_ASN_SN info = new()
			{
			AUTH_ORG = dtl.AUTH_ORG,
			CREATE_TIME = DateTime.Now,
			CREATE_USER = UserCode,
			UPDATE_TIME = DateTime.Now,
			UPDATE_USER = UserCode,
			STATUS = WMS_ITEM.STATUSs.Counted.GetValue(),
			ORDER_NO = dtl.ORDER_NO,
			LINE_NO = dtl.LINE_NO,
			SN = barcode.SN,
			META_SN = metaSn,
			ITEM_CODE = barcode.ItemCode,
			QTY = sn.QTY,
			LOTNO = barcode.LotNo,
			CARTON_NO = barcode.SN,
			RECEIVER = UserCode,
			RECEIVE_DATE = DateTime.Now,
			};
			sns.Add(info);

			var item = new WMS_ITEM()
			{
			SN = barcode.SN,
			ITEM_CODE = barcode.ItemCode,
			AUTH_ORG = dtl.AUTH_ORG,
			STATUS = WMS_ITEM.STATUSs.Counted.GetValue(),
			QTY = sn.QTY,
			PROD_DATE = barcode.ProdDate ?? BarcodeAnalysis.GetDateTime(dtl.SUPP_LOTNO) ?? DateTime.Now,
			UNIT = barcode.Unit,
			TRANS_CODE = nameof(BIZ_U9_ASN),
			TRANS_NO = info.ORDER_NO,
			TRANS_LINE = info.LINE_NO,
			SUPP_CODE = dtl.SUPP_CODE,
			SUPP_LOTNO = dtl.SUPP_LOTNO,
			};
			items.Add(item);
			hiss.Add(new WMS_ITEM_HIS(item, $"条码[{barcode.SN}]导入，操作单据[{item.TRANS_NO}]"));
			var ext = new WMS_ITEM_EXT()
			{
			SN = barcode.SN,
			META_SN = metaSn,
			QR_CODE = metaSn,
			};
			itemExts.Add(ext);
			var pkg = new WMS_ITEM_PKG()
			{
			SN = barcode.SN,
			ITEM_CODE = barcode.ItemCode,
			AUTH_ORG = dtl.AUTH_ORG,
			QTY = sn.QTY,
			UNIT = barcode.Unit,
			TRANS_CODE = nameof(BIZ_U9_ASN),
			TRANS_NO = info.ORDER_NO,
			TRANS_LINE = info.LINE_NO,
			SUPP_CODE = dtl.SUPP_CODE,
			SUPP_LOTNO = dtl.SUPP_LOTNO,
			};
			pkgs.Add(pkg);
			}
			//更新当前清点的条码状态
			foreach (var sn in CurSn)
			{
			sn.STATUS = WMS_ITEM.STATUSs.Counted.GetValue();
			}
			CurOrder.STATUS = BIZ_U9_ASN.STATUSs.Counting.GetValue();

			AddCommitAction("CountedAndPrint", () =>
			{
			//使用统一的事务DB对象
			var db = GetCommitDB();
			//数据保存逻辑
			db.Updateable<BIZ_U9_ASN>(UserCode).SetColumns(q => q.STATUS == BIZ_U9_ASN.STATUSs.Counting.GetValue()).Where(q => q.ORDER_NO == dtl.ORDER_NO).ExecuteCommand();
			db.Storageable(sns, UserCode).ExecuteCommand();
			var s = db.Storageable(items, UserCode).WhereColumns(t => new { t.SN, t.GHOST_ROW }).ToStorage();
			s.AsInsertable.ExecuteCommand();
			s.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.ITEM_CODE, q.AUTH_ORG, q.STATUS, q.QTY, q.PROD_DATE, q.UNIT, q.TRANS_CODE, q.TRANS_NO, q.TRANS_LINE, q.SUPP_CODE, q.SUPP_LOTNO, q.UPDATE_TIME, q.UPDATE_USER, }).ExecuteCommand();
			db.Insertable(hiss, UserCode).ExecuteCommand();
			var o = db.Storageable(itemExts, UserCode).WhereColumns(t => new { t.SN, t.GHOST_ROW }).ToStorage();
			o.AsInsertable.ExecuteCommand();
			o.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.META_SN, q.QR_CODE, q.UPDATE_TIME, q.UPDATE_USER, }).ExecuteCommand();
			var y = db.Storageable(pkgs, UserCode).WhereColumns(t => new { t.SN, t.GHOST_ROW }).ToStorage();
			y.AsInsertable.ExecuteCommand();
			y.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.ITEM_CODE, q.AUTH_ORG, q.QTY, q.UNIT, q.TRANS_CODE, q.TRANS_NO, q.TRANS_LINE, q.SUPP_CODE, q.SUPP_LOTNO, q.UPDATE_TIME, q.UPDATE_USER, }).ExecuteCommand();
			});

			//完成所有处理后使用事务保存数据
			@@ -190,189 +411,10 @@
			catch (Exception ex)
			{
			//取消当前操作
			ResetScan();
			//action.CatchExceptionWithLog(ex, $"扫描条码[{0}]复核异常");
			action.CatchExceptionWithLog(ex, Biz.L("WMS.Default.ScanItem.ScanException", input.SN));
			ResetTrans();
			action.CatchExceptionWithLog(ex, Biz.L("WMS.Default.Scan.ScanException", input.SN));
			}
			return SetOutPutMqttMsg(action, input.Locale);
			}

			/// <summary>
			/// 完成所有处理后使用事务保存数据
			/// </summary>
			/// <param name="action"></param>
			/// <returns></returns>
			public ApiAction<ScanOutput> DoIfFinish(ApiAction<ScanOutput> action, string locale)
			{
			//保存数据库
			SaveCommitListToDB();

			if (!OrderList.Contains(CurSn.First().ORDER_NO))
			{
			OrderList.Add(CurSn.First().ORDER_NO);
			}
			ScanList.AddRange(CurSn);

			// 返回数据
			action.Data.Data = ScanList;

			//action.LocaleMsg = Biz.L($"条码[{0}]清点成功！");
			action.LocaleMsg = Biz.L("WMS.Print_BIZ_U9_ASN.CountSuccess", CurSn.First().SN);

			//重置工序
			ResetScan();
			return SetOutPutMqttMsg(action, locale); ;
			}

			/// <summary>
			/// 删除当前所有已清点记录
			/// </summary>
			/// <returns></returns>
			public async Task<ApiAction> DeleteScannedList()
			{
			var action = new ApiAction();
			try
			{
			foreach (var sn in ScanList)
			{
			sn.STATUS = WMS_ITEM.STATUSs.Incoming.GetValue();
			sn.RECEIVER = null;
			sn.RECEIVE_DATE = DateTime.MinValue;
			}

			//使用统一的事务DB对象
			var db = GetCommitDB();
			var dbTran = db.UseTran(() =>
			{
			db.Updateable(ScanList, UserCode).UpdateColumns(q => new { q.UPDATE_TIME, q.UPDATE_USER, q.STATUS }).ExecuteCommandAsync();
			//db.Updateable(items, UserCode).ExecuteCommand();
			//db.Insertable(historys, UserCode).ExecuteCommand();
			});
			if (dbTran.IsSuccess)
			{
			ScanList.Clear();
			}
			else
			{
			Logger.Default.Fatal(dbTran.ErrorException, "Database transaction save exception");
			//抛出异常
			throw dbTran.ErrorException;
			}
			}
			catch (System.Exception ex)
			{
			//return action.CatchExceptionWithLog(ex, Biz.L("删除当前所有已清点记录异常"));
			return action.CatchExceptionWithLog(ex, Biz.L("WMS.Print_BIZ_U9_ASN.DeleteScanListException"));
			}
			return action;
			}

			/// <summary>
			/// 删除当前用户的已扫单个记录
			/// </summary>
			/// <returns></returns>
			public async Task<ApiAction> DeleteScannedSn(BaseInput input)
			{
			var action = new ApiAction();
			try
			{
			//使用统一的事务DB对象
			var db = GetCommitDB();
			var dbTran = db.UseTran(() =>
			{
			db.Updateable<BIZ_U9_ASN_SN>(UserCode).SetColumns(q => q.STATUS == WMS_ITEM.STATUSs.Incoming.GetValue())
			.SetColumns(q => q.RECEIVER == null)
			.SetColumns(q => q.RECEIVE_DATE == DateTime.MinValue)
			.Where(q => q.SN == input.SN).ExecuteCommand();
			//db.Updateable(item, UserCode).ExecuteCommand();
			//db.Insertable(new WMS_ITEM_HIS(item, $"条码[{item.SN}]取消清点，操作单据[{order}]"), UserCode).ExecuteCommand();
			});
			if (dbTran.IsSuccess)
			{
			ScanList.RemoveAll(q => q.SN == input.SN);
			}
			else
			{
			Logger.Default.Fatal(dbTran.ErrorException, "Database transaction save exception");
			//抛出异常
			throw dbTran.ErrorException;
			}
			}
			catch (System.Exception ex)
			{
			//return action.CatchExceptionWithLog(ex, Biz.L("删除已清点条码[{0}]异常"));
			return action.CatchExceptionWithLog(ex, Biz.L("WMS.Print_BIZ_U9_ASN.DeleteScannedSnException", input.SN));
			}
			return action;
			}

			/// <summary>
			/// 获取本次已清点的物料列表（带分页）
			/// </summary>
			/// <returns></returns>
			public async Task<ApiAction<PageAble<BIZ_U9_ASN_SN>>> GetScannedList(BaseInputWithPage input)
			{
			var action = new ApiAction<PageAble<BIZ_U9_ASN_SN>>();
			action.Data = new PageAble<BIZ_U9_ASN_SN>();
			action.Data.pageSize = input.pageSize;
			action.Data.pageIndex = input.pageIndex;
			action.Data.totals = ScanList.Count;
			action.Data.data = ScanList.Skip((input.pageIndex - 1) * input.pageSize).Take(input.pageSize).ToList();
			//action.Data = query;
			return action;
			}

			/// <summary>
			/// 获取当前所有单据信息
			/// </summary>
			/// <returns></returns>
			public async Task<ApiAction<List<BIZ_U9_ASN>>> GetOrderList()
			{
			var action = new ApiAction<List<BIZ_U9_ASN>>();
			action.Data = await Biz.Db.Queryable<BIZ_U9_ASN>().Where(q => OrderList.Contains(q.ORDER_NO)).IncludesAllFirstLayer().ToListAsync();
			if (!action.Data.IsNullOrEmpty())
			{
			foreach (var order in action.Data)
			{
			foreach (var dtl in order.Details)
			{
			dtl.SnList = order.SnList.Where(q => q.LINE_NO == dtl.LINE_NO).OrderByDescending(q => q.STATUS).ToList();
			dtl.QTY_COUNTED = dtl.SnList.Where(q => q.STATUS == WMS_ITEM.STATUSs.Counted.GetValue() \|\| q.STATUS == WMS_ITEM.STATUSs.Rejected.GetValue()).Sum(q => q.QTY);
			}
			order.IsFinished = !order.Details.Where(q => q.QTY != q.QTY_COUNTED).Any();
			}
			}
			return action;
			}

			/// <summary>
			/// 生成收货单：调用U9新增收货单接口
			/// </summary>
			/// <returns></returns>
			public async Task<ApiAction> SetGiftQty(BaseInput input)
			{
			var action = new ApiAction();
			try
			{
			var dtl = input?.Data?.JsonToObject<BIZ_U9_ASN_DTL>();
			if ((dtl?.ID ?? "").IsNullOrEmpty())
			{
			action.IsSuccessed = false;
			//action.LocaleMsg = Biz.L($"提交的收货单明细ID不能为空");
			action.LocaleMsg = Biz.L("WMS.Print_BIZ_U9_ASN.SetGiftQty.DetailIDIsNull");
			return action;
			}

			//使用统一的事务DB对象
			var db = GetCommitDB();
			await db.Updateable(dtl, UserCode).UpdateColumns(q => new { q.UPDATE_TIME, q.UPDATE_USER, q.QTY_GIFT }).ExecuteCommandAsync();
			}
			catch (System.Exception ex)
			{
			//return action.CatchExceptionWithLog(ex, Biz.L("设置收货单明细赠品数量为异常"));
			return action.CatchExceptionWithLog(ex, Biz.L("WMS.Print_BIZ_U9_ASN.SetGiftQtyException"));
			}
			return action;
			}

			/// <summary>
			@@ -383,15 +425,16 @@
			public async Task<ApiAction> GenerateReceipt(BaseInput input)
			{
			var action = new ApiAction();
			var orderNo = input.Data;
			var orderNo = CurOrder.ORDER_NO;
			try
			{
			var order = await MainDB.Queryable<BIZ_U9_ASN>().Where(q => q.ORDER_NO == orderNo).IncludesAllFirstLayer().FirstAsync();
			var reqType = input.Options["reqType"].ToString();
			var order = await MainDB.Queryable<BIZ_U9_ASN>().Where(q => q.ORDER_NO == orderNo).Includes(q => q.Details, d => d._ItemInfos).IncludesAllFirstLayer().FirstAsync();
			if (order.IsNullOrEmpty())
			{
			action.IsSuccessed = false;
			//action.LocaleMsg = Biz.L($"找不到送货单[{0}]的单据信息，请提交正确的单号");
			action.LocaleMsg = Biz.L("WMS.Print_BIZ_U9_ASN.GenerateReceipt.ASNNotExists", orderNo);
			action.LocaleMsg = Biz.L("WMS.Count_BIZ_U9_ASN.GenerateReceipt.ASNNotExists", orderNo);
			return action;
			}
			//验证条码是否正确
			@@ -399,35 +442,88 @@
			{
			action.IsSuccessed = false;
			//action.LocaleMsg = Biz.L("生成收货单：送货单状态[{0}]异常");
			action.LocaleMsg = Biz.L("WMS.Print_BIZ_U9_ASN.GenerateReceipt.StatusException", order.STATUS.GetEnumDesc<BIZ_U9_ASN.STATUSs>());
			action.LocaleMsg = Biz.L("WMS.Count_BIZ_U9_ASN.GenerateReceipt.StatusException", order.STATUS.GetEnumDesc<BIZ_U9_ASN.STATUSs>());
			return action;
			}

			//查询是否清点完成
			//查询是否存在清点完成的行明细，如果有则先提交完成的行，如果没有则报错
			var finishNotSubmit = order.Details.Where(q => SqlFunc.IsNullOrEmpty(q.RECEIVER_NO) && q.QTY == order.SnList.Where(s => s.LINE_NO == q.LINE_NO && (s.STATUS == WMS_ITEM.STATUSs.Counted.GetValue() \|\| q.STATUS == WMS_ITEM.STATUSs.Rejected.GetValue())).Sum(s => s.QTY)).ToList();
			var noFinish = order.Details.Where(q => q.QTY != order.SnList.Where(s => s.LINE_NO == q.LINE_NO && (s.STATUS == WMS_ITEM.STATUSs.Counted.GetValue() \|\| q.STATUS == WMS_ITEM.STATUSs.Rejected.GetValue())).Sum(s => s.QTY));
			if (noFinish.Any())
			if (!finishNotSubmit.Any())
			{
			action.IsSuccessed = false;
			//action.LocaleMsg = Biz.L("送货单[{0}]未清点完成，请先清点完成，未完成清点的行号如下：{1}");
			action.LocaleMsg = Biz.L("WMS.Print_BIZ_U9_ASN.GenerateReceipt.NoFinishCounting", orderNo, string.Join("，", noFinish.Select(q => q.LINE_NO)));
			//action.LocaleMsg = Biz.L("送货单[{0}]没有清点完成可以提交的行，未完成清点的行号如下：{1}");
			action.LocaleMsg = Biz.L("WMS.Count_BIZ_U9_ASN.GenerateReceipt.NoFinishCounting", orderNo, string.Join("，", noFinish.Select(q => q.LINE_NO)));
			return action;
			}

			var iInput = new CreateRcvBySrcASNInput
			ApiAction<List<U9CReturnData2>> result = new();
			//如果是随单赠品或者样品
			if (reqType.ToInt32() > 0)
			{
			userId = UserCode,
			IsLogin = true,
			CreateRcvBySrcASNParam = new()
			var iInput = new CreateReceivementInput
			{
			aSNToRcvTransDTOs = order.Details.Select(q => new ASNToRcvTransDTO { ASNLineKey = q.ID, TransQty = new() { m_amount1 = q.QTY } }).ToList(),
			userId = UserCode,
			IsLogin = true,
			CreateReceivementParam = new()
			{
			rcvDTO = new()
			{
			Supplier = new() { m_code = order.SUPP_CODE },
			RcvDocType = new() { m_code = rcvDocType },
			RcvLines = finishNotSubmit.Select(q=> new RcvLine
			{
			ItemInfo = new() { m_itemCode = q.ITEM_CODE},
			Wh = new() { m_code = "10101" },
			RcvLineLocations = new(){
			new(){
			Location = new(){ m_code= q.ItemInfo.DEFAULT_LOCATION},
			LocationQtyTU = q.QTY,
			}
			},
			ArriveQtyTU = q.QTY,
			ArriveQtyPU = q.QTY,
			RcvQtyTU = 0,
			RcvQtyPU = 0,
			EyeballingQtyTU = q.QTY,
			RcvProcedure = 0,
			RcvLotCode = q.SUPP_LOTNO,
			InvLotCode = q.LOTNO,
			}).ToList(),
			}
			},
			};
			result = await DI.Resolve<IWMS_U9C>().CreateReceivement(iInput);
			if (!result.IsSuccessed)
			{
			action.IsSuccessed = false;
			action.LocaleMsg = result.LocaleMsg;
			return action;
			}
			};
			var result = await DI.Resolve<IWMS_U9C>().CreateRcvBySrcASN(iInput);
			if (!result.IsSuccessed)
			}
			//如果是未上门户
			else
			{
			action.IsSuccessed = false;
			action.LocaleMsg = result.LocaleMsg;
			return action;
			var iInput = new CreateRcvBySrcASNInput
			{
			userId = UserCode,
			IsLogin = true,
			CreateRcvBySrcASNParam = new()
			{
			aSNToRcvTransDTOs = finishNotSubmit.Select(q => new ASNToRcvTransDTO
			{
			ASNLineKey = q.ID,
			TransQty = new() { m_amount1 = q.QTY },
			BinInfoList = new() { new() { Bin = new() { m_code = q.ItemInfo.DEFAULT_LOCATION }, LocationQtySU = q.QTY, LocationQtyTU = q.QTY } },
			}).ToList(),
			}
			};
			result = await DI.Resolve<IWMS_U9C>().CreateRcvBySrcASN(iInput);
			if (!result.IsSuccessed)
			{
			action.IsSuccessed = false;
			action.LocaleMsg = result.LocaleMsg;
			return action;
			}
			}

			//根据接口返回收货单单号查询单据明细，并创建条码明细
			@@ -435,7 +531,7 @@
			receipt.Details = new();
			receipt.SnList = new();
			DbClient U9Cdb = Biz.DataSource["YadaU9C"].Client;
			var list = U9Cdb.Queryable<mes_ReturnedDocInfo>().Where(x => x.RcvId == result.Data[0].ID.ToDouble() && x.DocNo == result.Data[0].Code).ToList();
			var list = U9Cdb.Queryable<mes_ReturnedDocInfo>().Where(x => x.RcvId == result.Data[0].ID.ToDouble() && x.DocNo == result.Data[0].Code && x.SplitFlag != 1).ToList();

			if (list != null && list.Count > 0)
			{
			@@ -455,7 +551,7 @@

			foreach (var item in list)
			{
			var asnDtl = order.Details.First(q => q.ID == item.SrcASNDocLineId.ToString());
			var asnDtl = finishNotSubmit.First(q => q.ID == item.SrcASNDocLineId.ToString());
			BIZ_U9_RECEIPT_DTL receiptDt = new()
			{
			ID = item.RcvLineId.ToString(),
			@@ -471,11 +567,19 @@
			ASN_LINE_ID = item.SrcASNDocLineId.ToString(),
			ASN_LINE = asnDtl.LINE_NO,
			ERP_CODE = item.ItemCode1,
			ERP_STATUS_CODE = item.Status.ToString(),
			ERP_STATUS_NAME = item.StatusName,
			};
			receipt.Details.Add(receiptDt);
			asnDtl.STATUS = BIZ_U9_ASN.STATUSs.Finished.GetValue();
			asnDtl.RECEIVER_ID = item.RcvId.ToString();
			asnDtl.RECEIVER_NO = item.DocNo;
			asnDtl.RECEIVER_LINE = item.DocLineNo.ToString();
			asnDtl.RECEIVER = UserCode;
			asnDtl.RECEIVE_DATE = DateTime.Now;
			}

			foreach (var sn in order.SnList)
			foreach (var sn in order.SnList.Where(q => finishNotSubmit.Any(s => s.LINE_NO == q.LINE_NO)))
			{
			var dtl = receipt.Details.First(q => q.ASN_LINE == sn.LINE_NO);
			BIZ_U9_RECEIPT_SN receiptSn = new()
			@@ -500,7 +604,7 @@
			}

			//更新库存表信息
			var items = MainDB.Queryable<WMS_ITEM>().Where(q => SqlFunc.Subqueryable<BIZ_U9_ASN_SN>().Where(s => s.SN == q.SN && s.ORDER_NO == order.ORDER_NO).Any()).ToList();
			var items = MainDB.Queryable<WMS_ITEM>().Where(q => SqlFunc.Subqueryable<BIZ_U9_ASN_SN>().Where(s => s.SN == q.SN && s.ORDER_NO == order.ORDER_NO && finishNotSubmit.Select(d => d.LINE_NO).Contains(s.LINE_NO)).Any()).ToList();
			var historys = new List<WMS_ITEM_HIS>();
			foreach (var item in items)
			{
			@@ -514,7 +618,7 @@
			item.TRANS_LINE = receipt.SnList.First(q => q.SN == item.SN).LINE_NO;
			historys.Add(new WMS_ITEM_HIS(item, $"送货单[{order.ORDER_NO}]的条码[{item.SN}]生成收货单[{receipt.ORDER_NO}]，待检验完成后可入库"));
			}
			var pkgs = MainDB.Queryable<WMS_ITEM_PKG>().Where(q => SqlFunc.Subqueryable<BIZ_U9_ASN_SN>().Where(s => s.SN == q.SN && s.ORDER_NO == order.ORDER_NO).Any()).ToList();
			var pkgs = MainDB.Queryable<WMS_ITEM_PKG>().Where(q => SqlFunc.Subqueryable<BIZ_U9_ASN_SN>().Where(s => s.SN == q.SN && s.ORDER_NO == order.ORDER_NO && finishNotSubmit.Select(d => d.LINE_NO).Contains(s.LINE_NO)).Any()).ToList();
			foreach (var item in pkgs)
			{
			item.AUTH_ORG = receipt.AUTH_ORG;
			@@ -525,11 +629,15 @@
			item.TRANS_NO = receipt.ORDER_NO;
			item.TRANS_LINE = receipt.SnList.First(q => q.SN == item.SN).LINE_NO;
			}
			order.STATUS = BIZ_U9_ASN.STATUSs.Finished.GetValue();
			order.RECEIVER_ID = receipt.ID;
			order.RECEIVER_NO = receipt.ORDER_NO;
			order.RECEIVER = UserCode;
			order.RECEIVE_DATE = DateTime.Now;

			if (!noFinish.Any())
			{
			order.STATUS = BIZ_U9_ASN.STATUSs.Finished.GetValue();
			order.RECEIVER = UserCode;
			order.RECEIVE_DATE = DateTime.Now;
			order.UPDATE_USER = UserCode;
			order.REMARK = "";
			}

			//使用统一的事务DB对象
			var db = GetCommitDB();
			@@ -538,7 +646,8 @@
			db.Updateable(items, UserCode).UpdateColumns(q => new { q.UPDATE_TIME, q.UPDATE_USER, q.AUTH_ORG, q.STATUS, q.TRANS_CODE, q.TRANS_NO, q.TRANS_LINE, q.SOURCE_CODE, q.SOURCE_ORDER, q.SOURCE_LINE }).ExecuteCommand();
			db.Updateable(pkgs, UserCode).UpdateColumns(q => new { q.UPDATE_TIME, q.UPDATE_USER, q.AUTH_ORG, q.TRANS_CODE, q.TRANS_NO, q.TRANS_LINE, q.SOURCE_CODE, q.SOURCE_ORDER, q.SOURCE_LINE }).ExecuteCommand();
			db.Insertable(historys, UserCode).ExecuteCommand();
			db.Updateable(order, UserCode).UpdateColumns(q => new { q.UPDATE_TIME, q.UPDATE_USER, q.STATUS, q.RECEIVER, q.RECEIVE_DATE, q.RECEIVER_ID, q.RECEIVER_NO }).ExecuteCommand();
			db.Updateable(order, UserCode).UpdateColumns(q => new { q.UPDATE_TIME, q.UPDATE_USER, q.STATUS, q.RECEIVER, q.RECEIVE_DATE }).ExecuteCommand();
			db.Updateable(finishNotSubmit, UserCode).UpdateColumns(q => new { q.UPDATE_TIME, q.UPDATE_USER, q.STATUS, q.RECEIVER, q.RECEIVE_DATE, q.RECEIVER_ID, q.RECEIVER_NO, q.RECEIVER_LINE }).ExecuteCommand();
			db.Insertable(receipt, UserCode).ExecuteCommand();
			db.Insertable(receipt.Details, UserCode).ExecuteCommand();
			db.Insertable(receipt.SnList, UserCode).ExecuteCommand();
			@@ -546,7 +655,8 @@
			if (dbTran.IsSuccess)
			{
			//action.LocaleMsg = Biz.L($"送货单[{0}]生成收货单[{1}]成功");
			action.LocaleMsg = Biz.L("WMS.Print_BIZ_U9_ASN.GenerateReceipt.Success", order.ORDER_NO, receipt.ORDER_NO);
			action.LocaleMsg = Biz.L("WMS.Count_BIZ_U9_ASN.GenerateReceipt.Success", order.ORDER_NO, receipt.ORDER_NO);
			CurSn.Clear();
			}
			else
			{
			@@ -558,23 +668,49 @@
			catch (System.Exception ex)
			{
			//return action.CatchExceptionWithLog(ex, Biz.L("送货单[{0}]生成收货单异常"));
			return action.CatchExceptionWithLog(ex, Biz.L("WMS.Print_BIZ_U9_ASN.GenerateReceiptException", orderNo));
			return action.CatchExceptionWithLog(ex, Biz.L("WMS.Count_BIZ_U9_ASN.GenerateReceiptException", orderNo));
			}
			return action;
			}
			/// <summary>
			/// 完成所有处理后使用事务保存数据
			/// </summary>
			/// <param name="action"></param>
			/// <param name="locale"></param>
			/// <param name="doAfterSave"></param>
			/// <returns></returns>
			public ApiAction<ScanOutput> DoIfFinish(ApiAction<ScanOutput> action, string locale, Action doAfterSave = null)
			{
			//保存数据库
			SaveCommitListToDB();

			//保存数据成功后执行
			doAfterSave?.Invoke();

			// 返回数据
			action.Data.Data = new { OrderNo = CurOrder.ORDER_NO, Sns = SnList };

			//action.LocaleMsg = Biz.L($"条码[{0}]清点成功！");
			//action.LocaleMsg = Biz.L("WMS.Count_BIZ_U9_ASN.CountSuccess", string.Join(",", SnList));

			//重置工序
			ResetTrans();
			return SetOutPutMqttMsg(action, locale); ;
			}

			#endregion

			/// <summary>
			/// 重置当前操作，有需要则重写此方法
			/// 重置事务数据，有需要则重写此方法
			/// </summary>
			public override void ResetScan()
			public override void ResetTrans()
			{
			base.ResetScan();
			base.ResetTrans();
			Command = null;
			CurInvItem = null;
			CurScanShelf = null;
			CurSn = null;
			//CurSn = null;
			SnList = new();
			}

			public override bool Close(bool needSaveHistoryLog = false)