日志添加

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

@@ -203,8 +203,11 @@ public class NormalChatAction {
     private void sendMsgToMember(ImApplication imApplication, ImConversationMembers member, ImMessageOnlineSend imMessageOnlineSend, PushVO push, Boolean isPush) {
     private void sendMsgToMember(ImApplication imApplication, ImConversationMembers member, ImMessageOnlineSend imMessageOnlineSend, PushVO push, Boolean isPush) {
         // 在线用户直接发消息
         // 在线用户直接发消息
 
 
+        long time1 = System.currentTimeMillis();
         sendMsgForOnline(member.getFkClientId(), imMessageOnlineSend);
         sendMsgForOnline(member.getFkClientId(), imMessageOnlineSend);
+        log.info("会话id{} 在线发消息耗时 {}", imMessageOnlineSend.getConversationId(), System.currentTimeMillis()-time1);
         if (isPush && !member.getDoNotDisturb()) {
         if (isPush && !member.getDoNotDisturb()) {
+            long time2 = System.currentTimeMillis();
             try {
             try {
                 // 异步推送系统通知消息 5分钟内推一次消息
                 // 异步推送系统通知消息 5分钟内推一次消息
                 PushDTO pushDTO = mqSender.buildPushDto(push, member.getFkClientId(), member.getClientId(), imApplication);
                 PushDTO pushDTO = mqSender.buildPushDto(push, member.getFkClientId(), member.getClientId(), imApplication);
@@ -214,6 +217,7 @@ public class NormalChatAction {
             } catch (Exception e) {
             } catch (Exception e) {
                 log.info("发送系统消息失败异常 ", e);
                 log.info("发送系统消息失败异常 ", e);
             }
             }
+            log.info("会话id{} mq推送耗时 {}", imMessageOnlineSend.getConversationId(), System.currentTimeMillis()-time2);
         }
         }
     }
     }