feat: msg doc len changed

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 {
+	// for _, conversationID := range conversationIDs {
-		conversationIDs = append(conversationIDs, msgprocessor.GetNotificationConversationIDByConversationID(conversationID))
+	// 	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))

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))