From 50021fe9ebee63aabfa0a23b511a8c3e62787b55 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Tue, 8 Aug 2023 11:44:14 +0800 Subject: [PATCH] feat: msg doc len changed --- internal/tools/msg_doc_convert.go | 8 ++++---- pkg/common/db/unrelation/msg_convert.go | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/internal/tools/msg_doc_convert.go b/internal/tools/msg_doc_convert.go index 4880415aa..433020126 100644 --- a/internal/tools/msg_doc_convert.go +++ b/internal/tools/msg_doc_convert.go @@ -14,15 +14,15 @@ func (c *MsgTool) ConvertTools() { log.ZError(ctx, "get all conversation ids failed", err) return } - for _, conversationID := range conversationIDs { - conversationIDs = append(conversationIDs, msgprocessor.GetNotificationConversationIDByConversationID(conversationID)) - } + // for _, conversationID := range conversationIDs { + // conversationIDs = append(conversationIDs, msgprocessor.GetNotificationConversationIDByConversationID(conversationID)) + // } userIDs, err := c.userDatabase.GetAllUserID(ctx, 0, 0) if err != nil { log.ZError(ctx, "get all user ids failed", err) return } - log.ZDebug(ctx, "all userIDs", "userIDs", userIDs) + log.ZDebug(ctx, "all userIDs", "len userIDs", len(userIDs)) for _, userID := range userIDs { conversationIDs = append(conversationIDs, msgprocessor.GetConversationIDBySessionType(constant.SingleChatType, userID, userID)) conversationIDs = append(conversationIDs, msgprocessor.GetNotificationConversationID(constant.SingleChatType, userID, userID)) diff --git a/pkg/common/db/unrelation/msg_convert.go b/pkg/common/db/unrelation/msg_convert.go index c8e932522..744ce68e1 100644 --- a/pkg/common/db/unrelation/msg_convert.go +++ b/pkg/common/db/unrelation/msg_convert.go @@ -25,7 +25,7 @@ func (m *MsgMongoDriver) ConvertMsgsDocLen(ctx context.Context, conversationIDs continue } if len(msgDocs) < 1 { - log.ZInfo(ctx, "len(msgs) < 1", "conversationID", conversationID) + log.ZDebug(ctx, "len(msgs) < 1", "conversationID", conversationID) continue } log.ZInfo(ctx, "msg doc convert", "conversationID", conversationID, "len(msgDocs)", len(msgDocs))