添加生成收货单功能及相关接口

Ben Lin

2025-03-28 e05f0fb09b78e6de1dd4ad808fdbe1e044ebbbdd

添加生成收货单功能及相关接口

在 `Print_BIZ_U9_ASN.cs` 中实现生成收货单的逻辑，包括订单状态验证、清点检查、接口调用和库存更新，并增加异常处理和事务管理以确保数据一致性。

在 `WMSController.Print_BIZ_U9_ASN.cs` 中新增 `Print_BIZ_U9_ASN_GenerateReceiptAsync` API 接口，支持异步请求并记录事务历史。

在 `IPrint_BIZ_U9_ASN.cs` 接口中添加 `GenerateReceipt` 方法定义，以支持生成收货单的功能。

 Tiger.Business.WMS/Transaction/Yada/Print_BIZ_U9_ASN.cs

@@ -223,10 +223,58 @@
                    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();
                });
                //清点完成调用接口生成无来源收货单
                Action generatedAction = () =>

                //完成所有处理后使用事务保存数据
                action = DoIfFinish(action, input.Locale);
            }
            catch (Exception ex)
                {
                    ApiAction<List<U9CReturnData2>> result = new ApiAction<List<U9CReturnData2>>();
                //取消当前操作
                ResetScan();
                action.CatchExceptionWithLog(ex, Biz.L("WMS.Default.Scan.ScanException", input.SN));
            }
            return SetOutPutMqttMsg(action, input.Locale);
        }

        /// <summary>
        /// 生成收货单：调用U9新增收货单接口
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<ApiAction> GenerateReceipt(BaseInput input)
        {
            var action = new ApiAction();
            var orderNo = input.Data;
            try
            {
                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.Count_BIZ_U9_ASN.GenerateReceipt.ASNNotExists", orderNo);
                    return action;
                }
                //验证条码是否正确
                if (order.STATUS != BIZ_U9_ASN.STATUSs.Counting.GetValue())
                {
                    action.IsSuccessed = false;
                    //action.LocaleMsg = Biz.L("生成收货单：送货单状态[{0}]异常");
                    action.LocaleMsg = Biz.L("WMS.Count_BIZ_U9_ASN.GenerateReceipt.StatusException", order.STATUS.GetEnumDesc<BIZ_U9_ASN.STATUSs>());
                    return action;
                }

                //查询是否清点完成
                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())
                {
                    action.IsSuccessed = false;
                    //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;
                }
                ApiAction<List<U9CReturnData2>> result = new();
                    //如果是随单赠品或者样品
                    if (reqType == "1")
                    {
@@ -259,14 +307,14 @@
                                },
                            }
                        };
                        result = DI.Resolve<IWMS_U9C>().CreateReceivement(iInput).Result;
                    result = await DI.Resolve<IWMS_U9C>().CreateReceivement(iInput);
                        if (!result.IsSuccessed)
                        {
                            throw new Exception(Biz.T(result.LocaleMsg, input.Locale));
                        }
                    }
                    //如果是未上门户
                    else if (reqType == "0")
                else
                    {
                        var iInput = new CreateRcvBySrcASNInput
                        {
@@ -274,10 +322,15 @@
                            IsLogin = true,
                            CreateRcvBySrcASNParam = new()
                            {
                                aSNToRcvTransDTOs = order.Details.Select(q => new ASNToRcvTransDTO { ASNLineKey = q.ID, TransQty = new() { m_amount1 = q.QTY } }).ToList(),
                            aSNToRcvTransDTOs = order.Details.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 = DI.Resolve<IWMS_U9C>().CreateRcvBySrcASN(iInput).Result;
                    result = await DI.Resolve<IWMS_U9C>().CreateRcvBySrcASN(iInput);
                        if (!result.IsSuccessed)
                        {
                            throw new Exception(Biz.T(result.LocaleMsg, input.Locale));
@@ -289,7 +342,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)
                    {
@@ -400,7 +453,7 @@
                    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);
                    }
                    else
                    {
@@ -408,20 +461,14 @@
                        //抛出异常
                        throw dbTran.ErrorException;
                    }
                };

                //完成所有处理后使用事务保存数据
                action = DoIfFinish(action, input.Locale, generatedAction);
            }
            catch (Exception ex)
            catch (System.Exception ex)
            {
                //取消当前操作
                ResetScan();
                action.CatchExceptionWithLog(ex, Biz.L("WMS.Default.Scan.ScanException", input.SN));
                //return action.CatchExceptionWithLog(ex, Biz.L("送货单[{0}]生成收货单异常"));
                return action.CatchExceptionWithLog(ex, Biz.L("WMS.Count_BIZ_U9_ASN.GenerateReceiptException", orderNo));
            }
            return SetOutPutMqttMsg(action, input.Locale);
            return action;
        }

        /// <summary>
        /// 完成所有处理后使用事务保存数据
        /// </summary>

 Tiger.Controllers.WMS/Controllers/WMSController.Print_BIZ_U9_ASN.cs

@@ -137,5 +137,51 @@
            return Ok(response);
        }


        /// <summary>
        /// GenerateReceipt(ApiAction(BaseInput(Data:OrderNo)))
        /// 根据传入的单号生成收货单，并调用U9新增收货单接口
        /// </summary>
        /// <param name="action"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("api/[controller]/Count_U9ASN/GenerateReceipt")]
        public async Task<IActionResult> Print_BIZ_U9_ASN_GenerateReceiptAsync([FromBody] ApiAction<BaseInput> action)
        {
            ApiAction response;
            IPrint_BIZ_U9_ASN trans = null;
            try
            {
                if (iBiz.WMS.Context.GetTransDic().ContainsKey(action.ID))
                {
                    trans = iBiz.WMS.Context.GetTransDic()[action.ID] as IPrint_BIZ_U9_ASN;
                    if (!trans.IsFinished)
                    {
                        if (action.IsAsync)
                        {
                            response = action.GetResponse(await trans.GenerateReceipt(action.Data));
                        }
                        else
                        {
                            lock (trans.TransLock) { response = action.GetResponse(trans.GenerateReceipt(action.Data).Result); }
                        }
                    }
                    else
                    {
                        response = action.GetResponse($"Transaction Error: 来料打印清点事务[ID:{action.ID}]已经关闭，请重新打开送货单(U9)清点功能", false);
                    }
                }
                else
                {
                    response = action.GetResponse($"Transaction Error: 来料打印清点事务[ID:{action.ID}]数据丢失，请重新打开送货单(U9)清点功能", false);
                }
            }
            catch (System.Exception ex)
            {
                response = action.GetResponse().CatchExceptionWithLog(ex);
            }
            trans?.AddHistory(Request, action);
            return Ok(response);
        }
    }
}

 Tiger.IBusiness.WMS/Transaction/IPrint_BIZ_U9_ASN.cs

@@ -20,6 +20,8 @@
        /// </summary>
        public Task<ApiAction<ScanOutput>> Scan(BaseInput input);

        public Task<ApiAction> GenerateReceipt(BaseInput input);

        public bool Close(bool needSaveHistoryLog = false);
    }
}