From 0958146a18820f58cc1e18a608086ba67fac2caf Mon Sep 17 00:00:00 2001
From: tianfeng <769204422@qq.com>
Date: Thu, 5 Mar 2026 15:35:09 +0800
Subject: [PATCH] =?UTF-8?q?=E9=A2=86=E5=8F=96=E6=88=BF=E9=97=B4=E6=AF=8F?=
 =?UTF-8?q?=E6=97=A5=E4=BB=BB=E5=8A=A1=E5=8A=A0=E9=94=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../other/app/service/task/RoomDailyTaskServiceImpl.java    | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/task/RoomDailyTaskServiceImpl.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/task/RoomDailyTaskServiceImpl.java
index b211eb95..9be099ce 100644
--- a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/task/RoomDailyTaskServiceImpl.java
+++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/task/RoomDailyTaskServiceImpl.java
@@ -7,6 +7,7 @@ import com.red.circle.other.app.dto.clientobject.task.RoomDailyTaskClaimCO;
 import com.red.circle.other.app.dto.clientobject.task.RoomDailyTaskClaimableCountCO;
 import com.red.circle.other.app.dto.clientobject.task.RoomDailyTaskListCO;
 import com.red.circle.other.app.dto.cmd.task.RoomDailyTaskClaimCmd;
+import com.red.circle.other.app.util.DistributedLockUtil;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
@@ -17,6 +18,7 @@ public class RoomDailyTaskServiceImpl implements RoomDailyTaskService {
     private final RoomDailyTaskQueryExe queryExe;
     private final RoomDailyTaskClaimExe claimExe;
     private final RoomDailyTaskClaimableCountQryExe claimableCountQryExe;
+    private final DistributedLockUtil distributedLockUtil;
 
     @Override
     public RoomDailyTaskListCO getTaskList(Long userId, Integer taskCategory) {
@@ -25,7 +27,9 @@ public class RoomDailyTaskServiceImpl implements RoomDailyTaskService {
 
     @Override
     public RoomDailyTaskClaimCO claimReward(RoomDailyTaskClaimCmd cmd) {
-        return claimExe.execute(cmd);
+        String key = "roomDailyTaskClaim:" + cmd.getTaskCode() + ":" + cmd.getReqUserId();
+        distributedLockUtil.executeWithLock(key, () -> claimExe.execute(cmd));
+        return new  RoomDailyTaskClaimCO();
     }
 
     @Override