From 3e94fbf4c0861fa2ae9af5c3879d9c3d67806928 Mon Sep 17 00:00:00 2001
From: u2nyakim <u2nyakim@gmail.com>
Date: Thu, 28 Aug 2025 17:51:45 +0800
Subject: [PATCH] =?UTF-8?q?up.=20=E6=B7=BB=E5=8A=A0worker=E7=9A=84admin:wo?=
 =?UTF-8?q?rker?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/command/admin/Worker.php          | 14 +++++++++-----
 app/http/worker/AdminWorkerHandle.php | 15 ---------------
 2 files changed, 9 insertions(+), 20 deletions(-)
 delete mode 100644 app/http/worker/AdminWorkerHandle.php

diff --git a/app/command/admin/Worker.php b/app/command/admin/Worker.php
index 0550091..8477da5 100644
--- a/app/command/admin/Worker.php
+++ b/app/command/admin/Worker.php
@@ -3,7 +3,6 @@
 namespace app\command\admin;
 
 
-use app\http\worker\AdminWorkerHandle;
 use think\console\Command;
 use think\console\Input;
 use think\console\input\Argument;
@@ -39,14 +38,19 @@ class Worker extends Command
         } else if ($mode == 'g') {
             $argv[] = '-g';
         }
-        $handle = new AdminWorkerHandle();
 
         /*
          * 创建后台ws链接
          */
-        $adminWorker = new WmWorker('ws://0.0.0.0:19980');
-        $adminWorker->onMessage = [$handle, 'onMessage'];
-        $adminWorker->onClose = [$handle, 'onClose'];
+        $adminWorker = new WmWorker('websocket://0.0.0.0:19980');
+        $adminWorker->onMessage = function ($connection, $message) {
+            var_dump($message);
+            $this->app->event->trigger('admin.websocket.Open', $connection, $message);
+        };
+        $adminWorker->onClose = function ($connection, $message) {
+            var_dump($message);
+            $this->app->event->trigger('admin.websocket.Close', $connection, $message);
+        };
 
         WmWorker::runAll();
     }
diff --git a/app/http/worker/AdminWorkerHandle.php b/app/http/worker/AdminWorkerHandle.php
deleted file mode 100644
index 8576aa0..0000000
--- a/app/http/worker/AdminWorkerHandle.php
+++ /dev/null
@@ -1,15 +0,0 @@
-<?php
-namespace app\http\worker;
-
-class AdminWorkerHandle
-{
-    public function onMessage($connection,$data)
-    {
-        $connection->send(json_encode($data));
-    }
-
-    public function onClose()
-    {
-
-    }
-}
\ No newline at end of file