发消息性能优化

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

 package com.wecloud.im.action;
 package com.wecloud.im.action;
 
 
-import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Lists;

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

@@ -41,6 +41,7 @@ import com.wecloud.im.param.add.ServerImConversationCreate;
 import com.wecloud.im.post.MessageBuilder;
 import com.wecloud.im.post.MessageBuilder;
 import com.wecloud.im.sdk.enums.ChatTypeEnum;
 import com.wecloud.im.sdk.enums.ChatTypeEnum;
 import com.wecloud.im.service.ContextService;
 import com.wecloud.im.service.ContextService;
+import com.wecloud.im.service.EhcacheService;
 import com.wecloud.im.service.ImApplicationService;
 import com.wecloud.im.service.ImApplicationService;
 import com.wecloud.im.service.ImClientService;
 import com.wecloud.im.service.ImClientService;
 import com.wecloud.im.service.ImConversationMembersService;
 import com.wecloud.im.service.ImConversationMembersService;
@@ -78,6 +79,7 @@ import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.annotation.Transactional;
 
 
+import javax.annotation.Resource;
 import java.util.ArrayList;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.Collections;
@@ -138,6 +140,9 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
     @Autowired
     @Autowired
     private SaveMessageService saveMessageService;
     private SaveMessageService saveMessageService;
 
 
+    @Resource
+    private EhcacheService ehcacheService;
+
     @Override
     @Override
     @Transactional(rollbackFor = Exception.class)
     @Transactional(rollbackFor = Exception.class)
     public ApiResult<Boolean> restApiImMessageSend(ImMsgSendToOnlineClient imMsgSendToOnlineClient, ImApplication imApplication) {
     public ApiResult<Boolean> restApiImMessageSend(ImMsgSendToOnlineClient imMsgSendToOnlineClient, ImApplication imApplication) {
@@ -1169,6 +1174,10 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
         if (members.getDoNotDisturb() != null && members.getDoNotDisturb()) {
         if (members.getDoNotDisturb() != null && members.getDoNotDisturb()) {
             return;
             return;
         }
         }
+        Boolean isPush = ehcacheService.getIsPush("push" + members.getFkConversationId());
+        if (!isPush) {
+            return;
+        }
         // 不是静默推送
         // 不是静默推送
         PushVO pushVO = new PushVO();
         PushVO pushVO = new PushVO();
         pushVO.setData(JSONObject.parseObject(pushContent, HashMap.class));
         pushVO.setData(JSONObject.parseObject(pushContent, HashMap.class));