fix: 批量删除装备 mongodb deletemany的问题

zhangqijia
1 parent 7cf63b79
Showing 4 changed files with 19 additions and 6 deletions Show diff stats
DesignerConfigs
cmd/gameserver/action/RoleAction.go
cmd/gameserver/action/RoleAction_test.go
common/db/mongoproxy/mongoplugin.go
-Subproject commit 4011876adebf1d046b150ec77e1714d25aa7cb35
+Subproject commit ca2a212e0e5ed06b6f33e3c4bd4570976a169010
@@ -173,10 +173,7 @@ func EquipmentDelRpc(role *models.RoleModel, msg components.IMessage) (int32, in
 		logger.Error("loginRpc err: %v", err)
 		return 1, nil
 	}
-	filter := make(bson.D, 5)
-	for _, id := range req.Id {
-		filter = append(filter, bson.E{Key: "id", Value: id})
-	}
+	filter := bson.D{{"id", bson.D{{"$in", req.Id}}}}
 	if err := mongoproxy.DelMany("equipment", filter); err != nil {
 		logger.Error(err.Error())
 		return 2, nil
@@ -2,8 +2,10 @@ package action
 import (
 	"fmt"
+	"go.mongodb.org/mongo-driver/bson"
 	"math/rand"
 	"pro2d/common"
+	"pro2d/common/db/mongoproxy"
 	"pro2d/common/db/redisproxy"
 	"pro2d/common/logger"
 	"testing"
@@ -20,3 +22,16 @@ func TestGetActionMap(t *testing.T) {
 	name := getRandomName()
 	fmt.Println(name)
 }
+
+func TestEquipmentDelRpc(t *testing.T) {
+	err := mongoproxy.ConnectMongo(common.GlobalConf.GameConf.MongoConf, common.GlobalConf.GameConf.ID)
+	if err != nil {
+		logger.Error(err)
+		return
+	}
+
+	filter := bson.D{{"id", bson.D{{"$in", bson.A{"10000020021", "10000020037"}}}}}
+	if err := mongoproxy.DelMany("equipment", filter); err != nil {
+		logger.Error(err.Error())
+	}
+}
@@ -90,7 +90,8 @@ func DelOne(coll string, key string, value interface{}) error {
 }
 func DelMany(coll string, filter bson.D) error {
-	_, err := mongoDatabase.Collection(coll).DeleteMany(context.TODO(), filter, nil)
+	r, err := mongoDatabase.Collection(coll).DeleteMany(context.TODO(), filter, nil)
+	logger.Debug(r.DeletedCount)
 	return err
 }