feat: 增强模拟器关闭逻辑，添加状态检查以避免重复操作

- 新增 _emulator_down 标志追踪模拟器关闭状态
- 各等待策略在模拟器关闭时跳过设备操作直接等待
- _wait_close_emulator_or 关闭模拟器后标记状态，跳过 nemu_ipc 释放
- 主循环在模拟器关闭后重新创建 Device 实例以恢复连接
- nemu_ipc.py 添加 io 模块导入和安全的 fileno 检查
- 在 stop 模拟器前先检查实例是否仍在运行，避免已关闭时重复发送 shutdown_player
- 修复 remove_duplicated_path 缺失导入

Author: LGG686

module/device/method/nemu_ipc.py

@@ -1,5 +1,6 @@
 import asyncio
 import ctypes
+import io
 import os
 import sys
 from functools import partial, wraps
@@ -42,6 +43,19 @@ class CaptureStd:
     def __init__(self):
         self.stdout = b''
         self.stderr = b''
+        self.enabled = False
+
+    @staticmethod
+    def _safe_fileno(stream):
+        if stream is None:
+            return None
+        fileno = getattr(stream, 'fileno', None)
+        if not callable(fileno):
+            return None
+        try:
+            return fileno()
+        except (AttributeError, ValueError, OSError, io.UnsupportedOperation):
+            return None
 
     def _redirect_stdout(self, to):
         sys.stdout.close()
@@ -54,8 +68,14 @@ def _redirect_stderr(self, to):
         sys.stderr = os.fdopen(self.fderr, 'w')
 
     def __enter__(self):
-        self.fdout = sys.stdout.fileno()
-        self.fderr = sys.stderr.fileno()
+        self.fdout = self._safe_fileno(sys.stdout)
+        self.fderr = self._safe_fileno(sys.stderr)
+        if self.fdout is None or self.fderr is None:
+            self.enabled = False
+            logger.warning('CaptureStd disabled because stdout/stderr has no valid fileno')
+            return self
+
+        self.enabled = True
         self.reader_out, self.writer_out = os.pipe()
         self.reader_err, self.writer_err = os.pipe()
         self.old_stdout = os.dup(self.fdout)
@@ -68,6 +88,9 @@ def __enter__(self):
         return self
 
     def __exit__(self, exc_type, exc_val, exc_tb):
+        if not self.enabled:
+            return
+
         self._redirect_stdout(to=self.old_stdout)
         self._redirect_stderr(to=self.old_stderr)
         os.close(self.old_stdout)

module/device/platform2/platform_windows.py

@@ -1,4 +1,5 @@
 import ctypes
+import os
 import re
 import subprocess
 import psutil
@@ -10,6 +11,7 @@
 from module.device.handle import Handle
 from module.device.platform2.platform_base import PlatformBase
 from module.device.platform2.emulator_windows import Emulator, EmulatorInstance, EmulatorManager
+from module.device.platform2.emulator_base import remove_duplicated_path
 from module.logger import logger
 
 import ctypes
@@ -114,6 +116,17 @@ def __bool__(self):
         return True
 
 class PlatformWindows(PlatformBase, EmulatorManager):
+    @staticmethod
+    def _normalize_path(path: str) -> str:
+        return os.path.abspath(path).replace('\\', '/').lower()
+
+    def _is_instance_running(self, instance: EmulatorInstance) -> bool:
+        target = self._normalize_path(instance.path)
+        for running_exe in remove_duplicated_path(list(self.iter_running_emulator())):
+            if self._normalize_path(running_exe) == target:
+                return True
+        return False
+
     @classmethod
     def execute(cls, command, show_window=True):
         """
@@ -204,6 +217,9 @@ def _emulator_stop(self, instance: EmulatorInstance):
         Stop a emulator without error handling
         """
         exe: str = instance.emulator.path
+        if not self._is_instance_running(instance):
+            logger.info(f'Emulator already closed, skip stop: {instance.name}')
+            return
         if instance == Emulator.MuMuPlayer:
             # MuMu6 does not have multi instance, kill one means kill all
             # Has 4 processes

script.py

@@ -347,6 +347,10 @@ def _handle_wait_during_idle(self, next_run: datetime) -> bool:
         return func(next_run)
 
     def _wait_close_game(self, next_run: datetime, close_game_limit_time=None) -> bool:
+        if self._emulator_down:
+            logger.info("Emulator is down, skip close_game/goto_main action and wait directly")
+            return self.wait_until(next_run)
+
         if close_game_limit_time and next_run > datetime.now() + timedelta(
             hours=close_game_limit_time.hour, minutes=close_game_limit_time.minute, seconds=close_game_limit_time.second):
             logger.info("Close game during wait")
@@ -363,6 +367,10 @@ def _wait_close_game(self, next_run: datetime, close_game_limit_time=None) -> bo
         return True
 
     def _wait_goto_main(self, next_run: datetime) -> bool:
+        if self._emulator_down:
+            logger.info("Emulator is down, skip goto_main and wait directly")
+            return self.wait_until(next_run)
+
         logger.info("Goto main page during wait")
         self.run("GotoMain")
         self.device.release_during_wait()
@@ -372,7 +380,10 @@ def _wait_close_emulator_or(self, next_run: datetime, close_game_limit_time=None
         if close_emulator_limit_time and next_run > datetime.now() + timedelta(
             hours=close_emulator_limit_time.hour, minutes=close_emulator_limit_time.minute, seconds=close_emulator_limit_time.second):
             logger.info("Close emulator during wait")
-            self.device.emulator_stop()
+            if not self._emulator_down:
+                self.device.emulator_stop()
+            else:
+                logger.info("Emulator already closed")
             self._emulator_down = True
             # 模拟器已关闭，不需要释放nemu_ipc连接
             if not self.wait_until(next_run):
@@ -385,6 +396,10 @@ def _wait_close_emulator_or(self, next_run: datetime, close_game_limit_time=None
         return True
 
     def _wait_stay_there(self, next_run: datetime) -> bool:
+        if self._emulator_down:
+            logger.info("Stay_there during wait (emulator is down)")
+            return self.wait_until(next_run)
+
         logger.info("Stay_there (no action) during wait")
         self.device.release_during_wait()
         return self.wait_until(next_run)