if ((message.getMsgType() == 1001 || message.getMsgType() == 1080) && publicScreenListeners.isEmpty()) {
cacheMessage(message.getRoomId(), message);
}
This commit is contained in:
@@ -203,7 +203,7 @@ public class MessageListenerSingleton {
|
||||
if (TextUtils.isEmpty(roomId)) {
|
||||
return;
|
||||
}
|
||||
|
||||
mRoomId = roomId;
|
||||
synchronized (groupOperationLock) {
|
||||
if (isGroupOperationInProgress) {
|
||||
// 如果有操作正在进行,延迟执行
|
||||
@@ -397,7 +397,7 @@ public class MessageListenerSingleton {
|
||||
// 使用默认解析
|
||||
event = GsonUtils.fromJson(message, RoomMessageEvent.class);
|
||||
}
|
||||
|
||||
LogUtils.e("收到群自定义消息:"+mRoomId+"===" + event);
|
||||
// event = GsonUtils.fromJson(message, RoomMessageEvent.class);
|
||||
} catch (Exception e) {
|
||||
// 处理 JSON 解析过程中可能出现的异常,例如记录日志
|
||||
@@ -644,7 +644,7 @@ public class MessageListenerSingleton {
|
||||
// listener.onMessageReceived(message);
|
||||
// }
|
||||
|
||||
if (message.getMsgType() == 1001 && publicScreenListeners.isEmpty()) {
|
||||
if ((message.getMsgType() == 1001 || message.getMsgType() == 1080) && publicScreenListeners.isEmpty()) {
|
||||
cacheMessage(message.getRoomId(), message);
|
||||
}
|
||||
|
||||
|
||||
@@ -175,8 +175,8 @@ public class ChatRoomFragment extends BaseMvpFragment<ChatRoomPresenter, RoomFra
|
||||
// 获取并处理缓存的消息
|
||||
List<RoomMessageEvent> cachedMessages = MessageListenerSingleton.getInstance().getAndClearCachedMessages(roomId);
|
||||
if (!cachedMessages.isEmpty()) {
|
||||
LogUtils.d("PublicScreenEaseChatFragment", "处理缓存消息数量: " + cachedMessages.size());
|
||||
for (RoomMessageEvent message : cachedMessages) {
|
||||
LogUtils.d("PublicScreenEaseChatFragment", "处理缓存消息数量: " + message.toString());
|
||||
handleRoomMessage(message);
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user