内部使用oa后台

app/Http/Controllers/Api/TestController.php

@@ -6,9 +6,16 @@ use App\Service\WorkFlowService;
 use Illuminate\Http\Request;
 use Illuminate\Support\Facades\Redis;
 use App\Events\MessageSent;
-
+use App\Console\Commands\WebSocketServer;
+use Ratchet\ConnectionInterface;
 class TestController extends BaseController
 {
+    protected $webSocketServer;
+
+    public function __construct(WebSocketServer $webSocketServer)
+    {
+        $this->webSocketServer = $webSocketServer;
+    }
     public function aa(){
 //       (new OaService())->sendWxMsg(1,3,2,48,["T9RMO.202408071529012839","拒绝","2024-08-07 15:29:44","(未填写原因)"],"/pages/ReturnExchangeOrder/detail/detail?order_number=55");
 
@@ -73,8 +80,11 @@ die;
                 'tag' => $request['tag'],
                 'timestamp' => time(),
             ];
-
-            broadcast(new MessageSent(json_encode($logData)))->toOthers();
+            $this->webSocketServer->pushMessageToClients(json_encode($logData));
+//            foreach ($this->clients as $client) {
+//                $client->send(json_encode($logData));
+//            }
+//            broadcast(new MessageSent(json_encode($logData)))->toOthers();
             // 推送数据到 Redis 队列
 //            Redis::rpush($queueName, json_encode($logData));