[community] 게시글 조회수 적용

src/main/kotlin/gogo/gogostage/GogoStageApplication.kt

@@ -2,6 +2,7 @@ package gogo.gogostage
 
 import org.springframework.boot.autoconfigure.SpringBootApplication
 import org.springframework.boot.runApplication
+import org.springframework.scheduling.annotation.EnableAsync
 import org.springframework.scheduling.annotation.EnableScheduling
 
 @EnableScheduling

src/main/kotlin/gogo/gogostage/domain/community/board/application/BoardProcessor.kt

@@ -28,6 +28,7 @@ class BoardProcessor(
             isFiltered = false,
             createdAt = LocalDateTime.now(),
             imageUrl = writeCommunityBoardDto.imageUrl,
+            viewCount = 0
         )
 
         return boardRepository.save(board)

src/main/kotlin/gogo/gogostage/domain/community/board/persistence/Board.kt

@@ -31,6 +31,9 @@ class Board(
     @Column(name = "like_count", nullable = false)
     var likeCount: Int,
 
+    @Column(name = "view_count", nullable = false)
+    var viewCount: Int,
+
     @Column(name = "is_filtered", nullable = false)
     var isFiltered: Boolean,
 
@@ -57,4 +60,8 @@ class Board(
         isFiltered = true
     }
 
+    fun plusViewCount() {
+        viewCount += 1
+    }
+
 }

src/main/kotlin/gogo/gogostage/domain/community/boardview/persistence/BoardView.kt

@@ -0,0 +1,21 @@
+package gogo.gogostage.domain.community.boardview.persistence
+
+import gogo.gogostage.domain.community.board.persistence.Board
+import jakarta.persistence.*
+
+@Entity
+@Table(name = "tbl_board_view")
+class BoardView(
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "id", nullable = false)
+    val id: Long = 0,
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "board_id", nullable = false)
+    val board: Board,
+
+    @Column(name = "student_id", nullable = false)
+    val studentId: Long,
+)

src/main/kotlin/gogo/gogostage/domain/community/boardview/persistence/BoardViewRepository.kt

@@ -0,0 +1,8 @@
+package gogo.gogostage.domain.community.boardview.persistence
+
+import org.springframework.data.jpa.repository.JpaRepository
+
+interface BoardViewRepository: JpaRepository<BoardView, Long> {
+
+    fun existsByBoardIdAndStudentId(boardId: Long, studentId: Long): Boolean
+}

src/main/kotlin/gogo/gogostage/domain/community/root/application/CommunityProcessor.kt

@@ -1,14 +1,18 @@
 package gogo.gogostage.domain.community.root.application
 
+import gogo.gogostage.domain.community.board.application.BoardReader
 import gogo.gogostage.domain.community.board.persistence.Board
 import gogo.gogostage.domain.community.board.persistence.BoardRepository
 import gogo.gogostage.domain.community.boardlike.persistence.BoardLike
 import gogo.gogostage.domain.community.boardlike.persistence.BoardLikeRepository
+import gogo.gogostage.domain.community.boardview.persistence.BoardView
+import gogo.gogostage.domain.community.boardview.persistence.BoardViewRepository
 import gogo.gogostage.domain.community.comment.persistence.Comment
 import gogo.gogostage.domain.community.comment.persistence.CommentRepository
 import gogo.gogostage.domain.community.commentlike.persistence.CommentLike
 import gogo.gogostage.domain.community.commentlike.persistence.CommentLikeRepository
 import gogo.gogostage.domain.community.root.application.dto.*
+import gogo.gogostage.domain.community.root.event.BoardViewEvent
 import gogo.gogostage.global.error.StageException
 import gogo.gogostage.global.internal.student.stub.StudentByIdStub
 import org.springframework.data.repository.findByIdOrNull
@@ -24,6 +28,8 @@ class CommunityProcessor(
     private val commentLikeRepository: CommentLikeRepository,
     private val commentMapper: CommunityMapper,
     private val boardRepository: BoardRepository,
+    private val boardViewRepository: BoardViewRepository,
+    private val boardReader: BoardReader
 ) {
 
     fun likeBoard(studentId: Long, board: Board): LikeResDto {
@@ -130,4 +136,22 @@ class CommunityProcessor(
 
         commentRepository.save(comment)
     }
+
+    @Transactional
+    fun saveBoardView(event: BoardViewEvent) {
+        val board = boardReader.read(event.boardId)
+
+        if (!boardViewRepository.existsByBoardIdAndStudentId(board.id, board.studentId)) {
+            val newBoardView = BoardView(
+                board = board,
+                studentId = board.studentId,
+            )
+
+            boardViewRepository.save(newBoardView)
+
+            board.plusViewCount()
+
+            boardRepository.save(board)
+        }
+    }
 }

src/main/kotlin/gogo/gogostage/domain/community/root/application/CommunityServiceImpl.kt

@@ -4,6 +4,7 @@ import gogo.gogostage.domain.community.board.application.BoardProcessor
 import gogo.gogostage.domain.community.board.application.BoardReader
 import gogo.gogostage.domain.community.root.application.dto.*
 import gogo.gogostage.domain.community.root.event.BoardCreateEvent
+import gogo.gogostage.domain.community.root.event.BoardViewEvent
 import gogo.gogostage.domain.community.root.event.CommentCreateEvent
 import gogo.gogostage.domain.community.root.persistence.SortType
 import gogo.gogostage.domain.game.persistence.GameCategory
@@ -55,7 +56,16 @@ class CommunityServiceImpl(
         val board = boardReader.read(boardId)
         stageValidator.validStage(student, board.community.stage.id)
         stageValidator.validProfanityFilter(student, board)
-        return communityReader.readBoardInfo(isFiltered, board, student)
+        val response = communityReader.readBoardInfo(isFiltered, board, student)
+
+        applicationEventPublisher.publishEvent(
+            BoardViewEvent(
+                boardId = boardId,
+                studentId = student.studentId,
+            )
+        )
+
+        return response
     }
 
     @Transactional

src/main/kotlin/gogo/gogostage/domain/community/root/application/dto/CommunityDto.kt

@@ -50,6 +50,7 @@ data class GetCommunityBoardInfoResDto(
     @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd'T'HH:mm:ss")
     val createdAt: LocalDateTime,
     val imageUrl: String?,
+    val viewCount: Int,
     val stage: StageDto,
     val commentCount: Int,
     val comment: List<CommentDto>

src/main/kotlin/gogo/gogostage/domain/community/root/event/BoardViewEvent.kt

@@ -0,0 +1,6 @@
+package gogo.gogostage.domain.community.root.event
+
+data class BoardViewEvent(
+    val boardId: Long,
+    val studentId: Long
+)

src/main/kotlin/gogo/gogostage/domain/community/root/event/handler/BoardViewEventHandler.kt

@@ -0,0 +1,21 @@
+package gogo.gogostage.domain.community.root.event.handler
+
+import gogo.gogostage.domain.community.root.application.CommunityProcessor
+import gogo.gogostage.domain.community.root.event.BoardViewEvent
+import org.springframework.scheduling.annotation.Async
+import org.springframework.stereotype.Component
+import org.springframework.transaction.event.TransactionPhase
+import org.springframework.transaction.event.TransactionalEventListener
+
+@Component
+class BoardViewEventHandler(
+    private val communityProcessor: CommunityProcessor,
+) {
+
+    @Async("asyncExecutor")
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    fun eventHandler(event: BoardViewEvent) {
+        communityProcessor.saveBoardView(event)
+    }
+
+}

src/main/kotlin/gogo/gogostage/domain/community/root/persistence/CommunityCustomRepositoryImpl.kt

@@ -124,7 +124,8 @@ class CommunityCustomRepositoryImpl(
             stage = stageDto,
             commentCount = board.commentCount,
             comment = commentDto,
-            imageUrl = board.imageUrl
+            imageUrl = board.imageUrl,
+            viewCount = board.viewCount,
         )
 
         return response

src/main/kotlin/gogo/gogostage/global/config/AsyncConfig.kt

@@ -0,0 +1,32 @@
+package gogo.gogostage.global.config
+
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.scheduling.annotation.EnableAsync
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
+import java.util.concurrent.Executor
+import java.util.concurrent.ThreadPoolExecutor
+
+
+@Configuration
+@EnableAsync
+class AsyncConfig {
+
+    @Bean(name = ["asyncExecutor"])
+    fun asyncExecutor(): Executor {
+        val executor = ThreadPoolTaskExecutor()
+        executor.corePoolSize = 5
+        executor.maxPoolSize = 20
+        executor.queueCapacity = 50
+        executor.keepAliveSeconds = 60
+        executor.setAllowCoreThreadTimeOut(true)
+        executor.setPrestartAllCoreThreads(true)
+        executor.setWaitForTasksToCompleteOnShutdown(true)
+        executor.setAwaitTerminationSeconds(20)
+        executor.setRejectedExecutionHandler(ThreadPoolExecutor.CallerRunsPolicy())
+        executor.initialize()
+
+        return executor
+    }
+
+}