From db8abb437b080fd254c1ac7c7140f1b868165632 Mon Sep 17 00:00:00 2001
From: zhouyonggao <1971162852@qq.com>
Date: Fri, 19 Dec 2025 18:07:35 +0800
Subject: [PATCH] =?UTF-8?q?fix(export):=20=E4=BC=98=E5=8C=96=E5=AF=BC?=
 =?UTF-8?q?=E5=87=BA=E5=AE=8C=E6=88=90=E6=97=B6=E7=9A=84=E7=BC=93=E5=AD=98?=
 =?UTF-8?q?=E6=B8=85=E7=90=86=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 导出完成时将缓存进度更新为实际完成行数，避免超过100%
- 延迟清理缓存，确保完成行数保持到任务完成
- 修改清理缓存时机，提升内存释放的准确性
---
 server/internal/repo/export_repo.go | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/server/internal/repo/export_repo.go b/server/internal/repo/export_repo.go
index 8416b28..88db0ff 100644
--- a/server/internal/repo/export_repo.go
+++ b/server/internal/repo/export_repo.go
@@ -328,8 +328,10 @@ func (r *ExportQueryRepo) MarkCompleted(metaDB *sql.DB, jobID uint64, totalRows
 	if err != nil {
 		logging.DBError("mark_completed", jobID, err)
 	}
-	// 导出完成时清除缓存，释放内存
-	ClearProgress(jobID)
+	// 更新缓存为实际完成的行数，確保不会国100%
+	SetProgress(jobID, totalRows)
+	// 一段时间后清除缓存，释放内存
+	// 不需要立即清除，因为实际完成的行数需要保持到事会完成
 }
 
 // InsertJobFile 插入任务文件记录