From 05999b9c77f009ac9a7e98366bc3d23fbb8e83e7 Mon Sep 17 00:00:00 2001
From: wanshenmean <cathay_xy@163.com>
Date: 星期日, 26 四月 2026 17:46:10 +0800
Subject: [PATCH] feat: 更新数据库连接配置和机器人任务处理逻辑

---
 Code/WMS/WIDESEA_WMSServer/WIDESEA_StockService/StockSerivce.cs |   44 ++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 44 insertions(+), 0 deletions(-)

diff --git a/Code/WMS/WIDESEA_WMSServer/WIDESEA_StockService/StockSerivce.cs b/Code/WMS/WIDESEA_WMSServer/WIDESEA_StockService/StockSerivce.cs
index 03fa684..7c21540 100644
--- a/Code/WMS/WIDESEA_WMSServer/WIDESEA_StockService/StockSerivce.cs
+++ b/Code/WMS/WIDESEA_WMSServer/WIDESEA_StockService/StockSerivce.cs
@@ -209,6 +209,30 @@
 
                 return await ExecuteWithinTransactionAsync(async () =>
                 {
+                    // 骞傜瓑鍐欏叆锛氭鏌ヤ复鏃惰〃鏄惁宸叉湁璇ユ墭鐩樿褰曪紝鏃犲垯鍐欏叆
+                    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();
+                            }
+                        }
+                    }
+
                     var sourceStock = await StockInfoService.Repository.QueryDataNavFirstAsync(s => s.PalletCode == stock.SourcePalletNo);
                     if (sourceStock == null) return content.Error("婧愭墭鐩樹笉瀛樺湪");
 
@@ -584,6 +608,26 @@
         }
 
         /// <summary>
+        /// 鏍规嵁鎵樼洏鍙锋煡璇㈠簱瀛樻槑缁嗘暟閲�
+        /// </summary>
+        /// <param name="palletCode">鎵樼洏鍙�</param>
+        /// <returns>搴撳瓨鏄庣粏鏁伴噺</returns>
+        public async Task<WebResponseContent> GetStockDetailCountByPalletCodeAsync(string palletCode)
+        {
+            WebResponseContent content = new WebResponseContent();
+            if (string.IsNullOrWhiteSpace(palletCode))
+                return content.Error("鎵樼洏鍙蜂笉鑳戒负绌�");
+
+            var stockInfo = StockInfoService.Repository.QueryFirst(s => s.PalletCode == palletCode);
+            if (stockInfo == null)
+                return content.Error("鎵樼洏涓嶅瓨鍦�");
+
+            var count = await StockInfoDetailService.Repository.Db.Queryable<Dt_StockInfoDetail>()
+                .CountAsync(d => d.StockId == stockInfo.Id);
+            return content.OK("鏌ヨ鎴愬姛", new { PalletCode = palletCode, DetailCount = count });
+        }
+
+        /// <summary>
         /// 鏍规嵁璁惧鍚嶇О鍜屾墭鐩樺彿瑙f瀽MES璁惧閰嶇疆
         /// </summary>
         /// <param name="deviceName">璁惧鍚嶇О</param>

--
Gitblit v1.9.3