From 55e2a6f351ebafbf2c95442f59699eb85cbdee5c Mon Sep 17 00:00:00 2001 From: dengjunjie <dengjunjie@hnkhzn.com> Date: 星期四, 16 一月 2025 10:30:17 +0800 Subject: [PATCH] Merge branch 'master' of http://115.159.85.185:8098/r/MeiRuiAn/HuaiAn --- 代码管理/WMS/WIDESEA_WMSServer/WIDESEA_OutboundService/OutboundOrderService.cs | 279 +++++++++++++++++++++++++++++++++++++++++-------------- 1 files changed, 208 insertions(+), 71 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 ddaeff6..0f3b2f5 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; @@ -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,12 +529,75 @@ _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) { 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> @@ -522,5 +628,36 @@ return WebResponseContent.Instance.Error(ex.Message); } } + /// <summary> + /// 鏍规嵁鍑哄簱鍗曟帹閫丒RP绯荤粺 + /// </summary> + /// <param name="outId"></param> + /// <param name="WarehouseCode"></param> + /// <returns></returns> + public WebResponseContent PushERPOutBound(int outId, string WarehouseCode) + { + WebResponseContent content=new WebResponseContent(); + try + { + //鑾峰彇鍑哄簱鍗� + Dt_OutboundOrder outboundOrder = Db.Queryable<Dt_OutboundOrder>().Where(x => x.Id == outId).Includes(x => x.Details).First(); + if (outboundOrder == null) + { + return content.Error("鍑哄簱鍗曚笉瀛樺湪"); + } + if (outboundOrder.Details.Count!=(outboundOrder.Details.Where(x=>x.OrderDetailStatus==OrderDetailStatusEnum.Over.ObjToInt()).ToList().Count)||outboundOrder.OrderStatus!=OutOrderStatusEnum.鍑哄簱瀹屾垚.ObjToInt()) + { + return content.Error("璇ュ嚭搴撳崟鏈畬鎴�"); + } + ERPIssueModel issueModel = GetERPIssueModel(outboundOrder, WarehouseCode); + string response=_invokeERPService.InvokeOutStandardsApi(issueModel); + return content.OK(response); + } + catch (Exception ex) + { + content.Error(ex.Message); + } + return content; + } } } -- Gitblit v1.9.3