From 5e39811c50a51a5b1c9af0f2f8dda4a21a28c677 Mon Sep 17 00:00:00 2001 From: dengjunjie <dengjunjie@hnkhzn.com> Date: 星期六, 11 一月 2025 14:52:57 +0800 Subject: [PATCH] 添加WMS和PDA平库出库功能 --- 代码管理/WMS/WIDESEA_WMSServer/WIDESEA_OutboundService/OutboundOrderService.cs | 150 ++++++++++++++++++++++++++++++++++++-------------- 1 files changed, 108 insertions(+), 42 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 213cd49..483ba11 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" @@ -43,9 +43,11 @@ 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) : base(BaseDal) + public OutboundOrderService(IOutboundOrderRepository BaseDal, IMapper mapper, IUnitOfWorkManage unitOfWorkManage, IBasicService basicService, IOutboundOrderDetailRepository outboundOrderDetailRepository, IStockInfoService stockInfoService, + IStockInfoRepository stockInfoRepository, IInvokeERPService invokeERPService, IOutStockLockInfoService outStockLockInfoService, + IOutboundOrderRepository outboundOrderRepository) : base(BaseDal) { _mapper = mapper; _unitOfWorkManage = unitOfWorkManage; @@ -55,8 +57,47 @@ _stockInfoRepository = stockInfoRepository; _invokeERPService = invokeERPService; _outStockLockInfoService = outStockLockInfoService; + _outboundOrderRepository = outboundOrderRepository; } + public override WebResponseContent AddData(SaveModel saveModel) + { + if (saveModel.MainData.TryGetValue(nameof(Dt_OutboundOrder.UpperOrderNo).FirstLetterToLower(), out object? upperOrderNo) && upperOrderNo != null && !string.IsNullOrEmpty(upperOrderNo.ToString())) + { + Dt_OutboundOrder outboundOrder = BaseDal.QueryFirst(x => x.UpperOrderNo == upperOrderNo.ToString() && x.WarehouseId == Convert.ToInt32(saveModel.MainData[nameof(Dt_OutboundOrder.WarehouseId).FirstLetterToLower()])); + if (outboundOrder != null) + { + return WebResponseContent.Instance.Error($"{upperOrderNo}棰嗘枡鍗曞彿宸插瓨鍦�"); + } + } + saveModel.DetailData[0].Add("orderDetailStatus", OrderDetailStatusEnum.New.ObjToInt()); + return base.AddData(saveModel); + } + public WebResponseContent GetOutboundOrders(SaveModel saveModel) + { + WebResponseContent content = new WebResponseContent(); + try + { + int pageNo = saveModel.MainData["pageNo"].ObjToInt(); + string? orderNo = saveModel.MainData["orderNo"].ToString(); + int warehouseId = saveModel.MainData["warehouseId"].ObjToInt(); + List<Dt_OutboundOrder> dt_ReceiveOrders = new List<Dt_OutboundOrder>(); + if (string.IsNullOrEmpty(orderNo)) + { + dt_ReceiveOrders = Db.Queryable<Dt_OutboundOrder>().Where(x => x.OrderStatus < OutLockStockStatusEnum.鍑哄簱瀹屾垚.ObjToInt() && x.WarehouseId == warehouseId).ToPageList(pageNo, 5); + } + else + { + dt_ReceiveOrders = Db.Queryable<Dt_OutboundOrder>().Where(x => (x.OrderNo.Contains(orderNo)) && x.OrderStatus < OutLockStockStatusEnum.鍑哄簱瀹屾垚.ObjToInt() && x.WarehouseId == warehouseId).ToPageList(pageNo, 5); + } + content.OK(data: dt_ReceiveOrders); + } + catch (Exception ex) + { + content.Error(ex.Message); + } + return content; + } public WebResponseContent ReceiveOutOrder(ErpOutOrderDTO model) { try @@ -112,10 +153,11 @@ MaterielName = materielInfo.MaterielName, OrderDetailStatus = OrderDetailStatusEnum.New.ObjToInt(), OrderQuantity = model.Qty, + Unit = materielInfo.MaterielUnit }; Dt_OutboundOrder outboundOrder = new Dt_OutboundOrder() { - OrderNo=model.OrderNo, + OrderNo = model.OrderNo, UpperOrderNo = model.OrderNo, OrderStatus = OutOrderStatusEnum.鏈紑濮�.ObjToInt(), OrderType = OutOrderTypeEnum.Issue.ObjToInt(), @@ -172,30 +214,45 @@ } } //涓婃姤鍑哄簱瀹屾垚 - public WebResponseContent TestOutUpload(int id,Dt_StockInfo stockInfo) + public WebResponseContent TestOutUpload(int id, List<Dt_OutStockLockInfo>? outStockLockInfos) { try { - Dt_OutboundOrder outboundOrder = Db.Queryable<Dt_OutboundOrder>().Where(x=>x.Id==id).Includes(x=>x.Details).First(); + Dt_OutboundOrder outboundOrder = Db.Queryable<Dt_OutboundOrder>().Where(x => x.Id == id).Includes(x => x.Details).First(); Dt_Warehouse warehouse = _basicService.WarehouseService.Repository.QueryFirst(x => x.WarehouseId == outboundOrder.WarehouseId); - //娴嬭瘯鏋跺簱缁橢RP涓婃姤鍑哄簱瀹屾垚 ERPIssueModel issueModel = new ERPIssueModel(); List<Dt_StockInfo> stockInfos = new List<Dt_StockInfo>(); - if (stockInfo==null) + List<Dt_OutStockLockInfo> _OutStockLockInfos = new List<Dt_OutStockLockInfo>(); + int overCount = outboundOrder.Details.Where(x => x.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt()).Count(); + if (outboundOrder.Details.Count == overCount) + { + outboundOrder.OrderStatus = OutOrderStatusEnum.鍑哄簱瀹屾垚.ObjToInt(); + _outboundOrderRepository.UpdateData(outboundOrder); + } + if (outboundOrder == null) + { + return WebResponseContent.Instance.Error("鍑哄簱鍗曚笉瀛樺湪"); + } + if (outboundOrder.CreateType == OrderCreateTypeEnum.CreateInSystem.ObjToInt()) + { + return WebResponseContent.Instance.OK(); + } + //娴嬭瘯鏋跺簱缁橢RP涓婃姤鍑哄簱瀹屾垚 + if (warehouse.WarehouseCode == WarehouseEnum.HA64.ToString()) { stockInfos = TestOutStocksUpdate(warehouse).Data as List<Dt_StockInfo> ?? new List<Dt_StockInfo>(); - List<ERPPickItemModel> eRPOutPick =new List<ERPPickItemModel>(); + List<ERPPickItemModel> eRPOutPick = new List<ERPPickItemModel>(); for (int i = 0; i < stockInfos.Count; i++) { ERPPickItemModel pickItemModel = new ERPPickItemModel() { - Lotno= stockInfos[i].Details[0].BatchNo, - Qty= stockInfos[i].Details[0].StockQuantity.ObjToInt().ToString(), - Location= warehouse.WarehouseCode + Lotno = stockInfos[i].Details[0].BatchNo, + Qty = stockInfos[i].Details[0].StockQuantity.ObjToInt().ToString(), + Location = warehouse.WarehouseCode }; eRPOutPick.Add(pickItemModel); } - + ERPPickModel pickModel = new ERPPickModel() { Rowindex = outboundOrder.Details[0].RowNo, @@ -212,66 +269,75 @@ issueModel = new ERPIssueModel() { UniqueTag = id.ToString(), - Code = "OT" + DateTime.Now.ToString("yyyyMMddHHmmss"),//娴嬭瘯 + Code = outboundOrder.OrderNo,//娴嬭瘯 WarehouseCode = warehouse.WarehouseCode, Docremark = "", Deptno = outboundOrder.DepartmentCode, Deptname = outboundOrder.DepartmentName, Createtime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), - Createuser = "TC20082", + Createuser = outboundOrder.Creater, Issitem = new List<ERPIssueItemModel>() { issueItemModel }, }; } else { - Dt_OutboundOrderDetail orderDetail = outboundOrder.Details.FirstOrDefault(x => x.MaterielCode == stockInfo.Details[0].MaterielCode); - - ERPPickItemModel pickItemModel = new ERPPickItemModel() + List<ERPPickModel> eRPPickModels = new List<ERPPickModel>(); + + //鑾峰彇鍑哄簱璇︽儏鍗� + foreach (var item in outStockLockInfos) { - Lotno = stockInfo.Details[0].BatchNo, - Qty = stockInfo.Details[0].StockQuantity.ObjToInt().ToString(), - Location = stockInfo.LocationCode - }; - ERPPickModel pickModel = new ERPPickModel() - { - Rowindex = outboundOrder.Details[0].RowNo, - Material = outboundOrder.Details[0].MaterielCode, - Qty = (outboundOrder.Details[0].OrderQuantity.ObjToInt()).ToString(), - Dataitem = new List<ERPPickItemModel> { pickItemModel } - }; + ERPPickItemModel pickItemModel = new ERPPickItemModel() + { + Lotno = item.BatchNo, + Qty = item.AssignQuantity.ObjToInt().ToString(), + Location = warehouse.WarehouseCode + }; + //鑾峰彇鍑哄簱鍗曟槑缁� + Dt_OutboundOrderDetail outboundOrderDetail = outboundOrder.Details.FirstOrDefault(x => x.Id == item.OrderDetailId); + ERPPickModel pickModel = new ERPPickModel() + { + Rowindex = outboundOrderDetail.RowNo, + Material = outboundOrderDetail.MaterielCode, + Qty = pickItemModel.Qty, + Dataitem = new List<ERPPickItemModel> { pickItemModel } + }; + if (item.OrderQuantity == item.AssignQuantity) + { + item.Status = OutLockStockStatusEnum.鍑哄簱瀹屾垚.ObjToInt(); + } + eRPPickModels.Add(pickModel); + _OutStockLockInfos.Add(item); + } ERPIssueItemModel issueItemModel = new ERPIssueItemModel() { Pickcode = outboundOrder.UpperOrderNo, - PickList = new List<ERPPickModel>() { pickModel } + PickList = eRPPickModels }; issueModel = new ERPIssueModel() { UniqueTag = id.ToString(), - Code = "OT" + DateTime.Now.ToString("yyyyMMddHHmmss"),//娴嬭瘯 + Code = outboundOrder.OrderNo,//娴嬭瘯 WarehouseCode = warehouse.WarehouseCode, Docremark = "", Deptno = outboundOrder.DepartmentCode, Deptname = outboundOrder.DepartmentName, Createtime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), - Createuser = "TC20082", + Createuser = outStockLockInfos.FirstOrDefault().Creater, Issitem = new List<ERPIssueItemModel>() { issueItemModel }, }; } - - string response = _invokeERPService.InvokeOutStandardsApi(issueModel); - ErpRequestContent requestContent = response.DeserializeObject<ErpRequestContent>(); - if (requestContent.res == 1) + + if (stockInfos.Count > 0) { - if (stockInfos.Count>0) - { - _stockInfoRepository.UpdateData(stockInfos); - } - return WebResponseContent.Instance.OK(requestContent.Data); + _stockInfoRepository.UpdateData(stockInfos); } else { - return WebResponseContent.Instance.Error(requestContent.Data); + _outStockLockInfoService.Repository.UpdateData(_OutStockLockInfos); } + //鍑哄簱瀹屾垚涓婃姤ERP 娴嬭瘯娉ㄩ噴 + _invokeERPService.InvokeOutStandardsApi(issueModel); + return WebResponseContent.Instance.OK(); } catch (Exception ex) { @@ -290,7 +356,7 @@ { //鑾峰彇鍑哄簱鍗曞簱瀛� List<Dt_StockInfo> stockInfos = _stockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => x.WarehouseId == warehouse.WarehouseId).Includes(x => x.Details).ToList(); - if (stockInfos.Count<=0) + if (stockInfos.Count <= 0) { return WebResponseContent.Instance.Error($"搴撳瓨涓嶈冻"); } -- Gitblit v1.9.3