From 3c21643d0f032cda00c538b3a42cc9f264943942 Mon Sep 17 00:00:00 2001 From: v Date: Fri, 29 Aug 2025 22:24:29 +0800 Subject: [PATCH] =?UTF-8?q?up.=20=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?= =?UTF-8?q?=E5=86=85=E5=AE=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/event.php | 2 +- app/subscribe/GatewaySubscribe.php | 9 +++------ 2 files changed, 4 insertions(+), 7 deletions(-) diff --git a/app/event.php b/app/event.php index 160c0cd..9203cf3 100644 --- a/app/event.php +++ b/app/event.php @@ -20,6 +20,6 @@ return [ /* * 网关事件订阅类 */ - 'gateway' => GatewaySubscribe::class, + GatewaySubscribe::class, ], ]; diff --git a/app/subscribe/GatewaySubscribe.php b/app/subscribe/GatewaySubscribe.php index 6bb297e..64b256a 100644 --- a/app/subscribe/GatewaySubscribe.php +++ b/app/subscribe/GatewaySubscribe.php @@ -29,8 +29,8 @@ class GatewaySubscribe public function subscribe(Event $event): void { $event->listen('gateway.clientLogin', [$this,'onClientLogin']); - $event->listen('lockClient',[$this,'onLockClient']); - $event->listen('clientClose',[$this,'onClientClose']); + $event->listen('gateway.lockClient',[$this,'onLockClient']); + $event->listen('gateway.clientClose',[$this,'onClientClose']); } /** @@ -42,11 +42,8 @@ class GatewaySubscribe * @throws DbException * @throws ModelNotFoundException */ - public function onClientLogin($data): void + public function onClientLogin(PutMessage $put, SysUser $sysUser): void { - var_dump($data); - var_dump("事件触发 "); - return; $client = SysUserClient::where([ 'client_id' => $put->getClientId(), 'client_name'=> $put->getClientName(),