From 58a5ed6791a00cb98337525be289dd2d7f33269e Mon Sep 17 00:00:00 2001
From: czw <selecti@yeah.net>
Date: 星期四, 24 七月 2025 10:24:48 +0800
Subject: [PATCH] 1

---
 2025年6月12日/AuxAllWCS/Build/Project/代码/VS自定义类/AutoThread.cs |   32 ++++++++++++++++++++++++++------
 1 files changed, 26 insertions(+), 6 deletions(-)

diff --git "a/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs" "b/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs"
index 6a2d2b8..f3448ea 100644
--- "a/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs"
+++ "b/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs"
@@ -30,6 +30,7 @@
 using System.Net.NetworkInformation;
 using System.Windows.Documents;
 using System.Text.RegularExpressions;
+using GZ.Device.PLC;
 
 namespace GZ.Projects.AuxAllWCS
 {
@@ -113,7 +114,7 @@
             }
             catch (Exception ex)
             {
-                LogHelper.Error($"InvokeMethod > cacheKey-{ex.Message}", ex);
+                LogHelper.Error($"InvokeMethod > cacheKey:{cacheKey}-{ex.Message}", ex);
                 throw ex;
             }
         }
@@ -149,6 +150,7 @@
         //        return _repository;
         //    }
         //}
+
         /// <summary>
         /// 閰嶇疆鍒濆鍖栥�
         /// </summary>
@@ -173,6 +175,7 @@
                 Console.Clear();
             }
         }
+
 
 
         public void ThreaTotal(Tag tag, Device device)
@@ -240,11 +243,26 @@
 
             tasks.Add(GetTask(ThreadMXC5, tag, 3000));
             tasks.Add(GetTask(ThreadMXC6, tag, 3000));
+            tasks.Add(GetTask(ThreadS7helper, tag, 3000));
 
             LogHelper.Info("ThreaTotal 绾跨▼鎬荤嚎runing");
             Task.WaitAll(tasks.ToArray());
             LogHelper.Info("ThreaTotal 绾跨▼鎬荤嚎over");
         }
+
+
+        private void ThreadS7helper(Tag tag)
+        {
+            //var plc = new Plc(CpuType.S71500,);
+
+            //foreach (var item in collection)
+            //{
+            //    S7.Net.Plc plc = new Plc(CpuType.S71500, item.address, 0, 1);
+            //    Link(plc);
+            //    PLCS.Add(item.deviceName, plc);
+            //}
+        }
+
         void taskssss1(Tag tag)
         {
             sa1025(tag);
@@ -264,7 +282,7 @@
             sa3010(tag);
         }
 
-        public static ConcurrentDictionary<string, bool> Iponlines = new ConcurrentDictionary<string, bool>();
+        //public static ConcurrentDictionary<string, bool> Iponlines = new ConcurrentDictionary<string, bool>();
         public bool IsMachineOnline(string hostNameOrIp, int timeout = 1000)
         {
             //device.p鍙戦偅绉�涓嬬嚎.Config.IP
@@ -2451,10 +2469,10 @@
         private void sa2008(Tag tag)
         {
             var rdisTcode = RedisHelper.Get<string>($"Arrive{2008}BarcodeLast", out string msg);
-            LogHelper.Info($"2008 鎵樼洏鍙穥tag.SA2030.R鎵樼洏鐮亇  redis Arrive{2008}BarcodeLast鎵樼洏鍙凤細{rdisTcode} 鍖归厤鏍¢獙銆�);
-            if (!string.IsNullOrEmpty(tag.ssx杈撻�绾�s2008.R鎵樼洏鐮� && rdisTcode != tag.ssx杈撻�绾�s2008.R鎵樼洏鐮�
+            var ntr = tag.ssx杈撻�绾�s2008.R鎵樼洏鐮�
+            LogHelper.Info($"2008 鎵樼洏鍙穥ntr}  redis Arrive{2008}BarcodeLast鎵樼洏鍙凤細{rdisTcode} 鍖归厤鏍¢獙銆�);
+            if (!string.IsNullOrEmpty(ntr) && rdisTcode != ntr)
             {
-                var ntr = tag.ssx杈撻�绾�s2008.R鎵樼洏鐮�
                 var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/224", JsonConvert.SerializeObject(new
                 {
                     cntrCode = ntr,
@@ -2642,6 +2660,8 @@
                 LogHelper.Info($"寰幆{i}娆�> 娓呯┖鎺у埗鍙般�");
                 i = 0;
             }
+
+            LogHelper.Info($"_methodCache>>>>"+ _methodCache.Count+">>>>"+JsonConvert.SerializeObject(_methodCache.Keys));
 
             //Console.WriteLine($"SA2030 浠诲姟鐘舵�锛�  =====>");
             //Console.WriteLine($"SA2030 浠诲姟鐘舵�锛歿tag.SA2030.RtaskState}- 绌洪棽{tag.SA2030.R5绌洪棽} - barcode:{tag.SA2030.R鎵樼洏鐮亇");
@@ -3519,7 +3539,7 @@
                     Console.WriteLine($"ip= {ip.ToString()}");
                     new HttpServer(ip.ToString()).HttpServerRun();
                     new TcpServer(ip.ToString());
-                    var server = new EnhancedWebSocketServer($"http://{ip.ToString()}:8809/").StartAsync();
+                    //var server = new EnhancedWebSocketServer($"http://{ip.ToString()}:8809/").StartAsync();
                     //var client = new WebSocketClient($"http://{ip.ToString()}:8809/").ConnectAsync();
                     break;
                 }

--
Gitblit v1.9.1