Commit bd85dd2f by Future

未读消息添加在线用户未读消息数量添加

parent bd2e5899
......@@ -295,9 +295,11 @@ public class NormalChatAction {
continue;
}
Integer count = ChannelManager.ONLINE_USER_MAP.get(String.valueOf(member.getFkClientId()));
if (count == null) {
continue;
if (conversation.getMemberCount() > 100) {
Integer count = ChannelManager.ONLINE_USER_MAP.get(String.valueOf(member.getFkClientId()));
if (count == null) {
continue;
}
}
ImInbox imInbox = new ImInbox();
imInbox.setId(SnowflakeUtil.getId());
......
......@@ -655,9 +655,11 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
if (senderClientId.equals(member.getClientId())) {
continue;
}
Integer count = ChannelManager.ONLINE_USER_MAP.get(String.valueOf(member.getFkClientId()));
if (count == null) {
continue;
if (conversation.getMemberCount() > 100) {
Integer count = ChannelManager.ONLINE_USER_MAP.get(String.valueOf(member.getFkClientId()));
if (count == null) {
continue;
}
}
ImInbox imInbox = new ImInbox();
imInbox.setId(SnowflakeUtil.getId());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment