From 9e6b28f0b0c29523d0dd11d0a01a53af5f1ada33 Mon Sep 17 00:00:00 2001 From: dengjunjie <dengjunjie@hnkhzn.com> Date: 星期六, 11 一月 2025 21:32:35 +0800 Subject: [PATCH] 添加PDA平库出库 --- 代码管理/WMS/WIDESEA_WMSServer/WIDESEA_OutboundService/OutboundOrderService.cs | 165 ++++++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 157 insertions(+), 8 deletions(-) diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_OutboundService/OutboundOrderService.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_OutboundService/OutboundOrderService.cs" index 483ba11..47d3b97 100644 --- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_OutboundService/OutboundOrderService.cs" +++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_OutboundService/OutboundOrderService.cs" @@ -15,9 +15,11 @@ using WIDESEA_Core; using WIDESEA_Core.BaseRepository; using WIDESEA_Core.BaseServices; +using WIDESEA_Core.CodeConfigEnum; using WIDESEA_Core.Enums; using WIDESEA_Core.Helper; using WIDESEA_Core.Utilities; +using WIDESEA_DTO.Basic; using WIDESEA_DTO.ERP; using WIDESEA_DTO.Inbound; using WIDESEA_DTO.Outbound; @@ -38,23 +40,20 @@ private readonly IUnitOfWorkManage _unitOfWorkManage; private readonly IBasicService _basicService; private readonly IOutboundOrderDetailRepository _outboundOrderDetailRepository; - private readonly IStockInfoService _stockInfoService; - private readonly IStockInfoRepository _stockInfoRepository; + private readonly IStockService _stockService; public IOutboundOrderRepository Repository => BaseDal; private readonly IInvokeERPService _invokeERPService; private readonly IOutStockLockInfoService _outStockLockInfoService; private readonly IOutboundOrderRepository _outboundOrderRepository; - public OutboundOrderService(IOutboundOrderRepository BaseDal, IMapper mapper, IUnitOfWorkManage unitOfWorkManage, IBasicService basicService, IOutboundOrderDetailRepository outboundOrderDetailRepository, IStockInfoService stockInfoService, - IStockInfoRepository stockInfoRepository, IInvokeERPService invokeERPService, IOutStockLockInfoService outStockLockInfoService, + public OutboundOrderService(IOutboundOrderRepository BaseDal, IMapper mapper, IUnitOfWorkManage unitOfWorkManage, IBasicService basicService, IOutboundOrderDetailRepository outboundOrderDetailRepository, IStockService stockService, IInvokeERPService invokeERPService, IOutStockLockInfoService outStockLockInfoService, IOutboundOrderRepository outboundOrderRepository) : base(BaseDal) { _mapper = mapper; _unitOfWorkManage = unitOfWorkManage; _basicService = basicService; _outboundOrderDetailRepository = outboundOrderDetailRepository; - _stockInfoService = stockInfoService; - _stockInfoRepository = stockInfoRepository; + _stockService = stockService; _invokeERPService = invokeERPService; _outStockLockInfoService = outStockLockInfoService; _outboundOrderRepository = outboundOrderRepository; @@ -72,6 +71,11 @@ saveModel.DetailData[0].Add("orderDetailStatus", OrderDetailStatusEnum.New.ObjToInt()); return base.AddData(saveModel); } + /// <summary> + /// 鑾峰彇鍑哄簱鍗曚俊鎭� + /// </summary> + /// <param name="saveModel"></param> + /// <returns></returns> public WebResponseContent GetOutboundOrders(SaveModel saveModel) { WebResponseContent content = new WebResponseContent(); @@ -98,6 +102,151 @@ } return content; } + + public WebResponseContent outpinku(SaveModel saveModel) + { + WebResponseContent content = new WebResponseContent(); + try + { + var orderNo = saveModel.MainData["orderNo"].ToString(); + var warehouseId = saveModel.MainData["warehouseId"].ObjToInt(); + var serNum = saveModel.MainData["sn"].ToString(); + Dt_Warehouse warehouse = _basicService.WarehouseService.Repository.QueryFirst(x => x.WarehouseId == warehouseId); + if (warehouse == null) + { + return WebResponseContent.Instance.Error($"鏈壘鍒拌浠撳簱淇℃伅"); + } + + Dt_OutboundOrder outboundOrder = BaseDal.Db.Queryable<Dt_OutboundOrder>().Where(x => x.OrderNo == orderNo && x.WarehouseId == warehouse.WarehouseId).Includes(x => x.Details).First(); + if (outboundOrder == null) + { + return WebResponseContent.Instance.Error($"鏈壘鍒板嚭搴撳崟淇℃伅"); + } + if (outboundOrder.Details == null || outboundOrder.Details.Count <= 0) + { + return WebResponseContent.Instance.Error($"鏈壘鍒板嚭搴撳崟鏄庣粏淇℃伅"); + } + + MatSerNumAnalysisModel model = CodeAnalysisHelper.CodeAnalysis<MatSerNumAnalysisModel>(AnalysisCodeEnum.MatSerNumAnalysis, serNum); + Dt_MaterielInfo materielInfo = _basicService.MaterielInfoService.Repository.QueryFirst(x => x.MaterielCode == model.MaterielCode); + if (materielInfo == null) + { + return WebResponseContent.Instance.Error($"鏈壘鍒拌鐗╂枡鐨勪俊鎭�"); + } + if (materielInfo.WarehouseId != outboundOrder.WarehouseId) + { + return WebResponseContent.Instance.Error($"璇ョ墿鏂欎笉灞炰簬鏈粨"); + } + + Dt_OutboundOrderDetail outboundOrderDetail = outboundOrder.Details.FirstOrDefault(x => x.MaterielCode == model.MaterielCode); + if (outboundOrderDetail == null) return WebResponseContent.Instance.Error($"璇ョ墿鏂欎笉灞炰簬鏈嚭搴撳崟"); + if (outboundOrderDetail.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt()) + return WebResponseContent.Instance.Error($"鏈嚭搴撳崟褰撳墠鐗╂枡宸插嚭搴撳畬鎴�"); + + if (outboundOrderDetail.OrderQuantity - outboundOrderDetail.OverOutQuantity < model.Quantity) + return WebResponseContent.Instance.Error($"鍑哄簱鏁伴噺瓒呭嚭鍑哄簱鍗�"); + + Dt_StockInfoDetail stockInfoDetail = _stockService.StockInfoDetailService.Repository.QueryFirst(x => x.MaterielCode == model.MaterielCode && x.BatchNo == model.LotNo); + + if (stockInfoDetail == null) return WebResponseContent.Instance.Error($"鏈壘鍒板簱瀛�"); + if (stockInfoDetail.StockQuantity < model.Quantity) return WebResponseContent.Instance.Error($"搴撳瓨涓嶈冻"); + Dt_StockInfo stockInfo = _stockService.StockInfoService.Repository.QueryFirst(x => x.Id == stockInfoDetail.StockId); + if (stockInfo == null) return WebResponseContent.Instance.Error($"鏈壘鍒板簱瀛樹富琛�"); + if (stockInfo.LocationCode != "骞冲簱浣�") return WebResponseContent.Instance.Error($"搴撳瓨涓嶅睘浜庡钩搴撲綅"); + + Dt_OutStockLockInfo outStockLockInfo = new Dt_OutStockLockInfo() + { + PalletCode = stockInfo.PalletCode, + AssignQuantity = model.Quantity, + MaterielCode = model.MaterielCode, + BatchNo = model.LotNo, + LocationCode = stockInfo.LocationCode, + MaterielName = materielInfo.MaterielName, + OrderDetailId = outboundOrderDetail.Id, + OrderNo = outboundOrder.OrderNo, + OrderType = outboundOrder.OrderType, + OriginalQuantity = stockInfoDetail.StockQuantity, + Status = OutLockStockStatusEnum.鍑哄簱瀹屾垚.ObjToInt(), + StockId = stockInfo.Id, + TaskNum = 0, + OrderQuantity = outboundOrderDetail.OrderQuantity, + Unit = outboundOrderDetail.Unit + }; + + #region 淇敼鍑哄簱鍗� + outboundOrderDetail.OverOutQuantity += outStockLockInfo.AssignQuantity; + if (outboundOrderDetail.OrderQuantity > outboundOrderDetail.OverOutQuantity) + outboundOrderDetail.OrderDetailStatus = OrderDetailStatusEnum.Outbound.ObjToInt(); + else + outboundOrderDetail.OrderDetailStatus = OrderDetailStatusEnum.Over.ObjToInt(); + int overCount = outboundOrder.Details.Where(x => x.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt()).Count(); + if (outboundOrder.Details.Count == overCount) outboundOrder.OrderStatus = OutOrderStatusEnum.鍑哄簱瀹屾垚.ObjToInt(); + #endregion + + #region 淇敼搴撳瓨 + stockInfoDetail.StockQuantity -= stockInfoDetail.StockQuantity - outStockLockInfo.AssignQuantity; + #endregion + + + _unitOfWorkManage.BeginTran(); + _outStockLockInfoService.Repository.AddData(outStockLockInfo); + BaseDal.UpdateData(outboundOrder); + _outboundOrderDetailRepository.UpdateData(outboundOrderDetail); + if (stockInfoDetail.StockQuantity > 0) + { + _stockService.StockInfoDetailService.Repository.UpdateData(stockInfoDetail); + } + else + { + _stockService.StockInfoDetailService.Repository.DeleteData(stockInfoDetail); + if (stockInfo.Details.Count <= 1) _stockService.StockInfoService.Repository.DeleteData(stockInfo); + } + _unitOfWorkManage.CommitTran(); + + #region 鍑哄簱瀹屾垚涓婃姤ERP + ERPPickItemModel pickItemModel = new ERPPickItemModel() + { + Lotno = model.LotNo, + Qty = model.Quantity.ToString(), + Location = warehouse.WarehouseCode + }; + ERPPickModel pickModel = new ERPPickModel() + { + Rowindex = outboundOrderDetail.RowNo, + Material = outboundOrderDetail.MaterielCode, + Qty = pickItemModel.Qty, + Dataitem = new List<ERPPickItemModel> { pickItemModel } + }; + List<ERPPickModel> eRPPickModels = new List<ERPPickModel>() { pickModel }; + ERPIssueItemModel issueItemModel = new ERPIssueItemModel() + { + Pickcode = outboundOrder.UpperOrderNo, + PickList = eRPPickModels + }; + ERPIssueModel issueModel = new ERPIssueModel() + { + UniqueTag = outboundOrderDetail.OrderId.ToString(), + Code = outboundOrder.OrderNo, + WarehouseCode = warehouse.WarehouseCode, + Docremark = "", + Deptno = outboundOrder.DepartmentCode, + Deptname = outboundOrder.DepartmentName, + Createtime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), + Createuser = App.User.UserName, + Issitem = new List<ERPIssueItemModel>() { issueItemModel }, + }; + _invokeERPService.InvokeOutStandardsApi(issueModel); + #endregion + content.OK(); + } + catch (Exception ex) + { + _unitOfWorkManage.RollbackTran(); + content.Error(ex.Message); + } + return content; + } + public WebResponseContent ReceiveOutOrder(ErpOutOrderDTO model) { try @@ -329,7 +478,7 @@ if (stockInfos.Count > 0) { - _stockInfoRepository.UpdateData(stockInfos); + _stockService.StockInfoService.Repository.UpdateData(stockInfos); } else { @@ -355,7 +504,7 @@ try { //鑾峰彇鍑哄簱鍗曞簱瀛� - List<Dt_StockInfo> stockInfos = _stockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => x.WarehouseId == warehouse.WarehouseId).Includes(x => x.Details).ToList(); + List<Dt_StockInfo> stockInfos = _stockService.StockInfoService.Repository.Db.Queryable<Dt_StockInfo>().Where(x => x.WarehouseId == warehouse.WarehouseId).Includes(x => x.Details).ToList(); if (stockInfos.Count <= 0) { return WebResponseContent.Instance.Error($"搴撳瓨涓嶈冻"); -- Gitblit v1.9.3