Function convertToEnhancedMessages

api/controller/message.go:76–129

convertToEnhancedMessages 将普通消息转换为增强消息

(messages []*model.Message, fileMap map[int64]string)

// convertToEnhancedMessages 将普通消息转换为增强消息
func convertToEnhancedMessages(messages []*model.Message, fileMap map[int64]string) []*EnhancedMessage {
	enhancedMessages := make([]*EnhancedMessage, len(messages))

	for i, msg := range messages {
		enhanced := &EnhancedMessage{
			Message:        msg,
			MessageType:    msg.GetMessageType(),
			ProcessRecords: []*model.MessageProcessStep{},
		}

		// 填充文件名
		if msg.FileID > 0 && fileMap != nil {
			enhanced.FileName = fileMap[msg.FileID]
		}

		// 根据消息类型解析内容
		switch enhanced.MessageType {
		case model.MessageTypeChat:
			// 解析聊天消息
			if parsedMsg, err := msg.ParseChatMessage(); err == nil {
				enhanced.ParsedMessage = parsedMsg
			} else {
				enhanced.ParsedMessage = msg.Message // 解析失败时返回原始内容
			}
			enhanced.ParsedAnswer = msg.Answer // 聊天消息的 answer 就是文本

		case model.MessageTypeWorkflow:
			// 解析工作流消息
			if parsedParams, err := msg.ParseWorkflowParameters(); err == nil {
				enhanced.ParsedMessage = parsedParams
			} else {
				enhanced.ParsedMessage = msg.Message // 解析失败时返回原始内容
			}

			if parsedOutput, err := msg.ParseWorkflowOutput(); err == nil {
				enhanced.ParsedAnswer = parsedOutput
			} else {
				enhanced.ParsedAnswer = msg.Answer // 解析失败时返回原始内容
			}
		}

		// 解析RAG统计数据
		if msg.RAGStats != "" {
			if ragStatsData, err := parseRAGStats(msg.RAGStats); err == nil {
				enhanced.RAGStats = ragStatsData
			}
			// 解析失败时RAGStats保持为nil，不影响其他字段
		}

		enhancedMessages[i] = enhanced
	}

	return enhancedMessages
}

func attachProcessRecords(enhancedMessages []*EnhancedMessage, processRecordMap map[int64][]*model.MessageProcessStep) {
	if len(enhancedMessages) == 0 || len(processRecordMap) == 0 {