Method CleanupFailedBatch

api/service/error_handler.go:140–170

CleanupFailedBatch 清理失败的批次

(batchID string)

// CleanupFailedBatch 清理失败的批次
func (h *ErrorHandler) CleanupFailedBatch(batchID string) error {
	log.Printf("开始清理失败的批次: BatchID=%s", batchID)

	batch, err := h.batchManager.GetBatch(batchID)
	if err != nil {
		return fmt.Errorf("获取批次失败: %v", err)
	}

	// 清理所有文件记录 - 先收集 keys 避免在遍历时修改 map 导致并发问题
	batch.mu.RLock()
	keys := make([]string, 0, len(batch.Files))
	for fid := range batch.Files {
		keys = append(keys, fid)
	}
	batch.mu.RUnlock()

	for _, fileID := range keys {
		if err := h.HandleInvalidConnection(batchID, fileID, fmt.Errorf("批次清理")); err != nil {
			log.Printf("清理文件失败: FileID=%s, Error=%v", fileID, err)
		}
	}

	// 标记批次为失败状态（在锁内修改状态）
	batch.mu.Lock()
	batch.Status = "failed"
	batch.mu.Unlock()
	h.batchManager.progressStorage.SaveBatch(batch)

	log.Printf("批次清理完成: BatchID=%s", batchID)
	return nil
}

// GetErrorHandler 获取全局错误处理器实例
var globalErrorHandler *ErrorHandler