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