From b698a2085fd090e90abedb1e91266ec496574b29 Mon Sep 17 00:00:00 2001
From: wanshenmean <cathay_xy@163.com>
Date: 星期四, 16 四月 2026 23:31:35 +0800
Subject: [PATCH] 1

---
 Code/WMS/WIDESEA_WMSServer/WIDESEA_StockService/StockSerivce.cs |  467 +++++++++++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 360 insertions(+), 107 deletions(-)

diff --git a/Code/WMS/WIDESEA_WMSServer/WIDESEA_StockService/StockSerivce.cs b/Code/WMS/WIDESEA_WMSServer/WIDESEA_StockService/StockSerivce.cs
index c7ad96a..d2f1044 100644
--- a/Code/WMS/WIDESEA_WMSServer/WIDESEA_StockService/StockSerivce.cs
+++ b/Code/WMS/WIDESEA_WMSServer/WIDESEA_StockService/StockSerivce.cs
@@ -1,31 +1,124 @@
-锘縰sing WIDESEA_Common.StockEnum;
+锘縰sing Newtonsoft.Json;
+using SqlSugar;
+using WIDESEA_Common.Constants;
+using WIDESEA_Common.StockEnum;
 using WIDESEA_Core;
+using WIDESEA_DTO.MES;
 using WIDESEA_DTO.Stock;
+using WIDESEA_IBasicService;
 using WIDESEA_IStockService;
 using WIDESEA_Model.Models;
 
 namespace WIDESEA_StockService
 {
     /// <summary>
-    /// 搴撳瓨鏈嶅姟
+    /// 搴撳瓨鏈嶅姟鑱氬悎瀹炵幇绫�
     /// </summary>
-    public class StockSerivce : IStockService
+    public class StockService : IStockService
     {
+        /// <summary>
+        /// 搴撳瓨鏄庣粏鏈嶅姟
+        /// </summary>
         public IStockInfoDetailService StockInfoDetailService { get; }
+
+        /// <summary>
+        /// 搴撳瓨淇℃伅鏈嶅姟
+        /// </summary>
         public IStockInfoService StockInfoService { get; }
+
+        /// <summary>
+        /// 搴撳瓨鏄庣粏鍘嗗彶鏈嶅姟
+        /// </summary>
         public IStockInfoDetail_HtyService StockInfoDetail_HtyService { get; }
+
+        /// <summary>
+        /// 搴撳瓨鍘嗗彶鏈嶅姟
+        /// </summary>
         public IStockInfo_HtyService StockInfo_HtyService { get; }
 
-        public StockSerivce(
+        /// <summary>
+        /// 浠撳簱鏈嶅姟
+        /// </summary>
+        public IWarehouseService _warehouseService { get; }
+
+        /// <summary>
+        /// SqlSugar瀹㈡埛绔紙鐢ㄤ簬涓存椂琛ㄦ搷浣滐級
+        /// </summary>
+        public ISqlSugarClient SqlSugarClient { get; }
+
+        /// <summary>
+        /// Mes鎺ュ彛鏈嶅姟
+        /// </summary>
+        public IMesService _mesService { get; }
+
+        /// <summary>
+        /// 鏋勯�犲嚱鏁�
+        /// </summary>
+        /// <param name="stockInfoDetailService">搴撳瓨鏄庣粏鏈嶅姟</param>
+        /// <param name="stockInfoService">搴撳瓨淇℃伅鏈嶅姟</param>
+        /// <param name="stockInfoDetail_HtyService">搴撳瓨鏄庣粏鍘嗗彶鏈嶅姟</param>
+        /// <param name="stockInfo_HtyService">搴撳瓨鍘嗗彶鏈嶅姟</param>
+        public StockService(
             IStockInfoDetailService stockInfoDetailService,
             IStockInfoService stockInfoService,
             IStockInfoDetail_HtyService stockInfoDetail_HtyService,
-            IStockInfo_HtyService stockInfo_HtyService)
+            IStockInfo_HtyService stockInfo_HtyService,
+            IMesService mesService,
+            IWarehouseService warehouseService,
+            ISqlSugarClient sqlSugarClient)
         {
             StockInfoDetailService = stockInfoDetailService;
             StockInfoService = stockInfoService;
             StockInfoDetail_HtyService = stockInfoDetail_HtyService;
             StockInfo_HtyService = stockInfo_HtyService;
+            _mesService = mesService;
+            _warehouseService = warehouseService;
+            SqlSugarClient = sqlSugarClient;
+        }
+
+        /// <summary>
+        /// 鍦ㄤ簨鍔′腑鎵ц鎿嶄綔
+        /// </summary>
+        private async Task<WebResponseContent> ExecuteWithinTransactionAsync(Func<Task<WebResponseContent>> operation)
+        {
+            var db = StockInfoService.Repository.Db as SqlSugarClient;
+            if (db == null)
+            {
+                return WebResponseContent.Instance.Error("Database context does not support transactions");
+            }
+
+            var ownsTransaction = db.Ado.Transaction == null;
+            try
+            {
+                if (ownsTransaction)
+                {
+                    db.BeginTran();
+                }
+
+                var result = await operation();
+                if (result?.Status == true)
+                {
+                    if (ownsTransaction)
+                    {
+                        db.CommitTran();
+                    }
+                    return result;
+                }
+
+                if (ownsTransaction)
+                {
+                    db.RollbackTran();
+                }
+                return result ?? WebResponseContent.Instance.Error("Transaction failed");
+            }
+            catch
+            {
+                if (ownsTransaction)
+                {
+                    db.RollbackTran();
+                }
+                throw;
+            }
         }
 
         /// <summary>
@@ -34,44 +127,59 @@
         public async Task<WebResponseContent> GroupPalletAsync(StockDTO stock)
         {
             WebResponseContent content = new WebResponseContent();
-            var now = DateTime.Now;
-            var details = stock.Details.Select(item => new Dt_StockInfoDetail
+            try
             {
-                MaterielCode = "鐢佃姱",
-                MaterielName = "鐢佃姱",
-                StockQuantity = item.Quantity,
-                Unit = "PCS",
-                Creater = "system",
-                OrderNo = "111",
-                ProductionDate = now.ToString(),
-                EffectiveDate = now.AddYears(1).ToString(),
-                SerialNumber = item.CellBarcode,
-                InboundOrderRowNo = item.Channel,
-                Status = StockStatusEmun.缁勭洏鏆傚瓨.GetHashCode(),
-            }).ToList();
+                var now = DateTime.Now;
+                var details = stock.Details.Select(item => new Dt_StockInfoDetail
+                {
+                    MaterielCode = StockConstants.MATERIAL_CODE,
+                    MaterielName = StockConstants.MATERIAL_NAME,
+                    StockQuantity = item.Quantity,
+                    Unit = StockConstants.UNIT,
+                    Creater = StockConstants.SYSTEM_USER,
+                    OrderNo = StockConstants.DEFAULT_ORDER_NO,
+                    ProductionDate = now.ToString(),
+                    EffectiveDate = now.AddYears(1).ToString(),
+                    SerialNumber = item.CellBarcode,
+                    InboundOrderRowNo = item.Channel,
+                    Status = StockStatusEmun.缁勭洏鏆傚瓨.GetHashCode(),
+                }).ToList();
 
-            var existingStock = StockInfoService.Repository.QueryFirst(s => s.PalletCode == stock.TargetPalletNo);
-            var result = false;
-            if (existingStock != null)
-            {
-                details.ForEach(d => d.StockId = existingStock.Id);
-                result = await StockInfoDetailService.Repository.AddDataAsync(details) > 0;
-                if (result) return content.OK("缁勭洏鎴愬姛");
-                return content.Error("缁勭洏澶辫触");
+                return await ExecuteWithinTransactionAsync(async () =>
+                {
+                    var existingStock = StockInfoService.Repository.QueryFirst(s => s.PalletCode == stock.TargetPalletNo);
+                    var result = false;
+                    if (existingStock != null)
+                    {
+                        details.ForEach(d => d.StockId = existingStock.Id);
+                        result = await StockInfoDetailService.Repository.AddDataAsync(details) > 0;
+                        return result ? content.OK("缁勭洏鎴愬姛") : content.Error("缁勭洏澶辫触");
+                    }
+
+                    int WarehouseId = stock.Roadway switch
+                    {
+                        "娉ㄦ恫缁勭洏鏈烘鎵�" => (await _warehouseService.Db.Queryable<Dt_Warehouse>().FirstAsync(w => w.WarehouseCode == "GWSC1")).WarehouseId,
+                        "鎹㈢洏鏈烘鎵�" => (await _warehouseService.Db.Queryable<Dt_Warehouse>().FirstAsync(w => w.WarehouseCode == "HCSC1")).WarehouseId
+                    };
+
+                    var entity = new Dt_StockInfo
+                    {
+                        PalletCode = stock.TargetPalletNo,
+                        WarehouseId = WarehouseId,
+                        StockStatus = StockStatusEmun.缁勭洏鏆傚瓨.GetHashCode(),
+                        Creater = StockConstants.SYSTEM_USER,
+                        Details = details
+                    };
+                    result = StockInfoService.Repository.AddData(entity, x => x.Details);
+                    if (!result) return content.Error("缁勭洏澶辫触");
+
+                    return content.OK("缁勭洏鎴愬姛");
+                });
             }
-
-            var entity = new Dt_StockInfo
+            catch (Exception ex)
             {
-                PalletCode = stock.TargetPalletNo,
-                WarehouseId = 1,
-                StockStatus = 1,
-                Creater = "system",
-                Details = details
-            };
-
-            result = StockInfoService.Repository.AddData(entity, x => x.Details);
-            if (result) return content.OK("缁勭洏鎴愬姛");
-            return content.Error("缁勭洏澶辫触");
+                return content.Error($"缁勭洏澶辫触: {ex.Message}");
+            }
         }
 
         /// <summary>
@@ -80,52 +188,63 @@
         public async Task<WebResponseContent> ChangePalletAsync(StockDTO stock)
         {
             WebResponseContent content = new WebResponseContent();
-            if (stock == null ||
-                string.IsNullOrWhiteSpace(stock.TargetPalletNo) ||
-                string.IsNullOrWhiteSpace(stock.SourcePalletNo) ||
-                string.Equals(stock.SourcePalletNo, stock.TargetPalletNo, StringComparison.OrdinalIgnoreCase))
+            try
             {
-                return content.Error("婧愭墭鐩樺彿涓庣洰鏍囨墭鐩樺彿鐩稿悓");
-            }
-
-            var sourceStock = StockInfoService.Repository.QueryFirst(s => s.PalletCode == stock.SourcePalletNo);
-            if (sourceStock == null) return content.Error("婧愭墭鐩樹笉瀛樺湪");
-
-            var targetStock = StockInfoService.Repository.QueryFirst(s => s.PalletCode == stock.TargetPalletNo);
-            if (targetStock == null)
-            {
-                var newStock = new Dt_StockInfo
+                if (stock == null ||
+                    string.IsNullOrWhiteSpace(stock.TargetPalletNo) ||
+                    string.IsNullOrWhiteSpace(stock.SourcePalletNo) ||
+                    string.Equals(stock.SourcePalletNo, stock.TargetPalletNo, StringComparison.OrdinalIgnoreCase))
                 {
-                    PalletCode = stock.TargetPalletNo,
-                    WarehouseId = sourceStock.WarehouseId,
-                    StockStatus = sourceStock.StockStatus,
-                    Creater = "system"
-                };
+                    return content.Error("婧愭墭鐩樺彿涓庣洰鏍囨墭鐩樺彿鐩稿悓");
+                }
 
-                var newId = StockInfoService.Repository.AddData(newStock);
-                if (newId <= 0) return content.Error("鎹㈢洏澶辫触");
+                return await ExecuteWithinTransactionAsync(async () =>
+                {
+                    var sourceStock = await StockInfoService.Repository.QueryDataNavFirstAsync(s => s.PalletCode == stock.SourcePalletNo);
+                    if (sourceStock == null) return content.Error("婧愭墭鐩樹笉瀛樺湪");
 
-                targetStock = newStock;
-                targetStock.Id = newId;
+                    var targetStock = StockInfoService.Repository.QueryFirst(s => s.PalletCode == stock.TargetPalletNo);
+                    if (targetStock == null)
+                    {
+                        var newStock = new Dt_StockInfo
+                        {
+                            PalletCode = stock.TargetPalletNo,
+                            WarehouseId = sourceStock.WarehouseId,
+                            StockStatus = StockStatusEmun.缁勭洏鏆傚瓨.GetHashCode(),
+                            Creater = StockConstants.SYSTEM_USER,
+                        };
+
+                        var newId = StockInfoService.Repository.AddData(newStock);
+                        if (newId <= 0) return content.Error("鎹㈢洏澶辫触");
+
+                        targetStock = newStock;
+                        targetStock.Id = newId;
+                    }
+
+                    var serialNumbers = stock.Details.Select(d => d.Channel).Distinct().ToList();
+                    if (!serialNumbers.Any()) return content.Error("鏈壘鍒版湁鏁堢殑搴忓垪鍙�");
+
+                    var detailEntities = StockInfoDetailService.Repository.QueryData(
+                        d => d.StockId == sourceStock.Id && serialNumbers.Contains(d.InboundOrderRowNo));
+                    if (!detailEntities.Any()) return content.Error("鏈壘鍒版湁鏁堢殑搴撳瓨鏄庣粏");
+
+                    if (await StockInfoDetail_HtyService.Repository.AddDataAsync(CreateDetailHistory(detailEntities, "鎹㈢洏")) <= 0)
+                        return content.Error("鎹㈢洏鍘嗗彶璁板綍淇濆瓨澶辫触");
+
+                    if (await StockInfo_HtyService.Repository.AddDataAsync(CreateStockHistory(new[] { sourceStock, targetStock }, "鎹㈢洏")) <= 0)
+                        return content.Error("鎹㈢洏鍘嗗彶璁板綍淇濆瓨澶辫触");
+
+                    detailEntities.ForEach(d => d.StockId = targetStock.Id);
+                    var result = await StockInfoDetailService.Repository.UpdateDataAsync(detailEntities);
+                    if (!result) return content.Error("鎹㈢洏澶辫触");
+
+                    return content.OK("鎹㈢洏鎴愬姛");
+                });
             }
-
-            var serialNumbers = stock.Details.Select(d => d.CellBarcode).Distinct().ToList();
-            if (!serialNumbers.Any()) return content.Error("鏈壘鍒版湁鏁堢殑搴忓垪鍙�");
-
-            var detailEntities = StockInfoDetailService.Repository.QueryData(
-                d => d.StockId == sourceStock.Id && serialNumbers.Contains(d.SerialNumber));
-            if (!detailEntities.Any()) return content.Error("鏈壘鍒版湁鏁堢殑搴撳瓨鏄庣粏");
-
-            if (await StockInfoDetail_HtyService.Repository.AddDataAsync(CreateDetailHistory(detailEntities, "鎹㈢洏")) <= 0)
-                return content.Error("鎹㈢洏鍘嗗彶璁板綍淇濆瓨澶辫触");
-
-            if (await StockInfo_HtyService.Repository.AddDataAsync(CreateStockHistory(new[] { sourceStock, targetStock }, "鎹㈢洏")) <= 0)
-                return content.Error("鎹㈢洏鍘嗗彶璁板綍淇濆瓨澶辫触");
-
-            detailEntities.ForEach(d => d.StockId = targetStock.Id);
-            var result = await StockInfoDetailService.Repository.UpdateDataAsync(detailEntities);
-            if (!result) return content.Error("鎹㈢洏澶辫触");
-            return content.OK("鎹㈢洏鎴愬姛");
+            catch (Exception ex)
+            {
+                return content.Error($"鎹㈢洏澶辫触: {ex.Message}");
+            }
         }
 
         /// <summary>
@@ -134,34 +253,66 @@
         public async Task<WebResponseContent> SplitPalletAsync(StockDTO stock)
         {
             WebResponseContent content = new WebResponseContent();
-            if (stock == null || string.IsNullOrWhiteSpace(stock.SourcePalletNo))
-                return content.Error("婧愭墭鐩樺彿涓嶈兘涓虹┖");
-
-            var sourceStock = StockInfoService.Repository.QueryFirst(s => s.PalletCode == stock.SourcePalletNo);
-            if (sourceStock == null) return content.Error("婧愭墭鐩樹笉瀛樺湪");
-
-            var serialNumbers = stock.Details.Select(d => d.CellBarcode).Distinct().ToList();
-            if (!serialNumbers.Any())
+            try
             {
-                serialNumbers = sourceStock.Details
-                                            .Where(x => stock.Details.Any(d => d.Channel == x.InboundOrderRowNo))
-                                            .Select(x => x.SerialNumber)
-                                            .ToList();
+                if (stock == null || string.IsNullOrWhiteSpace(stock.SourcePalletNo))
+                    return content.Error("婧愭墭鐩樺彿涓嶈兘涓虹┖");
+
+                // 骞傜瓑鍐欏叆锛氭鏌ヤ复鏃惰〃鏄惁宸叉湁璇ユ墭鐩樿褰曪紝鏃犲垯鍐欏叆
+                var existingTemp = SqlSugarClient.Queryable<Dt_SplitTemp>()
+                    .Where(t => t.PalletCode == stock.SourcePalletNo)
+                    .First();
+                if (existingTemp == null)
+                {
+                    // 鏌ヨ璇ユ墭鐩樺綋鍓嶆墍鏈夌數鑺紝瀛樺叆涓存椂琛�
+                    var sourceStockForTemp = StockInfoService.Repository.QueryFirst(s => s.PalletCode == stock.SourcePalletNo);
+                    if (sourceStockForTemp != null)
+                    {
+                        var allDetails = StockInfoDetailService.Repository.QueryData(d => d.StockId == sourceStockForTemp.Id);
+                        if (allDetails != null && allDetails.Any())
+                        {
+                            var sfcListJson = JsonConvert.SerializeObject(allDetails.Select(d => d.SerialNumber).ToList());
+                            await SqlSugarClient.Insertable(new Dt_SplitTemp
+                            {
+                                PalletCode = stock.SourcePalletNo,
+                                SfcList = sfcListJson,
+                                CreateTime = DateTime.Now
+                            }).ExecuteCommandAsync();
+                        }
+                    }
+                }
+
+                return await ExecuteWithinTransactionAsync(async () =>
+                {
+                    var sourceStock = StockInfoService.Repository.QueryFirst(s => s.PalletCode == stock.SourcePalletNo);
+                    if (sourceStock == null) return content.Error("婧愭墭鐩樹笉瀛樺湪");
+
+                    var serialNumbers = stock.Details.Select(d => d.CellBarcode).Distinct().ToList();
+                    if (!serialNumbers.Any())
+                    {
+                        serialNumbers = sourceStock.Details
+                                                    .Where(x => stock.Details.Any(d => d.Channel == x.InboundOrderRowNo))
+                                                    .Select(x => x.SerialNumber)
+                                                    .ToList();
+                    }
+
+                    var detailEntities = StockInfoDetailService.Repository.QueryData(
+                        d => d.StockId == sourceStock.Id && serialNumbers.Contains(d.SerialNumber));
+                    if (!detailEntities.Any()) return content.Error("鏈壘鍒版湁鏁堢殑搴撳瓨鏄庣粏");
+
+                    if (await StockInfoDetail_HtyService.Repository.AddDataAsync(CreateDetailHistory(detailEntities, "鎷嗙洏")) <= 0)
+                        return content.Error("鎷嗙洏鍘嗗彶璁板綍淇濆瓨澶辫触");
+
+                    if (await StockInfo_HtyService.Repository.AddDataAsync(CreateStockHistory(new[] { sourceStock }, "鎷嗙洏")) <= 0)
+                        return content.Error("鎷嗙洏鍘嗗彶璁板綍淇濆瓨澶辫触");
+
+                    return content.OK("鎷嗙洏鎴愬姛");
+                });
             }
-
-            var detailEntities = StockInfoDetailService.Repository.QueryData(
-                d => d.StockId == sourceStock.Id && serialNumbers.Contains(d.SerialNumber));
-            if (!detailEntities.Any()) return content.Error("鏈壘鍒版湁鏁堢殑搴撳瓨鏄庣粏");
-
-            if (await StockInfoDetail_HtyService.Repository.AddDataAsync(CreateDetailHistory(detailEntities, "鎷嗙洏")) <= 0)
-                return content.Error("鎷嗙洏鍘嗗彶璁板綍淇濆瓨澶辫触");
-
-            if (await StockInfo_HtyService.Repository.AddDataAsync(CreateStockHistory(new[] { sourceStock }, "鎷嗙洏")) <= 0)
-                return content.Error("鎷嗙洏鍘嗗彶璁板綍淇濆瓨澶辫触");
-
-            var result = await StockInfoDetailService.Repository.DeleteDataAsync(detailEntities);
-            if (!result) return content.Error("鎷嗙洏澶辫触");
-            return content.OK("鎷嗙洏鎴愬姛");
+            catch (Exception ex)
+            {
+                return content.Error($"鎷嗙洏澶辫触: {ex.Message}");
+            }
         }
 
         /// <summary>
@@ -231,8 +382,110 @@
                 Creater = s.Creater,
                 CreateDate = s.CreateDate,
                 Modifier = s.Modifier,
-                ModifyDate = s.ModifyDate
+                ModifyDate = s.ModifyDate,
+                LocationId = s.LocationId,
+                OutboundDate = s.OutboundDate
             }).ToList();
         }
+
+        /// <summary>
+        /// 鎵归噺鎷嗙洏纭 - 涓�娆℃�ц皟鐢∕ES瑙g粦鏁翠釜鎵樼洏
+        /// </summary>
+        /// <param name="palletCode">婧愭墭鐩樺彿</param>
+        /// <returns>鎿嶄綔缁撴灉</returns>
+        public async Task<WebResponseContent> SplitPalletConfirmAsync(string palletCode)
+        {
+            WebResponseContent content = new WebResponseContent();
+            try
+            {
+                if (string.IsNullOrWhiteSpace(palletCode))
+                    return content.Error("鎵樼洏鍙蜂笉鑳戒负绌�");
+
+                // 1. 浠庝复鏃惰〃璇诲彇鐢佃姱鍒楄〃
+                var tempRecord = SqlSugarClient.Queryable<Dt_SplitTemp>()
+                    .Where(t => t.PalletCode == palletCode)
+                    .First();
+                if (tempRecord == null)
+                    return content.Error("鏈壘鍒版媶鐩樹复鏃惰褰曪紝璇峰厛鎵ц鎷嗙洏鎿嶄綔");
+
+                var sfcList = JsonConvert.DeserializeObject<List<string>>(tempRecord.SfcList);
+                if (sfcList == null || !sfcList.Any())
+                    return content.Error("涓存椂琛ㄤ腑鐢佃姱鍒楄〃涓虹┖");
+
+                // 2. 璋冪敤MES瑙g粦
+                var unbindRequest = new UnBindContainerRequest
+                {
+                    EquipmentCode = StockConstants.MES_EQUIPMENT_CODE,
+                    ResourceCode = StockConstants.MES_RESOURCE_CODE,
+                    LocalTime = DateTime.Now,
+                    ContainCode = palletCode,
+                    SfcList = sfcList
+                };
+                var unbindResult = _mesService.UnBindContainer(unbindRequest);
+                if (unbindResult == null || unbindResult.Data == null || !unbindResult.Data.IsSuccess)
+                {
+                    return content.Error($"MES瑙g粦澶辫触: {unbindResult?.Data?.Msg ?? unbindResult?.ErrorMessage ?? "鏈煡閿欒"}");
+                }
+
+                // 3. 鍒犻櫎涓存椂琛ㄨ褰�
+                await SqlSugarClient.Deleteable<Dt_SplitTemp>().Where(t => t.PalletCode == palletCode).ExecuteCommandAsync();
+
+                return content.OK("鎵归噺鎷嗙洏纭鎴愬姛");
+            }
+            catch (Exception ex)
+            {
+                return content.Error($"鎵归噺鎷嗙洏纭澶辫触: {ex.Message}");
+            }
+        }
+
+        /// <summary>
+        /// 鎵归噺缁勭洏纭 - 涓�娆℃�ц皟鐢∕ES缁戝畾鏁翠釜鎵樼洏
+        /// </summary>
+        /// <param name="palletCode">鐩爣鎵樼洏鍙�</param>
+        /// <returns>鎿嶄綔缁撴灉</returns>
+        public async Task<WebResponseContent> GroupPalletConfirmAsync(string palletCode)
+        {
+            WebResponseContent content = new WebResponseContent();
+            try
+            {
+                if (string.IsNullOrWhiteSpace(palletCode))
+                    return content.Error("鎵樼洏鍙蜂笉鑳戒负绌�");
+
+                // 1. 鏌ヨ璇ユ墭鐩樹笅鐨勬墍鏈夌數鑺槑缁�
+                var stockInfo = StockInfoService.Repository.QueryFirst(s => s.PalletCode == palletCode);
+                if (stockInfo == null)
+                    return content.Error("鎵樼洏涓嶅瓨鍦�");
+
+                var details = StockInfoDetailService.Repository.QueryData(d => d.StockId == stockInfo.Id);
+                if (details == null || !details.Any())
+                    return content.Error("鎵樼洏涓嬫棤鐢佃姱鏁版嵁");
+
+                // 2. 璋冪敤MES缁戝畾
+                var bindRequest = new BindContainerRequest
+                {
+                    ContainerCode = palletCode,
+                    EquipmentCode = StockConstants.MES_EQUIPMENT_CODE,
+                    ResourceCode = StockConstants.MES_RESOURCE_CODE,
+                    LocalTime = DateTime.Now,
+                    OperationType = StockConstants.MES_BIND_OPERATION_TYPE,
+                    ContainerSfcList = details.Select(d => new ContainerSfcItem
+                    {
+                        Sfc = d.SerialNumber,
+                        Location = d.InboundOrderRowNo.ToString()
+                    }).ToList()
+                };
+                var bindResult = _mesService.BindContainer(bindRequest);
+                if (bindResult == null || bindResult.Data == null || !bindResult.Data.IsSuccess)
+                {
+                    return content.Error($"MES缁戝畾澶辫触: {bindResult?.Data?.Msg ?? bindResult?.ErrorMessage ?? "鏈煡閿欒"}");
+                }
+
+                return content.OK("鎵归噺缁勭洏纭鎴愬姛");
+            }
+            catch (Exception ex)
+            {
+                return content.Error($"鎵归噺缁勭洏纭澶辫触: {ex.Message}");
+            }
+        }
     }
 }
\ No newline at end of file

--
Gitblit v1.9.3