Method cleanupFileRecord

api/service/error_handler.go:45–67

cleanupFileRecord 清理批次中的文件记录

(batchID, fileID string)

// cleanupFileRecord 清理批次中的文件记录
func (h *ErrorHandler) cleanupFileRecord(batchID, fileID string) error {
	batch, err := h.batchManager.GetBatch(batchID)
	if err != nil {
		return fmt.Errorf("获取批次失败: %v", err)
	}

	batch.mu.Lock()
	if fileUpload, exists := batch.Files[fileID]; exists {
		// 标记为失败状态
		fileUpload.Status = "failed"
		fileUpload.Error = "连接异常，请重新上传"
		fileUpload.Progress = 0
		fileUpload.UploadedSize = 0

		// 更新进度（在持有 batch 锁的情况下安全修改）
		// Fix: Use updateFileProgressNoLock to avoid deadlock since we already hold the lock
		h.batchManager.updateFileProgressNoLock(batch, fileID, fileUpload)
		
		log.Printf("已清理文件记录: BatchID=%s, FileID=%s", batchID, fileID)
	}
	batch.mu.Unlock()
	return nil
}

// cleanupDatabaseRecords 清理数据库中的相关记录
func (h *ErrorHandler) cleanupDatabaseRecords(batchID, fileID string) error {