diff --git a/service/roomrank/handle.go b/service/roomrank/handle.go index 275c6ee..49642dd 100644 --- a/service/roomrank/handle.go +++ b/service/roomrank/handle.go @@ -57,6 +57,10 @@ func HandleInfo(req *models.ReqRoomRankInfo) (code string, rsp models.RspRoomRan // 采用分布式锁 lockKey := getLockKey(gameId, config.Id) lock := zredislock.Obtain(lockKey, RoomLockMillisecond, nil) + if lock.Err != nil { + code = code_msg.RECODE_CAOZUOPINFAN_ERROR + return + } defer lock.Release() // 尝试判断结算 @@ -116,6 +120,10 @@ func HandleGetSettleAward(req *models.ReqRoomRankGetSettleAward) (code string, r // 采用分布式锁 lockKey := getLockKey(gameId, config.Id) lock := zredislock.Obtain(lockKey, RoomLockMillisecond, nil) + if lock.Err != nil { + code = code_msg.RECODE_CAOZUOPINFAN_ERROR + return + } defer lock.Release() // 尝试判断结算 @@ -165,6 +173,10 @@ func HandleAddScore(req *models.ReqRoomRankAddScore) (code string, rsp models.Rs // 采用分布式锁 lockKey := getLockKey(gameId, config.Id) lock := zredislock.Obtain(lockKey, RoomLockMillisecond, nil) + if lock.Err != nil { + code = code_msg.RECODE_CAOZUOPINFAN_ERROR + return + } defer lock.Release() // 尝试判断结算 -- libgit2 0.21.0