Method updateFileProgress

api/service/batch_upload_manager.go:387–402

updateFileProgress 更新文件进度（对外安全接口） 如果批次存在，会对 batch.mu 加锁后调用 updateFileProgressNoLock；否则直接持久化到 storage

(batchID, fileID string, fileUpload *FileUpload)

// updateFileProgress 更新文件进度（对外安全接口）
// 如果批次存在，会对 batch.mu 加锁后调用 updateFileProgressNoLock；否则直接持久化到 storage
func (m *BatchUploadManager) updateFileProgress(batchID, fileID string, fileUpload *FileUpload) {
	// 先快速获取 batch 指针（使用读锁），避免长期持有全局锁
	m.mu.RLock()
	batch, exists := m.batches[batchID]
	m.mu.RUnlock()
	if !exists {
		// 保存到存储（尽量保持幂等）
		m.progressStorage.UpdateFileProgress(batchID, fileID, fileUpload)
		return
	}

	// 使用 batch 的 mutex 保护对 batch.Files 的写入
	batch.mu.Lock()
	defer batch.mu.Unlock()
	m.updateFileProgressNoLock(batch, fileID, fileUpload)
}

// updateBatchStatus 更新批次状态
func (m *BatchUploadManager) updateBatchStatus(batch *BatchUpload) {