From b2fb0fe217892fd77f979cb98babfe04bd3daa65 Mon Sep 17 00:00:00 2001
From: tianfeng <769204422@qq.com>
Date: Wed, 26 Nov 2025 11:40:37 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8A=A2=E7=BA=A2=E5=8C=85=E5=A2=9E=E5=8A=A0?=
 =?UTF-8?q?=E9=94=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../circle/other/app/service/RoomRedPacketServiceImpl.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/RoomRedPacketServiceImpl.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/RoomRedPacketServiceImpl.java
index 2e2faceb..3d831b9e 100644
--- a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/RoomRedPacketServiceImpl.java
+++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/RoomRedPacketServiceImpl.java
@@ -11,6 +11,7 @@ import com.red.circle.other.app.dto.cmd.GrabRoomRedPacketCmd;
 import com.red.circle.other.app.dto.cmd.QueryRoomRedPacketDetailCmd;
 import com.red.circle.other.app.dto.cmd.QueryRoomRedPacketListCmd;
 import com.red.circle.other.app.dto.cmd.SendRoomRedPacketCmd;
+import com.red.circle.other.app.util.DistributedLockUtil;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -29,6 +30,7 @@ public class RoomRedPacketServiceImpl implements RoomRedPacketService {
     private final GrabRoomRedPacketCmdExe grabRoomRedPacketCmdExe;
     private final QueryRoomRedPacketListQryExe queryRoomRedPacketListQryExe;
     private final QueryRoomRedPacketDetailQryExe queryRoomRedPacketDetailQryExe;
+    private final DistributedLockUtil distributedLockUtil;
 
     @Override
     public RoomRedPacketCO sendRedPacket(SendRoomRedPacketCmd cmd) {
@@ -37,7 +39,8 @@ public class RoomRedPacketServiceImpl implements RoomRedPacketService {
 
     @Override
     public GrabRoomRedPacketResultCO grabRedPacket(GrabRoomRedPacketCmd cmd) {
-        return grabRoomRedPacketCmdExe.execute(cmd);
+        String key = "room:red_packet:" + cmd.getPacketId() + ":" + cmd.getReqUserId();
+        return distributedLockUtil.executeWithLock(key, () -> grabRoomRedPacketCmdExe.execute(cmd));
     }
 
     @Override