From 5ab6b36c0c4bd80a31dcdd9f15cc835b7352c4e7 Mon Sep 17 00:00:00 2001
From: wangxinhui <wangxinhui@hnkhzn.com>
Date: 星期四, 16 一月 2025 11:08:02 +0800
Subject: [PATCH] 1

---
 代码管理/WMS/WIDESEA_WMSServer/WIDESEA_InboundService/InboundOrderService.cs |  144 ++++++++++++++++++++++++++++++++---------------
 1 files changed, 97 insertions(+), 47 deletions(-)

diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_InboundService/InboundOrderService.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_InboundService/InboundOrderService.cs"
index 8a57f20..b7ab61d 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_InboundService/InboundOrderService.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_InboundService/InboundOrderService.cs"
@@ -18,8 +18,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;
 using WIDESEA_DTO.Basic;
@@ -370,6 +372,7 @@
                         EffectiveDate = model.EffectiveDate,
                         InboundOrderRowNo = notGroupDetail.RowNo,
                     };
+                    oldCount++;
 
                     if (stockInfo.Id > 0)
                     {
@@ -385,8 +388,7 @@
                 }
 
                 //鍏ュ簱鏄庣粏鏂板瀹屾垚鏁伴噺
-                int newCount = inboundOrderDetails.Where(x => x.OrderDetailStatus == OrderDetailStatusEnum.Over.ObjToInt()).ToList().Count;
-                if (inboundOrder.Details.Count == (newCount + oldCount))
+                if (inboundOrder.Details.Count == oldCount)
                 {
                     inboundOrder.OrderStatus = InOrderStatusEnum.鍏ュ簱瀹屾垚.ObjToInt();
                 }
@@ -408,39 +410,9 @@
                 _recordService.StockQuantityChangeRecordService.AddStockChangeRecord(stockInfo, stockInfoDetails, beforeQuantity, totalQuantity, StockChangeTypeEnum.Inbound);
                 _unitOfWorkManage.CommitTran();
 
-                #region 涓婃姤ERP鍏ュ簱瀹屾垚
-                List<ERPInboundDetailModel> detailModels = new List<ERPInboundDetailModel>();
-                foreach (var item in stockInfo.Details)
-                {
-                    ERPInboundDetailModel detailModel = new ERPInboundDetailModel()
-                    {
-                        ExpiryDate = item.EffectiveDate ?? "",
-                        LocationCode = warehouse.WarehouseCode,
-                        MaterialsCode = item.MaterielCode,
-                        MfgDate = item.ProductionDate ?? "",
-                        QtyCustoms = "0",
-                        Quantity = item.StockQuantity.ToString(),
-                        Rack = stockInfo.LocationCode,
-                        ReceiptCode = inboundOrder.UpperOrderNo,
-                        ReceiptSerNo = item.InboundOrderRowNo.ToString()
-                    };
-                    detailModels.Add(detailModel);
-                }
-                ERPInboundModel eRPInboundModel = new ERPInboundModel()
-                {
-                    Code = inboundOrder.InboundOrderNo,
-                    CreatorCode = inboundOrder.Creater,
-                    EntDate = inboundOrder.CreateDate.ToString("yyyy-MM-dd HH:mm:ss"),
-                    StockDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
-                    SuppliersId = inboundOrder.SupplierId,
-                    Type = "S",
-                    UniqueTag = inboundOrder.Id.ToString(),
-                    WarehouseCode = warehouse.WarehouseCode,
-                    Way = 1,
-                    Details = detailModels
-                };
-                //鎺ㄩ�丒RP 娴嬭瘯娉ㄩ噴
-                _invokeERPService.InvokeInboundOrderApi(eRPInboundModel);
+                #region 鍏ュ簱瀹屾垚涓婃姤ERP
+                if (inboundOrder.OrderStatus == InOrderStatusEnum.鍏ュ簱瀹屾垚.ObjToInt())
+                    FeedbackInboundOrder(inboundOrder);
                 #endregion
                 content.OK();
             }
@@ -509,7 +481,7 @@
                     return WebResponseContent.Instance.Error($"鏈壘鍒拌鐗╂枡鐨勪俊鎭�");
                 }
 
-                List<Dt_InboundOrderDetail> inboundOrderDetails = inboundOrder.Details.Where(x => x.MaterielCode == materielCode).ToList();
+                List<Dt_InboundOrderDetail> inboundOrderDetails = inboundOrder.Details.Where(x => x.MaterielCode == materielCode && x.BatchNo == (models.FirstOrDefault()?.LotNo ?? "")).ToList();
 
                 if (inboundOrderDetails == null || inboundOrderDetails.Count <= 0)
                 {
@@ -530,7 +502,7 @@
                         PalletCode = palletCode,
                         StockStatus = StockStatusEmun.缁勭洏鏆傚瓨.ObjToInt(),
                         WarehouseId = inboundOrder.WarehouseId,
-                        PalletType = GetPalletType(warehouse, palletCode, materielInfo),
+                        PalletType = GetPalletType(warehouse, palletCode),
                         Details = new List<Dt_StockInfoDetail>()
                     };
                 }
@@ -674,7 +646,7 @@
                         PalletCode = palletCode,
                         StockStatus = StockStatusEmun.鎵嬪姩缁勭洏鏆傚瓨.ObjToInt(),
                         WarehouseId = warehouse.WarehouseId,
-                        PalletType = GetPalletType(warehouse, palletCode, materielInfo),
+                        PalletType = GetPalletType(warehouse, palletCode),
                         Details = new List<Dt_StockInfoDetail>()
                     };
                 }
@@ -765,7 +737,7 @@
         /// 鍏ュ簱瀹屾垚涓婃姤ERP
         /// </summary>
         /// <returns></returns>
-        public WebResponseContent FeedbackInboundOrder(Dt_StockInfo stockInfo, Dt_InboundOrder inboundOrder, List<ERPInboundDetailModel> detailModels)
+        public WebResponseContent FeedbackInboundOrder(Dt_InboundOrder inboundOrder)
         {
             WebResponseContent content = new WebResponseContent();
             try
@@ -774,20 +746,39 @@
                 {
                     return WebResponseContent.Instance.Error($"鏈壘鍒板叆搴撳崟鏄庣粏淇℃伅");
                 }
-                if (inboundOrder.OrderStatus == InOrderStatusEnum.鍏ュ簱瀹屾垚.ObjToInt())
+
+                List<Dt_StockInfoDetail> stockInfoDetails = _stockRepository.StockInfoDetailRepository.QueryData(x => x.OrderNo == inboundOrder.InboundOrderNo);
+                if (stockInfoDetails.Count == 0)
                 {
-                    return WebResponseContent.Instance.Error($"鍏ュ簱鍗曟嵁宸插畬鎴�");
+                    return WebResponseContent.Instance.Error($"鏈壘鍒板簱瀛樻槑缁嗕俊鎭�");
                 }
-                Dt_Warehouse warehouse = _warehouseService.Repository.QueryFirst(x => x.WarehouseId == stockInfo.WarehouseId);
+                List<Dt_StockInfo> stockInfos = _stockRepository.StockInfoRepository.QueryData(x => stockInfoDetails.Select(x => x.StockId).ToList().Contains(x.Id));
+                Dt_Warehouse warehouse = _warehouseService.Repository.QueryFirst(x => x.WarehouseId == inboundOrder.WarehouseId);
                 if (warehouse == null)
                 {
                     return WebResponseContent.Instance.Error($"鏈壘鍒颁粨搴撲俊鎭�");
                 }
-
+                List<ERPInboundDetailModel>? detailModels = new List<ERPInboundDetailModel>();
+                foreach (var item in stockInfoDetails)
+                {
+                    ERPInboundDetailModel detailModel = new ERPInboundDetailModel()
+                    {
+                        ExpiryDate = item.EffectiveDate ?? "",
+                        LocationCode = warehouse.WarehouseCode,
+                        MaterialsCode = item.MaterielCode,
+                        MfgDate = item.ProductionDate ?? "",
+                        QtyCustoms = "0",
+                        Quantity = item.StockQuantity.ToString(),
+                        Rack = stockInfos.FirstOrDefault(x => x.Id == item.StockId).LocationCode,
+                        ReceiptCode = inboundOrder.UpperOrderNo,
+                        ReceiptSerNo = item.InboundOrderRowNo.ToString()
+                    };
+                    detailModels.Add(detailModel);
+                }
                 ERPInboundModel model = new ERPInboundModel()
                 {
-                    Code = inboundOrder.InboundOrderNo,
-                    CreatorCode = inboundOrder.Creater,//娴嬭瘯
+                    Code = CreateCodeByRule(nameof(RuleCodeEnum.RLCodeRule)),
+                    CreatorCode = inboundOrder.Creater,
                     EntDate = inboundOrder.CreateDate.ToString("yyyy-MM-dd HH:mm:ss"),
                     StockDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
                     SuppliersId = inboundOrder.SupplierId,
@@ -797,7 +788,7 @@
                     Way = 1,
                     Details = detailModels
                 };
-                //鎺ㄩ�丒RP 娴嬭瘯娉ㄩ噴
+                //鎺ㄩ�丒RP
                 _invokeERPService.InvokeInboundOrderApi(model);
                 return WebResponseContent.Instance.OK();
             }
@@ -807,6 +798,65 @@
                 content.Error(ex.Message);
             }
             return content;
+        }
+        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>
@@ -892,7 +942,7 @@
         //    }
         //}
 
-        public int GetPalletType(Dt_Warehouse warehouse, string palletCode, Dt_MaterielInfo materielInfo)
+        public int GetPalletType(Dt_Warehouse warehouse, string palletCode)
         {
             if (warehouse.WarehouseCode == WarehouseEnum.HA64.ToString())
             {

--
Gitblit v1.9.3