Commit f78c4891 by wei

修改被拉入群没有事件通知bug

parent 126f953c
...@@ -244,6 +244,10 @@ public class ImConversationMembersServiceImpl extends BaseServiceImpl<ImConversa ...@@ -244,6 +244,10 @@ public class ImConversationMembersServiceImpl extends BaseServiceImpl<ImConversa
return true; return true;
} }
ImClient operatorClient = imClientService.getOne(new QueryWrapper<ImClient>().lambda()
.eq(ImClient::getFkAppid, imApplication.getId())
.eq(ImClient::getClientId, imConversationMemApiAdd.getOperator()));
ImClient passivityOperatorClient = imClientService.getOne(new QueryWrapper<ImClient>().lambda() ImClient passivityOperatorClient = imClientService.getOne(new QueryWrapper<ImClient>().lambda()
.eq(ImClient::getFkAppid, imApplication.getId()) .eq(ImClient::getFkAppid, imApplication.getId())
.eq(ImClient::getClientId, imConversationMemApiAdd.getPassivityOperator())); .eq(ImClient::getClientId, imConversationMemApiAdd.getPassivityOperator()));
...@@ -294,7 +298,7 @@ public class ImConversationMembersServiceImpl extends BaseServiceImpl<ImConversa ...@@ -294,7 +298,7 @@ public class ImConversationMembersServiceImpl extends BaseServiceImpl<ImConversa
imMessage.setId(messageId); imMessage.setId(messageId);
imMessage.setCreateTime(new Date()); imMessage.setCreateTime(new Date());
imMessage.setFkAppid(imApplication.getId()); imMessage.setFkAppid(imApplication.getId());
imMessage.setSender(0L); imMessage.setSender(operatorClient.getId());
imMessage.setWithdraw(false); imMessage.setWithdraw(false);
imMessage.setEvent(true); imMessage.setEvent(true);
imMessage.setSystem(false); imMessage.setSystem(false);
...@@ -304,7 +308,7 @@ public class ImConversationMembersServiceImpl extends BaseServiceImpl<ImConversa ...@@ -304,7 +308,7 @@ public class ImConversationMembersServiceImpl extends BaseServiceImpl<ImConversa
//推送到被拉入方 //推送到被拉入方
Long fkConversationId = imConversationMemApiAdd.getConversationId(); Long fkConversationId = imConversationMemApiAdd.getConversationId();
String clientId = "0"; String clientId = imConversationMemApiAdd.getOperator();
String toClientId = passivityOperatorClient.getClientId(); String toClientId = passivityOperatorClient.getClientId();
String imApplicationAppKey = imApplication.getAppKey(); String imApplicationAppKey = imApplication.getAppKey();
sendEventMsg(messageId, (HashMap) content, fkConversationId, clientId, toClientId, imApplicationAppKey); sendEventMsg(messageId, (HashMap) content, fkConversationId, clientId, toClientId, imApplicationAppKey);
......
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