ehcache

core/src/main/java/com/wecloud/im/action/NormalChatAction.java

@@ -104,23 +104,23 @@ public class NormalChatAction {
             log.warn("会reqId: {} ,会话id: {}db中不存在", reqId, data.getToConversation());
             log.warn("会reqId: {} ,会话id: {}db中不存在", reqId, data.getToConversation());
             return;
             return;
         }
         }
-
         // 查询发送者client
         // 查询发送者client
         ImClient imClientSender = ehcacheService.getEhCacheClient(request.getSenderClientId());
         ImClient imClientSender = ehcacheService.getEhCacheClient(request.getSenderClientId());
         if (imClientSender == null) {
         if (imClientSender == null) {
             log.warn("根据senderClientId: {} 查找不到 imClientSender！", request.getSenderClientId());
             log.warn("根据senderClientId: {} 查找不到 imClientSender！", request.getSenderClientId());
             return;
             return;
         }
         }
-
         // 查询imApplication
         // 查询imApplication
         ImApplication imApplication = imApplicationService.getCacheById(imClientSender.getFkAppid());
         ImApplication imApplication = imApplicationService.getCacheById(imClientSender.getFkAppid());
 
 
         // 给所有人（在线+离线）遍历发送
         // 给所有人（在线+离线）遍历发送
         // 先查询该会话所有成员
         // 先查询该会话所有成员
+        Long time1 = System.currentTimeMillis();
         List<ImConversationMembers> membersList = imConversationMembersService.list(
         List<ImConversationMembers> membersList = imConversationMembersService.list(
                 new QueryWrapper<ImConversationMembers>().lambda()
                 new QueryWrapper<ImConversationMembers>().lambda()
                         .eq(ImConversationMembers::getFkConversationId, data.getToConversation())
                         .eq(ImConversationMembers::getFkConversationId, data.getToConversation())
         );
         );
+        log.info("获取群成员列表耗时 {}",System.currentTimeMillis() - time1);
         if (membersList.isEmpty()) {
         if (membersList.isEmpty()) {
             log.info("查询会话所有成员返回空，会话ID: {}", data.getToConversation());
             log.info("查询会话所有成员返回空，会话ID: {}", data.getToConversation());
             WsResponse<HashMap<String, Long>> responseModel = new WsResponse<>();
             WsResponse<HashMap<String, Long>> responseModel = new WsResponse<>();
@@ -145,7 +145,6 @@ public class NormalChatAction {
                 return;
                 return;
             }
             }
         }
         }
-
         if (ChatTypeEnum.NORMAL_GROUP.getCode().equals(conversation.getChatType())) {
         if (ChatTypeEnum.NORMAL_GROUP.getCode().equals(conversation.getChatType())) {
             if (beKickOut(reqId, imClientSender, membersList, request.getSenderChannel())) {
             if (beKickOut(reqId, imClientSender, membersList, request.getSenderChannel())) {
                 return;
                 return;
@@ -179,7 +178,7 @@ public class NormalChatAction {
                 imConversationMembersService.updateBatchById(tempMemberToUpdate);
                 imConversationMembersService.updateBatchById(tempMemberToUpdate);
             }
             }
         }
         }
-        final Boolean isPush = ehcacheService.getIsPush("push" + conversation.getId().toString());
+        final Boolean isPush = ehcacheService.getIsPush("push" + conversation.getId());
         // 多线程处理消息下发
         // 多线程处理消息下发
         for (ImConversationMembers member : membersList) {
         for (ImConversationMembers member : membersList) {
             if (member.getFkClientId().equals(imClientSender.getId())) {
             if (member.getFkClientId().equals(imClientSender.getId())) {