Skip to content

W
wecloud_im_server
Commit 1859e55a by Future
Options

群聊消息添加多线程操作

parent 36cd4e3e
Showing with 4 additions and 4 deletions
core/src/main/java/com/wecloud/im/service/impl/ImConversationServiceImpl.java
...@@ -1353,7 +1353,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap ...@@ -1353,7 +1353,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
List<ImConversationMembers> memberList = List<ImConversationMembers> memberList =
imConversationMembersService.list(Wrappers.<ImConversationMembers>lambdaQuery().eq(ImConversationMembers::getFkConversationId, existConversation.getId())); imConversationMembersService.list(Wrappers.<ImConversationMembers>lambdaQuery().eq(ImConversationMembers::getFkConversationId, existConversation.getId()));
for (ImConversationMembers members : memberList) { for (ImConversationMembers members : memberList) {
members.setDisplayStatus(1L); members.setDisplayStatus(1);
} }
imConversationMembersService.updateBatchById(memberList); imConversationMembersService.updateBatchById(memberList);
...@@ -1403,7 +1403,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap ...@@ -1403,7 +1403,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
List<ImConversationMembers> memberList = List<ImConversationMembers> memberList =
imConversationMembersService.list(Wrappers.<ImConversationMembers>lambdaQuery().eq(ImConversationMembers::getFkConversationId, existConversation.getId())); imConversationMembersService.list(Wrappers.<ImConversationMembers>lambdaQuery().eq(ImConversationMembers::getFkConversationId, existConversation.getId()));
for (ImConversationMembers members : memberList) { for (ImConversationMembers members : memberList) {
members.setDisplayStatus(1L); members.setDisplayStatus(1);
} }
imConversationMembersService.updateBatchById(memberList); imConversationMembersService.updateBatchById(memberList);
...@@ -1420,7 +1420,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap ...@@ -1420,7 +1420,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
// 如果是陌生人，刚创建会话的时候 会话类型设置为临时会话 双方都不可见 // 如果是陌生人，刚创建会话的时候 会话类型设置为临时会话 双方都不可见
conversation.setChatType(ChatTypeEnum.TEMP.getCode()); conversation.setChatType(ChatTypeEnum.TEMP.getCode());
for (ImConversationMembers members : conversationMemberList) { for (ImConversationMembers members : conversationMemberList) {
members.setDisplayStatus(0L); members.setDisplayStatus(0);
} }
} }
this.save(conversation); this.save(conversation);
...@@ -1600,7 +1600,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap ...@@ -1600,7 +1600,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
imConversationMembers.setFkConversationId(conversationId); imConversationMembers.setFkConversationId(conversationId);
imConversationMembers.setFkClientId(member.getId()); imConversationMembers.setFkClientId(member.getId());
imConversationMembers.setClientId(member.getClientId()); imConversationMembers.setClientId(member.getClientId());
imConversationMembers.setDisplayStatus(1L); imConversationMembers.setDisplayStatus(1);
if (role.equals(GroupRoleEnum.OWNER)) { if (role.equals(GroupRoleEnum.OWNER)) {
imConversationMembers.setRole(GroupRoleEnum.OWNER.getCode()); imConversationMembers.setRole(GroupRoleEnum.OWNER.getCode());
// 会话拥有者加入会话方式固定 // 会话拥有者加入会话方式固定
......
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