Function executeWorkflowDirect

api/controller/relay/relay_workflow.go:223–247

executeWorkflowDirect 直接执行工作流，简化参数传递

(c *gin.Context, workflowRequest *WorkflowRunRequest, agent *model.Agent, channel *model.Channel, modelName string)

// executeWorkflowDirect 直接执行工作流，简化参数传递
func executeWorkflowDirect(c *gin.Context, workflowRequest *WorkflowRunRequest, agent *model.Agent, channel *model.Channel, modelName string) (*custom.WorkflowResponseData, error) {
	// 根据渠道类型选择对应的工作流适配器
	if channel.Type == channeltype.Coze || channel.Type == model.ChannelApiTypeCozeStudio {
		return executeCozeWorkflow(c, workflowRequest, agent, channel, modelName)
	}

	if channel.Type == model.ChannelApiDify {
		return executeDifyWorkflowByMode(c, workflowRequest, agent, channel, modelName)
	}

	if channel.Type == channeltype.FastGPT || channel.Type == model.ChannelApiTypeFastGpt {
		// 这个 fastgpt 是因为 适配器的默认给 0 了，所以这里要手动设置一下，实际上数据库里面不会存 1007
		return executeFastGPTWorkflow(c, workflowRequest, agent, channel, modelName)
	}

	if channel.Type == model.ChannelApi53AI {
		return executeAI53Workflow(c, workflowRequest, agent, channel, modelName)
	}

	if channel.Type == model.ChannelApiTypeN8n {
		return executeN8nWorkflow(c, workflowRequest, agent, channel, modelName)
	}

	return nil, fmt.Errorf("不支持的渠道类型: %d", channel.Type)
}

// handleWorkflowError 处理工作流HTTP错误响应
func handleWorkflowError(resp *http.Response, workflowType string) error {