feat: 添加LLM插件系统和游戏控制命令

Author: ljzloser

src/main.py

@@ -18,7 +18,8 @@
 # 插件系统（新）
 from plugin_sdk import GameServerBridge
 from plugin_manager.app_paths import get_env_for_subprocess
-from shared_types.commands import NewGameCommand
+from shared_types.commands import NewGameCommand, MouseClickCommand
+from shared_types.enums import GameLevel
 import subprocess
 
 os.environ["QT_FONT_DPI"] = "96"
@@ -202,12 +203,34 @@ def cli_check_file(file_path: str) -> int:
 
         # 注册控制命令处理器（自动在主线程执行）
         def handle_new_game(cmd: NewGameCommand):
-            print(f"[NewGameCommand] rows={cmd.rows}, cols={cmd.cols}, mines={cmd.mines}")
-            ui.setBoard_and_start(cmd.rows, cmd.cols, cmd.mines)
+            """处理新游戏命令"""
             from lib_zmq_plugins.shared.base import CommandResponse
+            
+            # 根据 level 确定参数
+            if cmd.level == GameLevel.BEGINNER.value:
+                rows, cols, mines = 8, 8, 10
+            elif cmd.level == GameLevel.INTERMEDIATE.value:
+                rows, cols, mines = 16, 16, 40
+            elif cmd.level == GameLevel.EXPERT.value:
+                rows, cols, mines = 16, 30, 99
+            else:
+                # 自定义模式，使用传入的参数
+                rows, cols, mines = cmd.rows, cmd.cols, cmd.mines
+            
+            print(f"[NewGameCommand] level={cmd.level}, rows={rows}, cols={cols}, mines={mines}")
+            ui.setBoard_and_start(rows, cols, mines)
             return CommandResponse(request_id=cmd.request_id, success=True)
 
+        def handle_mouse_click(cmd: MouseClickCommand):
+            """处理鼠标点击命令"""
+            from lib_zmq_plugins.shared.base import CommandResponse
+            
+            print(f"[MouseClickCommand] row={cmd.row}, col={cmd.col}, button={cmd.button}")
+            success = ui.execute_cell_click(cmd.row, cmd.col, cmd.button)
+            return CommandResponse(request_id=cmd.request_id, success=success)
+        
         GameServerBridge.instance().register_handler(NewGameCommand, handle_new_game)
+        GameServerBridge.instance().register_handler(MouseClickCommand, handle_mouse_click)
 
         # _translate = QtCore.QCoreApplication.translate
         hwnd = int(ui.mainWindow.winId())

src/mineSweeperGUI.py

@@ -7,7 +7,7 @@
 # from PyQt5.QtWidgets import QApplication, QFileDialog, QWidget
 import gameDefinedParameter
 from plugin_sdk.server_bridge import GameServerBridge
-from shared_types.events import VideoSaveEvent
+from shared_types.events import VideoSaveEvent, BoardUpdateEvent, GameStatusChangeEvent
 import superGUI
 import gameAbout
 import gameSettings
@@ -219,6 +219,8 @@ def game_state(self):
     @game_state.setter
     def game_state(self, game_state: str):
         # print(self._game_state, " -> " ,game_state)
+        last_state = self._game_state
+        
         match self._game_state:
             case "playing":
                 self.try_append_evfs(game_state)
@@ -252,7 +254,29 @@ def game_state(self, game_state: str):
                 self.label.paint_cursor = False
                 self.label.paintProbability = False
                 self.num_bar_ui.QWidget.close()
+        
         self._game_state = game_state
+        
+        # 发送游戏状态变化事件
+        state_map = {
+            "ready": 1,
+            "playing": 2,
+            "win": 3,
+            "fail": 4,
+            "joking": 2,  # joking 也视为游戏中
+            "jowin": 3,
+            "jofail": 4,
+            "show": 5,
+            "study": 6,
+            "display": 7,
+            "showdisplay": 8,
+        }
+        if last_state != game_state:
+            event = GameStatusChangeEvent(
+                last_status=state_map.get(last_state, 0),
+                current_status=state_map.get(game_state, 0),
+            )
+            GameServerBridge.instance().send_event(event)
 
     @property
     def row(self):
@@ -477,6 +501,100 @@ def mineNumWheel(self, i):
             # self.timer_mine_num.setSingleShot(True)
             # self.timer_mine_num.start(3000)
 
+    def _send_board_update_event(self):
+        """发送棋盘更新事件给插件"""
+        try:
+            ms_board = self.label.ms_board
+            # 将 game_board 转换为列表格式
+            game_board_list = []
+            for row in ms_board.game_board:
+                game_board_list.append(list(row))
+            
+            event = BoardUpdateEvent(
+                rows=self.row,
+                cols=self.column,
+                game_board=game_board_list,
+                mines_remaining=self.mineUnFlagedNum,
+                game_time=ms_board.time if hasattr(ms_board, 'time') else 0.0,
+            )
+            GameServerBridge.instance().send_event(event)
+        except Exception:
+            pass  # 忽略发送失败
+
+    def execute_cell_click(self, row: int, col: int, button: int) -> bool:
+        """
+        执行格子点击（供外部命令调用）
+        
+        Args:
+            row: 行索引（从 0 开始）
+            col: 列索引（从 0 开始）
+            button: 鼠标按钮（0=左键, 2=右键）
+        
+        Returns:
+            True 表示成功执行
+        """
+        # 检查游戏状态
+        if self.game_state not in ('ready', 'playing', 'joking'):
+            return False
+        
+        # 检查坐标有效性
+        if row < 0 or row >= self.row or col < 0 or col >= self.column:
+            return False
+        
+        # 转换为像素坐标（中心点）
+        i = row * self.pixSize + self.pixSize // 2
+        j = col * self.pixSize + self.pixSize // 2
+        
+        try:
+            if button == 0:  # 左键
+                # 模拟点击流程：按下 -> 抬起
+                self.label.ms_board.step('lc', (i, j))
+                
+                # 处理第一次点击埋雷
+                if self.game_state == 'ready':
+                    if self.label.ms_board.mouse_state == 4:
+                        if self.board_constraint:
+                            self.game_state = 'joking'
+                        else:
+                            self.game_state = 'playing'
+                        if self.player_identifier[:6] != "[live]":
+                            self.disable_screenshot()
+                        if self.cursor_limit:
+                            self.limit_cursor()
+                        self.start_time_unix_2 = QtCore.QDateTime.currentDateTime().toMSecsSinceEpoch()
+                        self.timer_10ms.start()
+                        self.score_board_manager.editing_row = -2
+                        # 埋雷
+                        self.layMine(row, col)
+                
+                self.label.ms_board.step('lr', (i, j))
+                
+                # 检查游戏结束
+                if self.label.ms_board.game_board_state == 3:
+                    self.gameWin()
+                elif self.label.ms_board.game_board_state == 4:
+                    self.gameFailed()
+                    
+            elif button == 2:  # 右键
+                # 更新剩余雷数
+                cell_state = self.label.ms_board.game_board[row][col]
+                if cell_state == 11:  # 已标旗，取消标旗
+                    self.mineUnFlagedNum += 1
+                    self.showMineNum(self.mineUnFlagedNum)
+                elif cell_state == 10:  # 未揭开，标旗
+                    self.mineUnFlagedNum -= 1
+                    self.showMineNum(self.mineUnFlagedNum)
+                
+                self.label.ms_board.step('rc', (i, j))
+                self.label.ms_board.step('rr', (i, j))
+            
+            self.label.update()
+            self._send_board_update_event()
+            return True
+            
+        except Exception:
+            return False
+
     def gameStart(self):
         # 画界面，但是不埋雷。等价于点脸、f2、设置确定后的效果
         self.mineUnFlagedNum = self.minenum  # 没有标出的雷，显示在左上角
@@ -570,6 +688,9 @@ def gameFinished(self):
                     data[key] = getattr(ms_board, key)
             event = VideoSaveEvent(**data)
             GameServerBridge.instance().send_event(event)
+        
+        # 发送棋盘更新事件，让插件知道最终状态
+        self._send_board_update_event()
 
     def gameWin(self):  # 成功后改脸和状态变量，停时间
         self.timer_10ms.stop()

src/mineSweeperGUIEvent.py

@@ -69,6 +69,7 @@ def mineAreaLeftRelease(self, i, j):
                     return
                 else:
                     self.label.update()
+                    self._send_board_update_event()
             self.set_face(14)
         elif self.game_state == 'playing' or self.game_state == 'joking':
             # 如果是游戏中，且是左键抬起（不是双击），且是在10上，且在局面内，则用ai劫持、处理下
@@ -88,6 +89,7 @@ def mineAreaLeftRelease(self, i, j):
                 self.label.update()
                 return
             self.label.update()
+            self._send_board_update_event()
             self.set_face(14)
 
         elif self.game_state == 'show':
@@ -121,6 +123,7 @@ def mineAreaRightRelease(self, i, j):
             self.chording_ai(i // self.pixSize, j // self.pixSize)
             self.label.ms_board.step('rr', (i, j))
             self.label.update()
+            self._send_board_update_event()
             self.set_face(14)
         elif self.game_state == 'show':
             # 看概率时，所有操作都移出局面外

src/plugins/llm_minesweeper_controller/__init__.py

@@ -0,0 +1,8 @@
+"""
+llm_minesweeper_controller - 使用requests进行反向控制扫雷并处理func calling的插件
+"""
+from __future__ import annotations
+
+from .plugin import LlmMinesweeperControllerPlugin
+
+__all__ = ["LlmMinesweeperControllerPlugin"]