refactor: 合并重复实现精简代码 (emitter.rs 统一 emit_serial_data 三份, conn.rs 泛型 pump_read_loop 合并串口/TCP 读循环, spawn_idf_bat 收敛 ESP 子进程样板并补 CREATE_NO_WINDOW 修取消烧录闪黑窗, ConnCore::set/is_reconnecting 收敛状态样板, utils.js copyText/textToUtf8Bytes/textToHex/pad2/fileStamp 收敛前端重复工具, menu.js 下拉样板 helpers 收敛清选中与键盘导航)

Author: Martlet-Tech

src-tauri/src/conn.rs

@@ -17,6 +17,80 @@ pub fn validate_mode(mode: u8) -> bool {
 
 const IO_STATS_INTERVAL: Duration = Duration::from_millis(250);
 
+/// 读取间隔静默判定：空闲超过该时长即把已累积的数据作为一帧推出。
+/// 串口 / TCP / UDP / SSH 四条兄弟管线共用同一阈值。
+pub const GAP_TIMEOUT: Duration = Duration::from_millis(5);
+
+/// 读取泵的退出原因（兄弟管线共用，见 [`pump_read_loop`]）。
+#[derive(Clone, Copy, PartialEq)]
+pub enum ReadLoopEnd {
+    /// 外部请求停止（关闭端口 / 代次过期）。
+    Stopped,
+    /// 读错误或对端关闭，连接已不可用。
+    DeviceLost,
+}
+
+/// 统一的接收读取泵：所有兄弟连接（串口 / TCP）共用同一套成帧逻辑——
+/// 累积到 4096 字节立即成帧，或空闲超过 [`GAP_TIMEOUT`] 后把残留作为一帧推出。
+///
+/// 停止/让位判定与 EOF 行为各不相同，通过参数注入：
+/// - `label`: 日志上下文（"Serial" / "TCP" …）
+/// - `should_stop`: 请求停止或代次过期
+/// - `is_parked`: 工具占用管线时让位（烧录 / 监控期间不读）
+/// - `on_eof`: 读到 EOF 时的处理；串口无 EOF 语义传 `None`
+pub fn pump_read_loop<R: Read>(
+    reader: R,
+    meter: Arc<Meter>,
+    app: &tauri::AppHandle,
+    label: &str,
+    should_stop: impl Fn() -> bool,
+    is_parked: impl Fn() -> bool,
+    on_eof: Option<Box<dyn Fn() -> ReadLoopEnd>>,
+) -> ReadLoopEnd {
+    let mut reader = MeteredReader::new(reader, meter);
+    let mut buf = [0u8; 4096];
+    let mut acc: Vec<u8> = Vec::new();
+    let mut last_time = Instant::now();
+
+    loop {
+        if should_stop() {
+            if !acc.is_empty() {
+                crate::emitter::emit_serial_data(app, acc.clone(), true);
+            }
+            return ReadLoopEnd::Stopped;
+        }
+        if is_parked() {
+            std::thread::sleep(Duration::from_millis(10));
+            continue;
+        }
+        match reader.read(&mut buf) {
+            Ok(0) => {
+                if let Some(end) = on_eof {
+                    return end();
+                }
+            }
+            Ok(n) if n > 0 => {
+                acc.extend_from_slice(&buf[..n]);
+                last_time = Instant::now();
+                if acc.len() >= 4096 {
+                    crate::emitter::emit_serial_data(app, std::mem::take(&mut acc), false);
+                }
+            }
+            Err(ref e) if e.kind() == std::io::ErrorKind::TimedOut => {
+                if !acc.is_empty() && last_time.elapsed() >= GAP_TIMEOUT {
+                    crate::emitter::emit_serial_data(app, std::mem::take(&mut acc), true);
+                }
+                std::thread::sleep(Duration::from_millis(10));
+            }
+            Err(e) => {
+                log::warn!("{} read error: {}", label, e);
+                return ReadLoopEnd::DeviceLost;
+            }
+            _ => {}
+        }
+    }
+}
+
 /// 收发字节计数：连接管线上的非侵入装饰（计数 + 节流 io-stats 事件内聚）。
 /// 兄弟连接（串口/TCP/UDP/未来 SSH）共享同一实例；`info()` 与前端状态栏
 /// 均从它取值，清空按钮经 `reset_and_emit` 联动归零。

src-tauri/src/emitter.rs

@@ -0,0 +1,14 @@
+//! 前端接收帧的统一出口。
+//!
+//! 串口 / TCP / UDP / SSH 四条兄弟管线把数据以同一个 `serial-data` 事件
+//! 推给前端，emit 逻辑因此收敛到一处：各 cmd 模块只管读，不管怎么发。
+
+use tauri::Emitter;
+
+/// 推送一帧接收数据。`frame_end` 标记该帧是否完整（用于前端帧聚合）。
+pub(crate) fn emit_serial_data(app: &tauri::AppHandle, data: Vec<u8>, frame_end: bool) {
+    let _ = app.emit(
+        "serial-data",
+        serde_json::json!({ "bytes": data, "frameEnd": frame_end }),
+    );
+}

src-tauri/src/encoding_utils.rs

@@ -174,6 +174,7 @@ pub(crate) fn get_port_description(name: &str) -> Option<String> {
     #[cfg(windows)]
     {
         use std::os::windows::process::CommandExt;
+        // CREATE_NO_WINDOW：wmic 只是查数据，不该闪出控制台窗口。
         cmd.creation_flags(0x08000000);
     }
     let output = cmd

src-tauri/src/esp_cmd.rs

@@ -268,6 +268,36 @@ fn write_step_bat(script: &str) -> Result<PathBuf, String> {
     Ok(bat)
 }
 
+/// CREATE_NO_WINDOW：所有子进程都不该弹出控制台窗口（烧录、环境探测、
+/// 取消时的 taskkill 同理），否则取消烧录会闪出黑窗。
+const CREATE_NO_WINDOW: u32 = 0x08000000;
+
+/// 统一的 IDF 子进程启动样板：写临时 bat → 剥离 MSYS 变量 → 双管道 spawn。
+/// 错误以原始 `io::Error` 返回，由调用方按其上下文格式化文案。
+fn spawn_idf_bat(cwd: &str, script: &str) -> Result<Child, std::io::Error> {
+    let bat = write_step_bat(script).map_err(std::io::Error::other)?;
+    let bat_path = bat.to_string_lossy().to_string();
+    let mut cmd = Command::new("cmd");
+    cmd.arg("/C")
+        .arg(&bat_path)
+        .current_dir(cwd)
+        .env("PYTHONUNBUFFERED", "1")
+        // 从 Git Bash 启动时这些变量会让 export/activate 脚本拒绝执行。
+        .env_remove("MSYSTEM")
+        .env_remove("MSYS")
+        .env_remove("MINGW_PREFIX")
+        .env_remove("MINGW_CHOST")
+        .env_remove("MSYSTEM_CHOST")
+        .stdout(Stdio::piped())
+        .stderr(Stdio::piped());
+    #[cfg(windows)]
+    {
+        use std::os::windows::process::CommandExt;
+        cmd.creation_flags(CREATE_NO_WINDOW);
+    }
+    cmd.spawn()
+}
+
 /// Runs one raw cmd script (blocking). Returns:
 /// - Ok(true)  success (exit 0)
 /// - Ok(false) non-zero exit
@@ -285,21 +315,7 @@ fn run_cmd(
     script: &str,
     cwd: &str,
 ) -> Result<bool, String> {
-    let bat = write_step_bat(script)?;
-    let bat_path = bat.to_string_lossy().to_string();
-    let mut child = Command::new("cmd")
-        .arg("/C")
-        .arg(&bat_path)
-        .current_dir(cwd)
-        .env("PYTHONUNBUFFERED", "1")
-        .env_remove("MSYSTEM")
-        .env_remove("MSYS")
-        .env_remove("MINGW_PREFIX")
-        .env_remove("MINGW_CHOST")
-        .env_remove("MSYSTEM_CHOST")
-        .stdout(Stdio::piped())
-        .stderr(Stdio::piped())
-        .spawn()
+    let mut child = spawn_idf_bat(cwd, script)
         .map_err(|e| format!("Failed to start {}: {}", stage, e))?;
 
     let stdout = child.stdout.take();
@@ -538,9 +554,14 @@ pub async fn esp_flash_cancel(handle: tauri::State<'_, EspHandle>) -> Result<(),
     if let Some(mut c) = child {
         let pid = c.id();
         let _ = c.kill();
-        let _ = Command::new("taskkill")
-            .args(["/PID", &pid.to_string(), "/T", "/F"])
-            .output();
+        let mut cmd = Command::new("taskkill");
+        cmd.args(["/PID", &pid.to_string(), "/T", "/F"]);
+        #[cfg(windows)]
+        {
+            use std::os::windows::process::CommandExt;
+            cmd.creation_flags(CREATE_NO_WINDOW);
+        }
+        let _ = cmd.output();
     }
     Ok(())
 }
@@ -738,25 +759,7 @@ fn run_probe(python: &str, activate: &Path, idf_path: &str) -> (bool, String) {
         python,
         activate.to_string_lossy()
     );
-    let bat = match write_step_bat(&script) {
-        Ok(b) => b,
-        Err(e) => return (false, e),
-    };
-    let bat_path = bat.to_string_lossy().to_string();
-    let mut child = match Command::new("cmd")
-        .arg("/C")
-        .arg(&bat_path)
-        .current_dir(idf_path)
-        .env("PYTHONUNBUFFERED", "1")
-        .env_remove("MSYSTEM")
-        .env_remove("MSYS")
-        .env_remove("MINGW_PREFIX")
-        .env_remove("MINGW_CHOST")
-        .env_remove("MSYSTEM_CHOST")
-        .stdout(Stdio::piped())
-        .stderr(Stdio::piped())
-        .spawn()
-    {
+    let mut child = match spawn_idf_bat(idf_path, &script) {
         Ok(c) => c,
         Err(e) => return (false, format!("启动失败: {}", e)),
     };

src-tauri/src/lib.rs

@@ -2,6 +2,7 @@ mod serial_cmd;
 mod checksum;
 mod state;
 mod conn;
+mod emitter;
 mod receive_buffer;
 mod mcp_server;
 mod window_helper;