Method HandleInvalidConnection

api/service/error_handler.go:23–42

HandleInvalidConnection 处理无效连接错误

(batchID, fileID string, err error)

// HandleInvalidConnection 处理无效连接错误
func (h *ErrorHandler) HandleInvalidConnection(batchID, fileID string, err error) error {
	log.Printf("处理无效连接错误: BatchID=%s, FileID=%s, Error=%v", batchID, fileID, err)

	// 1. 清理批次中的文件记录
	if err := h.cleanupFileRecord(batchID, fileID); err != nil {
		log.Printf("清理文件记录失败: %v", err)
	}

	// 2. 清理数据库中的相关记录
	if err := h.cleanupDatabaseRecords(batchID, fileID); err != nil {
		log.Printf("清理数据库记录失败: %v", err)
	}

	// 3. 重置文件状态为可重新上传
	if err := h.resetFileForReupload(batchID, fileID); err != nil {
		log.Printf("重置文件状态失败: %v", err)
	}

	return nil
}

// cleanupFileRecord 清理批次中的文件记录
func (h *ErrorHandler) cleanupFileRecord(batchID, fileID string) error {