From 503608c5ad94cbc5ccff0f8806e2d5fa54143875 Mon Sep 17 00:00:00 2001
From: pan <antony1029@163.com>
Date: 星期四, 11 十二月 2025 11:24:47 +0800
Subject: [PATCH] 提交

---
 项目代码/WMS无仓储版/WIDESEA_WMSServer/WIDESEA_OutboundService/SplitPackageService.cs |  322 ++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 256 insertions(+), 66 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_OutboundService/SplitPackageService.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_OutboundService/SplitPackageService.cs"
index 7635616..33d0e13 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_OutboundService/SplitPackageService.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_OutboundService/SplitPackageService.cs"
@@ -1,5 +1,7 @@
 锘縰sing Microsoft.AspNetCore.Http;
+using Microsoft.Extensions.Logging;
 using Org.BouncyCastle.Asn1.Ocsp;
+using SqlSugar.Extensions;
 using System;
 using System.Collections.Generic;
 using System.Linq;
@@ -9,11 +11,13 @@
 using WIDESEA_Core;
 using WIDESEA_Core.BaseRepository;
 using WIDESEA_Core.BaseServices;
+using WIDESEA_DTO.Basic;
 using WIDESEA_DTO.Outbound;
 using WIDESEA_IBasicService;
 using WIDESEA_IOutboundService;
 using WIDESEA_IStockService;
 using WIDESEA_Model.Models;
+using WIDESEA_Model.Models.Basic;
 
 namespace WIDESEA_OutboundService
 {
@@ -26,19 +30,21 @@
         private readonly IStockInfoDetailService _stockInfoDetailService;
         private readonly IOutStockLockInfoService _outStockLockInfoService;
         private readonly IDailySequenceService _dailySequenceService;
-
-        public SplitPackageService(IRepository<Dt_SplitPackageRecord> BaseDal, IUnitOfWorkManage unitOfWorkManage, IStockInfoService stockInfoService, IOutStockLockInfoService outStockLockInfoService, IStockInfoDetailService stockInfoDetailService, IDailySequenceService dailySequenceService) : base(BaseDal)
+        private readonly IInvokeMESService _invokeMESService;
+        private readonly IMaterielToMesService _materielToMesService;
+        private readonly ILogger<SplitPackageService> _logger;
+        public SplitPackageService(IRepository<Dt_SplitPackageRecord> BaseDal, IUnitOfWorkManage unitOfWorkManage, IStockInfoService stockInfoService, IOutStockLockInfoService outStockLockInfoService, IStockInfoDetailService stockInfoDetailService, IDailySequenceService dailySequenceService, IInvokeMESService invokeMESService, ILogger<SplitPackageService> logger, IMaterielToMesService materielToMesService) : base(BaseDal)
         {
             _unitOfWorkManage = unitOfWorkManage;
             _stockInfoService = stockInfoService;
             _outStockLockInfoService = outStockLockInfoService;
             _stockInfoDetailService = stockInfoDetailService;
             _dailySequenceService = dailySequenceService;
+            _invokeMESService = invokeMESService;
+            _logger = logger;
+            _materielToMesService = materielToMesService;
         }
 
-        /// <summary>
-        /// 鎷嗗寘鎷嗙鎿嶄綔
-        /// </summary>
         public async Task<WebResponseContent> SplitPackage(SplitPackageDto request)
         {
             try
@@ -57,82 +63,106 @@
                     return WebResponseContent.Instance.Error("鏈壘鍒版湁鏁堢殑鍑哄簱閿佸畾淇℃伅");
 
                 // 2. 妫�鏌ュ墿浣欓攣瀹氭暟閲�
-                decimal remainingLockQuantity = lockInfo.AssignQuantity - lockInfo.PickedQty;
+                decimal remainingLockQuantity = lockInfo.OriginalQuantity - lockInfo.PickedQty;
                 if (request.SplitQuantity > remainingLockQuantity)
                     return WebResponseContent.Instance.Error($"鎷嗗寘鏁伴噺涓嶈兘澶т簬鍓╀綑閿佸畾鏁伴噺锛屽墿浣欙細{remainingLockQuantity}");
 
-                var stockDetail = await _stockInfoDetailService.Db.Queryable<Dt_StockInfoDetail>()
-               .Where(x => x.Barcode == request.OriginalBarcode && x.StockId == lockInfo.StockId)
-               .FirstAsync();
-                if (stockDetail == null)
+                // 3. 鏌ユ壘褰撳墠鏉$爜鐨勫簱瀛樹俊鎭�
+                var baseStockDetail = await _stockInfoDetailService.Db.Queryable<Dt_StockInfoDetail>()
+                    .Where(x => x.Barcode == request.OriginalBarcode && x.StockId == lockInfo.StockId)
+                    .FirstAsync();
+
+                if (baseStockDetail == null)
                     throw new Exception($"鏈壘鍒版潯鐮亄request.OriginalBarcode}瀵瑰簲鐨勫簱瀛樿褰�");
 
+                // 4. 璁板綍鎷嗗寘鍓嶇殑搴撳瓨鏁伴噺鍜岄攣瀹氫俊鎭�
+                decimal stockBeforeSplit = baseStockDetail.StockQuantity;
+                decimal assignBeforeSplit = lockInfo.AssignQuantity;
+
+                // 5. 璁$畻鎷嗗垎鍚庣殑鍓╀綑鏁伴噺
+                decimal remainingQty = baseStockDetail.StockQuantity - request.SplitQuantity;
+
+                // 鏇存柊鍩虹鏉$爜鐨勫簱瀛樻暟閲忎负鍓╀綑鏁伴噺
+                baseStockDetail.StockQuantity = remainingQty;
+                baseStockDetail.OutboundQuantity = remainingQty;
+                await _stockInfoDetailService.Db.Updateable(baseStockDetail).ExecuteCommandAsync();
+
+                // 6. 鐢熸垚鏂版潯鐮�
                 var seq = await _dailySequenceService.GetNextSequenceAsync();
-                // 3. 鐢熸垚鏂版潯鐮�
                 string newBarcode = "WSLOT" + DateTime.Now.ToString("yyyyMMdd") + seq.ToString()?.PadLeft(5, '0');
 
-                decimal remainingQty = remainingLockQuantity - request.SplitQuantity;
-
-                // 涓烘媶鍖呬骇鐢熺殑鏂版潯鐮佸垱寤哄簱瀛樿褰�
+                // 7. 涓烘柊鏉$爜鍒涘缓搴撳瓨璁板綍锛堟媶鍒嗗嚭鐨勬暟閲忥級
                 var newStockDetail = new Dt_StockInfoDetail
-                {                    
+                {
+                    SupplyCode = baseStockDetail.SupplyCode,
+                    WarehouseCode = baseStockDetail.WarehouseCode,
+                    BarcodeQty = baseStockDetail.BarcodeQty,
+                    BarcodeUnit = baseStockDetail.BarcodeUnit,
+                    BusinessType = baseStockDetail.BusinessType,
+                    Unit = baseStockDetail.Unit,
                     StockId = lockInfo.StockId,
-                    MaterielCode = lockInfo.MaterielCode,
-                    OrderNo = lockInfo.OrderNo,
-                    BatchNo = lockInfo.BatchNo,
-                    StockQuantity = remainingQty,
-                    OutboundQuantity = remainingQty, // 閿佸畾鍏ㄩ儴鏁伴噺
+                    MaterielCode = baseStockDetail.MaterielCode,
+                    OrderNo = baseStockDetail.OrderNo,
+                    BatchNo = baseStockDetail.BatchNo,
+                    StockQuantity = request.SplitQuantity,
+                    OutboundQuantity = request.SplitQuantity,
                     Barcode = newBarcode,
-                    InboundOrderRowNo = stockDetail.InboundOrderRowNo,
-                  
+                    InboundOrderRowNo = baseStockDetail.InboundOrderRowNo,
+                    FactoryArea = baseStockDetail.FactoryArea,
                 };
-                await _outStockLockInfoService.Db.Insertable(newStockDetail).ExecuteCommandAsync();
+                await _stockInfoDetailService.Db.Insertable(newStockDetail).ExecuteCommandAsync();
 
-                // 4. 鍒涘缓鏂扮殑鍑哄簱閿佸畾淇℃伅锛堟柊鏉$爜锛�
+                // 8. 鍒涘缓鏂扮殑鍑哄簱閿佸畾淇℃伅锛堟柊鏉$爜锛�
                 var newLockInfo = new Dt_OutStockLockInfo
                 {
-                    
                     OrderNo = lockInfo.OrderNo,
                     OrderDetailId = lockInfo.OrderDetailId,
                     BatchNo = lockInfo.BatchNo,
                     MaterielCode = lockInfo.MaterielCode,
                     MaterielName = lockInfo.MaterielName,
                     StockId = lockInfo.StockId,
-                    OrderQuantity = remainingQty,
-                    OriginalQuantity = remainingQty,
-                    AssignQuantity = remainingQty, // 鏂版潯鐮佸垎閰嶆暟閲�
-                    PickedQty = 0, // 鏂版潯鐮佹湭鎷i��
+                    OrderQuantity = request.SplitQuantity,
+                    OriginalQuantity = request.SplitQuantity,
+                    AssignQuantity = request.SplitQuantity,
+                    PickedQty = 0,
                     LocationCode = lockInfo.LocationCode,
                     PalletCode = lockInfo.PalletCode,
                     TaskNum = lockInfo.TaskNum,
                     Status = (int)OutLockStockStatusEnum.鍑哄簱涓�,
                     Unit = lockInfo.Unit,
                     SupplyCode = lockInfo.SupplyCode,
-                    OrderType=lockInfo.OrderType,
-                    CurrentBarcode = newBarcode, // 鏂版潯鐮�
+                    OrderType = lockInfo.OrderType,
+                    CurrentBarcode = newBarcode,
                     OriginalLockQuantity = request.SplitQuantity,
                     IsSplitted = 1,
-                    ParentLockId = lockInfo.Id // 璁板綍鐖剁骇閿佸畾ID
+                    ParentLockId = lockInfo.Id,
+                     Operator = App.User.UserName,
+                    FactoryArea = lockInfo.FactoryArea,
+                    lineNo = lockInfo.lineNo,
+                    WarehouseCode = lockInfo.WarehouseCode,
                 };
                 await _outStockLockInfoService.Db.Insertable(newLockInfo).ExecuteCommandAsync();
 
-                // 5. 鏇存柊鍘熼攣瀹氫俊鎭殑鍒嗛厤鏁伴噺锛堝噺灏戞媶鍖呮暟閲忥級
-                lockInfo.AssignQuantity = request.SplitQuantity;
+                // 9. 鏇存柊鍘熼攣瀹氫俊鎭殑鍒嗛厤鏁伴噺锛堝噺灏戞媶鍖呮暟閲忥級
+                lockInfo.AssignQuantity = remainingQty;
+                lockInfo.IsSplitted = 1;
                 await _outStockLockInfoService.Db.Updateable(lockInfo).ExecuteCommandAsync();
 
-                // 6. 璁板綍鎷嗗寘鍘嗗彶锛堢敤浜庤拷韪級
+                // 10. 璁板綍鎷嗗寘鍘嗗彶
                 var splitHistory = new Dt_SplitPackageRecord
                 {
                     FactoryArea = lockInfo.FactoryArea,
-                    TaskNum=lockInfo.TaskNum,
+                    TaskNum = lockInfo.TaskNum,
                     OutStockLockInfoId = lockInfo.Id,
-                    StockId = stockDetail?.StockId ?? 0,
+                    StockId = baseStockDetail.StockId,
                     Operator = App.User.UserName,
                     IsReverted = false,
-                    OriginalBarcode = lockInfo.CurrentBarcode,
+                    OriginalBarcode = request.OriginalBarcode,
                     NewBarcode = newBarcode,
                     SplitQty = request.SplitQuantity,
-                    RemainQuantity = lockInfo.RemainQuantity - request.SplitQuantity,
+                    RemainQuantity = remainingQty,
+                    StockBeforeSplit = stockBeforeSplit, // 璁板綍鎷嗗寘鍓嶇殑搴撳瓨鏁伴噺
+                    AssignBeforeSplit = assignBeforeSplit, // 璁板綍鎷嗗寘鍓嶇殑鍒嗛厤鏁伴噺
                     MaterielCode = lockInfo.MaterielCode,
                     SplitTime = DateTime.Now,
                     OrderNo = request.OrderNo,
@@ -143,13 +173,35 @@
 
                 _unitOfWorkManage.CommitTran();
 
-                // 7. 鍥炰紶鏂版潯鐮佺粰MES
-                // await SendBarcodeToMES(newBarcode, request.MaterielCode, request.SplitQuantity);
+                try
+                {
+                   
+                    var dt_MaterielToMes = new Dt_MaterielToMes
+                    {
+                        OldMaterialBarCode = request.OriginalBarcode,
+                        NewMaterialBarCode = newBarcode,
+                        Unit = baseStockDetail.BarcodeUnit,
+                        factoryArea = baseStockDetail.FactoryArea,
+                        Qty = remainingQty,
+                        supplyCode = baseStockDetail.SupplyCode,
+                        warehouseCode = baseStockDetail.WarehouseCode,
+                        BatchNo = baseStockDetail.BatchNo,
+                        MaterielCode = baseStockDetail.MaterielCode,
 
-                return WebResponseContent.Instance.OK("鎷嗗寘鎴愬姛", new
+                    };
+                    _materielToMesService.AddData(dt_MaterielToMes);    
+              
+                }
+                catch (Exception ex)
+                {
+                    _logger.LogError("SplitPackage 鍥炰紶MES:  " + ex.Message);
+                }
+
+                return WebResponseContent.Instance.OK("鎷嗗寘鎴愬姛", new SplitPackageChainDto
                 {
                     NewBarcode = newBarcode,
-                    NewLockInfoId = newLockInfo.Id
+                    NewLockInfoId = newLockInfo.Id,
+                    RemainQuantity = remainingQty
                 });
             }
             catch (Exception ex)
@@ -159,48 +211,87 @@
             }
         }
 
-        // 鎾ら攢鎷嗗寘
         public async Task<WebResponseContent> RevertSplitPackage(string originalBarcode)
         {
             try
             {
                 _unitOfWorkManage.BeginTran();
-                // 鏌ユ壘鏈�杩戠殑鏈挙閿�鎷嗗寘璁板綍
-                var splitPackage = await Db.Queryable<Dt_SplitPackageRecord>()
+
+                // 1. 鏌ユ壘璇ユ潯鐮佷綔涓哄師濮嬫潯鐮佺殑鎵�鏈夋湭鎾ら攢鎷嗗寘璁板綍锛屾寜鏃堕棿鍊掑簭
+                var splitRecords = await Db.Queryable<Dt_SplitPackageRecord>()
                         .Where(x => x.OriginalBarcode == originalBarcode && !x.IsReverted)
-                        .OrderByDescending(x => x.CreateDate)
-                        .FirstAsync();
+                        .OrderByDescending(x => x.SplitTime)
+                        .ToListAsync();
 
-                if (splitPackage == null)
-                    return WebResponseContent.Instance.Error("鏈壘鍒版媶鍖呰褰�");
+                if (splitRecords == null || !splitRecords.Any())
+                    return WebResponseContent.Instance.Error("鏈壘鍒板彲鎾ら攢鐨勬媶鍖呰褰�");
 
-                // 妫�鏌ユ柊鏉$爜鏄惁宸叉嫞閫�
-                var newOutStockInfo = await _outStockLockInfoService.Db.Queryable<Dt_OutStockLockInfo>()
-                    .Where(x => x.CurrentBarcode == splitPackage.NewBarcode)
-                    .FirstAsync();
+                // 2. 妫�鏌ユ墍鏈夋柊鏉$爜鏄惁宸叉嫞閫�
+                var newBarcodes = splitRecords.Select(x => x.NewBarcode).ToList();
+                var newLockInfos = await _outStockLockInfoService.Db.Queryable<Dt_OutStockLockInfo>()
+                    .Where(x => newBarcodes.Contains(x.CurrentBarcode))
+                    .ToListAsync();
 
-                if (newOutStockInfo.Status == 2)
-                    return WebResponseContent.Instance.Error("鏂版潯鐮佸凡鎷i�夛紝鏃犳硶鎾ら攢鎷嗗寘");
+                var pickedBarcodes = newLockInfos.Where(x => x.Status == 2).Select(x => x.CurrentBarcode).ToList();
+                if (pickedBarcodes.Any())
+                    return WebResponseContent.Instance.Error($"浠ヤ笅鏉$爜宸叉嫞閫夛紝鏃犳硶鎾ら攢鎷嗗寘锛歿string.Join(",", pickedBarcodes)}");
 
-                // 杩樺師鍘熷嚭搴撹鎯呮暟閲�
-                var originalOutStockInfo = await _outStockLockInfoService.Db.Queryable<Dt_OutStockLockInfo>()
+                // 3. 鑾峰彇鍘熸潯鐮佺殑閿佸畾淇℃伅鍜屽簱瀛樹俊鎭�
+                var originalLockInfo = await _outStockLockInfoService.Db.Queryable<Dt_OutStockLockInfo>()
                     .Where(x => x.CurrentBarcode == originalBarcode)
                     .FirstAsync();
 
-                originalOutStockInfo.AssignQuantity += splitPackage.SplitQty;
-                await _outStockLockInfoService.Db.Updateable(originalOutStockInfo).ExecuteCommandAsync();
+                if (originalLockInfo == null)
+                    return WebResponseContent.Instance.Error("鏈壘鍒板師鏉$爜閿佸畾淇℃伅");
 
-                // 鍒犻櫎鏂板嚭搴撹鎯呰褰�
+                var originalStockDetail = await _stockInfoDetailService.Db.Queryable<Dt_StockInfoDetail>()
+                    .Where(x => x.Barcode == originalBarcode && x.StockId == originalLockInfo.StockId)
+                    .FirstAsync();
+
+                if (originalStockDetail == null)
+                    return WebResponseContent.Instance.Error("鏈壘鍒板師鏉$爜搴撳瓨淇℃伅");
+
+                // 4. 鏌ユ壘绗竴娆℃媶鍖呰褰曪紝鑾峰彇鎷嗗寘鍓嶇殑鐘舵��
+                var firstSplitRecord = splitRecords.OrderBy(x => x.SplitTime).FirstOrDefault();
+                if (firstSplitRecord == null)
+                    return WebResponseContent.Instance.Error("鏈壘鍒版湁鏁堢殑鎷嗗寘璁板綍");
+
+                // 5. 鎭㈠鍘熸潯鐮佸埌鎷嗗寘鍓嶇殑鐘舵��
+                originalStockDetail.StockQuantity = firstSplitRecord.StockBeforeSplit;
+                originalStockDetail.OutboundQuantity = firstSplitRecord.StockBeforeSplit;
+                await _stockInfoDetailService.Db.Updateable(originalStockDetail).ExecuteCommandAsync();
+
+                // 6. 鎭㈠鍘熸潯鐮侀攣瀹氫俊鎭埌鎷嗗寘鍓嶇殑鐘舵��
+                originalLockInfo.AssignQuantity = firstSplitRecord.AssignBeforeSplit;
+                originalLockInfo.OriginalQuantity = firstSplitRecord.AssignBeforeSplit;
+                originalLockInfo.OrderQuantity = firstSplitRecord.AssignBeforeSplit;
+                originalLockInfo.Status = (int)OutLockStockStatusEnum.鍑哄簱涓�;
+                originalLockInfo.IsSplitted = 0; // 鎭㈠涓烘湭鎷嗗寘鐘舵��
+                await _outStockLockInfoService.Db.Updateable(originalLockInfo).ExecuteCommandAsync();
+
+                // 7. 鍒犻櫎鎵�鏈夋柊鏉$爜鐨勯攣瀹氫俊鎭�
                 await _outStockLockInfoService.Db.Deleteable<Dt_OutStockLockInfo>()
-                    .Where(x => x.CurrentBarcode == splitPackage.NewBarcode)
+                    .Where(x => newBarcodes.Contains(x.CurrentBarcode))
                     .ExecuteCommandAsync();
 
-                // 鏍囪鎷嗗寘璁板綍涓哄凡鎾ら攢
-                splitPackage.IsReverted = true;
-                await Db.Updateable(splitPackage).ExecuteCommandAsync();
+                // 8. 鍒犻櫎鎵�鏈夋柊鏉$爜鐨勫簱瀛樿褰�
+                await _stockInfoDetailService.Db.Deleteable<Dt_StockInfoDetail>()
+                    .Where(x => newBarcodes.Contains(x.Barcode))
+                    .ExecuteCommandAsync();
+
+                // 9. 鏍囪鎵�鏈夋媶鍖呰褰曚负宸叉挙閿�
+                foreach (var record in splitRecords)
+                {
+                    record.IsReverted = true;
+                    record.RevertTime = DateTime.Now;
+
+                    record.Status = (int)SplitPackageStatusEnum.宸叉挙閿�;
+                }
+                await Db.Updateable(splitRecords).ExecuteCommandAsync();
 
                 _unitOfWorkManage.CommitTran();
-                return WebResponseContent.Instance.OK("鎾ら攢鎷嗗寘鎴愬姛");
+
+                return WebResponseContent.Instance.OK($"鎾ら攢鎷嗗寘鎴愬姛锛屽叡鎾ら攢{splitRecords.Count}娆℃媶鍖咃紝{originalBarcode}鎭㈠涓烘媶鍖呭墠鏁伴噺锛歿firstSplitRecord.StockBeforeSplit}");
 
             }
             catch (Exception ex)
@@ -210,6 +301,105 @@
             }
         }
 
+        //public async Task<WebResponseContent> RevertSplitPackage(string originalBarcode)
+        //{
+        //    try
+        //    {
+        //        _unitOfWorkManage.BeginTran();
+
+        //        // 1. 鏌ユ壘鏈�杩戠殑鏈挙閿�鎷嗗寘璁板綍
+        //        var splitRecord = await Db.Queryable<Dt_SplitPackageRecord>()
+        //                .Where(x => x.OriginalBarcode == originalBarcode && !x.IsReverted)
+        //                .OrderByDescending(x => x.SplitTime)
+        //                .FirstAsync();
+
+        //        if (splitRecord == null)
+        //            return WebResponseContent.Instance.Error("鏈壘鍒板彲鎾ら攢鐨勬媶鍖呰褰�");
+
+        //        // 2. 妫�鏌ユ柊鏉$爜鏄惁宸叉嫞閫�
+        //        var newLockInfo = await _outStockLockInfoService.Db.Queryable<Dt_OutStockLockInfo>()
+        //            .Where(x => x.CurrentBarcode == splitRecord.NewBarcode)
+        //            .FirstAsync();
+
+        //        if (newLockInfo?.Status ==6) // 鍋囪鐘舵��2琛ㄧず宸叉嫞閫�
+        //            return WebResponseContent.Instance.Error("鏂版潯鐮佸凡鎷i�夛紝鏃犳硶鎾ら攢鎷嗗寘");
+
+        //        // 3. 鑾峰彇鍘熸潯鐮佺殑閿佸畾淇℃伅
+        //        var originalLockInfo = await _outStockLockInfoService.Db.Queryable<Dt_OutStockLockInfo>()
+        //            .Where(x => x.CurrentBarcode == originalBarcode)
+        //            .FirstAsync();
+
+        //        if (originalLockInfo == null)
+        //            return WebResponseContent.Instance.Error("鏈壘鍒板師鏉$爜閿佸畾淇℃伅");
+
+
+        //        originalLockInfo.AssignQuantity  += splitRecord.RemainQuantity;  
+        //       // originalLockInfo.Status = (int)OutLockStockStatusEnum.鍑哄簱涓�;
+        //        originalLockInfo.IsSplitted = 0; // 鏍囪涓烘湭鎷嗗寘
+        //        await _outStockLockInfoService.Db.Updateable(originalLockInfo).ExecuteCommandAsync();
+
+        //        // 5. 杩樺師鍘熸潯鐮佸簱瀛樿褰�
+        //        var originalStockDetail = await _stockInfoDetailService.Db.Queryable<Dt_StockInfoDetail>()
+        //            .Where(x => x.Barcode == originalBarcode && x.StockId == splitRecord.StockId)
+        //            .FirstAsync();
+
+        //        if (originalStockDetail != null)
+        //        {
+        //            // 灏嗘媶鍑虹殑鏁伴噺鍔犲洖鍒板師鏉$爜搴撳瓨
+        //            originalStockDetail.StockQuantity += splitRecord.RemainQuantity;
+        //            originalStockDetail.OutboundQuantity += splitRecord.RemainQuantity;
+        //            await _stockInfoDetailService.Db.Updateable(originalStockDetail).ExecuteCommandAsync();
+        //        }
+
+        //        // 6. 鍒犻櫎鏂版潯鐮佺殑閿佸畾淇℃伅
+        //        if (newLockInfo != null)
+        //        {
+        //            await _outStockLockInfoService.Db.Deleteable<Dt_OutStockLockInfo>()
+        //                .Where(x => x.CurrentBarcode == splitRecord.NewBarcode)
+        //                .ExecuteCommandAsync();
+        //        }
+
+        //        // 7. 鍒犻櫎鏂版潯鐮佺殑搴撳瓨璁板綍
+        //        var newStockDetail = await _stockInfoDetailService.Db.Queryable<Dt_StockInfoDetail>()
+        //            .Where(x => x.Barcode == splitRecord.NewBarcode)
+        //            .FirstAsync();
+
+        //        if (newStockDetail != null)
+        //        {
+        //            await _stockInfoDetailService.Db.Deleteable<Dt_StockInfoDetail>()
+        //                .Where(x => x.Barcode == splitRecord.NewBarcode)
+        //                .ExecuteCommandAsync();
+        //        }
+
+        //        // 8. 鏇存柊鎷嗗寘璁板綍涓哄凡鎾ら攢
+        //        splitRecord.IsReverted = true;              
+
+        //        await Db.Updateable(splitRecord).ExecuteCommandAsync();
+
+        //        _unitOfWorkManage.CommitTran();
+
+        //        return WebResponseContent.Instance.OK($"鎾ら攢鎷嗗寘鎴愬姛锛岃繕鍘熸暟閲忥細{splitRecord.SplitQty}");
+
+        //    }
+        //    catch (Exception ex)
+        //    {
+        //        _unitOfWorkManage.RollbackTran();
+        //        return WebResponseContent.Instance.Error($"鎾ら攢鎷嗗寘澶辫触锛歿ex.Message}");
+        //    }
+        //}
+
+
+        // 鑾峰彇鍙挙閿�鐨勬媶鍖呰褰曞垪琛�
+        public Dt_SplitPackageRecord GetRevertableSplitRecords(string originalBarcode)
+        {
+            var revertableRecords = Db.Queryable<Dt_SplitPackageRecord>()
+                    .Where(x => x.OriginalBarcode == originalBarcode && !x.IsReverted)
+                    .OrderBy(x => x.SplitTime)
+                   .First();
+
+            return revertableRecords;
+        }
+
         // 鑾峰彇鎷嗗寘淇℃伅
         public async Task<WebResponseContent> GetSplitPackageInfo(string orderNo, string palletCode, string barcode)
         {

--
Gitblit v1.9.3