Commit 8347c0cf by 罗长华

修复加入群聊发送事件失败

parent 02997e8e
...@@ -185,6 +185,10 @@ public class ImGroupServiceImpl implements ImGroupService { ...@@ -185,6 +185,10 @@ public class ImGroupServiceImpl implements ImGroupService {
List<ImClient> clientList = clientService.list(Wrappers.<ImClient>lambdaQuery().eq(ImClient::getFkAppid, List<ImClient> clientList = clientService.list(Wrappers.<ImClient>lambdaQuery().eq(ImClient::getFkAppid,
appId).in(ImClient::getClientId, memberClientIds)); appId).in(ImClient::getClientId, memberClientIds));
List<ImConversationMembers> oldMembers =
conversationMembersService.list(Wrappers.<ImConversationMembers>lambdaQuery()
.eq(ImConversationMembers::getFkConversationId, conversation.getId()));
// 查找已经在群组里的客户端 // 查找已经在群组里的客户端
List<ImConversationMembers> existMemberList = List<ImConversationMembers> existMemberList =
conversationMembersService.list(Wrappers.<ImConversationMembers>lambdaQuery() conversationMembersService.list(Wrappers.<ImConversationMembers>lambdaQuery()
...@@ -231,7 +235,7 @@ public class ImGroupServiceImpl implements ImGroupService { ...@@ -231,7 +235,7 @@ public class ImGroupServiceImpl implements ImGroupService {
imApplication, inviter, conversation, JsonUtils.encodeJson(content)); imApplication, inviter, conversation, JsonUtils.encodeJson(content));
boolean save = imMessageService.save(imMessage); boolean save = imMessageService.save(imMessage);
// 发送给在群内的成员 // 发送给在群内的成员
conversationService.sendMsgToMembers(conversation, existMemberList, inviter, imMessage, content); conversationService.sendMsgToMembers(conversation, oldMembers, inviter, imMessage, content);
// 发送给被邀请人 // 发送给被邀请人
couriers.deliver(imMessage, content, inviter, newMember, WsResponseCmdEnum.CONVERSATION_EVENT_MSG); couriers.deliver(imMessage, content, inviter, newMember, WsResponseCmdEnum.CONVERSATION_EVENT_MSG);
} }
......
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