From e4da65b951cc0e7cf91789be8d3a258c982c4328 Mon Sep 17 00:00:00 2001 From: AskaEth Date: Sat, 22 Aug 2026 13:47:29 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20TUI=20=E6=AF=8F=E7=A7=92=E5=AE=9A?= =?UTF-8?q?=E6=97=B6=E5=99=A8=E5=BC=BA=E5=88=B6=E9=87=8D=E7=BB=98=20+=20?= =?UTF-8?q?=E5=B8=A7=E6=95=B0=E7=BB=9F=E8=AE=A1=E5=86=99=E5=85=A5=E6=97=A5?= =?UTF-8?q?=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- transfer.py | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/transfer.py b/transfer.py index 40a1939..572a502 100644 --- a/transfer.py +++ b/transfer.py @@ -437,6 +437,7 @@ class TaskRunner: self.proc: subprocess.Popen | None = None self.stats = ProgressStats() self._stop = threading.Event() + self.stats_frames = 0 # -- 命令构建 def build_command(self) -> list[str]: @@ -540,6 +541,7 @@ class TaskRunner: self.lm.write_error(line) def _emit_stats(self) -> None: + self.stats_frames += 1 if self.on_stats: self.on_stats(self.stats) @@ -578,7 +580,7 @@ class TaskRunner: if self._stop.is_set(): self.proc.kill() rc = self.proc.wait() - self.lm.write(f"exit code: {rc}") + self.lm.write(f"exit code: {rc} (进度帧 {self.stats_frames} 次)") removed = self.lm.prune() if removed: self.lm.write(f"pruned old logs: {len(removed)}") @@ -766,9 +768,16 @@ class TransferApp(App): def on_mount(self) -> None: self.query_one("#file-log", RichLog).write("[green]文件日志[/]") self.query_one("#error-log", RichLog).write("[red]错误日志[/]") + # 每秒定时器: 强制重绘 UI (不依赖帧回调) + self.set_interval(1.0, self._tick) if self.preset: self._start_task(self.preset) + def _tick(self) -> None: + """每秒重绘: 基于 runner 缓存的 stats 刷新进度/文字""" + if self.runner and self._task_running: + self._on_stats(self.runner.stats) + # -- 输入处理 def on_input_submitted(self, event: Input.Submitted) -> None: text = event.value.strip()