红包领取事件

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

@@ -709,8 +709,14 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
                     message.setReceivers(receivers);
                     message.setReceivers(receivers);
                 }
                 }
             }
             }
-            // 持久化
-            saveMessageService.saveMessageToDb(message);
+            if ("201".equals(param.getMessageType())) {
+                // 红包领取自定义消息 不做落库
+                message.setId(SnowflakeUtil.getId());
+                message.setPreMessageId(-1L);
+            } else {
+                // 持久化
+                saveMessageService.saveMessageToDb(message);
+            }
             // 拼装发送消息体
             // 拼装发送消息体
             ImMessageOnlineSend imMessageOnlineSend = assembleImMessageOnlineSend(message, sender, appId);
             ImMessageOnlineSend imMessageOnlineSend = assembleImMessageOnlineSend(message, sender, appId);
 
 

core/src/main/java/com/wecloud/im/ws/manager/ChannelManager.java

@@ -60,7 +60,7 @@ public class ChannelManager {
      */
      */
     public void online(Long clientId, Integer platform, NioSocketChannel channel) {
     public void online(Long clientId, Integer platform, NioSocketChannel channel) {
         String longChannelId = channel.id().asLongText();
         String longChannelId = channel.id().asLongText();
-        log.info("保存本地连接clientId {} platform {} channel is null {}", clientId, platform, channel==null);
+        log.info("保存本地连接clientId {} platform {}", clientId, platform);
         this.putSessionInfoMap(clientId, platform, channel);
         this.putSessionInfoMap(clientId, platform, channel);
 
 
         UserStateListener.triggerOnlineEvent(clientId, platform, longChannelId);
         UserStateListener.triggerOnlineEvent(clientId, platform, longChannelId);