Hermes / api-game

Download as
Browse Code »

Commit 3bbdc302de8d09057a32735eedf18b7f5f746a2e

Authored by 王家文
1 parent 019264c8
Exists in master and in 1 other branch dev-wjw

feat✨:房间排行活动：数据操作添加分布式锁

Showing 1 changed file with 12 additions and 0 deletions   Show diff stats
service/roomrank/handle.go
  Diff comments   View file @3bbdc30
@@ -57,6 +57,10 @@ func HandleInfo(req *models.ReqRoomRankInfo) (code string, rsp models.RspRoomRan @@ -57,6 +57,10 @@ func HandleInfo(req *models.ReqRoomRankInfo) (code string, rsp models.RspRoomRan
57 // 采用分布式锁 57 // 采用分布式锁
58 lockKey := getLockKey(gameId, config.Id) 58 lockKey := getLockKey(gameId, config.Id)
59 lock := zredislock.Obtain(lockKey, RoomLockMillisecond, nil) 59 lock := zredislock.Obtain(lockKey, RoomLockMillisecond, nil)
  60 + if lock.Err != nil {
  61 + code = code_msg.RECODE_CAOZUOPINFAN_ERROR
  62 + return
  63 + }
60 defer lock.Release() 64 defer lock.Release()
61 65
62 // 尝试判断结算 66 // 尝试判断结算
@@ -116,6 +120,10 @@ func HandleGetSettleAward(req *models.ReqRoomRankGetSettleAward) (code string, r @@ -116,6 +120,10 @@ func HandleGetSettleAward(req *models.ReqRoomRankGetSettleAward) (code string, r
116 // 采用分布式锁 120 // 采用分布式锁
117 lockKey := getLockKey(gameId, config.Id) 121 lockKey := getLockKey(gameId, config.Id)
118 lock := zredislock.Obtain(lockKey, RoomLockMillisecond, nil) 122 lock := zredislock.Obtain(lockKey, RoomLockMillisecond, nil)
  123 + if lock.Err != nil {
  124 + code = code_msg.RECODE_CAOZUOPINFAN_ERROR
  125 + return
  126 + }
119 defer lock.Release() 127 defer lock.Release()
120 128
121 // 尝试判断结算 129 // 尝试判断结算
@@ -165,6 +173,10 @@ func HandleAddScore(req *models.ReqRoomRankAddScore) (code string, rsp models.Rs @@ -165,6 +173,10 @@ func HandleAddScore(req *models.ReqRoomRankAddScore) (code string, rsp models.Rs
165 // 采用分布式锁 173 // 采用分布式锁
166 lockKey := getLockKey(gameId, config.Id) 174 lockKey := getLockKey(gameId, config.Id)
167 lock := zredislock.Obtain(lockKey, RoomLockMillisecond, nil) 175 lock := zredislock.Obtain(lockKey, RoomLockMillisecond, nil)
  176 + if lock.Err != nil {
  177 + code = code_msg.RECODE_CAOZUOPINFAN_ERROR
  178 + return
  179 + }
168 defer lock.Release() 180 defer lock.Release()
169 181
170 // 尝试判断结算 182 // 尝试判断结算