From 3bbdc302de8d09057a32735eedf18b7f5f746a2e Mon Sep 17 00:00:00 2001
From: 王家文 <wangjiawen@puchigames.com>
Date: Mon, 22 Apr 2024 19:08:47 +0800
Subject: [PATCH] feat✨:房间排行活动：数据操作添加分布式锁

---
 service/roomrank/handle.go | 12 ++++++++++++
 1 file changed, 12 insertions(+), 0 deletions(-)

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