|
|
@ -18,6 +18,7 @@ import (
|
|
|
|
"context"
|
|
|
|
"context"
|
|
|
|
"encoding/json"
|
|
|
|
"encoding/json"
|
|
|
|
"errors"
|
|
|
|
"errors"
|
|
|
|
|
|
|
|
|
|
|
|
"github.com/openimsdk/tools/mq"
|
|
|
|
"github.com/openimsdk/tools/mq"
|
|
|
|
|
|
|
|
|
|
|
|
"sync"
|
|
|
|
"sync"
|
|
|
@ -280,8 +281,6 @@ func (och *OnlineHistoryRedisConsumerHandler) handleMsg(ctx context.Context, key
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if isNewConversation {
|
|
|
|
if isNewConversation {
|
|
|
|
// 需要每一条消息 都去检查了 有没有会话
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
switch msg.SessionType {
|
|
|
|
switch msg.SessionType {
|
|
|
|
case constant.ReadGroupChatType:
|
|
|
|
case constant.ReadGroupChatType:
|
|
|
|
log.ZDebug(ctx, "group chat first create conversation", "conversationID",
|
|
|
|
log.ZDebug(ctx, "group chat first create conversation", "conversationID",
|
|
|
|