Feat/#146: 포즈 조회수

src/main/kotlin/com/neki/pose/application/port/PoseRepositoryPort.kt

@@ -32,4 +32,6 @@ interface PoseRepositoryPort {
     fun countPoses(headCount: HeadCount, excludeIds: List<Long>): Long
 
     fun findPoseByOffset(offset: Long, headCount: HeadCount, excludeIds: List<Long>): Pose?
+
+    fun incrementViewCount(poseId: Long)
 }

src/main/kotlin/com/neki/pose/application/port/PoseViewCachePort.kt

@@ -0,0 +1,6 @@
+package com.neki.pose.application.port
+
+interface PoseViewCachePort {
+
+    fun addViewer(poseId: Long, userId: Long): Boolean
+}

src/main/kotlin/com/neki/pose/application/usecase/GetPoseUseCase.kt

@@ -3,19 +3,30 @@ package com.neki.pose.application.usecase
 import com.neki.common.annotation.UseCase
 import com.neki.common.api.dto.ResultCode
 import com.neki.common.exception.BusinessException
+import com.neki.common.transaction.TransactionRunner
 import com.neki.pose.application.command.GetPoseCommand
 import com.neki.pose.application.contract.MediaStorageInfo
 import com.neki.pose.application.port.MediaClientPort
 import com.neki.pose.application.port.PoseRepositoryPort
+import com.neki.pose.application.port.PoseViewCachePort
 import com.neki.pose.application.result.GetPoseResult
 
 @UseCase
-class GetPoseUseCase(private val poseRepository: PoseRepositoryPort, private val mediaClient: MediaClientPort) {
+class GetPoseUseCase(
+    private val poseRepository: PoseRepositoryPort,
+    private val mediaClient: MediaClientPort,
+    private val poseViewCache: PoseViewCachePort,
+    private val transactionRunner: TransactionRunner,
+) {
 
     fun execute(command: GetPoseCommand): GetPoseResult {
         val (pose, isScraped) = poseRepository.getOwnedPoseWithScrap(command.userId, command.poseId)
             ?: throw BusinessException(ResultCode.NOT_FOUND)
 
+        if (poseViewCache.addViewer(command.poseId, command.userId)) {
+            transactionRunner.run { poseRepository.incrementViewCount(command.poseId) }
+        }
+
         val mediaInfo: MediaStorageInfo = mediaClient.getMediaStorageInfo(pose.mediaId)
 
         return GetPoseResult(

src/main/kotlin/com/neki/pose/domain/entity/Pose.kt

@@ -38,4 +38,7 @@ class Pose(
 
     @Column(name = "memo", nullable = true)
     var memo: String? = null,
+
+    @Column(name = "view_count", nullable = false)
+    var viewCount: Long = 0,
 ) : BaseTimeEntity()

src/main/kotlin/com/neki/pose/infra/cache/fake/FakePoseViewCacheAdapter.kt

@@ -0,0 +1,22 @@
+package com.neki.pose.infra.cache.fake
+
+import com.neki.pose.application.port.PoseViewCachePort
+import org.springframework.context.annotation.Profile
+import org.springframework.stereotype.Component
+import java.util.concurrent.ConcurrentHashMap
+
+@Component
+@Profile("test")
+class FakePoseViewCacheAdapter : PoseViewCachePort {
+
+    private val viewers = ConcurrentHashMap<Long, MutableSet<Long>>()
+
+    override fun addViewer(poseId: Long, userId: Long): Boolean {
+        val userSet = viewers.computeIfAbsent(poseId) { ConcurrentHashMap.newKeySet() }
+        return userSet.add(userId)
+    }
+
+    fun clearAll() {
+        viewers.clear()
+    }
+}

src/main/kotlin/com/neki/pose/infra/cache/redis/PoseViewRedisCacheKey.kt

@@ -0,0 +1,7 @@
+package com.neki.pose.infra.cache.redis
+
+internal object PoseViewRedisCacheKey {
+    private const val VIEW_PREFIX = "pose:view:"
+
+    fun viewKey(poseId: Long): String = "$VIEW_PREFIX$poseId"
+}

src/main/kotlin/com/neki/pose/infra/cache/redis/RedisPoseViewCacheAdapter.kt

@@ -0,0 +1,44 @@
+package com.neki.pose.infra.cache.redis
+
+import com.neki.pose.application.port.PoseViewCachePort
+import org.slf4j.LoggerFactory
+import org.springframework.context.annotation.Primary
+import org.springframework.context.annotation.Profile
+import org.springframework.data.redis.core.RedisTemplate
+import org.springframework.stereotype.Component
+import java.time.Instant
+import java.time.LocalDate
+import java.time.ZoneId
+
+@Component
+@Primary
+@Profile("!test")
+class RedisPoseViewCacheAdapter(private val redisTemplate: RedisTemplate<String, Any>) : PoseViewCachePort {
+
+    private val log = LoggerFactory.getLogger(javaClass)
+
+    override fun addViewer(poseId: Long, userId: Long): Boolean {
+        val key = PoseViewRedisCacheKey.viewKey(poseId)
+        return try {
+            val added = redisTemplate.opsForSet().add(key, userId) ?: 0
+            if (added > 0) {
+                redisTemplate.expireAt(key, getMidnight())
+                true
+            } else {
+                false
+            }
+        } catch (e: Exception) {
+            log.warn("[PoseViewCache] Failed to check viewer for pose: $poseId, user: $userId", e)
+            true // fail-open: Redis 장애 시 신규 조회로 처리
+        }
+    }
+
+    private fun getMidnight(): Instant {
+        val tomorrow = LocalDate.now(KOREA_ZONE).plusDays(1)
+        return tomorrow.atStartOfDay(KOREA_ZONE).toInstant()
+    }
+
+    companion object {
+        private val KOREA_ZONE = ZoneId.of("Asia/Seoul")
+    }
+}

src/main/kotlin/com/neki/pose/infra/persist/PoseRepositoryAdapter.kt

@@ -44,4 +44,8 @@ class PoseRepositoryAdapter(
 
     override fun findPoseByOffset(offset: Long, headCount: HeadCount, excludeIds: List<Long>): Pose? =
         queryRepository.findPoseByOffset(offset, headCount, excludeIds)
+
+    override fun incrementViewCount(poseId: Long) {
+        queryRepository.incrementViewCount(poseId)
+    }
 }

src/main/kotlin/com/neki/pose/infra/persist/jpa/PosesQueryRepository.kt

@@ -110,4 +110,10 @@ class PosesQueryRepository(private val queryFactory: JPAQueryFactory) {
         .offset(offset)
         .limit(1)
         .fetchOne()
+
+    fun incrementViewCount(poseId: Long): Long = queryFactory
+        .update(pose)
+        .set(pose.viewCount, pose.viewCount.add(1))
+        .where(pose.id.eq(poseId))
+        .execute()
 }

src/main/resources/db/migration/V12__add_view_count_to_pose.sql

@@ -0,0 +1 @@
+ALTER TABLE TB_POSE ADD COLUMN view_count BIGINT NOT NULL DEFAULT 0;

src/test/kotlin/com/neki/e2e/pose/GetPoseE2ETest.kt

@@ -5,6 +5,7 @@ import com.neki.media.domain.entity.MediaStatus
 import com.neki.pose.domain.HeadCount
 import com.neki.user.domain.entity.User
 import io.restassured.RestAssured
+import org.assertj.core.api.Assertions.assertThat
 import org.hamcrest.Matchers.equalTo
 import org.hamcrest.Matchers.notNullValue
 import org.hamcrest.Matchers.startsWith
@@ -90,6 +91,53 @@ class GetPoseE2ETest : PoseE2ETestBase() {
                 .body("data.scrap", equalTo(true))
         }
 
+        @Test
+        @DisplayName("포즈 상세 조회 성공 - 조회수 증가")
+        fun givenPoseExists_whenGetPose_thenViewCountIncreases() {
+            // given
+            val media = createMedia(ownerId = testUser.id!!, status = MediaStatus.UPLOADED)
+            val pose = createPose(userId = testUser.id!!, mediaId = media.id!!, headCount = HeadCount.ONE)
+
+            // when
+            RestAssured.given()
+                .header("Authorization", "Bearer $accessToken")
+                .`when`()
+                .get("/api/poses/${pose.id}")
+                .then()
+                .statusCode(HttpStatus.OK.value())
+
+            // then
+            val updated = poseRepository.findById(pose.id!!).get()
+            assertThat(updated.viewCount).isEqualTo(1)
+        }
+
+        @Test
+        @DisplayName("포즈 상세 조회 성공 - 동일 유저 중복 조회 시 조회수 미증가")
+        fun givenSameUser_whenGetPoseTwice_thenViewCountIncreasesOnce() {
+            // given
+            val media = createMedia(ownerId = testUser.id!!, status = MediaStatus.UPLOADED)
+            val pose = createPose(userId = testUser.id!!, mediaId = media.id!!, headCount = HeadCount.ONE)
+
+            // when: 같은 유저가 두 번 조회
+            RestAssured.given()
+                .header("Authorization", "Bearer $accessToken")
+                .`when`()
+                .get("/api/poses/${pose.id}")
+                .then()
+                .statusCode(HttpStatus.OK.value())
+
+            RestAssured.given()
+                .header("Authorization", "Bearer $accessToken")
+                .`when`()
+                .get("/api/poses/${pose.id}")
+                .then()
+                .statusCode(HttpStatus.OK.value())
+
+            // then: 조회수는 1만 증가
+            val updated = poseRepository.findById(pose.id!!).get()
+            assertThat(updated.viewCount).isEqualTo(1)
+        }
+
         @Test
         @DisplayName("포즈 상세 조회 성공 - 다양한 headCount")
         fun givenPoseWithFiveOrMore_whenGetPose_thenReturnsPoseDetail() {

src/test/kotlin/com/neki/e2e/pose/PoseE2ETestBase.kt

@@ -8,6 +8,7 @@ import com.neki.media.infra.persist.jpa.JpaMediaRepository
 import com.neki.pose.domain.HeadCount
 import com.neki.pose.domain.entity.Pose
 import com.neki.pose.domain.entity.ScrapPose
+import com.neki.pose.infra.cache.fake.FakePoseViewCacheAdapter
 import com.neki.pose.infra.persist.jpa.JpaPoseRepository
 import com.neki.pose.infra.persist.jpa.JpaScrapPoseRepository
 import org.junit.jupiter.api.AfterEach
@@ -30,11 +31,15 @@ abstract class PoseE2ETestBase : E2ETestBase() {
     @Autowired
     protected lateinit var mediaRepository: JpaMediaRepository
 
+    @Autowired
+    protected lateinit var fakePoseViewCache: FakePoseViewCacheAdapter
+
     @AfterEach
     override fun tearDown() {
         scrapPoseRepository.deleteAllInBatch()
         poseRepository.deleteAllInBatch()
         mediaRepository.deleteAllInBatch()
+        fakePoseViewCache.clearAll()
         super.tearDown()
     }