cache key 중복으로 대기열 key 변경

Tiketeer · May 19, 2024 · 0f18aea · 0f18aea
1 parent 5503451
commit 0f18aea
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/...main/kotlin/com/tiketeer/TiketeerWaiting/domain/waiting/usecase/GetRankAndTokenUseCase.kt b/...main/kotlin/com/tiketeer/TiketeerWaiting/domain/waiting/usecase/GetRankAndTokenUseCase.kt
@@ -21,13 +21,14 @@ class GetRankAndTokenUseCase @Autowired constructor(private val redisTemplate: R
     override fun getRankAndToken(dto: GetRankAndTokenCommandDto): Mono<GetRankAndTokenResultDto> {
         val currentTime = dto.entryTime
         val token = generateToken(dto.email, dto.ticketingId)
+        val key = "queue::${dto.ticketingId}"
 
         val validateResult = validateSalePeriod(dto.ticketingId, currentTime)
         val mono = validateResult.flatMap { _ ->
-            redisTemplate.opsForZSet().rank(dto.ticketingId.toString(), token)
+            redisTemplate.opsForZSet().rank(key, token)
                 .switchIfEmpty(
-                    redisTemplate.opsForZSet().add(dto.ticketingId.toString(), token, currentTime.toDouble())
-                        .then(redisTemplate.opsForZSet().rank(dto.ticketingId.toString(), token))
+                    redisTemplate.opsForZSet().add(key, token, currentTime.toDouble())
+                        .then(redisTemplate.opsForZSet().rank(key, token))
                 )
         }