负载同步

game/game_cluster/nodes/game/module/player/actor_player.go

@@ -429,7 +429,7 @@ func (p *actorPlayer) refreshRoll() {
 }
 
 func (p *actorPlayer) playerSessionClose() {
-	deadline := time.Now().Add(-p.exitTime).Unix()
+	deadline := mhayaTime.Now().Add(-p.exitTime).Unix()
 	if p.LastAt() < deadline {
 		p.sessionClose()
 	}
@@ -468,8 +468,8 @@ func (p *actorPlayer) Init(req *token.Token) bool {
 		}
 		p.Account = &account
 	} else {
-		dbErr := mdb.MDB.Collection(constant.CNameAccount).FindOne(context.Background(), bson.M{"openId": req.OpenID}).Decode(&account).Error()
-		if dbErr != "" {
+		err = mdb.MDB.Collection(constant.CNameAccount).FindOne(ctx, bson.M{"openId": req.OpenID}).Decode(&account)
+		if err != nil {
 			clog.Debugf("[actorPlayer] read account data by db error: %v", err)
 			return false
 		}
@@ -490,8 +490,8 @@ func (p *actorPlayer) Init(req *token.Token) bool {
 		}
 		p.Player = &player
 	} else {
-		dbErr := mdb.MDB.Collection(constant.CNamePlayer).FindOne(context.Background(), bson.M{"userName": req.PlayerID}).Decode(&player).Error()
-		if dbErr != "" {
+		err = mdb.MDB.Collection(constant.CNamePlayer).FindOne(ctx, bson.M{"userName": req.PlayerID}).Decode(&player)
+		if err != nil {
 			clog.Debugf("[actorPlayer] read player data by db error: %v", err)
 			return false
 		}