fix(export): 优化导出完成时的缓存清理逻辑

- 导出完成时将缓存进度更新为实际完成行数,避免超过100%
- 延迟清理缓存,确保完成行数保持到任务完成
- 修改清理缓存时机,提升内存释放的准确性
This commit is contained in:
zhouyonggao 2025-12-19 18:07:35 +08:00
parent 328a8ced3a
commit db8abb437b
1 changed files with 4 additions and 2 deletions

View File

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