From 4d5b4319ebfb155b199ec641ec377b220f9fa837 Mon Sep 17 00:00:00 2001
From: wanshenmean <cathay_xy@163.com>
Date: 星期三, 08 四月 2026 00:55:31 +0800
Subject: [PATCH] fix(wms): 优化组盘库存逻辑与数据库连接配置

---
 Code/WMS/WIDESEA_WMSServer/WIDESEA_StockService/StockSerivce.cs |   37 +++++++++++++++++++++++++++++--------
 1 files changed, 29 insertions(+), 8 deletions(-)

diff --git a/Code/WMS/WIDESEA_WMSServer/WIDESEA_StockService/StockSerivce.cs b/Code/WMS/WIDESEA_WMSServer/WIDESEA_StockService/StockSerivce.cs
index 49f6657..2b27518 100644
--- a/Code/WMS/WIDESEA_WMSServer/WIDESEA_StockService/StockSerivce.cs
+++ b/Code/WMS/WIDESEA_WMSServer/WIDESEA_StockService/StockSerivce.cs
@@ -35,6 +35,11 @@
         public IStockInfo_HtyService StockInfo_HtyService { get; }
 
         /// <summary>
+        /// 浠撳簱鏈嶅姟
+        /// </summary>
+        public IWarehouseService _warehouseService { get; }
+
+        /// <summary>
         /// Mes鎺ュ彛鏈嶅姟
         /// </summary>
         public IMesService _mesService { get; }
@@ -51,13 +56,15 @@
             IStockInfoService stockInfoService,
             IStockInfoDetail_HtyService stockInfoDetail_HtyService,
             IStockInfo_HtyService stockInfo_HtyService,
-            IMesService mesService)
+            IMesService mesService,
+            IWarehouseService warehouseService)
         {
             StockInfoDetailService = stockInfoDetailService;
             StockInfoService = stockInfoService;
             StockInfoDetail_HtyService = stockInfoDetail_HtyService;
             StockInfo_HtyService = stockInfo_HtyService;
             _mesService = mesService;
+            _warehouseService = warehouseService;
         }
 
         /// <summary>
@@ -157,8 +164,7 @@
                     var entity = new Dt_StockInfo
                     {
                         PalletCode = stock.TargetPalletNo,
-                        //WarehouseId = stock.WarehouseId > 0 ? stock.WarehouseId : 1,
-                        WarehouseId = 1,
+                        WarehouseId = stock.Roadway == "娉ㄦ恫缁勭洏鏈烘鎵�" ? (await _warehouseService.Db.Queryable<Dt_Warehouse>().FirstAsync(w => w.WarehouseCode == "GW1")).WarehouseId : 0,
                         StockStatus = StockStatusEmun.缁勭洏鏆傚瓨.GetHashCode(),
                         Creater = "system",
                         Details = details
@@ -166,11 +172,11 @@
                     result = StockInfoService.Repository.AddData(entity, x => x.Details);
                     if (!result) return content.Error("缁勭洏澶辫触");
 
-                    var mesResult = _mesService.BindContainer(bindRequest);
-                    if (mesResult == null || mesResult.Data == null || !mesResult.Data.IsSuccess)
-                    {
-                        return content.Error($"缁勭洏鎴愬姛锛屼絾MES缁戝畾澶辫触: {mesResult?.Data?.Msg ?? mesResult?.ErrorMessage ?? "鏈煡閿欒"}");
-                    }
+                    //var mesResult = _mesService.BindContainer(bindRequest);
+                    //if (mesResult == null || mesResult.Data == null || !mesResult.Data.IsSuccess)
+                    //{
+                    //    return content.Error($"缁勭洏鎴愬姛锛屼絾MES缁戝畾澶辫触: {mesResult?.Data?.Msg ?? mesResult?.ErrorMessage ?? "鏈煡閿欒"}");
+                    //}
                     return content.OK("缁勭洏鎴愬姛");
                 });
             }
@@ -315,6 +321,21 @@
                     if (await StockInfo_HtyService.Repository.AddDataAsync(CreateStockHistory(new[] { sourceStock }, "鎷嗙洏")) <= 0)
                         return content.Error("鎷嗙洏鍘嗗彶璁板綍淇濆瓨澶辫触");
 
+                    // 璋冪敤MES瑙g粦鐢佃姱
+                    var unbindRequest = new UnBindContainerRequest
+                    {
+                        EquipmentCode = "STK-GROUP-001",
+                        ResourceCode = "STK-GROUP-001",
+                        LocalTime = DateTime.Now,
+                        ContainCode = stock.SourcePalletNo,
+                        SfcList = detailEntities.Select(d => d.SerialNumber).ToList()
+                    };
+                    var unbindResult = _mesService.UnBindContainer(unbindRequest);
+                    if (unbindResult == null || unbindResult.Data == null || !unbindResult.Data.IsSuccess)
+                    {
+                        return content.Error($"鎷嗙洏鎴愬姛锛屼絾MES瑙g粦澶辫触: {unbindResult?.Data?.Msg ?? unbindResult?.ErrorMessage ?? "鏈煡閿欒"}");
+                    }
+
                     var result = await StockInfoDetailService.Repository.DeleteDataAsync(detailEntities);
                     if (!result) return content.Error("鎷嗙洏澶辫触");
                     return content.OK("鎷嗙洏鎴愬姛");

--
Gitblit v1.9.3