|
|
@ -61,11 +61,13 @@ class LiveChatMessageService { |
|
|
// 解析消息内容 |
|
|
// 解析消息内容 |
|
|
final messageText = _parseMessageContent(event.message); |
|
|
final messageText = _parseMessageContent(event.message); |
|
|
final messageData = json.decode(messageText) as Map<String, dynamic>; |
|
|
final messageData = json.decode(messageText) as Map<String, dynamic>; |
|
|
|
|
|
|
|
|
|
|
|
print('📥 收到消息: $messageData'); |
|
|
// 只处理聊天消息类型 |
|
|
// 只处理聊天消息类型 |
|
|
if (messageData['type'] == 'chat_message') { |
|
|
if (messageData['type'] == 'chat_message') { |
|
|
final chatMessage = LiveChatMessage.fromJson(messageData); |
|
|
final chatMessage = LiveChatMessage.fromJson(messageData); |
|
|
onMessageReceived?.call(chatMessage); |
|
|
onMessageReceived?.call(chatMessage); |
|
|
|
|
|
}else if(messageData['type'] == 'like_message'){ |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
} catch (e, stackTrace) { |
|
|
} catch (e, stackTrace) { |
|
|
final error = '解析RTM消息失败: $e'; |
|
|
final error = '解析RTM消息失败: $e'; |
|
|
|