From ed3a236c4ec7f79c9d94b241d3520fcaf1bf2708 Mon Sep 17 00:00:00 2001 From: wangxinhui <wangxinhui@hnkhzn.com> Date: 星期三, 15 一月 2025 10:10:22 +0800 Subject: [PATCH] 1 --- 代码管理/WMS/WIDESEA_WMSServer/WIDESEA_OutboundService/OutboundOrderService.cs | 252 +++++++++++++++++++++++++++++++++++-------------- 1 files changed, 179 insertions(+), 73 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 ba1c64e..e3deb6c 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" @@ -3,6 +3,7 @@ using Newtonsoft.Json; using Newtonsoft.Json.Serialization; using OfficeOpenXml.FormulaParsing.Excel.Functions.DateTime; +using SqlSugar; using System; using System.Collections.Generic; using System.Linq; @@ -16,8 +17,10 @@ using WIDESEA_Core.BaseRepository; using WIDESEA_Core.BaseServices; using WIDESEA_Core.CodeConfigEnum; +using WIDESEA_Core.DB; using WIDESEA_Core.Enums; using WIDESEA_Core.Helper; +using WIDESEA_Core.Seed; using WIDESEA_Core.Utilities; using WIDESEA_DTO.Basic; using WIDESEA_DTO.ERP; @@ -82,11 +85,11 @@ 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); + dt_ReceiveOrders = Db.Queryable<Dt_OutboundOrder>().Where(x => x.OrderStatus < OutLockStockStatusEnum.鍑哄簱瀹屾垚.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).ToPageList(pageNo, 5); + 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); } content.OK(data: dt_ReceiveOrders); @@ -201,38 +204,8 @@ _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); + if (outboundOrder.OrderStatus == OutOrderStatusEnum.鍑哄簱瀹屾垚.ObjToInt()) + _invokeERPService.InvokeOutStandardsApi(GetERPIssueModel(outboundOrder, warehouse.WarehouseCode)); #endregion content.OK(); } @@ -242,6 +215,59 @@ content.Error(ex.Message); } return content; + } + public ERPIssueModel GetERPIssueModel(Dt_OutboundOrder outboundOrder, string WarehouseCode) + { + ERPIssueModel issueModel = new ERPIssueModel(); + try + { + List<Dt_OutStockLockInfo> stockLockInfos = _outStockLockInfoService.OutStockLockInfos(outboundOrder.OrderNo); + List<ERPPickModel> eRPPickModels = new List<ERPPickModel>(); + foreach (var item in stockLockInfos) + { + ERPPickItemModel pickItemModel = new ERPPickItemModel() + { + Lotno = item.BatchNo, + Qty = item.AssignQuantity.ObjToInt().ToString(), + Location = 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 } + }; + eRPPickModels.Add(pickModel); + } + ERPIssueItemModel issueItemModel = new ERPIssueItemModel() + { + Pickcode = outboundOrder.UpperOrderNo, + PickList = eRPPickModels + }; + string Createuser = ""; + if (!string.IsNullOrEmpty(App.User.UserName)) Createuser = App.User.UserName; + else Createuser = stockLockInfos.FirstOrDefault().Creater; + issueModel = new ERPIssueModel() + { + UniqueTag = outboundOrder.Id.ToString(), + Code = CreateCodeByRule(nameof(RuleCodeEnum.FLCodeRule)), + WarehouseCode = WarehouseCode, + Docremark = "", + Deptno = outboundOrder.DepartmentCode, + Deptname = outboundOrder.DepartmentName, + Createtime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), + Createuser = string.IsNullOrEmpty(Createuser) ? Createuser : "admin", + Issitem = new List<ERPIssueItemModel>() { issueItemModel }, + }; + } + catch (Exception ex) + { + throw new Exception(ex.Message); + } + return issueModel; } public WebResponseContent ReceiveOutOrder(ErpOutOrderDTO model) { @@ -309,7 +335,9 @@ WarehouseId = warehouse.WarehouseId, DepartmentCode = model.DepartmentCode, DepartmentName = model.DepartmentName, - Details = new List<Dt_OutboundOrderDetail> { outboundOrderDetail } + Details = new List<Dt_OutboundOrderDetail> { outboundOrderDetail }, + Remark = model.Node + }; Db.InsertNav(outboundOrder).Include(x => x.Details).ExecuteCommand(); } @@ -337,6 +365,7 @@ MaterielName = materielInfo.MaterielName, OrderDetailStatus = OrderDetailStatusEnum.New.ObjToInt(), OrderQuantity = model.Qty, + Unit = model.Unit, }; _outboundOrderDetailRepository.UpdateData(outboundOrderDetail); @@ -419,7 +448,7 @@ issueModel = new ERPIssueModel() { UniqueTag = id.ToString(), - Code = outboundOrder.OrderNo,//娴嬭瘯 + Code = CreateCodeByRule(nameof(RuleCodeEnum.FLCodeRule)),//娴嬭瘯 WarehouseCode = warehouse.WarehouseCode, Docremark = "", Deptno = outboundOrder.DepartmentCode, @@ -428,53 +457,67 @@ Createuser = outboundOrder.Creater, Issitem = new List<ERPIssueItemModel>() { issueItemModel }, }; + _invokeERPService.InvokeOutStandardsApi(issueModel); } else { - List<ERPPickModel> eRPPickModels = new List<ERPPickModel>(); - - //鑾峰彇鍑哄簱璇︽儏鍗� + #region MyRegion foreach (var item in outStockLockInfos) { - 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 = eRPPickModels - }; - issueModel = new ERPIssueModel() - { - UniqueTag = id.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 = outStockLockInfos.FirstOrDefault().Creater, - Issitem = new List<ERPIssueItemModel>() { issueItemModel }, - }; + #endregion + + #region MyRegion + //List<ERPPickModel> eRPPickModels = new List<ERPPickModel>(); + + ////鑾峰彇鍑哄簱璇︽儏鍗� + //foreach (var item in outStockLockInfos) + //{ + // 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 = eRPPickModels + //}; + //issueModel = new ERPIssueModel() + //{ + // UniqueTag = id.ToString(), + // Code = CreateCodeByRule(nameof(RuleCodeEnum.FLCodeRule)), + // WarehouseCode = warehouse.WarehouseCode, + // Docremark = "", + // Deptno = outboundOrder.DepartmentCode, + // Deptname = outboundOrder.DepartmentName, + // Createtime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), + // Createuser = outStockLockInfos.FirstOrDefault().Creater, + // Issitem = new List<ERPIssueItemModel>() { issueItemModel }, + //}; + #endregion } if (stockInfos.Count > 0) @@ -486,7 +529,11 @@ _outStockLockInfoService.Repository.UpdateData(_OutStockLockInfos); } //鍑哄簱瀹屾垚涓婃姤ERP 娴嬭瘯娉ㄩ噴 - _invokeERPService.InvokeOutStandardsApi(issueModel); + if (outboundOrder.OrderStatus == OutOrderStatusEnum.鍑哄簱瀹屾垚.ObjToInt()) + { + issueModel = GetERPIssueModel(outboundOrder, warehouse.WarehouseCode); + _invokeERPService.InvokeOutStandardsApi(issueModel); + } return WebResponseContent.Instance.OK(); } catch (Exception ex) @@ -494,6 +541,65 @@ return WebResponseContent.Instance.Error(ex.Message); } } + static object lock_code = new object(); + public string CreateCodeByRule(string ruleCode) + { + lock (lock_code) + { + + string code = string.Empty; + DateTime dateTime = DateTime.Now; + DateTime now = DateTime.Now; + try + { + if (string.IsNullOrEmpty(ruleCode)) + throw new ArgumentNullException(nameof(ruleCode)); + SqlSugarClient sugarClient = new SqlSugarClient(new ConnectionConfig + { + IsAutoCloseConnection = false, + DbType = DbType.SqlServer, + ConnectionString = DBContext.ConnectionString + }); + Dt_CodeRuleConfig codeRuleConfig = sugarClient.Queryable<Dt_CodeRuleConfig>().Where(x => x.RuleCode == ruleCode).First(); + if (codeRuleConfig == null) + throw new ArgumentNullException(nameof(codeRuleConfig)); + if (codeRuleConfig.ModifyDate != null) + { + dateTime = Convert.ToDateTime(codeRuleConfig.ModifyDate); + } + else + { + dateTime = Convert.ToDateTime(codeRuleConfig.CreateDate); + } + + if (now.Year == dateTime.Year && now.Month == dateTime.Month && now.Day == dateTime.Day) + { + now = dateTime; + codeRuleConfig.CurrentVal = Convert.ToInt32(codeRuleConfig.CurrentVal) + 1; + } + else + { + codeRuleConfig.CurrentVal = 1; + } + codeRuleConfig.ModifyDate = DateTime.Now; + code = codeRuleConfig.Format; + code = code.Replace($"[{CodeFormatTypeEnum.YYYY}]", now.Year.ToString().PadLeft(4, '0')); + code = code.Replace($"[{CodeFormatTypeEnum.MM}]", now.Month.ToString().PadLeft(2, '0')); + code = code.Replace($"[{CodeFormatTypeEnum.DD}]", now.Day.ToString().PadLeft(2, '0')); + code = code.Replace($"[{CodeFormatTypeEnum.ST}]", codeRuleConfig.StartStr?.ToString() ?? ""); + code = code.Replace($"[{CodeFormatTypeEnum.NUM}]", codeRuleConfig.CurrentVal.ToString().PadLeft(codeRuleConfig.Length, '0')); + Dictionary<string, object> keyValuePairs = new Dictionary<string, object>() { { nameof(codeRuleConfig.CurrentVal), codeRuleConfig.CurrentVal }, { nameof(codeRuleConfig.Id), codeRuleConfig.Id }, { nameof(codeRuleConfig.ModifyDate), DateTime.Now } }; + sugarClient.Updateable(keyValuePairs).AS(MainDb.CodeRuleConfig).WhereColumns(nameof(codeRuleConfig.Id)).ExecuteCommand(); + sugarClient.Updateable(codeRuleConfig); + + } + catch (Exception ex) + { + + } + return code; + } + } /// <summary> /// 鏇存敼鍑哄簱鍗曞簱瀛樼姸鎬� /// </summary> -- Gitblit v1.9.3