服务端的TigerApi 框架，基于.NET6 2024 版本
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
Rodney Chen
2025-04-08 43b2af8956d54dc3a53f211c53d8af582806b6ba 
 Tiger.Business.WMS/Transaction/Yada/Out_BIZ_WMS_PREP.cs


@@ -12,6 +12,8 @@


using Tiger.Business.WMS.Common;


using Org.BouncyCastle.Ocsp;


using Tiger.Model.Sharetronic.Shelf;


using MailKit.Search;


using Tiger.Business.WMS.Extensions;




namespace Tiger.Business.WMS.Transaction


{


@@ -29,7 +31,7 @@


        }




        #region Propertys & Variables


        private Preparation CurPREP;


        public Preparation CurPREP { get; set; }


        private List<BIZ_WMS_PREP_SN> CurSn = new();


        private BIZ_WMS_PREP_DTL CurPrepDtl = new();


        public List<SuggestItem> Suggests { get; set; } = new();


@@ -95,7 +97,7 @@


            catch (Exception ex)


            {


                //取消当前操作


                ResetScan();


                ResetTrans();


                //action.CatchExceptionWithLog(ex, $"扫描[{input.SN}]异常");


                action.CatchExceptionWithLog(ex, Biz.L("WMS.Default.Scan.ScanException", input.SN));


            }


@@ -141,7 +143,7 @@


            catch (Exception ex)


            {


                //取消当前操作


                ResetScan();


                ResetTrans();


                //action.CatchExceptionWithLog(ex, $"备料任务扫描单据异常(Data: {0})");


                action.CatchExceptionWithLog(ex, Biz.L("WMS.Out_BIZ_WMS_PREP.ScanOrderException", input?.Data));


            }


@@ -156,6 +158,7 @@


        {


            var action = new ApiAction<BIZ_WMS_PREP>();


            CurPREP.Order = MainDB.Queryable<BIZ_WMS_PREP>().Where(q => q.ID == CurPREP.Order.ID).IncludesAllFirstLayer().First();




            action.Data = CurPREP.Order;


            return action;


        }


@@ -177,11 +180,11 @@


                    action.LocaleMsg = Biz.L("WMS.Out_BIZ_WMS_PREP.ScanItem.NotSelectItem");


                    return action;


                }


                if (prepDtl.QTY_PREP > GetActReqQty(prepDtl))


                if (prepDtl.QTY_PREP > CurPREP.BizType.GetActReqQty(prepDtl))


                {


                    action.IsSuccessed = false;


                    //action.LocaleMsg = Biz.L("当前选择物料行[{0}]已备料数量[{1}]，以满足实际需求数量[{2}]，无需继续备料");


                    action.LocaleMsg = Biz.L("WMS.Out_BIZ_WMS_PREP.SelectItem.PrepFinish", prepDtl.ITEM_CODE, prepDtl.QTY_PREP, GetActReqQty(prepDtl));


                    action.LocaleMsg = Biz.L("WMS.Out_BIZ_WMS_PREP.SelectItem.PrepFinish", prepDtl.ITEM_CODE, prepDtl.QTY_PREP, CurPREP.BizType.GetActReqQty(prepDtl));


                    return action;


                }


                //删除物料池中上一次分配的物料


@@ -215,7 +218,7 @@


                    if (Suggests.Count > 0)


                    {


                        var inv = Suggests.First();


                        var actQty = CurPrepDtl.QTY_PREP > GetActReqQty(CurPrepDtl) ? 0 : (GetActReqQty(CurPrepDtl) - CurPrepDtl.QTY_PREP);


                        var actQty = CurPrepDtl.QTY_PREP > CurPREP.BizType.GetActReqQty(CurPrepDtl) ? 0 : (CurPREP.BizType.GetActReqQty(CurPrepDtl) - CurPrepDtl.QTY_PREP);


                        if (inv != null && actQty > 0)


                        {


                            inv.poolItem = inv.Item.GetPoolItem(OrgCode, nameof(CurPREP.Order), CurPrepDtl.ORDER_NO, CurPrepDtl.ORDER_LINE, actQty, true);


@@ -232,7 +235,7 @@


                if (CurPREP.Order.CurBatch.DLVY_MODE == BIZ_WMS_PREP_BTH.DLVY_MODEs.Supply.GetValue())


                {


                    //推荐物料


                    var actQty = CurPrepDtl.QTY_PREP > GetActReqQty(CurPrepDtl) ? 0 : (GetActReqQty(CurPrepDtl) - CurPrepDtl.QTY_PREP);


                    var actQty = CurPrepDtl.QTY_PREP > CurPREP.BizType.GetActReqQty(CurPrepDtl) ? 0 : (CurPREP.BizType.GetActReqQty(CurPrepDtl) - CurPrepDtl.QTY_PREP);


                    Result<List<SuggestItem>> result = Suggest(CurPrepDtl.ORDER_NO, CurPrepDtl.ITEM_CODE, null, inputDtl.WH_ID, inputDtl.REGION_ID, inputDtl.SHELF_ID, input.AuthOption, actQty);


                    action.LocaleMsg = result.LocaleMsg;


                    if (result.IsException)


@@ -272,7 +275,7 @@


            catch (Exception ex)


            {


                //取消当前操作


                ResetScan();


                ResetTrans();


                //action.CatchExceptionWithLog(ex, $"备料任务选择要物料行异常(Data: {0})");


                action.CatchExceptionWithLog(ex, Biz.L("WMS.Out_BIZ_WMS_PREP.SelectItemException", input?.Data));


            }


@@ -450,9 +453,11 @@


                    ORDER_BATCH = CurPREP.Order.CurBatch.BATCH.ToString(),


                    SN = q.SN,


                    ITEM_CODE = q.ITEM_CODE,


                    UNIT = q.UNIT,


                    QTY = q.QTY,


                    QTY_DLVY = q.QTY,


                    STATUS = q.STATUS,


                    LOTNO = q.LOTNO,


                    WH_CODE = CurInvItem.Warehouse.WH_CODE,


                    REGION_CODE = CurInvItem.Region.REGION_CODE,


                    SHELF_CODE = CurInvItem.Shelf.SHELF_CODE,


@@ -475,7 +480,7 @@


                //判断是否超发


                isExceed = false;


                //计算剩余需求数量和条码中的发出数量


                var actQty = CurPrepDtl.QTY_PREP > GetActReqQty(CurPrepDtl) ? 0 : (GetActReqQty(CurPrepDtl) - CurPrepDtl.QTY_PREP);


                var actQty = CurPrepDtl.QTY_PREP > CurPREP.BizType.GetActReqQty(CurPrepDtl) ? 0 : (CurPREP.BizType.GetActReqQty(CurPrepDtl) - CurPrepDtl.QTY_PREP);


                if (actQty < CurInvItem.CurPkg.QTY)


                {


                    isExceed = true;


@@ -496,7 +501,7 @@


                {


                    //action.LocaleMsg = Biz.L($"条码[{0}]扫描成功，备料物料[{1}]需求[{2}]还需备料[{3}]，条码需要截料，发出数量[{4}]");


                    //action.LocaleMsg = Biz.L($"条码[{0}]扫描成功，备料物料[{1}]需求[{2}]还需备料[{3}]，请选择要超发还是截料？");


                    action.LocaleMsg = Biz.L($"WMS.Out_BIZ_WMS_PREP.ScanItem.Success{(isNeedCut ? "" : "Confirm")}", CurInvItem.SN, CurInvItem.ItemInfo.ITEM_CODE, GetActReqQty(CurPrepDtl), actQty);


                    action.LocaleMsg = Biz.L($"WMS.Out_BIZ_WMS_PREP.ScanItem.Success{(isNeedCut ? "" : "Confirm")}", CurInvItem.SN, CurInvItem.ItemInfo.ITEM_CODE, CurPREP.BizType.GetActReqQty(CurPrepDtl), actQty);


                    action.Data.Command = "ConfirmExceed";


                    action.Data.Data = new  


                    {


@@ -531,11 +536,11 @@


                var sns = (input.Data ?? "").JsonToObject<List<BIZ_WMS_PREP_SN>>() ?? new List<BIZ_WMS_PREP_SN>();


                if (!sns.Any())


                {


                    var actQty = CurPrepDtl.QTY_PREP > GetActReqQty(CurPrepDtl) ? 0 : (GetActReqQty(CurPrepDtl) - CurPrepDtl.QTY_PREP);


                    var actQty = CurPrepDtl.QTY_PREP > CurPREP.BizType.GetActReqQty(CurPrepDtl) ? 0 : (CurPREP.BizType.GetActReqQty(CurPrepDtl) - CurPrepDtl.QTY_PREP);


                    action.IsSuccessed = false;


                    //action.LocaleMsg = Biz.L($"条码[{0}]扫描成功，备料物料[{1}]需求[{2}]还需备料[{3}]，条码需要截料，发出数量[{4}]");


                    //action.LocaleMsg = Biz.L($"条码[{0}]扫描成功，备料物料[{1}]需求[{2}]还需备料[{3}]，请选择要超发还是截料？");


                    action.LocaleMsg = Biz.L($"WMS.Out_BIZ_WMS_PREP.ScanItem.Success{(isNeedCut ? "" : "Confirm")}", CurInvItem.SN, CurInvItem.ItemInfo.ITEM_CODE, GetActReqQty(CurPrepDtl), actQty);


                    action.LocaleMsg = Biz.L($"WMS.Out_BIZ_WMS_PREP.ScanItem.Success{(isNeedCut ? "" : "Confirm")}", CurInvItem.SN, CurInvItem.ItemInfo.ITEM_CODE, CurPREP.BizType.GetActReqQty(CurPrepDtl), actQty);


                    action.Data.Command = "ConfirmExceed";


                    action.Data.Data = new


                    {


@@ -581,7 +586,7 @@


                {


                    action.IsSuccessed = false;


                    action.LocaleMsg = downResult.LocaleMsg;


                    ResetScanInfo();


                    ResetScan();


                    return SetOutPutMqttMsg(action, input.Locale);


                }


                else//处理备料任务数据


@@ -600,7 +605,7 @@


                    CurPrepDtl.QTY_PREP += CurSn.Sum(q => q.QTY_DLVY);


                    CurPREP.Order.STATUS = BIZ_WMS_PREP.STATUSs.Picking.GetValue();


                    CurPREP.Order.CurBatch.STATUS = BIZ_WMS_PREP_BTH.STATUSs.Picking.GetValue();


                    CurPREP.Order.CurBatch.PICK_TIME = DateTime.Now;


                    CurPREP.Order.CurBatch.PICK_TIME = CurPREP.Order.CurBatch.PICK_TIME < new DateTime(2000, 1, 1) ? DateTime.Now : CurPREP.Order.CurBatch.PICK_TIME;




                    //创建变量克隆对象用于传入DBSubmitAction中保存当前需要暂存的数据值


                    var _CurSn = CurSn.Clone();


@@ -632,23 +637,11 @@


            catch (Exception ex)


            {


                //取消当前操作


                ResetScan();


                //清理暂存数据提交操作


                DBCommitList.Clear();


                ResetTrans();


                //action.CatchExceptionWithLog(ex, $"扫描条码[{input.SN}]复核异常");


                action.CatchExceptionWithLog(ex, Biz.L("WMS.Default.ScanItem.ScanException", input.SN));


            }


            return SetOutPutMqttMsg(action, input.Locale);


        }




        /// <summary>


        /// 实际需求数量计算方法


        /// </summary>


        /// <param name="dtl"></param>


        /// <returns></returns>


        private double GetActReqQty(BIZ_WMS_PREP_DTL dtl)


        {


            return dtl.QTY_REQ;


        }




        /// <summary>


@@ -735,7 +728,7 @@


            catch (Exception ex)


            {


                //取消当前操作


                ResetScan();


                ResetTrans();


                //action.CatchExceptionWithLog(ex, $"扫描货架/储位[{0}]异常");


                action.CatchExceptionWithLog(ex, Biz.L("WMS.Default.ScanShelf.ScanException", Code));


            }


@@ -775,30 +768,44 @@


            action.LocaleMsg = Biz.L("WMS.Default.ScanItem.TakeDownSucceeded", CurInvItem.SN, CurInvItem.Location?.LOCATION_CODE);




            //重置工序


            ResetScanInfo();


            ResetScan();


            return SetOutPutMqttMsg(action, locale);


        }




        /// <summary>


        /// 调用发料单据的ERP接口


        /// </summary>


        /// <param name="input"></param>


        /// <returns></returns>


        public async Task<ApiAction> CommitToERP(BaseInput input)


        {


            var action = await CurPREP.Order.BIZ_TYPE.GetEnum<BIZ_WMS_PREP.BIZ_TYPEs>() .CommitToERP(this, input);


            return action;


        }




        #endregion




        /// <summary>


        /// 重置当前操作，有需要则重写此方法


        /// 重置事务数据，有需要则重写此方法


        /// </summary>


        public override void ResetScan()


        public override void ResetTrans()


        {


            base.ResetScan();


            ResetScanInfo();


            ResetScan();


            CurPREP = new(MainDB, UserCode, OrgCode);


            CurPrepDtl = new();


            CurScanShelf = null;


            base.ResetTrans();


        }




        /// <summary>


        /// 重置扫码信息


        /// 重置本次扫码信息


        /// </summary>


        public void ResetScanInfo()


        public override void ResetScan()


        {


            Command = "Normal";


            CurInvItem = null;


            CurSn = new();


            base.ResetScan();


        }




        public override bool Close(bool needSaveHistoryLog = false)