From 423911c9dd6e202667a05c63c75b0e296a580519 Mon Sep 17 00:00:00 2001
From: wxw <Administrator@DESKTOP-5BIMHQ3>
Date: 星期三, 18 六月 2025 13:21:08 +0800
Subject: [PATCH] 修改问题

---
 Admin.NET/WCS.Application/PLC/PLCService.cs |   68 ++++++++++++++++++++--------------
 1 files changed, 40 insertions(+), 28 deletions(-)

diff --git a/Admin.NET/WCS.Application/PLC/PLCService.cs b/Admin.NET/WCS.Application/PLC/PLCService.cs
index db502b1..7cee1bc 100644
--- a/Admin.NET/WCS.Application/PLC/PLCService.cs
+++ b/Admin.NET/WCS.Application/PLC/PLCService.cs
@@ -21,6 +21,8 @@
 public static class PLCService
 {
     private static readonly object OLock = new object();
+    private static readonly object RuKuLock = new object();
+    private static readonly object OutLock = new object();
 
     private static readonly ISqlSugarClient _db = SqlSugarSetup.ITenant.GetConnectionScope(SqlSugarConst.MainConfigId);
     private static decimal weight94 = 0;
@@ -108,7 +110,7 @@
                         {
                             #region 璺ㄨ泛鏈轰换鍔″鐞�     ###########
                             // 鍒ゆ柇鐩爣浣嶇疆鏄惁鏄法璺烘満鍑哄簱宸ヤ綅
-                            if (modTask.EndLocate == "266" && modTask.StartRoadway != "R05")
+                            if (modTask.EndLocate == "266")// && modTask.StartRoadway != "R05"
                             {
                                 // 鍒ゆ柇鍏ュ簱宸ヤ綅鏄惁瀛樺湪鏈畬鎴愮殑鍏ュ簱浠诲姟
                                 var modInTask = _db.Queryable<WcsTask>().OrderBy(m => m.Levels, OrderByType.Asc).OrderBy(m => m.CreateTime, OrderByType.Asc)
@@ -133,17 +135,19 @@
                                         break;
                                     }
                                 }
-
-                                string aaa = PLCCommon.RoadwayToOutStationNum(modTask.StartRoadway, "1");  // 鑾峰彇1妤间腑涓撳伐浣嶅彿
-                                taskInfo.Ip = PLCCommon.GetPlcIp(aaa).PlcIP;
-                                taskInfo.EndPai = "2";
-                                taskInfo.EndLie = "60";
-                                taskInfo.EndCeng = "1";
-                                taskInfo.EndStation = aaa;
+                                if (modTask.StartRoadway != "R05")
+                                {
+                                    string aaa = PLCCommon.RoadwayToOutStationNum(modTask.StartRoadway, "1");  // 鑾峰彇1妤间腑涓撳伐浣嶅彿
+                                    taskInfo.Ip = PLCCommon.GetPlcIp(aaa).PlcIP;
+                                    taskInfo.EndPai = "2";
+                                    taskInfo.EndLie = "60";
+                                    taskInfo.EndCeng = "1";
+                                    taskInfo.EndStation = aaa;
+                                }                               
 
                             }
 
-                            if (modTask.EndLocate == "265" && modTask.StartRoadway != "R05" && modTask.StartRoadway != "R06") 
+                            if (modTask.EndLocate == "265") // && modTask.StartRoadway != "R05" && modTask.StartRoadway != "R06"
                             {
                                 // 鍒ゆ柇鍏ュ簱宸ヤ綅鏄惁瀛樺湪鏈畬鎴愮殑鍏ュ簱浠诲姟
                                 var modInTask = _db.Queryable<WcsTask>().OrderBy(m => m.Levels, OrderByType.Asc).OrderBy(m => m.CreateTime, OrderByType.Asc)
@@ -168,13 +172,15 @@
                                         break;
                                     }
                                 }
-
-                                string aaa = PLCCommon.RoadwayToOutStationNum(modTask.StartRoadway, "1");  // 鑾峰彇1妤间腑涓撳伐浣嶅彿
-                                taskInfo.Ip = PLCCommon.GetPlcIp(aaa).PlcIP;
-                                taskInfo.EndPai = "2";
-                                taskInfo.EndLie = "60";
-                                taskInfo.EndCeng = "1";
-                                taskInfo.EndStation = aaa;
+                                if (modTask.StartRoadway != "R05" && modTask.StartRoadway != "R06")
+                                {
+                                    string aaa = PLCCommon.RoadwayToOutStationNum(modTask.StartRoadway, "1");  // 鑾峰彇1妤间腑涓撳伐浣嶅彿
+                                    taskInfo.Ip = PLCCommon.GetPlcIp(aaa).PlcIP;
+                                    taskInfo.EndPai = "2";
+                                    taskInfo.EndLie = "60";
+                                    taskInfo.EndCeng = "1";
+                                    taskInfo.EndStation = aaa;
+                                }                                
                             }
 
                             // 鍐欏叆鏀捐揣宸ヤ綅鍥哄畾鍦板潃
@@ -1814,9 +1820,12 @@
                     #endregion
 
                     var http = new HttpService();
-                    string TaskNo = "";
-                    // 鍚慦MS鐢宠鍌ㄤ綅淇℃伅
-                    strMsg = http.RequestLocate(palletVal, modDevice.StationNum, taskModel, roadway, ref TaskNo, (int)taskInfo2.PalletQty);
+                    string TaskNo = "";                    
+                    lock (RuKuLock)
+                    {
+                        // 鍚慦MS鐢宠鍌ㄤ綅淇℃伅
+                        strMsg = http.RequestLocate(palletVal, modDevice.StationNum, taskModel, roadway, ref TaskNo, (int)taskInfo2.PalletQty);
+                    }                        
 
                     // 鏍规嵁浠诲姟鍙疯幏鍙栬捣濮嬪伐浣嶅湴鍧�锛屾牴鎹捣濮嬪伐浣嶅湴鍧�鑾峰彇LEDIP 鎺ㄩ�佸埌LED灞忓箷銆�
                     var taskInfo = _db.Queryable<WcsTask>().First(w => w.TaskNo == TaskNo);
@@ -2388,15 +2397,18 @@
                                 TaskType = ((int)TaskTypeEnum.Out).ToString(),
                                 TaskStatus = ((int)TaskStatusEnum.Complete).ToString()
                             };
-                            HttpService httpService = new HttpService();
-                            var modResponseTask = httpService.RequestTask(requestMode).Result;
-                            if (modResponseTask.StatusCode == 0)
-                            {
-                                modInsertTaskMonitor.InteractiveMsg += "锛岃繑鍥炵粰WMS浠诲姟瀹屾垚";
-                            }
-                            else
-                            {
-                                Log.Error(string.Format("浠诲姟鍙嶉澶辫触锛歋tatusCode锛歿0};Msg锛歿1}", modResponseTask.StatusCode, modResponseTask.Msg));
+                            lock(OutLock)
+                            { 
+                                HttpService httpService = new HttpService();
+                                var modResponseTask = httpService.RequestTask(requestMode).Result;
+                                if (modResponseTask.StatusCode == 0)
+                                {
+                                    modInsertTaskMonitor.InteractiveMsg += "锛岃繑鍥炵粰WMS浠诲姟瀹屾垚";
+                                }
+                                else
+                                {
+                                    Log.Error(string.Format("浠诲姟鍙嶉澶辫触锛歋tatusCode锛歿0};Msg锛歿1}", modResponseTask.StatusCode, modResponseTask.Msg));
+                                }
                             }
                         }
 

--
Gitblit v1.8.0