上传最新代码

wangxinhui

2025-04-29 95e39ae7aecd6e1016c71cf5ae70a680d8f569bb

 ´úÂë¹ÜÀí/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService_Outbound.cs

@@ -19,6 +19,7 @@
using WIDESEA_External.Model;
using WIDESEA_Core.CodeConfigEnum;
using Microsoft.AspNetCore.Mvc;
using WIDESEA_DTO.ERP;

namespace WIDESEA_TaskInfoService
{
@@ -82,16 +83,20 @@
        /// <param name="ProOutNo">出库订单号</param>
        /// <param name="StationCode">站台地址</param>
        /// <returns></returns>
        public WebResponseContent OutProductTask(int[] keys, string StationCode)
        public async Task<WebResponseContent> OutProductTask(int[] keys, string StationCode)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                if (StationCode.IsNullOrEmpty())
                {
                    return await Task.FromResult(content.Error("线体输入错误"));
                }
                //获取成品出库订单
                List<Dt_ProOutOrderDetail> _ProOutOrderDetails = _outboundRepository.ProOutOrderDetailRepository.QueryData(x => keys.Contains(x.Id));
                List<Dt_ProOutOrderDetail> _ProOutOrderDetails = await _outboundRepository.ProOutOrderDetailRepository.QueryDataAsync(x => keys.Contains(x.Id));
                if (_ProOutOrderDetails.Count<=0)
                {
                    return content.Error("勾选订单明细不存在");
                    return await Task.FromResult(content.Error("勾选订单明细不存在"));
                }
                List<Dt_Task> tasks = new List<Dt_Task>();
                List<StockSelectViewDTO> stockSelectViews = new List<StockSelectViewDTO>();
@@ -127,7 +132,7 @@
                    tasks.AddRange(result.Item1);
                }
                //处理出库数据
                content = GenerateOutboundTaskDataUpdate(tasks, proStockInfos, proOutOrderDetails, outProStockInfos, locationInfos);
                return await Task.FromResult(GenerateOutboundTaskDataUpdate(tasks, proStockInfos, proOutOrderDetails, outProStockInfos, locationInfos));
            }
            catch (Exception ex)
            {
@@ -136,7 +141,200 @@
            }
            return content;
        }
        
        /// <summary>
        /// äººå·¥é€‰å®šåº“存出库
        /// </summary>
        /// <returns></returns>
        public WebResponseContent OutProductSelect(int orderDetailId,List<ProStockViewDTO> proStockViews)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                //获取出库单明细
                Dt_ProOutOrderDetail proOutOrderDetail = _outboundRepository.ProOutOrderDetailRepository.QueryFirst(x=>x.Id==orderDetailId);
                if (proOutOrderDetail == null)
                {
                    return content.Error("订单明细不存在");
                }
                if (proOutOrderDetail.ProOrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt())
                {
                    return content.Error("当前的明细单已完成");
                }
                //获取出库单据
                Dt_ProOutOrder proOutOrder = _outboundRepository.ProOutOrderRepository.Db.Queryable<Dt_ProOutOrder>().Where(x=>x.Id==proOutOrderDetail.ProOrderId).Includes(x => x.Details).First();
                if (proOutOrder==null)
                {
                    return content.Error("出库单据不存在");
                }
                if (proOutOrder.ProOrderStatus>=OutOrderStatusEnum.出库完成.ObjToInt())
                {
                    return content.Error($"{proOutOrder.ProOutOrderNo}出库单已完成");
                }
                if ((proOutOrderDetail.QtyPcs-proOutOrderDetail.OverQtyPcs)> proStockViews.Sum(x=>x.SumStocks))
                {
                    return content.Error($"需满足{proOutOrderDetail.QtyPcs - proOutOrderDetail.OverQtyPcs}出库量");
                }
                //获取所有库存
                List<Dt_ProStockInfo> proStockInfos = _stockRepository.ProStockInfoRepository.Db.Queryable<Dt_ProStockInfo>().Where(b => b.LocationCode == "成品待发货区" && b.StockStatus == StockStatusEmun.平库入库完成.ObjToInt() && (b.ShipmentOrder == null || b.ShipmentOrder == "")).Includes(x => x.proStockInfoDetails).Where(x => x.proStockInfoDetails.Any(v => v.ProductCode == proOutOrderDetail.PCode)).ToList();
                //获取已完成数量
                int OverCount = proOutOrder.Details.Where(x => x.ProOrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt()).Count();
                List<Dt_ProStockInfo> outStockInfos=new List<Dt_ProStockInfo>();
                List<Dt_ProStockInfoDetail> outStockInfoDetails=new List<Dt_ProStockInfoDetail>();
                List<StockOutItemsItem> stockOutItems = new List<StockOutItemsItem>();
                foreach (var item in proStockViews.OrderBy(x => x.SumStocks))
                {
                    //获取当前库存
                    Dt_ProStockInfo? proStockInfo = proStockInfos.FirstOrDefault(x => x.Id == item.ProStockId);
                    if (proStockInfo!=null && proStockInfo.proStockInfoDetails.Count>0)
                    {
                        proStockInfo.ShipmentOrder = proOutOrder.ProOutOrderNo;
                        proStockInfo.StockStatus = StockStatusEmun.平库待发货.ObjToInt();
                        //剩余数量
                        float Amount = proOutOrderDetail.QtyPcs - proOutOrderDetail.LockQtyPcs;
                        if (Amount > item.SumStocks)
                        {
                            proOutOrderDetail.LockQtyPcs += item.SumStocks;
                            Dt_ProStockInfoDetail proStockInfoDetail = proStockInfo.proStockInfoDetails.FirstOrDefault();
                            
                            proStockInfoDetail.OutboundQuantity = proStockInfoDetail.StockPcsQty;
                            proStockInfoDetail.OutSETQty = proStockInfoDetail.SETQty;
                            proStockInfoDetail.OutDetailSaleNo = proOutOrderDetail.SaleOrder;
                            outStockInfoDetails.Add(proStockInfoDetail);
                        }
                        else
                        {
                            Dt_ProStockInfoDetail proStockInfoDetail = proStockInfo.proStockInfoDetails.FirstOrDefault();
                            float intervalSet = proStockInfoDetail.StockPcsQty / proStockInfoDetail.SETQty;
                            proStockInfoDetail.OutboundQuantity += Amount;
                            proStockInfoDetail.OutSETQty += (Amount / intervalSet);
                            proOutOrderDetail.LockQtyPcs += Amount;
                            proStockInfoDetail.OutDetailSaleNo = proOutOrderDetail.SaleOrder;
                            outStockInfoDetails.Add(proStockInfoDetail);
                        }
                        if (proOutOrderDetail.QtyPcs==proOutOrderDetail.LockQtyPcs)
                        {
                            proOutOrderDetail.ProOrderDetailStatus = OrderDetailStatusEnum.Over.ObjToInt();
                        }
                        outStockInfos.Add(proStockInfo);
                    }
                    else
                    {
                        return content.Error("未找到成品库存");
                    }
                }
                List<Dt_ProStockInfo> deleteStocks=new List<Dt_ProStockInfo>();
                List<Dt_ProStockInfoDetail> deleteStockDetails = new List<Dt_ProStockInfoDetail>();
                List<Dt_ProStockInfo> updateStocks = new List<Dt_ProStockInfo>();
                List<Dt_ProStockInfoDetail> updateStockDetails = new List<Dt_ProStockInfoDetail>();
                if (proOutOrderDetail.ProOrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt() && (OverCount+1)== proOutOrder.Details.Count)
                {
                    proOutOrder.ProOrderStatus=OutOrderStatusEnum.出库完成.ObjToInt();
                    //获取所有已扫码待发货的库存
                    List<Dt_ProStockInfo> AllOutStocks = _stockRepository.ProStockInfoRepository.Db.Queryable<Dt_ProStockInfo>()
                    .Where(x => x.ShipmentOrder == proOutOrder.ProOutOrderNo && x.StockStatus == StockStatusEmun.平库待发货.ObjToInt())
                    .Includes(x => x.proStockInfoDetails).ToList();
                    AllOutStocks.ForEach(x =>
                    {
                        outStockInfoDetails.AddRange(x.proStockInfoDetails);
                    });
                    outStockInfos.AddRange(AllOutStocks);
                    foreach (var item in outStockInfoDetails)
                    {
                        StockOutItemsItem outItemsItem = new StockOutItemsItem()
                        {
                            PartNum = item.ProductCode,
                            Rev = item.ProductVersion,
                            SoNumber = item.OutDetailSaleNo,
                            BatchNumber = item.BagNo,
                            QtyPcs = item.OutboundQuantity,
                            QtySet = item.OutSETQty
                        };
                        stockOutItems.Add(outItemsItem);
                        if (item.OutboundQuantity == item.StockPcsQty)
                        {
                            Dt_ProStockInfo proStockInfo = outStockInfos.FirstOrDefault(x => x.Id == item.ProStockId);
                            if (proStockInfo != null)
                            {
                                deleteStocks.Add(proStockInfo);
                                deleteStockDetails.Add(item);
                            }
                            else
                            {
                                return content.Error("未找到上报的库存数据");
                            }
                        }
                        if (item.OutboundQuantity < item.StockPcsQty)
                        {
                            Dt_ProStockInfo proStockInfo = outStockInfos.FirstOrDefault(x => x.Id == item.ProStockId);
                            if (proStockInfo != null)
                            {
                                proStockInfo.StockStatus = StockStatusEmun.平库入库完成.ObjToInt();
                                proStockInfo.ShipmentOrder = "";
                                updateStocks.Add(proStockInfo);
                                item.StockPcsQty -= item.OutboundQuantity;
                                item.OutboundQuantity = 0;
                                item.OutSETQty = 0;
                                updateStockDetails.Add(item);
                            }
                            else
                            {
                                return content.Error("未找到上报的库存数据");
                            }
                        }
                    }
                }
                Dt_Warehouse warehouse = _basicRepository.WarehouseRepository.QueryFirst(x => x.WarehouseId == proOutOrder.WarehouseId);
                _unitOfWorkManage.BeginTran();
                if (proOutOrder.ProOrderStatus == OutOrderStatusEnum.出库完成.ObjToInt())
                {
                    //成品库存记录变动待加入
                    ERPProOutOrderModel proOutOrderModel = new ERPProOutOrderModel()
                    {
                        Way = 1,
                        StockOutCode = _outboundService.OutboundOrderService.CreateCodeByRule(nameof(RuleCodeEnum.ProOutCOdeRule)),
                        ConfirmedUserNo = App.User.UserName,
                        AssignUserNo = App.User.UserName,
                        WarehouseCode = warehouse.WarehouseCode,
                        ShipDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
                        DeliverplanCode = proOutOrder.ProOutOrderNo,
                        Remark = proOutOrder.Remark,
                        StockOutItems = stockOutItems
                    };
                    _stockRepository.ProStockInfoRepository.DeleteAndMoveIntoHty(deleteStocks, OperateTypeEnum.自动完成);
                    _stockRepository.ProStockInfoDetailRepository.DeleteAndMoveIntoHty(deleteStockDetails, OperateTypeEnum.自动完成);
                    if (updateStockDetails.Count>0)
                    {
                        _stockRepository.ProStockInfoRepository.UpdateData(updateStocks);
                        updateStockDetails.ForEach(x =>
                        {
                            x.OutDetailSaleNo = "";
                        });
                        _stockRepository.ProStockInfoDetailRepository.UpdateData(updateStockDetails);
                    }
                    string response = _invokeERPService.InvokeProOutApi(proOutOrderModel);
                    ErpRequestContent erpRequestContent = response.DeserializeObject<ErpRequestContent>();
                    if (erpRequestContent.res != 1)
                    {
                        throw new Exception("同步ERP失败,错误信息:" + erpRequestContent.Data);
                    }
                }
                else
                {
                    _stockRepository.ProStockInfoRepository.UpdateData(outStockInfos);
                    _stockRepository.ProStockInfoDetailRepository.UpdateData(outStockInfoDetails);
                    _outboundRepository.ProOutOrderDetailRepository.UpdateData(proOutOrderDetail);
                    _outboundRepository.ProOutOrderRepository.UpdateData(proOutOrder);
                }
                _unitOfWorkManage.CommitTran();
                content.OK("成功");
            }
            catch (Exception ex)
            {
                _unitOfWorkManage.RollbackTran();
                content.Error(ex.Message);
            }
            return content;
        }
        /// <summary>
        /// å¤„理出库数据
        /// </summary>
@@ -146,6 +344,13 @@
            {
                _unitOfWorkManage.BeginTran();

                //获取成品出库单主表
                Dt_ProOutOrder proOutOrder = _outboundRepository.ProOutOrderRepository.QueryFirst(x => x.Id == proOutOrderDetails.FirstOrDefault().ProOrderId);
                if (proOutOrder!=null && proOutOrder.ProOrderStatus == OutOrderStatusEnum.未开始.ObjToInt())
                {
                    proOutOrder.ProOrderStatus = OutOrderStatusEnum.出库中.ObjToInt();
                    _outboundRepository.ProOutOrderRepository.UpdateData(proOutOrder);
                }
                BaseDal.AddData(tasks);
                if (proStockInfos != null && proStockInfos.Count > 0 && proOutOrderDetails != null && proOutOrderDetails.Count > 0 && outProStockInfos != null && outProStockInfos.Count > 0 && locationInfos != null && locationInfos.Count > 0)
                {
@@ -163,13 +368,6 @@
                }
                else if (proOutOrderDetails != null && proOutOrderDetails.Count > 0)
                {
                    //获取成品出库单主表
                    Dt_ProOutOrder proOutOrder = _outboundRepository.ProOutOrderRepository.QueryFirst(x => x.Id == proOutOrderDetails.FirstOrDefault().ProOrderId);
                    if (proOutOrder.ProOrderStatus == OutOrderStatusEnum.未开始.ObjToInt())
                    {
                        proOutOrder.ProOrderStatus = OutOrderStatusEnum.出库中.ObjToInt();
                        _outboundRepository.ProOutOrderRepository.UpdateData(proOutOrder);
                    }
                    proOutOrderDetails.ForEach(x =>
                    {
                        x.ProOrderDetailStatus = OrderDetailStatusEnum.Outbound.ObjToInt();
@@ -224,7 +422,9 @@
                {
                    x.Status = OutLockStockStatusEnum.出库中.ObjToInt();
                });

                string groupId = DateTime.Now.ToString("yyyyMMddHHmmss");
                tasks.ForEach(x => x.OrderNo = proOutOrder.ProOutOrderNo);
                tasks.ForEach(x => x.GroupId = groupId);
                proStockInfos = result.Item1;
                proOutOrderDetails = result.Item2;
                outProStockInfos = result.Item3;