[Feat/#215] article_view_his 테이블 추가 및 조회수 응답 추가

.gitignore

@@ -95,3 +95,10 @@ Footer
 *.log
 *.tmp
 
+# DB schema migration path (except data module)
+data/src/main/resources/**/*.sql
+api/**/*.sql
+api-repo/**/*.sql
+batch/**/*.sql
+email/**/*.sql
+storage/**/*.sql

api-repo/src/main/kotlin/com/few/api/repo/dao/article/ArticleViewHisDao.kt

@@ -0,0 +1,31 @@
+package com.few.api.repo.dao.article
+
+import com.few.api.repo.dao.article.command.ArticleViewHisCommand
+import com.few.api.repo.dao.article.query.ArticleViewHisCountQuery
+import jooq.jooq_dsl.tables.ArticleViewHis
+import org.jooq.DSLContext
+import org.springframework.stereotype.Repository
+
+@Repository
+class ArticleViewHisDao(
+    private val dslContext: DSLContext,
+) {
+
+    fun insertArticleViewHis(command: ArticleViewHisCommand) {
+        dslContext.insertInto(
+            ArticleViewHis.ARTICLE_VIEW_HIS,
+            ArticleViewHis.ARTICLE_VIEW_HIS.ARTICLE_MST_ID,
+            ArticleViewHis.ARTICLE_VIEW_HIS.MEMBER_ID
+        ).values(
+            command.articleId,
+            command.memberId
+        ).execute()
+    }
+
+    fun countArticleViews(query: ArticleViewHisCountQuery): Long? {
+        return dslContext.selectCount()
+            .from(ArticleViewHis.ARTICLE_VIEW_HIS)
+            .where(ArticleViewHis.ARTICLE_VIEW_HIS.ARTICLE_MST_ID.eq(query.articleId))
+            .fetchOne(0, Long::class.java)
+    }
+}

api-repo/src/main/kotlin/com/few/api/repo/dao/article/command/ArticleViewHisCommand.kt

@@ -0,0 +1,6 @@
+package com.few.api.repo.dao.article.command
+
+data class ArticleViewHisCommand(
+    val articleId: Long,
+    val memberId: Long,
+)

api-repo/src/main/kotlin/com/few/api/repo/dao/article/query/ArticleViewHisCountQuery.kt

@@ -0,0 +1,5 @@
+package com.few.api.repo.dao.article.query
+
+data class ArticleViewHisCountQuery(
+    val articleId: Long,
+)

api-repo/src/main/kotlin/com/few/api/repo/dao/problem/ProblemDao.kt

@@ -12,9 +12,9 @@ import jooq.jooq_dsl.tables.Problem
 import org.jooq.DSLContext
 import org.jooq.JSON
 import org.jooq.impl.DSL
-import org.springframework.stereotype.Component
+import org.springframework.stereotype.Repository
 
-@Component
+@Repository
 class ProblemDao(
     private val dslContext: DSLContext,
     private val contentsJsonMapper: ContentsJsonMapper,

api-repo/src/main/kotlin/com/few/api/repo/dao/problem/SubmitHistoryDao.kt

@@ -3,9 +3,9 @@ package com.few.api.repo.dao.problem
 import com.few.api.repo.dao.problem.command.InsertSubmitHistoryCommand
 import jooq.jooq_dsl.Tables.SUBMIT_HISTORY
 import org.jooq.DSLContext
-import org.springframework.stereotype.Component
+import org.springframework.stereotype.Repository
 
-@Component
+@Repository
 class SubmitHistoryDao(
     private val dslContext: DSLContext,
 ) {

api-repo/src/main/kotlin/com/few/api/repo/dao/subscription/SubscriptionDao.kt

@@ -10,10 +10,10 @@ import com.few.api.repo.dao.subscription.record.CountAllSubscriptionStatusRecord
 import jooq.jooq_dsl.Tables.MAPPING_WORKBOOK_ARTICLE
 import jooq.jooq_dsl.Tables.SUBSCRIPTION
 import org.jooq.DSLContext
-import org.springframework.stereotype.Component
+import org.springframework.stereotype.Repository
 import java.time.LocalDateTime
 
-@Component
+@Repository
 class SubscriptionDao(
     private val dslContext: DSLContext,
 ) {

api/src/main/kotlin/com/few/api/config/DatabaseAccessThreadPoolConfig.kt

@@ -0,0 +1,38 @@
+package com.few.api.config
+
+import com.few.api.config.properties.ThreadPoolProperties
+import io.github.oshai.kotlinlogging.KotlinLogging
+import org.springframework.boot.context.properties.ConfigurationProperties
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
+
+@Configuration
+class DatabaseAccessThreadPoolConfig {
+    private val log = KotlinLogging.logger {}
+
+    companion object {
+        const val DATABASE_ACCESS_POOL = "database-task-"
+    }
+
+    @Bean
+    @ConfigurationProperties(prefix = "database.thread-pool")
+    fun databaseAccessThreadPoolProperties(): ThreadPoolProperties {
+        return ThreadPoolProperties()
+    }
+
+    @Bean(DATABASE_ACCESS_POOL)
+    fun databaseAccessThreadPool() = ThreadPoolTaskExecutor().apply {
+        val properties = databaseAccessThreadPoolProperties()
+        corePoolSize = properties.getCorePoolSize()
+        maxPoolSize = properties.getMaxPoolSize()
+        queueCapacity = properties.getQueueCapacity()
+        setWaitForTasksToCompleteOnShutdown(properties.getWaitForTasksToCompleteOnShutdown())
+        setAwaitTerminationSeconds(properties.getAwaitTerminationSeconds())
+        setThreadNamePrefix("databaseAccessThreadPool-")
+        setRejectedExecutionHandler { r, _ ->
+            log.warn { "Database Access Task Rejected: $r" }
+        }
+        initialize()
+    }
+}

api/src/main/kotlin/com/few/api/domain/article/usecase/ReadArticleUseCase.kt

@@ -1,5 +1,6 @@
 package com.few.api.domain.article.usecase
 
+import com.few.api.config.DatabaseAccessThreadPoolConfig.Companion.DATABASE_ACCESS_POOL
 import com.few.api.domain.article.usecase.dto.ReadArticleUseCaseIn
 import com.few.api.domain.article.usecase.dto.ReadArticleUseCaseOut
 import com.few.api.domain.article.usecase.dto.WriterDetail
@@ -9,8 +10,13 @@ import com.few.api.domain.article.service.dto.BrowseArticleProblemIdsInDto
 import com.few.api.domain.article.service.dto.ReadWriterRecordInDto
 import com.few.api.exception.common.NotFoundException
 import com.few.api.repo.dao.article.ArticleDao
+import com.few.api.repo.dao.article.ArticleViewHisDao
+import com.few.api.repo.dao.article.command.ArticleViewHisCommand
+import com.few.api.repo.dao.article.query.ArticleViewHisCountQuery
 import com.few.api.repo.dao.article.query.SelectArticleRecordQuery
 import com.few.data.common.code.CategoryType
+import io.github.oshai.kotlinlogging.KotlinLogging
+import org.springframework.scheduling.annotation.Async
 import org.springframework.stereotype.Component
 import org.springframework.transaction.annotation.Transactional
 
@@ -19,8 +25,11 @@ class ReadArticleUseCase(
     private val articleDao: ArticleDao,
     private val readArticleWriterRecordService: ReadArticleWriterRecordService,
     private val browseArticleProblemsService: BrowseArticleProblemsService,
+    private val articleViewHisDao: ArticleViewHisDao,
 ) {
 
+    private val log = KotlinLogging.logger {}
+
     @Transactional(readOnly = true)
     fun execute(useCaseIn: ReadArticleUseCaseIn): ReadArticleUseCaseOut {
         val articleRecord = SelectArticleRecordQuery(useCaseIn.articleId).let { query: SelectArticleRecordQuery ->
@@ -31,9 +40,14 @@ class ReadArticleUseCase(
             readArticleWriterRecordService.execute(query) ?: throw NotFoundException("writer.notfound.id")
         }
 
-        val problemIds = BrowseArticleProblemIdsInDto(articleRecord.articleId).let { query: BrowseArticleProblemIdsInDto ->
-            browseArticleProblemsService.execute(query)
-        }
+        val problemIds =
+            BrowseArticleProblemIdsInDto(articleRecord.articleId).let { query: BrowseArticleProblemIdsInDto ->
+                browseArticleProblemsService.execute(query)
+            }
+
+        val views = (articleViewHisDao.countArticleViews(ArticleViewHisCountQuery(useCaseIn.articleId)) ?: 0L) + 1L
+
+        insertArticleViewHisAsync(useCaseIn.articleId, useCaseIn.memberId)
 
         return ReadArticleUseCaseOut(
             id = articleRecord.articleId,
@@ -46,7 +60,19 @@ class ReadArticleUseCase(
             content = articleRecord.content,
             problemIds = problemIds.problemIds,
             category = CategoryType.convertToDisplayName(articleRecord.category),
-            createdAt = articleRecord.createdAt
+            createdAt = articleRecord.createdAt,
+            views = views
         )
     }
+
+    @Async(value = DATABASE_ACCESS_POOL)
+    @Transactional
+    fun insertArticleViewHisAsync(articleId: Long, memberId: Long) {
+        try {
+            articleViewHisDao.insertArticleViewHis(ArticleViewHisCommand(articleId, memberId))
+            log.debug { "Successfully inserted article view history for articleId: $articleId and memberId: $memberId" }
+        } catch (e: Exception) {
+            log.error { "Failed to insert article view history for articleId: $articleId and memberId: $memberId" }
+        }
+    }
 }

api/src/main/kotlin/com/few/api/domain/article/usecase/dto/ReadArticleUseCaseIn.kt

@@ -2,4 +2,5 @@ package com.few.api.domain.article.usecase.dto
 
 data class ReadArticleUseCaseIn(
     val articleId: Long,
+    val memberId: Long,
 )

api/src/main/kotlin/com/few/api/domain/article/usecase/dto/ReadArticleUseCaseOut.kt

@@ -11,6 +11,7 @@ data class ReadArticleUseCaseOut(
     val problemIds: List<Long>,
     val category: String,
     val createdAt: LocalDateTime,
+    val views: Long,
 )
 
 data class WriterDetail(

api/src/main/kotlin/com/few/api/web/controller/article/ArticleController.kt

@@ -27,7 +27,7 @@ class ArticleController(
         @Min(value = 1, message = "{min.id}")
         articleId: Long,
     ): ApiResponse<ApiResponse.SuccessBody<ReadArticleResponse>> {
-        val useCaseOut = ReadArticleUseCaseIn(articleId).let { useCaseIn: ReadArticleUseCaseIn ->
+        val useCaseOut = ReadArticleUseCaseIn(articleId = articleId, memberId = 0L).let { useCaseIn: ReadArticleUseCaseIn -> //TODO: membberId검토
             readArticleUseCase.execute(useCaseIn)
         }
 

api/src/main/resources/application-client-local.yml

@@ -13,3 +13,11 @@ discord:
         queue-capacity: 30
         wait-for-tasks-to-complete-on-shutdown: true
         await-termination-seconds: 60
+
+database:
+    thread-pool:
+        core-pool-size: 10
+        max-pool-size: 30
+        queue-capacity: 70
+        wait-for-tasks-to-complete-on-shutdown: true
+        await-termination-seconds: 60

api/src/main/resources/application-client-prd.yml

@@ -13,3 +13,11 @@ discord:
         queue-capacity: ${DISCORD_THREAD_POOL_QUEUE_CAPACITY:30}
         wait-for-tasks-to-complete-on-shutdown: ${DISCORD_THREAD_POOL_WAIT_FOR_TASKS_TO_COMPLETE_ON_SHUTDOWN:true}
         await-termination-seconds: ${DISCORD_THREAD_POOL_AWAIT_TERMINATION_SECONDS:60}
+
+database:
+    thread-pool:
+        core-pool-size: 10
+        max-pool-size: 30
+        queue-capacity: 70
+        wait-for-tasks-to-complete-on-shutdown: true
+        await-termination-seconds: 60

api/src/test/kotlin/com/few/api/domain/article/usecase/ReadArticleUseCaseTest.kt

@@ -6,12 +6,11 @@ import com.few.api.domain.article.service.dto.BrowseArticleProblemsOutDto
 import com.few.api.domain.article.service.dto.ReadWriterOutDto
 import com.few.api.domain.article.usecase.dto.ReadArticleUseCaseIn
 import com.few.api.repo.dao.article.ArticleDao
+import com.few.api.repo.dao.article.ArticleViewHisDao
 import com.few.api.repo.dao.article.record.SelectArticleRecord
 import io.kotest.assertions.throwables.shouldThrow
 import io.kotest.core.spec.style.BehaviorSpec
-import io.mockk.every
-import io.mockk.mockk
-import io.mockk.verify
+import io.mockk.*
 
 import java.net.URL
 import java.time.LocalDateTime
@@ -22,13 +21,20 @@ class ReadArticleUseCaseTest : BehaviorSpec({
     lateinit var readArticleWriterRecordService: ReadArticleWriterRecordService
     lateinit var browseArticleProblemsService: BrowseArticleProblemsService
     lateinit var useCase: ReadArticleUseCase
-    val useCaseIn = ReadArticleUseCaseIn(articleId = 1L)
+    lateinit var articleViewHisDao: ArticleViewHisDao
+    val useCaseIn = ReadArticleUseCaseIn(articleId = 1L, memberId = 1L)
 
     beforeContainer {
         articleDao = mockk<ArticleDao>()
         readArticleWriterRecordService = mockk<ReadArticleWriterRecordService>()
         browseArticleProblemsService = mockk<BrowseArticleProblemsService>()
-        useCase = ReadArticleUseCase(articleDao, readArticleWriterRecordService, browseArticleProblemsService)
+        articleViewHisDao = mockk<ArticleViewHisDao>()
+        useCase = ReadArticleUseCase(
+            articleDao,
+            readArticleWriterRecordService,
+            browseArticleProblemsService,
+            articleViewHisDao
+        )
     }
 
     given("아티클 조회 요청이 온 상황에서") {
@@ -52,6 +58,8 @@ class ReadArticleUseCaseTest : BehaviorSpec({
             every { articleDao.selectArticleRecord(any()) } returns record
             every { readArticleWriterRecordService.execute(any()) } returns writerSvcOutDto
             every { browseArticleProblemsService.execute(any()) } returns probSvcOutDto
+            every { articleViewHisDao.insertArticleViewHis(any()) } just Runs
+            every { articleViewHisDao.countArticleViews(any()) } returns 1L
 
             then("아티클이 정상 조회된다") {
                 useCase.execute(useCaseIn)

api/src/test/kotlin/com/few/api/web/controller/article/ArticleControllerTest.kt

@@ -69,7 +69,8 @@ class ArticleControllerTest : ControllerTestSpec() {
         val uri = UriComponentsBuilder.newInstance().path("$BASE_URL/{articleId}").build().toUriString()
         // set usecase mock
         val articleId = 1L
-        `when`(readArticleUseCase.execute(ReadArticleUseCaseIn(articleId))).thenReturn(
+        val memberId = 1L
+        `when`(readArticleUseCase.execute(ReadArticleUseCaseIn(articleId, memberId))).thenReturn(
             ReadArticleUseCaseOut(
                 id = 1L,
                 writer = WriterDetail(
@@ -81,7 +82,8 @@ class ArticleControllerTest : ControllerTestSpec() {
                 content = CategoryType.fromCode(0)!!.name,
                 problemIds = listOf(1L, 2L, 3L),
                 category = "경제",
-                createdAt = LocalDateTime.now()
+                createdAt = LocalDateTime.now(),
+                views = 1L
             )
         )
 
@@ -119,7 +121,9 @@ class ArticleControllerTest : ControllerTestSpec() {
                                         PayloadDocumentation.fieldWithPath("data.category")
                                             .fieldWithString("아티클 카테고리"),
                                         PayloadDocumentation.fieldWithPath("data.createdAt")
-                                            .fieldWithString("아티클 생성일")
+                                            .fieldWithString("아티클 생성일"),
+                                        PayloadDocumentation.fieldWithPath("data.views")
+                                            .fieldWithString("아티클 조회수")
                                     )
                                 )
                             ).build()

data/db/migration/entity/V1.00.0.7__article_view_his_table.sql

@@ -0,0 +1,13 @@
+-- 아티클 조회수 저장 테이블
+CREATE TABLE ARTICLE_VIEW_HIS
+(
+    id             BIGINT    NOT NULL AUTO_INCREMENT,
+    article_mst_id BIGINT    NOT NULL,
+    member_id      BIGINT    NOT NULL,
+    created_at     TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    deleted_at     TIMESTAMP NULL DEFAULT NULL,
+    PRIMARY KEY (id)
+);
+
+-- [인덱스 추가] --
+CREATE INDEX article_view_his_idx1 ON ARTICLE_VIEW_HIS (article_mst_id);