Commit 74531d56 authored by pengjun's avatar pengjun

fix pokerbull player check

parent e6b843b4
...@@ -530,23 +530,23 @@ func (action *Action) selectGameFromIds(ids []string, value int64) *pkt.PokerBul ...@@ -530,23 +530,23 @@ func (action *Action) selectGameFromIds(ids []string, value int64) *pkt.PokerBul
return gameRet return gameRet
} }
func (action *Action) checkPlayerExistInGame() bool { //func (action *Action) checkPlayerExistInGame() bool {
values, err := action.localDB.List(calcPBGameAddrPrefix(action.fromaddr), nil, pkt.DefaultCount, pkt.ListDESC) // values, err := action.localDB.List(calcPBGameAddrPrefix(action.fromaddr), nil, pkt.DefaultCount, pkt.ListDESC)
if err == types.ErrNotFound { // if err == types.ErrNotFound {
return false // return false
} // }
//
var value pkt.PBGameRecord // var value pkt.PBGameRecord
length := len(values) // length := len(values)
if length != 0 { // if length != 0 {
valueBytes := values[length-1] // valueBytes := values[length-1]
err := types.Decode(valueBytes, &value) // err := types.Decode(valueBytes, &value)
if err == nil && value.Status == pkt.PBGameActionQuit { // if err == nil && value.Status == pkt.PBGameActionQuit {
return false // return false
} // }
} // }
return true // return true
} //}
// GameStart 游戏开始 // GameStart 游戏开始
func (action *Action) GameStart(start *pkt.PBGameStart) (*types.Receipt, error) { func (action *Action) GameStart(start *pkt.PBGameStart) (*types.Receipt, error) {
...@@ -566,10 +566,11 @@ func (action *Action) GameStart(start *pkt.PBGameStart) (*types.Receipt, error) ...@@ -566,10 +566,11 @@ func (action *Action) GameStart(start *pkt.PBGameStart) (*types.Receipt, error)
return nil, types.ErrNoBalance return nil, types.ErrNoBalance
} }
if action.checkPlayerExistInGame() { // 由应用平台限制
logger.Error("GameStart", "addr", action.fromaddr, "execaddr", action.execaddr, "err", "Address is already in a game") //if action.checkPlayerExistInGame() {
return nil, fmt.Errorf("Address is already in a game") // logger.Error("GameStart", "addr", action.fromaddr, "execaddr", action.execaddr, "err", "Address is already in a game")
} // return nil, fmt.Errorf("Address is already in a game")
//}
var game *pkt.PokerBull var game *pkt.PokerBull
ids, err := queryGameListByStatusAndPlayer(action.localDB, pkt.PBGameActionStart, start.PlayerNum, start.Value) ids, err := queryGameListByStatusAndPlayer(action.localDB, pkt.PBGameActionStart, start.PlayerNum, start.Value)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment