|
|
@@ -27,7 +27,7 @@ func (p *ActorSaves) AliasID() string {
|
|
|
}
|
|
|
|
|
|
func (p *ActorSaves) OnInit() {
|
|
|
- p.Timer().Add(60*time.Second, p.saveAccountDB1)
|
|
|
+ p.Timer().Add(50*time.Second, p.saveAccountDB1)
|
|
|
p.Timer().Add(60*time.Second, p.savePlayerDB1)
|
|
|
}
|
|
|
|
|
|
@@ -125,22 +125,26 @@ func (p *ActorSaves) savePlayerDB() {
|
|
|
newPlayers := mdb.RDB.HGetAll(ctx, constant.NewPlayers).Val()
|
|
|
updPlayer := []string{}
|
|
|
for k, _ := range newPlayers {
|
|
|
+ if key < 10000 {
|
|
|
+ var player models.Player
|
|
|
+ acc, _ := mdb.RDB.Get(ctx, fmt.Sprintf("%v:%v", constant.CNamePlayer, k)).Bytes()
|
|
|
+ if len(acc) > 0 {
|
|
|
+ err := jsoniter.Unmarshal(acc, &player)
|
|
|
+ if err != nil {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ }
|
|
|
+ filter := bson.M{"openId": player.OpenId}
|
|
|
+ update := bson.M{"$set": &player}
|
|
|
+ bulkUpdOps = append(bulkUpdOps, mongo.NewUpdateOneModel().SetFilter(filter).SetUpdate(update))
|
|
|
+ updPlayer = append(updPlayer, player.OpenId)
|
|
|
+ }
|
|
|
+ key++
|
|
|
if key > 10000 {
|
|
|
break
|
|
|
}
|
|
|
- var player models.Player
|
|
|
- acc, _ := mdb.RDB.Get(ctx, fmt.Sprintf("%v:%v", constant.CNamePlayer, k)).Bytes()
|
|
|
- if len(acc) > 0 {
|
|
|
- err := jsoniter.Unmarshal(acc, &player)
|
|
|
- if err != nil {
|
|
|
- continue
|
|
|
- }
|
|
|
- }
|
|
|
- filter := bson.M{"openId": player.OpenId}
|
|
|
- update := bson.M{"$set": &player}
|
|
|
- bulkUpdOps = append(bulkUpdOps, mongo.NewUpdateOneModel().SetFilter(filter).SetUpdate(update))
|
|
|
- updPlayer = append(updPlayer, player.OpenId)
|
|
|
}
|
|
|
+
|
|
|
if len(bulkUpdOps) > 0 {
|
|
|
_, err := mdb.MDB.Collection(constant.CNamePlayer).BulkWrite(context.Background(), bulkUpdOps)
|
|
|
if err != nil {
|
