From 669a8a72482c1d4222f8c5235becb73cbb829934 Mon Sep 17 00:00:00 2001 From: hailin Date: Tue, 24 Feb 2026 01:40:32 -0800 Subject: [PATCH] =?UTF-8?q?fix(snapshot):=20=E8=BF=9B=E5=BA=A6=E5=86=99=20?= =?UTF-8?q?DB=20=E6=94=B9=E4=B8=BA=E6=AF=8F=202=20=E7=A7=92=E4=B8=80?= =?UTF-8?q?=E6=AC=A1=EF=BC=8C=E9=81=BF=E5=85=8D=E5=89=8D=E7=AB=AF=E9=95=BF?= =?UTF-8?q?=E6=97=B6=E9=97=B4=E6=98=BE=E7=A4=BA=200%?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-Authored-By: Claude Opus 4.6 --- .../application/services/snapshot-orchestrator.service.ts | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/backend/services/snapshot-service/src/application/services/snapshot-orchestrator.service.ts b/backend/services/snapshot-service/src/application/services/snapshot-orchestrator.service.ts index cd9b2841..752bc4a8 100644 --- a/backend/services/snapshot-service/src/application/services/snapshot-orchestrator.service.ts +++ b/backend/services/snapshot-service/src/application/services/snapshot-orchestrator.service.ts @@ -112,10 +112,13 @@ export class SnapshotOrchestratorService implements OnModuleInit { throw new Error(`备份处理器不存在: ${target}`); } + let lastDbWriteTime = 0; const result = await handler.execute(outputDir, (percent, msg) => { this.gateway.emitProgress(taskId, target, percent, msg); - // 进度更新不频繁写库，每10%写一次 - if (percent % 10 === 0) { + // 每 2 秒写一次 DB，保证前端轮询能看到进度变化 + const now = Date.now(); + if (now - lastDbWriteTime >= 2000) { + lastDbWriteTime = now; this.repo.updateDetailProgress(taskId, target, percent).catch(() => {}); } });