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 插入任务文件记录