룰렛 돌리기 API 추가

src/main/kotlin/kr/co/vividnext/sodalive/can/CanService.kt

@@ -53,7 +53,7 @@ class CanService(private val repository: CanRepository) {
             }
             .map {
                 val title: String = when (it.canUsage) {
-                    CanUsage.DONATION -> {
+                    CanUsage.DONATION, CanUsage.SPIN_ROULETTE -> {
                         if (it.room != null) {
                             "[라이브 후원] ${it.room!!.member!!.nickname}"
                         } else if (it.audioContent != null) {

src/main/kotlin/kr/co/vividnext/sodalive/can/use/CanUsage.kt

@@ -4,5 +4,6 @@ enum class CanUsage {
     LIVE,
     DONATION,
     CHANGE_NICKNAME,
-    ORDER_CONTENT
+    ORDER_CONTENT,
+    SPIN_ROULETTE
 }

src/main/kotlin/kr/co/vividnext/sodalive/live/roulette/RouletteController.kt

@@ -39,4 +39,14 @@ class RouletteController(private val service: RouletteService) {
 
         return ApiResponse.ok(response)
     }
+
+    @PostMapping("/spin")
+    fun spinRoulette(
+        @RequestBody request: SpinRouletteRequest,
+        @AuthenticationPrincipal(expression = "#this == 'anonymousUser' ? null : member") member: Member?
+    ) = run {
+        if (member == null) throw SodaException("로그인 정보를 확인해주세요.")
+
+        ApiResponse.ok(service.spinRoulette(request = request, memberId = member.id!!))
+    }
 }

src/main/kotlin/kr/co/vividnext/sodalive/live/roulette/RouletteService.kt

@@ -1,11 +1,24 @@
 package kr.co.vividnext.sodalive.live.roulette
 
+import kr.co.vividnext.sodalive.can.payment.CanPaymentService
+import kr.co.vividnext.sodalive.can.use.CanUsage
 import kr.co.vividnext.sodalive.common.SodaException
+import kr.co.vividnext.sodalive.live.room.LiveRoomRepository
+import kr.co.vividnext.sodalive.member.MemberRole
 import org.springframework.data.repository.findByIdOrNull
 import org.springframework.stereotype.Service
+import org.springframework.transaction.annotation.Transactional
+import java.util.concurrent.locks.ReentrantReadWriteLock
+import kotlin.concurrent.write
 
 @Service
-class RouletteService(private val repository: RouletteRepository) {
+class RouletteService(
+    private val canPaymentService: CanPaymentService,
+    private val repository: RouletteRepository,
+    private val roomRepository: LiveRoomRepository
+) {
+    private val tokenLocks: MutableMap<Long, ReentrantReadWriteLock> = mutableMapOf()
+
     fun createOrUpdateRoulette(memberId: Long, request: CreateOrUpdateRouletteRequest) {
         rouletteValidate(request)
 
@@ -16,7 +29,10 @@ class RouletteService(private val repository: RouletteRepository) {
             items = request.items
         )
 
-        repository.save(roulette)
+        val lock = getOrCreateLock(memberId = memberId)
+        lock.write {
+            repository.save(roulette)
+        }
     }
 
     private fun rouletteValidate(request: CreateOrUpdateRouletteRequest) {
@@ -46,4 +62,39 @@ class RouletteService(private val repository: RouletteRepository) {
 
         return GetRouletteResponse(can = roulette.can, items = roulette.items)
     }
+
+    @Transactional
+    fun spinRoulette(request: SpinRouletteRequest, memberId: Long): GetRouletteResponse {
+        // STEP 1 - 라이브 정보 가져오기
+        val room = roomRepository.findByIdOrNull(request.roomId)
+            ?: throw SodaException("해당하는 라이브가 없습니다.")
+
+        val host = room.member ?: throw SodaException("잘못된 요청입니다.")
+
+        if (host.role != MemberRole.CREATOR) {
+            throw SodaException("비비드넥스트와 계약한\n크리에이터에게만 후원을 하실 수 있습니다.")
+        }
+
+        // STEP 2 - 룰렛 데이터 가져오기
+        val roulette = repository.findByIdOrNull(id = host.id!!)
+
+        if (roulette == null || !roulette.isActive || roulette.items.isEmpty()) {
+            throw SodaException("룰렛을 사용할 수 없습니다.")
+        }
+
+        // STEP 3 - 캔 사용
+        canPaymentService.spendCan(
+            memberId = memberId,
+            needCan = roulette.can,
+            canUsage = CanUsage.SPIN_ROULETTE,
+            liveRoom = room,
+            container = request.container
+        )
+
+        return GetRouletteResponse(can = roulette.can, items = roulette.items)
+    }
+
+    private fun getOrCreateLock(memberId: Long): ReentrantReadWriteLock {
+        return tokenLocks.computeIfAbsent(memberId) { ReentrantReadWriteLock() }
+    }
 }

src/main/kotlin/kr/co/vividnext/sodalive/live/roulette/SpinRouletteRequest.kt

@@ -0,0 +1,6 @@
+package kr.co.vividnext.sodalive.live.roulette
+
+data class SpinRouletteRequest(
+    val roomId: Long,
+    val container: String
+)