删除事件通知

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

@@ -154,9 +154,7 @@ public class NormalChatAction {
         if (!checkMsg(imClientSender, conversation, reqId, data, request.getSenderChannel(), memberMap)) {
             return;
         }
-        Long time = System.currentTimeMillis();
         ImMessageOnlineSend imMessageOnlineSend = assembleImMessageOnlineSend(data, imClientSender, imApplication.getId());
-        log.info("消息落库耗时 {}", System.currentTimeMillis()-time);
 
         // 入库 保存收件箱
         batchSaveInbox(imApplication, imClientSender, conversation, imMessageOnlineSend.getMsgId(), membersList);
@@ -231,9 +229,7 @@ public class NormalChatAction {
     private ImMessageOnlineSend assembleImMessageOnlineSend(ChatContentVo data, ImClient imClientSender, Long appId) {
         // 入库  保存消息至消息表
         ImClientSimpleDto client = new ImClientSimpleDto().setId(imClientSender.getId()).setFkAppid(appId);
-        Long time = System.currentTimeMillis();
         ImMessage imMessage = imMessageService.saveImMessage(client, data);
-        log.info("外层插入落库耗时 {}", System.currentTimeMillis() - time);
 
         // 封装响应的实体
         ImMessageOnlineSend imMessageOnlineSend = new ImMessageOnlineSend();

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

@@ -227,9 +227,7 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
         String contentJsonString = JsonUtils.encodeJson(data);
         imMessage.setContent(contentJsonString);
 
-        Long snowTime = System.currentTimeMillis();
         imMessage.setId(SnowflakeUtil.getId());
-        log.info("雪花id生产耗时 {}", System.currentTimeMillis() - snowTime);
         imMessage.setCreateTime(new Date());
         imMessage.setFkAppid(client.getFkAppid());
         imMessage.setSender(client.getId());
@@ -240,13 +238,9 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
         imMessage.setMsgType(data.getType());
         imMessage.setAt(data.getAt());
         imMessage.setFkConversationId(data.getToConversation());
-        Long dbTime = System.currentTimeMillis();
         this.save(imMessage);
-        log.info("内部落库耗时 {}", System.currentTimeMillis() - dbTime);
 
-        Long eventTime = System.currentTimeMillis();
-        eventPublisher.publishEvent(new ClientSendMessageEvent(client.getFkAppid(), imMessage));
-        log.info("事件耗时 {}", System.currentTimeMillis() - eventTime);
+//        eventPublisher.publishEvent(new ClientSendMessageEvent(client.getFkAppid(), imMessage));
 
         return imMessage;
     }