From 95e39ae7aecd6e1016c71cf5ae70a680d8f569bb Mon Sep 17 00:00:00 2001 From: wangxinhui <wangxinhui@hnkhzn.com> Date: 星期二, 29 四月 2025 10:48:30 +0800 Subject: [PATCH] 上传最新代码 --- 代码管理/WMS/WIDESEA_WMSServer/WIDESEA_OutboundService/OutboundOrderService.cs | 124 ++++++++++++++++++++++++++++++++-------- 1 files changed, 98 insertions(+), 26 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 8cb1176..9a7f842 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" @@ -88,17 +88,17 @@ 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>(); + List<Dt_OutboundOrder> _OutboundOrders = new List<Dt_OutboundOrder>(); if (string.IsNullOrEmpty(orderNo)) { - dt_ReceiveOrders = Db.Queryable<Dt_OutboundOrder>().Where(x => x.OrderStatus < OutLockStockStatusEnum.鍑哄簱瀹屾垚.ObjToInt() && x.WarehouseId == warehouseId).OrderByDescending(x => x.CreateDate).ToPageList(pageNo, 5); + _OutboundOrders = Db.Queryable<Dt_OutboundOrder>().Where(x => x.OrderStatus < OutOrderStatusEnum.鍑哄簱瀹屾垚.ObjToInt() && x.WarehouseId == warehouseId).OrderByDescending(x => x.CreateDate).ToPageList(pageNo, 5); } else { - dt_ReceiveOrders = Db.Queryable<Dt_OutboundOrder>().Where(x => (x.OrderNo.Contains(orderNo)) && x.OrderStatus < OutLockStockStatusEnum.鍑哄簱瀹屾垚.ObjToInt() && x.WarehouseId == warehouseId).OrderByDescending(x => x.CreateDate).ToPageList(pageNo, 5); + _OutboundOrders = Db.Queryable<Dt_OutboundOrder>().Where(x => (x.OrderNo.Contains(orderNo)) && x.OrderStatus < OutOrderStatusEnum.鍑哄簱瀹屾垚.ObjToInt() && x.WarehouseId == warehouseId).OrderByDescending(x => x.CreateDate).ToPageList(pageNo, 5); } - content.OK(data: dt_ReceiveOrders); + content.OK(data: _OutboundOrders); } catch (Exception ex) { @@ -210,7 +210,8 @@ _unitOfWorkManage.CommitTran(); #region 鍑哄簱瀹屾垚涓婃姤ERP - if (outboundOrder.OrderStatus == OutOrderStatusEnum.鍑哄簱瀹屾垚.ObjToInt()) + //鐢熶骇棰嗘枡,鐮斿彂棰嗘枡锛屾爣鍑嗛鏂欙紝鎺ㄩ�丒RP鍑哄簱 + if (outboundOrder.OrderStatus == OutOrderStatusEnum.鍑哄簱瀹屾垚.ObjToInt() && outboundOrder.OrderType==OutOrderTypeEnum.Issue.ObjToInt()) _invokeERPService.InvokeOutStandardsApi(GetERPIssueModel(outboundOrder, warehouse.WarehouseCode)); #endregion content.OK(); @@ -234,7 +235,7 @@ ERPPickItemModel pickItemModel = new ERPPickItemModel() { Lotno = item.BatchNo, - Qty = item.AssignQuantity.ObjToInt().ToString(), + Qty = item.AssignQuantity.ToString(), Location = WarehouseCode }; //鑾峰彇鍑哄簱鍗曟槑缁� @@ -265,9 +266,12 @@ Deptno = outboundOrder.DepartmentCode, Deptname = outboundOrder.DepartmentName, Createtime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), - Createuser = string.IsNullOrEmpty(Createuser) ? Createuser : "admin", + Createuser = Createuser, Issitem = new List<ERPIssueItemModel>() { issueItemModel }, }; + //鏇存柊鍙戞枡鍗曞彿 + outboundOrder.UpFLOrderNo = issueModel.Code; + BaseDal.UpdateData(outboundOrder); } catch (Exception ex) { @@ -279,19 +283,21 @@ { try { + Dt_OutboundOrder oldOutboundOrder = BaseDal.Db.Queryable<Dt_OutboundOrder>().Where(x => x.UpperOrderNo == model.OrderNo && x.OrderStatus < OutOrderStatusEnum.鍏抽棴.ObjToInt()).Includes(x => x.Details).OrderBy(x => x.CreateDate).First(); Dt_MaterielInfo materielInfo = _basicService.MaterielInfoService.Repository.QueryFirst(x => x.MaterielCode == model.MCode); + if (materielInfo == null) { + DelOutOrder(oldOutboundOrder); return WebResponseContent.Instance.Error($"鏈壘鍒拌鐗╂枡淇℃伅"); } Dt_Warehouse warehouse = _basicService.WarehouseService.Repository.QueryFirst(x => x.WarehouseCode == model.WaId); if (warehouse == null) { + DelOutOrder(oldOutboundOrder); return WebResponseContent.Instance.Error($"鏈壘鍒拌浠撳簱淇℃伅"); } - - Dt_OutboundOrder oldOutboundOrder = BaseDal.Db.Queryable<Dt_OutboundOrder>().Where(x => x.UpperOrderNo == model.OrderNo).Includes(x => x.Details).First(); if (model.Way == 1) { @@ -299,10 +305,12 @@ { if (oldOutboundOrder.Details.FirstOrDefault(x => x.RowNo == Convert.ToInt32(model.RowNo)) != null) { + DelOutOrder(oldOutboundOrder); return WebResponseContent.Instance.Error($"璇ユ槑缁嗚鍙峰凡瀛樺湪"); } if (oldOutboundOrder.WarehouseId != warehouse.WarehouseId) { + DelOutOrder(oldOutboundOrder); return WebResponseContent.Instance.Error($"浠撳簱涓嶄竴鑷�"); } else @@ -313,6 +321,7 @@ BatchNo = model.MLot, MaterielCode = model.MCode, MaterielName = materielInfo.MaterielName, + MaterielSpec=materielInfo.MaterielSpec, OrderDetailStatus = OrderDetailStatusEnum.New.ObjToInt(), OrderQuantity = model.Qty, OrderId = oldOutboundOrder.Id @@ -327,6 +336,7 @@ RowNo = Convert.ToInt32(model.RowNo), BatchNo = model.MLot, MaterielCode = model.MCode, + MaterielSpec = materielInfo.MaterielSpec, MaterielName = materielInfo.MaterielName, OrderDetailStatus = OrderDetailStatusEnum.New.ObjToInt(), OrderQuantity = model.Qty, @@ -343,7 +353,16 @@ DepartmentName = model.DepartmentName, Details = new List<Dt_OutboundOrderDetail> { outboundOrderDetail }, Remark = model.Node - + }; + outboundOrder.OrderType = model.OType switch + { + 1 or 2 or 3=> OutOrderTypeEnum.Issue.ObjToInt(), + 4=>OutOrderTypeEnum.Quality.ObjToInt(), + 5=>OutOrderTypeEnum.Allocate.ObjToInt(), + 6=>OutOrderTypeEnum.MaintenanceIssue.ObjToInt(), + 7=>OutOrderTypeEnum.SaleOut.ObjToInt(), + 8=>OutOrderTypeEnum.Rework.ObjToInt(), + _=>0 }; Db.InsertNav(outboundOrder).Include(x => x.Details).ExecuteCommand(); } @@ -368,6 +387,7 @@ RowNo = Convert.ToInt32(model.RowNo), BatchNo = model.MLot, MaterielCode = model.MCode, + MaterielSpec = materielInfo.MaterielSpec, MaterielName = materielInfo.MaterielName, OrderDetailStatus = OrderDetailStatusEnum.New.ObjToInt(), OrderQuantity = model.Qty, @@ -382,6 +402,10 @@ { return WebResponseContent.Instance.Error($"鏈壘鍒拌鍑哄簱鍗�"); } + _unitOfWorkManage.BeginTran(); + BaseDal.DeleteData(oldOutboundOrder); + _outboundOrderDetailRepository.DeleteData(oldOutboundOrder.Details); + _unitOfWorkManage.CommitTran(); } return WebResponseContent.Instance.OK(); @@ -390,6 +414,28 @@ { _unitOfWorkManage.RollbackTran(); return WebResponseContent.Instance.Error(ex.Message); + } + } + /// <summary> + /// 璇ュ崟鎹け璐ヨ繘琛屽垹闄� + /// </summary> + /// <returns></returns> + public void DelOutOrder(Dt_OutboundOrder outboundOrder) + { + try + { + if (outboundOrder != null && outboundOrder.Details.Count > 0) + { + _unitOfWorkManage.BeginTran(); + _outboundOrderRepository.DeleteAndMoveIntoHty(outboundOrder, OperateTypeEnum.鑷姩鍒犻櫎); + _outboundOrderDetailRepository.DeleteAndMoveIntoHty(outboundOrder.Details, OperateTypeEnum.鑷姩鍒犻櫎); + _unitOfWorkManage.CommitTran(); + } + } + catch (Exception ex) + { + _unitOfWorkManage.RollbackTran(); + throw new Exception(ex.Message); } } //涓婃姤鍑哄簱瀹屾垚 @@ -454,7 +500,7 @@ issueModel = new ERPIssueModel() { UniqueTag = id.ToString(), - Code = CreateCodeByRule(nameof(RuleCodeEnum.FLCodeRule)),//娴嬭瘯 + Code = CreateCodeByRule(nameof(RuleCodeEnum.FLCodeRule)), WarehouseCode = warehouse.WarehouseCode, Docremark = "", Deptno = outboundOrder.DepartmentCode, @@ -463,6 +509,9 @@ Createuser = outboundOrder.Creater, Issitem = new List<ERPIssueItemModel>() { issueItemModel }, }; + //鏇存柊鍙戞枡鍗曞彿 + outboundOrder.UpFLOrderNo = issueModel.Code; + BaseDal.UpdateData(outboundOrder); _invokeERPService.InvokeOutStandardsApi(issueModel); } else @@ -524,21 +573,20 @@ // Issitem = new List<ERPIssueItemModel>() { issueItemModel }, //}; #endregion - } - - if (stockInfos.Count > 0) - { - _stockService.StockInfoService.Repository.UpdateData(stockInfos); - } - else - { - _outStockLockInfoService.Repository.UpdateData(_OutStockLockInfos); - } - //鍑哄簱瀹屾垚涓婃姤ERP 娴嬭瘯娉ㄩ噴 - if (outboundOrder.OrderStatus == OutOrderStatusEnum.鍑哄簱瀹屾垚.ObjToInt()) - { - issueModel = GetERPIssueModel(outboundOrder, warehouse.WarehouseCode); - _invokeERPService.InvokeOutStandardsApi(issueModel); + if (stockInfos.Count > 0) + { + _stockService.StockInfoService.Repository.UpdateData(stockInfos); + } + else + { + _outStockLockInfoService.Repository.UpdateData(_OutStockLockInfos); + } + //鍑哄簱瀹屾垚涓婃姤ERP 娴嬭瘯娉ㄩ噴 + if (outboundOrder.OrderStatus == OutOrderStatusEnum.鍑哄簱瀹屾垚.ObjToInt()) + { + issueModel = GetERPIssueModel(outboundOrder, warehouse.WarehouseCode); + _invokeERPService.InvokeOutStandardsApi(issueModel); + } } return WebResponseContent.Instance.OK(); } @@ -665,5 +713,29 @@ } return content; } + public WebResponseContent OutUpOrderGetFLOrder() + { + WebResponseContent content = new WebResponseContent(); + try + { + //鑾峰彇鍑哄簱鍗� + List<Dt_OutboundOrder> outboundOrders = BaseDal.QueryData(x => x.OrderStatus == OutOrderStatusEnum.鍑哄簱瀹屾垚.ObjToInt() && x.UpFLOrderNo == null); + List<Sys_Log> logs = BaseDal.Db.Queryable<Sys_Log>().Where(x => x.RequestParam.Contains("棰嗘枡鍑哄簱閫氱煡鍗�") && x.Id > 14606).ToList(); + foreach (var item in outboundOrders) + { + Sys_Log? log = logs.FirstOrDefault(x=>x.RequestParam.Contains(item.UpperOrderNo)); + if (log == null) { continue; } + ERPBaseModel <ERPIssueModel> baseModel= log.RequestParam.DeserializeObject<ERPBaseModel<ERPIssueModel>>(); + item.UpFLOrderNo = baseModel.Data.Code; + } + BaseDal.UpdateData(outboundOrders); + content.OK(); + } + catch (Exception ex) + { + content.Error(ex.Message); + } + return content; + } } } -- Gitblit v1.9.3