Feat/#34. 유저 활동 데이터 누적 AOP로 처리

adevspoon-domain/src/main/kotlin/com/adevspoon/domain/board/service/BoardPostDomainService.kt

@@ -7,6 +7,8 @@ import com.adevspoon.domain.board.exception.BoardTageNotFoundException
 import com.adevspoon.domain.board.repository.BoardPostRepository
 import com.adevspoon.domain.board.repository.BoardTagRepository
 import com.adevspoon.domain.common.annotation.DomainService
+import com.adevspoon.domain.common.annotation.ActivityEvent
+import com.adevspoon.domain.common.annotation.ActivityEventType
 import com.adevspoon.domain.common.service.LikeDomainService
 import com.adevspoon.domain.common.utils.CursorPageable
 import com.adevspoon.domain.common.utils.PageWithCursor
@@ -23,6 +25,7 @@ class BoardPostDomainService(
     val memberDomainService: MemberDomainService,
     val likeDomainService: LikeDomainService
 ) {
+    @ActivityEvent(ActivityEventType.BOARD_POST)
     @Transactional
     fun registerBoardPost(userId: Long, tagId: Int, title: String, content: String): BoardPost {
         val user = memberDomainService.getUserEntity(userId)

adevspoon-domain/src/main/kotlin/com/adevspoon/domain/common/annotation/ActivityEvent.kt

@@ -0,0 +1,7 @@
+package com.adevspoon.domain.common.annotation
+
+@Target(AnnotationTarget.FUNCTION)
+@Retention(AnnotationRetention.RUNTIME)
+annotation class ActivityEvent(
+    val type: ActivityEventType
+)

adevspoon-domain/src/main/kotlin/com/adevspoon/domain/common/annotation/ActivityEventType.kt

@@ -0,0 +1,7 @@
+package com.adevspoon.domain.common.annotation
+
+enum class ActivityEventType {
+    ATTENDANCE,
+    ANSWER,
+    BOARD_POST,
+}

adevspoon-domain/src/main/kotlin/com/adevspoon/domain/common/aop/ActivityEventAdvisor.kt

@@ -0,0 +1,55 @@
+package com.adevspoon.domain.common.aop
+
+import com.adevspoon.domain.board.dto.response.BoardPost
+import com.adevspoon.domain.common.annotation.ActivityEvent
+import com.adevspoon.domain.common.annotation.ActivityEventType
+import com.adevspoon.domain.common.event.BoardPostActivityEvent
+import org.aspectj.lang.JoinPoint
+import org.aspectj.lang.annotation.AfterReturning
+import org.aspectj.lang.annotation.Aspect
+import org.aspectj.lang.reflect.MethodSignature
+import org.springframework.context.ApplicationEventPublisher
+import org.springframework.core.Ordered
+import org.springframework.core.annotation.Order
+import org.springframework.stereotype.Component
+
+
+@Aspect
+@Component
+@Order(Ordered.LOWEST_PRECEDENCE)
+class ActivityEventAdvisor(
+    private val eventPublisher: ApplicationEventPublisher
+) {
+    @AfterReturning(pointcut = "@annotation(com.adevspoon.domain.common.annotation.ActivityEvent)", returning = "result")
+    fun afterReturningAdvice(joinPoint: JoinPoint, result: Any?) {
+        val activityAnnotation = getAnnotation(joinPoint)
+
+        when(activityAnnotation.type) {
+            ActivityEventType.ATTENDANCE -> attendanceEventPublish(result)
+            ActivityEventType.ANSWER -> answerEventPublish(result)
+            ActivityEventType.BOARD_POST -> boardPostEventPublish(result)
+        }
+    }
+
+    private fun getAnnotation(joinPoint: JoinPoint) =
+        (joinPoint.signature as MethodSignature).method
+            .getAnnotation(ActivityEvent::class.java)
+
+    private fun boardPostEventPublish(result: Any?) {
+        (result as? BoardPost)?.let {
+            eventPublisher.publishEvent(BoardPostActivityEvent(it.user.memberId))
+        }
+    }
+
+    private fun attendanceEventPublish(result: Any?) {
+        TODO("""
+            Implement the logic to publish the ATTENDANCE event
+        """.trimIndent())
+    }
+
+    private fun answerEventPublish(result: Any?) {
+        TODO("""
+            Implement the logic to publish the ANSWER event
+        """.trimIndent())
+    }
+}

adevspoon-domain/src/main/kotlin/com/adevspoon/domain/common/event/AnswerActivityEvent.kt

@@ -0,0 +1,6 @@
+package com.adevspoon.domain.common.event
+
+data class AnswerActivityEvent(
+    val memberId: Long,
+    val answerId: Long,
+)

adevspoon-domain/src/main/kotlin/com/adevspoon/domain/common/event/AttendanceActivityEvent.kt

@@ -0,0 +1,5 @@
+package com.adevspoon.domain.common.event
+
+data class AttendanceActivityEvent(
+    val memberId: Long
+)

adevspoon-domain/src/main/kotlin/com/adevspoon/domain/common/event/BoardPostActivityEvent.kt

@@ -0,0 +1,5 @@
+package com.adevspoon.domain.common.event
+
+data class BoardPostActivityEvent(
+    val memberId: Long,
+)

adevspoon-domain/src/main/kotlin/com/adevspoon/domain/config/AsyncConfig.kt

@@ -0,0 +1,8 @@
+package com.adevspoon.domain.config
+
+import org.springframework.context.annotation.Configuration
+import org.springframework.scheduling.annotation.EnableAsync
+
+@Configuration
+@EnableAsync
+class AsyncConfig

adevspoon-domain/src/main/kotlin/com/adevspoon/domain/config/JpaConfig.kt

@@ -7,15 +7,19 @@ import org.springframework.boot.context.properties.ConfigurationProperties
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration
 import org.springframework.context.annotation.Primary
+import org.springframework.core.Ordered
 import org.springframework.data.jpa.repository.config.EnableJpaAuditing
 import org.springframework.data.jpa.repository.config.EnableJpaRepositories
+import org.springframework.transaction.annotation.EnableTransactionManagement
 import javax.sql.DataSource
 
 
 @Configuration
 @EnableJpaAuditing
 @EntityScan(basePackages = ["com.adevspoon.domain"])
 @EnableJpaRepositories(basePackages = ["com.adevspoon.domain"])
+// Transaction 전 후로 실행되는 AOP를 위해 직접 설정
+@EnableTransactionManagement(order = Ordered.LOWEST_PRECEDENCE - 10)
 class JpaConfig {
 
     @Bean

adevspoon-domain/src/main/kotlin/com/adevspoon/domain/member/repository/UserActivityRepository.kt

@@ -1,7 +1,18 @@
 package com.adevspoon.domain.member.repository
 
 import com.adevspoon.domain.member.domain.UserActivityEntity
+import jakarta.persistence.LockModeType
 import org.springframework.data.jpa.repository.JpaRepository
+import org.springframework.data.jpa.repository.Lock
+import org.springframework.data.jpa.repository.Modifying
+import org.springframework.data.jpa.repository.Query
 
 interface UserActivityRepository : JpaRepository<UserActivityEntity, Long> {
+    @Modifying(clearAutomatically = true)
+    @Query("UPDATE UserActivityEntity u SET u.boardPostCount = u.boardPostCount + 1 WHERE u.id = :userId")
+    fun increaseBoardPostCount(userId: Long): Int
+
+    @Lock(LockModeType.PESSIMISTIC_WRITE)
+    @Query("SELECT u FROM UserActivityEntity u WHERE u.id = :userid")
+    fun findByIdWithLock(userid: Long): UserActivityEntity?
 }

adevspoon-domain/src/main/kotlin/com/adevspoon/domain/member/service/MemberActivityEventHandler.kt

@@ -0,0 +1,42 @@
+package com.adevspoon.domain.member.service
+
+import com.adevspoon.domain.common.annotation.DomainService
+import com.adevspoon.domain.common.event.AnswerActivityEvent
+import com.adevspoon.domain.common.event.AttendanceActivityEvent
+import com.adevspoon.domain.common.event.BoardPostActivityEvent
+import com.adevspoon.domain.member.repository.UserActivityRepository
+import jakarta.transaction.Transactional
+import org.springframework.scheduling.annotation.Async
+import org.springframework.transaction.event.TransactionPhase
+import org.springframework.transaction.event.TransactionalEventListener
+
+@DomainService
+class MemberActivityEventHandler(
+    private val userActivityRepository: UserActivityRepository,
+) {
+
+    @Async
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    @Transactional
+    fun handleAttendanceEvent(event: AttendanceActivityEvent) {
+        TODO("""
+            Implement the logic to handle the ATTENDANCE event
+        """.trimIndent())
+    }
+
+    @Async
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    @Transactional
+    fun handleAnswerEvent(event: AnswerActivityEvent) {
+        TODO("""
+            Implement the logic to handle the ANSWER event
+        """.trimIndent())
+    }
+
+    @Async
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    @Transactional
+    fun handleBoardPostEvent(event: BoardPostActivityEvent) {
+        userActivityRepository.increaseBoardPostCount(event.memberId)
+    }
+}