From 5335e892470760a25db793d249c94d8aa32e8b0b Mon Sep 17 00:00:00 2001
From: pan <antony1029@163.com>
Date: 星期二, 09 十二月 2025 13:44:46 +0800
Subject: [PATCH] Merge branch 'master' of http://115.159.85.185:8098/r/ZhongRui/ALDbanyunxiangmu

---
 项目代码/WMS无仓储版/WIDESEA_WMSServer/WIDESEA_InboundService/InboundOrderService.cs |  149 +++++++++++++++++++++++++++++++++++++++----------
 1 files changed, 119 insertions(+), 30 deletions(-)

diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS\346\227\240\344\273\223\345\202\250\347\211\210/WIDESEA_WMSServer/WIDESEA_InboundService/InboundOrderService.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS\346\227\240\344\273\223\345\202\250\347\211\210/WIDESEA_WMSServer/WIDESEA_InboundService/InboundOrderService.cs"
index 0b6f7fa..ccbb4de 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS\346\227\240\344\273\223\345\202\250\347\211\210/WIDESEA_WMSServer/WIDESEA_InboundService/InboundOrderService.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS\346\227\240\344\273\223\345\202\250\347\211\210/WIDESEA_WMSServer/WIDESEA_InboundService/InboundOrderService.cs"
@@ -1,6 +1,7 @@
 锘縰sing AutoMapper;
 using SqlSugar;
 using System.Dynamic;
+using System.Text.RegularExpressions;
 using System.Threading.Tasks;
 using WIDESEA_Common.CommonEnum;
 using WIDESEA_Common.OrderEnum;
@@ -646,53 +647,141 @@
             }
         }
 
-        public WebResponseContent UndoPalletGroup(string palletCode)
+        public WebResponseContent UndoPalletGroup(string palletCode, string barcode = "")
         {
+            
             if (string.IsNullOrWhiteSpace(palletCode))
             {
                 return WebResponseContent.Instance.Error("鎵樼洏鍙蜂笉鑳戒负绌�");
             }
-            var stock = _stockRepository.Db.Queryable<Dt_StockInfo>().Includes(o => o.Details).First(x => x.PalletCode == palletCode && x.StockStatus == (int)StockStatusEmun.缁勭洏鏆傚瓨);
-            if (stock == null)
-            {
-                return WebResponseContent.Instance.Error($"鏈壘鍒版墭鐩樺彿{palletCode}瀵瑰簲鐨勫簱瀛樿褰�");
-            }
 
-            if (stock.Details == null || !stock.Details.Any())
+            
+            try
             {
+                _unitOfWorkManage.BeginTran(); 
+
+                // 2. 鏌ヨ鎵樼洏搴撳瓨涓昏褰曪紙閬垮厤鏃犳暟鎹姏寮傚父锛�
+                var stock = _stockRepository.Db.Queryable<Dt_StockInfo>()
+                    .Includes(o => o.Details)
+                    .First(x => x.PalletCode == palletCode
+                                         && (x.StockStatus == (int)StockStatusEmun.缁勭洏鏆傚瓨
+                                             || x.StockStatus == StockStatusEmun.鍏ュ簱纭.ObjToInt()));
+
+                if (stock == null)
+                {
+                    return WebResponseContent.Instance.Error($"鏈壘鍒版墭鐩樺彿{palletCode}瀵瑰簲鐨勫簱瀛樿褰�");
+                }
+
+                // 3. 鍦烘櫙1锛氬垹闄ゆ寚瀹氭潯鐮�
+                if (!string.IsNullOrWhiteSpace(barcode))
+                {
+                    var targetDetail = stock.Details?.FirstOrDefault(x => x.Barcode == barcode);
+                    if (targetDetail == null)
+                    {
+                        _unitOfWorkManage.RollbackTran();
+                        return WebResponseContent.Instance.Error($"鎵樼洏{palletCode}涓嬫湭鎵惧埌鏉$爜{barcode}鐨勬槑缁嗚褰�");
+                    }
+
+                    ResetInboundOrderStatus(new List<string> { targetDetail.OrderNo},new List<string> { targetDetail.Barcode});
+                    // 鍒犻櫎鎸囧畾鏄庣粏
+                    _stockDetailRepository.DeleteData(targetDetail);
+
+
+                    // 閲嶆柊鏌ヨ鍓╀綑鏄庣粏锛堜繚璇佹暟鎹噯纭�э級
+                    var remainingDetails = _stockDetailRepository.Db.Queryable<Dt_StockInfoDetail>()
+                        .Where(x => x.StockId == stock.Id)
+                        .ToList();
+
+                    // 鍓╀綑鏄庣粏涓虹┖ 鈫� 鍒犻櫎涓昏〃 + 閲嶇疆鍏ュ簱鍗曞強鏄庣粏鐘舵��
+                    if (!remainingDetails.Any())
+                    {
+                        // 閲嶇疆鍏ュ簱鍗曞強鏄庣粏鐘舵��
+                        ResetInboundOrderStatus(stock.Details.Select(d => d.OrderNo).Distinct().ToList());
+
+                        _stockRepository.DeleteData(stock);
+                        _unitOfWorkManage.CommitTran();
+                        return WebResponseContent.Instance.OK($"鏉$爜{barcode}鎾ら攢鎴愬姛锛屾墭鐩樻棤鍓╀綑鏄庣粏锛屽凡鍒犻櫎鎵樼洏骞堕噸缃叧鑱斿叆搴撳崟鐘舵��");
+                    }
+
+                    _unitOfWorkManage.CommitTran();
+                    return WebResponseContent.Instance.OK($"鏉$爜{barcode}鎾ら攢鎴愬姛锛屾墭鐩樹粛鏈夊墿浣欐槑缁�");
+                }
+
+                // 鍒犻櫎鏁存墭鐩橈紙鏃犳潯鐮佷紶鍏ワ級
+                if (stock.Details == null || !stock.Details.Any())
+                {
+                    _stockRepository.DeleteData(stock);
+                    _unitOfWorkManage.CommitTran();
+                    return WebResponseContent.Instance.OK("鎵樼洏鏃犳槑缁嗚褰曪紝宸茬洿鎺ュ垹闄ゆ墭鐩樹富鏁版嵁");
+                }
+
+                // 鏈夋槑缁� 鈫� 閲嶇疆鍏ュ簱鍗曞強鏄庣粏鐘舵�� + 鍒犻櫎搴撳瓨
+                var relatedOrderNos = stock.Details.Select(d => d.OrderNo).Distinct().ToList();
+                if (!relatedOrderNos.Any())
+                {
+                    _unitOfWorkManage.RollbackTran();
+                    return WebResponseContent.Instance.Error("搴撳瓨鏄庣粏鏈叧鑱斾换浣曞叆搴撳崟鍙凤紝鏃犳硶瀹屾垚鎾ら攢");
+                }
+
+                // 閲嶇疆鍏ュ簱鍗曚富鐘舵�� + 鏄庣粏鐘舵��
+                ResetInboundOrderStatus(relatedOrderNos, stock.Details.Select(d => d.Barcode).ToList());
+
+                // 4.3 鍒犻櫎搴撳瓨鏄庣粏鍜屼富琛�
+                _stockDetailRepository.DeleteData(stock.Details);
                 _stockRepository.DeleteData(stock);
-                return WebResponseContent.Instance.OK();
+
+                _unitOfWorkManage.CommitTran();
+                return WebResponseContent.Instance.OK("鎵樼洏鎾ら攢鎴愬姛锛屽凡閲嶇疆鍏宠仈鍏ュ簱鍗曞強鏄庣粏鐘舵��");
             }
-            //  鑾峰彇搴撳瓨璇︽儏鍏宠仈鐨勬墍鏈夊叆搴撳崟鍙�
-            var relatedOrderNos = stock.Details.Select(d => d.OrderNo).First();
-            //  鏌ヨ鎵�鏈夊叧鑱旂殑鍏ュ簱鍗曪紙鍚鎯咃級
-            var inboundOrders = _inboundOrderRepository.Db.Queryable<Dt_InboundOrder>()
-                .Includes(x => x.Details)
-                .Where(x => relatedOrderNos == x.InboundOrderNo)
-                .First();
-
-            var barcodes = stock.Details.Select(d => d.Barcode).ToList();
-
-            // 鍖归厤搴撳瓨鏉$爜瀵瑰簲鐨勫叆搴撳崟鏄庣粏
-            var matchedInboundDetails = inboundOrders.Details
-                ?.Where(d => barcodes.Contains(d.Barcode))
-                .ToList();
-            foreach (var detail in matchedInboundDetails)
+            catch (Exception ex)
             {
-                detail.ReceiptQuantity = 0;
-                detail.OrderDetailStatus = 0;
-                _inboundOrderDetailRepository.UpdateData(detail);
+                _unitOfWorkManage.RollbackTran(); 
+                return WebResponseContent.Instance.Error($"鎵樼洏鎾ら攢澶辫触锛歿ex.Message}");
             }
-            _stockDetailRepository.DeleteData(stock.Details);
-            _stockRepository.DeleteData(stock);
+        }
 
 
-            return WebResponseContent.Instance.OK("鎵樼洏鎾ら攢鎴愬姛");
+        private void ResetInboundOrderStatus(List<string> orderNos, List<string> barcodes = null)
+        {
+            foreach (var orderNo in orderNos)
+            {
+                var inboundOrder = _inboundOrderRepository.Db.Queryable<Dt_InboundOrder>()
+                    .Includes(x => x.Details)
+                    .First(x => x.InboundOrderNo == orderNo);
+
+                if (inboundOrder == null) continue;
+
+                bool isSingleBarcode = barcodes != null && barcodes.Count == 1;
+                if (!isSingleBarcode)
+                {
+                    // 闈炲崟涓潯鐮侊紙鏁村崟/澶氫釜鏉$爜锛夛細閲嶇疆涓昏〃鐘舵�佷负0
+                    inboundOrder.OrderStatus = 0;
+                    _inboundOrderRepository.UpdateData(inboundOrder);
+                }
+
+                // 閲嶇疆鍏ュ簱鍗曟槑缁嗙姸鎬�
+                if (inboundOrder.Details == null || !inboundOrder.Details.Any()) continue;
+
+                var targetDetails = barcodes == null
+                    ? inboundOrder.Details.ToList() // 涓嶄紶鏉$爜鍒欓噸缃暣鍗曟槑缁�
+                    : inboundOrder.Details.Where(d => barcodes.Contains(d.Barcode)).ToList();
+
+                foreach (var detail in targetDetails)
+                {
+                    detail.ReceiptQuantity = 0;
+                    detail.OrderDetailStatus = 0;
+                    _inboundOrderDetailRepository.UpdateData(detail);
+                }
+            }
         }
 
         public override PageGridData<Dt_InboundOrder> GetPageData(PageDataOptions options)
         {
             string wheres = ValidatePageOptions(options);
+
+            string pattern = @"inboundOrderNo like '[^']+'\s*and\s*";
+            wheres = Regex.Replace(wheres, pattern, "", RegexOptions.IgnoreCase);
+
             //鑾峰彇鎺掑簭瀛楁
             Dictionary<string, SqlSugar.OrderByType> orderbyDic = GetPageDataSort(options, TProperties);
             List<OrderByModel> orderByModels = new List<OrderByModel>();
@@ -712,7 +801,7 @@
             if (!string.IsNullOrEmpty(options.Wheres))
             {
                 try
-                {
+                {                  
                     searchParametersList = options.Wheres.DeserializeObject<List<SearchParameters>>();
                     if (searchParametersList.Count > 0)
                     {

--
Gitblit v1.9.3