feat: 完善消息模块，新增多种消息类型和统一消息解析机制

message/cq_message.go

@@ -1,6 +1,76 @@
 package message
 
+import (
+	"encoding/json"
+	"fmt"
+	"sync"
+)
+
+// CQMessage 接口定义了所有 CQ 消息必须实现的方法
 type CQMessage interface {
 	ToCQString() string
 	ParseMessage(data string) error
 }
+
+// RawMessage 用于初始解析 JSON 的通用结构
+type RawMessage struct {
+	Type string          `json:"type"`
+	Data json.RawMessage `json:"data"`
+}
+
+// messageFactory 用于创建具体的消息实例
+type messageFactory func() CQMessage
+
+var (
+	messageFactories = make(map[string]messageFactory)
+	factoryMutex     sync.RWMutex
+)
+
+// RegisterMessageType 注册消息类型和对应的工厂函数
+func RegisterMessageType(messageType string, factory messageFactory) {
+	factoryMutex.Lock()
+	defer factoryMutex.Unlock()
+	messageFactories[messageType] = factory
+}
+
+// CreateMessage 根据类型创建具体的消息实例
+func CreateMessage(messageType string) (CQMessage, error) {
+	factoryMutex.RLock()
+	factory, exists := messageFactories[messageType]
+	factoryMutex.RUnlock()
+
+	if !exists {
+		return nil, fmt.Errorf("未知的消息类型: %s", messageType)
+	}
+
+	return factory(), nil
+}
+
+// ParseCQMessages 解析消息数组
+func ParseCQMessages(jsonData []byte) ([]CQMessage, error) {
+	var rawMessages []RawMessage
+	if err := json.Unmarshal(jsonData, &rawMessages); err != nil {
+		return nil, fmt.Errorf("解析 JSON 数组失败: %v", err)
+	}
+
+	messages := make([]CQMessage, 0, len(rawMessages))
+	for _, raw := range rawMessages {
+		msg, err := CreateMessage(raw.Type)
+		if err != nil {
+			return nil, err
+		}
+
+		// 使用类型断言获取具体类型的Data字段
+		if v, ok := msg.(interface{ SetData(json.RawMessage) error }); ok {
+			if err := v.SetData(raw.Data); err != nil {
+				return nil, fmt.Errorf("解析消息数据失败: %v", err)
+			}
+		} else {
+			return nil, fmt.Errorf("消息类型 %s 未实现 SetData 方法", raw.Type)
+		}
+
+		messages = append(messages, msg)
+	}
+
+	return messages, nil
+}