Commit 0527b47c by Future

发送消息收件箱逻辑修改

parent 538abb7a
...@@ -139,10 +139,6 @@ public class NormalChatAction { ...@@ -139,10 +139,6 @@ public class NormalChatAction {
// 再给所有人发 todo 需要改成批量 // 再给所有人发 todo 需要改成批量
for (ImConversationMembers conversationMembers : membersList) { for (ImConversationMembers conversationMembers : membersList) {
// 入库 保存收件箱
long imInboxId = SnowflakeUtil.getId();
saveImInbox(imApplication, data.getToConversation(), imMessageOnlineSend.getMsgId(), conversationMembers, imInboxId);
// 查询接收方 // 查询接收方
ImClient imClientReceiver = imClientService.getOne(new QueryWrapper<ImClient>().lambda() ImClient imClientReceiver = imClientService.getOne(new QueryWrapper<ImClient>().lambda()
.eq(ImClient::getFkAppid, imApplication.getId()) .eq(ImClient::getFkAppid, imApplication.getId())
...@@ -154,6 +150,10 @@ public class NormalChatAction { ...@@ -154,6 +150,10 @@ public class NormalChatAction {
// 不给自己发 // 不给自己发
continue; continue;
} }
// 入库 保存收件箱
saveImInbox(imApplication, data.getToConversation(), imMessageOnlineSend.getMsgId(),
conversationMembers, SnowflakeUtil.getId());
// 在线用户直接发消息 // 在线用户直接发消息
sendMsgForOnline(imClientReceiver.getId(), imMessageOnlineSend); sendMsgForOnline(imClientReceiver.getId(), imMessageOnlineSend);
......
...@@ -1094,7 +1094,6 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap ...@@ -1094,7 +1094,6 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
public List<ConversationVo> getMyImConversationListAndMsgCount() { public List<ConversationVo> getMyImConversationListAndMsgCount() {
try { try {
ImClient currentClient = imClientService.getCurrentClient(); ImClient currentClient = imClientService.getCurrentClient();
// 查询用户加入的所有会话 与每个会话的未读条数 成员 // 查询用户加入的所有会话 与每个会话的未读条数 成员
List<ConversationVo> myImConversationListAndMsgCount = imConversationMapper.getMyImConversationListAndMsgCount(currentClient.getId(), null); List<ConversationVo> myImConversationListAndMsgCount = imConversationMapper.getMyImConversationListAndMsgCount(currentClient.getId(), null);
......
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