From edb5cb4ee585eb77169002281238841878442d51 Mon Sep 17 00:00:00 2001
From: wangchuxiao <wangchuxiao97@outlook.com>
Date: Mon, 30 May 2022 15:45:19 +0800
Subject: [PATCH] superGroup

---
 pkg/common/db/mongoModel.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/pkg/common/db/mongoModel.go b/pkg/common/db/mongoModel.go
index 29e7e10d1..3fc7aa041 100644
--- a/pkg/common/db/mongoModel.go
+++ b/pkg/common/db/mongoModel.go
@@ -981,7 +981,11 @@ func (d *DataBases) CreateSuperGroup(groupID string, initMemberIDList []string,
 			UserID: v,
 		})
 	}
-	_, err = c.UpdateOne(sCtx, users, bson.M{"$addToSet": bson.M{"group_id_list": groupID}})
+	upsert := true
+	opts := &options.UpdateOptions{
+		Upsert: &upsert,
+	}
+	_, err = c.UpdateMany(sCtx, bson.M{"user_id": bson.M{"$in": initMemberIDList}}, bson.M{"$addToSet": bson.M{"group_id_list": groupID}}, opts)
 	if err != nil {
 		session.AbortTransaction(ctx)
 		return utils.Wrap(err, "transaction failed")