feat: msg doc len changed

internal/tools/msg_doc_convert.go

@@ -14,6 +14,9 @@ func (c *MsgTool) ConvertTools() {
 		log.ZError(ctx, "get all conversation ids failed", err)
 		return
 	}
+	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)

pkg/common/db/unrelation/msg_convert.go

@@ -49,6 +49,7 @@ func (m *MsgMongoDriver) ConvertMsgsDocLen(ctx context.Context, conversationIDs
 					} else {
 						msgDocModel.Msg = msgDoc.Msg[index:end]
 					}
+					newMsgDocs = append(newMsgDocs, msgDocModel)
 					index = end
 				} else {
 					break

pkg/msgprocessor/conversation.go

@@ -100,6 +100,16 @@ func GetConversationIDBySessionType(sessionType int, ids ...string) string {
 	return ""
 }
 
+func GetNotificationConversationIDByConversationID(conversationID string) string {
+	l := strings.Split(conversationID, "_")
+	if len(l) > 1 {
+		l[0] = "n"
+		return strings.Join(l, "_")
+	} else {
+		return ""
+	}
+}
+
 func GetNotificationConversationID(sessionType int, ids ...string) string {
 	sort.Strings(ids)
 	if len(ids) > 2 || len(ids) < 1 {