系统消息推送

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

@@ -192,7 +192,7 @@ public class NormalChatAction {
         // 在线用户直接发消息
 
         Boolean sendSuccess = sendMsgForOnline(member.getFkClientId(), imMessageOnlineSend);
-        if (isPush && !sendSuccess && !member.getDoNotDisturb()) {
+        if (isPush && !member.getDoNotDisturb()) {
             try {
                 // 异步推送系统通知消息 5分钟内推一次消息
                 PushDTO pushDTO = mqSender.buildPushDto(push, member.getFkClientId(), member.getClientId(), imApplication);

core/src/main/java/com/wecloud/im/service/impl/ImMessageServiceImpl.java

@@ -625,12 +625,10 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
                 }
                 // 在线用户直接发消息
                 Boolean sendResult = sendMsgForOnline(members.getFkClientId(), imMessageOnlineSend);
-                if (!sendResult) {
                     // 离线消息推送
                 pushMsgToOfflineMembers(application, members, param.getPushContent(), param.getPushExt());
             }
         }
-        }
 
         return true;
     }
@@ -774,11 +772,9 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
                         members, SnowflakeUtil.getId());
                 // 在线用户直接发消息
                 Boolean sendResult = sendMsgForOnline(members.getFkClientId(), imMessageOnlineSend);
-                if (!sendResult) {
                     // 离线消息推送
                 pushMsgToOfflineMembers(application, members, param.getPushContent(), param.getPushExt());
             }
-            }
 
         });
         return true;
@@ -876,11 +872,8 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
 
                 // 在线用户直接发消息
                 Boolean sendResult = sendMsgForOnline(members.getFkClientId(), imMessageOnlineSend);
-                if (!sendResult) {
-                    // 离线消息推送
                 pushMsgToOfflineMembers(application, members, param.getPushContent(), param.getPushExt());
             }
-            }
 
         });
         return true;