Merge pull request #182 from team-gogo/feature/community-community-board-hits-add

Umjiseung · web-flow · commit 14f936e4ef3e · 2025-04-28T11:00:27.000+09:00
[community] 게시글 조회수 적용
diff --git a/src/main/kotlin/gogo/gogostage/GogoStageApplication.kt b/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
diff --git a/src/main/kotlin/gogo/gogostage/domain/community/board/application/BoardProcessor.kt b/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)
diff --git a/src/main/kotlin/gogo/gogostage/domain/community/board/persistence/Board.kt b/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
+    }
+
 }
diff --git a/src/main/kotlin/gogo/gogostage/domain/community/boardview/persistence/BoardView.kt b/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,
+)
diff --git a/src/main/kotlin/gogo/gogostage/domain/community/boardview/persistence/BoardViewRepository.kt b/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
+}
diff --git a/src/main/kotlin/gogo/gogostage/domain/community/root/application/CommunityProcessor.kt b/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)
+        }
+    }
 }
diff --git a/src/main/kotlin/gogo/gogostage/domain/community/root/application/CommunityServiceImpl.kt b/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
diff --git a/src/main/kotlin/gogo/gogostage/domain/community/root/application/dto/CommunityDto.kt b/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>
diff --git a/src/main/kotlin/gogo/gogostage/domain/community/root/event/BoardViewEvent.kt b/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
+)
diff --git a/src/main/kotlin/gogo/gogostage/domain/community/root/event/handler/BoardViewEventHandler.kt b/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)
+    }
+
+}
diff --git a/src/main/kotlin/gogo/gogostage/domain/community/root/persistence/CommunityCustomRepositoryImpl.kt b/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
diff --git a/src/main/kotlin/gogo/gogostage/global/config/AsyncConfig.kt b/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
+    }
+
+}

Original file line number	Diff line number	Diff line change
`@@ -28,6 +28,7 @@ class BoardProcessor(`
`28`	`28`	`isFiltered = false,`
`29`	`29`	`createdAt = LocalDateTime.now(),`
`30`	`30`	`imageUrl = writeCommunityBoardDto.imageUrl,`
	`31`	`+ viewCount = 0`
`31`	`32`	`)`
`32`	`33`
`33`	`34`	`return boardRepository.save(board)`