代码调试

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

@@ -188,7 +188,7 @@ public class NormalChatAction {
 //        }
 //        String key = "push_" + conversation.getId();
 //        String value = redisUtils.getKey(key);
-        final Boolean isPush = false;
+//        final Boolean isPush = false;
 //        if (StringUtils.isBlank(value)) {
 //            isPush = Boolean.TRUE;
 //            redisUtils.addKey(key, "1", Duration.ofMinutes(5));
@@ -202,7 +202,7 @@ public class NormalChatAction {
                 continue;
             }
             SendMsgThreadPool.SEND_MSG_THREAD_POOL_EXECUTOR.execute(() -> {
-                this.sendMsgToMember(imApplication, member, imMessageOnlineSend, data.getPush(), isPush);
+                this.sendMsgToMember(imApplication, member, imMessageOnlineSend, data.getPush());
             });
         }
 
@@ -213,7 +213,7 @@ public class NormalChatAction {
     private void sendMsgToMember(ImApplication imApplication, ImConversationMembers member, ImMessageOnlineSend imMessageOnlineSend, PushVO push, Boolean isPush) {
         // 在线用户直接发消息
         Boolean sendSuccess = sendMsgForOnline(member.getFkClientId(), imMessageOnlineSend);
-        if (isPush && !sendSuccess && !member.getDoNotDisturb()) {
+        if (!sendSuccess && !member.getDoNotDisturb()) {
             // 异步推送系统通知消息 5分钟内推一次消息
             PushDTO pushDTO = mqSender.buildPushDto(push, member.getFkClientId(), member.getClientId(), imApplication);
             if (pushDTO != null) {