From 9419ec6e2825e3e5b6e4c8f9fc7feabfe7d6ad9b Mon Sep 17 00:00:00 2001
From: SoulStar <gxhsoulstar@163.com>
Date: Mon, 9 Sep 2024 10:29:19 +0800
Subject: [PATCH] =?UTF-8?q?add=20-=20=E6=8E=A5=E5=8F=A3=E6=B5=8B=E8=AF=95?=
 =?UTF-8?q?=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 SlnMesnac.TouchSocket/ApiServer.cs | 19 +++++++++++++++++++
 SlnMesnac.WPF/MainWindow.xaml.cs   |  5 +++++
 2 files changed, 24 insertions(+)

diff --git a/SlnMesnac.TouchSocket/ApiServer.cs b/SlnMesnac.TouchSocket/ApiServer.cs
index 29f2ee3..c5d5212 100644
--- a/SlnMesnac.TouchSocket/ApiServer.cs
+++ b/SlnMesnac.TouchSocket/ApiServer.cs
@@ -31,6 +31,10 @@ namespace SlnMesnac.TouchSocket
 {
     public class ApiServer: RpcServer
     {
+        public ApiServer()
+        {
+            SubscribeToAGVArrivalEvent();
+        }
 
         public delegate void AGVArrivalStart(string message, AGVArrivalSingalEntity aGVArrivalSingalEntity);
         /// <summary>
@@ -70,6 +74,21 @@ namespace SlnMesnac.TouchSocket
             return "Success";
         }
 
+
+        public void SubscribeToAGVArrivalEvent()
+        {
+            // 订阅 AGV 到位事件
+            AGVArrivalStartEvent += OnAGVArrival;
+        }
+
+        // 处理 AGV 到位事件的方法
+        public void OnAGVArrival(string message, AGVArrivalSingalEntity aGVArrivalSingalEntity)
+        {
+            Console.WriteLine($"收到AGV到位信号: {message}");
+            Console.WriteLine($"AGV编号: {aGVArrivalSingalEntity.AGVNo}, 到达位置: {aGVArrivalSingalEntity.DestinationNo}");
+            // 这里可以处理更多的业务逻辑，比如记录日志、更新系统状态等
+        }
+
     }
 
 }
diff --git a/SlnMesnac.WPF/MainWindow.xaml.cs b/SlnMesnac.WPF/MainWindow.xaml.cs
index df5d322..6a06a5e 100644
--- a/SlnMesnac.WPF/MainWindow.xaml.cs
+++ b/SlnMesnac.WPF/MainWindow.xaml.cs
@@ -34,6 +34,11 @@ namespace SlnMesnac.WPF
         {
             var a = AirPorthttpClient.ManipulatorStateRequest(new ManipulatorStateRequestEntity());
             var b = AirPorthttpClient.AGVStateRequest(new AGVStateRequestEntity());
+
+
+
+
+
             return;
         }
     }