From c2461f320a6b36390d8dd26d4ce11a62baa0e215 Mon Sep 17 00:00:00 2001
From: xxyy <cathay_xy@163.com>
Date: 星期五, 28 二月 2025 10:42:35 +0800
Subject: [PATCH] 更新 .gitignore 和优化任务处理逻辑

---
 Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_BZ/CommonConveyorLine_BZJob.cs |    2 +-
 .gitignore                                                                                            |    6 ++++++
 Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs              |    8 ++++----
 Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs      |   16 +++++++++++++++-
 4 files changed, 26 insertions(+), 6 deletions(-)

diff --git a/.gitignore b/.gitignore
index 1c1e893..c15ec92 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1666,3 +1666,9 @@
 /Code Management/WMS/WIDESEA_WMSServer/.vs/WIDESEA_WMSServer/CopilotIndices/17.12.53.23981/SemanticSymbols.db
 /Code Management/WMS/WIDESEA_WMSServer/.vs/WIDESEA_WMSServer/CopilotIndices/17.12.53.23981/SemanticSymbols.db-shm
 /Code Management/WMS/WIDESEA_WMSServer/.vs/WIDESEA_WMSServer/CopilotIndices/17.12.53.23981/SemanticSymbols.db-wal
+/Code Management/WMS/WIDESEA_WMSServer/.vs/WIDESEA_WMSServer/CopilotIndices/17.13.433.20974/CodeChunks.db
+/Code Management/WMS/WIDESEA_WMSServer/.vs/WIDESEA_WMSServer/CopilotIndices/17.13.433.20974/CodeChunks.db-shm
+/Code Management/WMS/WIDESEA_WMSServer/.vs/WIDESEA_WMSServer/CopilotIndices/17.13.433.20974/CodeChunks.db-wal
+/Code Management/WMS/WIDESEA_WMSServer/.vs/WIDESEA_WMSServer/CopilotIndices/17.13.433.20974/SemanticSymbols.db
+/Code Management/WMS/WIDESEA_WMSServer/.vs/WIDESEA_WMSServer/CopilotIndices/17.13.433.20974/SemanticSymbols.db-shm
+/Code Management/WMS/WIDESEA_WMSServer/.vs/WIDESEA_WMSServer/CopilotIndices/17.13.433.20974/SemanticSymbols.db-wal
diff --git a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_BZ/CommonConveyorLine_BZJob.cs b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_BZ/CommonConveyorLine_BZJob.cs
index 307f12b..2c38342 100644
--- a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_BZ/CommonConveyorLine_BZJob.cs
+++ b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_BZ/CommonConveyorLine_BZJob.cs
@@ -191,7 +191,7 @@
             needBarcode.inLineNum = _taskRepository.QueryData(x => x.TargetAddress == station.stationChildCode).Count();
 
             //鑻ュ湪閫旀暟閲忓皬浜庣洰鏍囦綅缃殑缂撳瓨鏁伴噺 鍒欏鎵惧搴斿父娓╁簱瀛樹腑甯告俯3宸ュ簭鐨勫彲鍑哄簱鏁版嵁 骞跺缓绔嬪嚭搴撲换鍔�
-            if (needBarcode.inLineNum <= needBarcode.cacheNum)
+            if (needBarcode.inLineNum < needBarcode.cacheNum)
             {
                 if (_taskService.RequestOutTaskToBZAsync(station).Result.Status)
                 {
diff --git a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
index d25b73b..d185ef3 100644
--- a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
+++ b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
@@ -896,7 +896,7 @@
                 List<string> strings = stationManagers.Roadway.Split(',').ToList();
                 Console.WriteLine(strings.ToJsonString() + "b-----------------------");
                 //// 璋冪敤CreateNewTask鏂规硶锛屽垱寤烘柊浠诲姟
-                content = await CreateNewTask(input, result.ProductionLine,result.ProcessCode, strings);
+                content = await CreateNewTask(input, result.ProductionLine, result.ProcessCode, strings);
                 if (content.Status)
                 {
                     var isBox = await _boxingInfoRepository.AddDataNavAsync(boxing);
@@ -1128,7 +1128,7 @@
             }
             List<string> strings = stationManagers.Roadway.Split(',').ToList();
 
-            return await CreateNewTask(input, result.ProductionLine, result.ProcessCode,strings, 1);
+            return await CreateNewTask(input, result.ProductionLine, result.ProcessCode, strings, 1);
         }
         catch (Exception)
         {
@@ -1282,7 +1282,7 @@
 
         var devices = SqlSugarHelper.DbWCS.Queryable<Dt_DeviceInfo>()
             .Where(x => x.DeviceStatus == "1")
-            .Where(x => x.DeviceRemark == "1")
+            .Where(x => x.DeviceCode.Contains("CWSC"))
             .ToList();
         var deviceCode = devices.Select(x => x.DeviceCode).ToList();
 
@@ -1734,7 +1734,7 @@
                         TaskNum = await BaseDal.GetTaskNo(),
                         Creater = "Systeam",
                         ProductionLine = result.ProductionLine,
-                        ProcessCode=result.ProcessCode,
+                        ProcessCode = result.ProcessCode,
                     };
 
                     // 鍒涘缓WMS浠诲姟
diff --git a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs
index b95bab5..fa9dab8 100644
--- a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs
+++ b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs
@@ -804,14 +804,21 @@
                 {
                     try
                     {
-                        Thread.Sleep(10000);
+                        Thread.Sleep(TimeSpan.FromMinutes(10));
+
                         var area = await _areaInfoRepository.QueryFirstAsync(x => x.AreaCode == "GWSC1");
+                        var devices = SqlSugarHelper.DbWCS.Queryable<Dt_DeviceInfo>()
+                            .Where(x => x.DeviceStatus == "1")
+                            .Where(x => x.DeviceCode.Contains("GWSC"))
+                            .ToList();
+                        var deviceCode = devices.Select(x => x.DeviceCode).ToList();
 
                         var stockInfo = await _stockInfoRepository.Db.Queryable<DtStockInfo>()
                              .Includes(x => x.LocationInfo) // 棰勫姞杞絃ocationInfo
                              .Includes(x => x.StockInfoDetails) // 棰勫姞杞絊tockInfoDetails
                              .Where(x => x.AreaCode == area.AreaCode && x.OutboundTime < DateTime.Now && x.IsFull == true) // 杩囨护鏉′欢
                              .Where(x => x.LocationInfo.LocationStatus == (int)LocationEnum.InStock && x.LocationInfo.AreaId == area.AreaID) // 杩囨护鏉′欢
+                             .WhereIF(!deviceCode.IsNullOrEmpty(), x => deviceCode.Contains(x.LocationInfo.RoadwayNo))
                              .OrderBy(x => x.OutboundTime) // 鎺掑簭
                              .ToListAsync(); // 鑾峰彇绗竴涓厓绱�
 
@@ -983,12 +990,19 @@
             Dt_StationManager station = _stationManagerRepository.QueryFirst(x => x.stationChildCode == json.Position && x.stationType == 12 && x.stationArea == "Call");
             if (station == null) { throw new Exception($"鏈壘鍒板寘瑁呯珯鍙颁俊鎭紝璇锋鏌ヤ紶鍏ュ弬鏁皗json.Position}"); }
 
+            var devices = SqlSugarHelper.DbWCS.Queryable<Dt_DeviceInfo>()
+                .Where(x => x.DeviceStatus == "1")
+                .Where(x => x.DeviceCode.Contains("GWSC"))
+                .ToList();
+            var deviceCode = devices.Select(x => x.DeviceCode).ToList();
+
             //LogFactory.GetLog("甯告俯3鍑哄簱鑷冲寘瑁�").Info(true, $"甯告俯3鍑哄簱鑷冲寘瑁呬紶鍏ュ弬鏁帮細" + JsonConvert.SerializeObject(json, Formatting.Indented));
             var stockInfo = _stockInfoRepository.Db.Queryable<DtStockInfo>()
                     .Where(x => x.ProductionLine == station.productLine)
                     .Includes(x => x.LocationInfo) // 棰勫姞杞絃ocationInfo
                     .Where(x => x.AreaCode == "CWSC3" && x.IsFull == true) // 杩囨护鏉′欢
                     .Where(x => x.LocationInfo.LocationStatus == (int)LocationEnum.InStock) // 杩囨护鏉′欢
+                    .WhereIF(!deviceCode.IsNullOrEmpty(), x => deviceCode.Contains(x.LocationInfo.RoadwayNo))
                     .OrderBy(x => x.OutboundTime) // 鎺掑簭
                     .First(); // 鑾峰彇绗竴涓厓绱�
 

--
Gitblit v1.9.3