优化后台实时对局页面

app/process/GameWebSocketServer.php

@@ -5,6 +5,7 @@ declare(strict_types=1);
 namespace app\process;
 
 use app\common\service\GameWebSocketEventBus;
+use app\common\service\GameLiveService;
 use Workerman\Connection\TcpConnection;
 use Workerman\Timer;
 
@@ -17,6 +18,7 @@ class GameWebSocketServer
     private static array $connections = [];
 
     private static bool $eventBusConsumerStarted = false;
+    private static bool $adminSnapshotTickerStarted = false;
 
     /**
      * 从 Redis 队列拉取事件并推送给已订阅连接。
@@ -60,9 +62,52 @@ class GameWebSocketServer
         });
     }
 
+    /**
+     * 兜底直推：admin.live.snapshot 每秒主动构建并广播。
+     * 目的：即使 Redis 队列不可用，也能保证 /admin/game/live 实时看到对局变化。
+     */
+    private static function ensureAdminLiveSnapshotTicker(): void
+    {
+        if (self::$adminSnapshotTickerStarted) {
+            return;
+        }
+        self::$adminSnapshotTickerStarted = true;
+        Timer::add(1, static function (): void {
+            $hasAdminSubscriber = false;
+            foreach (self::$connections as $connection) {
+                $topics = $connection->topics ?? [];
+                if (is_array($topics) && in_array('admin.live.snapshot', $topics, true)) {
+                    $hasAdminSubscriber = true;
+                    break;
+                }
+            }
+            if (!$hasAdminSubscriber) {
+                return;
+            }
+            $snapshot = GameLiveService::buildSnapshot(null);
+            $payload = json_encode([
+                'event' => 'admin.live.snapshot',
+                'topic' => 'admin.live.snapshot',
+                'data' => $snapshot,
+                'server_time' => time(),
+            ], JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
+            if (!is_string($payload) || $payload === '') {
+                return;
+            }
+            foreach (self::$connections as $connection) {
+                $topics = $connection->topics ?? [];
+                if (!is_array($topics) || !in_array('admin.live.snapshot', $topics, true)) {
+                    continue;
+                }
+                $connection->send($payload);
+            }
+        });
+    }
+
     public function onWorkerStart(): void
     {
         self::ensureEventBusConsumer();
+        self::ensureAdminLiveSnapshotTicker();
     }
 
     public function onConnect(TcpConnection $connection): void
@@ -74,6 +119,7 @@ class GameWebSocketServer
     public function onWebSocketConnect(TcpConnection $connection): void
     {
         self::ensureEventBusConsumer();
+        self::ensureAdminLiveSnapshotTicker();
         $connection->send(json_encode([
             'event' => 'ws.connected',
             'message' => 'WebSocket connected',