diff --git a/BaseModule/src/main/java/com/xscm/moduleutil/listener/MessageListenerSingleton.java b/BaseModule/src/main/java/com/xscm/moduleutil/listener/MessageListenerSingleton.java index 97e0dfd8..d74e0fb9 100644 --- a/BaseModule/src/main/java/com/xscm/moduleutil/listener/MessageListenerSingleton.java +++ b/BaseModule/src/main/java/com/xscm/moduleutil/listener/MessageListenerSingleton.java @@ -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); } diff --git a/MainModule/src/main/java/com/xscm/modulemain/activity/room/fragment/ChatRoomFragment.java b/MainModule/src/main/java/com/xscm/modulemain/activity/room/fragment/ChatRoomFragment.java index 7b3bdf5a..00acac2e 100644 --- a/MainModule/src/main/java/com/xscm/modulemain/activity/room/fragment/ChatRoomFragment.java +++ b/MainModule/src/main/java/com/xscm/modulemain/activity/room/fragment/ChatRoomFragment.java @@ -175,8 +175,8 @@ public class ChatRoomFragment extends BaseMvpFragment cachedMessages = MessageListenerSingleton.getInstance().getAndClearCachedMessages(roomId); if (!cachedMessages.isEmpty()) { - LogUtils.d("PublicScreenEaseChatFragment", "处理缓存消息数量: " + cachedMessages.size()); for (RoomMessageEvent message : cachedMessages) { + LogUtils.d("PublicScreenEaseChatFragment", "处理缓存消息数量: " + message.toString()); handleRoomMessage(message); } }