fix: transactionTemplate 을 적용하여 횟수가 잘못 판단되는 경우 최소화

src/main/kotlin/kr/co/vividnext/sodalive/content/order/OrderRepository.kt

@@ -291,6 +291,7 @@ class OrderQueryRepositoryImpl(
                 order.audioContent.id.eq(contentId),
                 order.createdAt.after(createdAt)
             )
+            .orderBy(order.id.desc())
             .fetchFirst()
     }
 }

src/main/kotlin/kr/co/vividnext/sodalive/useraction/UserActionService.kt

@@ -10,7 +10,9 @@ import kr.co.vividnext.sodalive.point.MemberPointRepository
 import kr.co.vividnext.sodalive.point.PointGrantLog
 import kr.co.vividnext.sodalive.point.PointGrantLogRepository
 import kr.co.vividnext.sodalive.point.PointRewardPolicyRepository
+import org.slf4j.LoggerFactory
 import org.springframework.stereotype.Service
+import org.springframework.transaction.support.TransactionTemplate
 import java.time.LocalDateTime
 
 @Service
@@ -20,6 +22,7 @@ class UserActionService(
     private val policyRepository: PointRewardPolicyRepository,
     private val grantLogRepository: PointGrantLogRepository,
     private val memberPointRepository: MemberPointRepository,
+    private val transactionTemplate: TransactionTemplate,
 
     private val fcmService: FcmService
 ) {
@@ -34,82 +37,107 @@ class UserActionService(
     ) {
         coroutineScope.launch {
             val now = LocalDateTime.now()
-            repository.save(UserActionLog(memberId, actionType))
+            transactionTemplate.execute {
+                repository.save(UserActionLog(memberId, actionType))
+                repository.flush()
+            }
 
-            val policy = policyRepository.findByActionTypeAndIsActiveTrue(actionType, now)
+            try {
-            if (policy != null) {
+                transactionTemplate.execute {
-                val policyType = policy.policyType
+                    val policy = policyRepository.findByActionTypeAndIsActiveTrue(actionType, now)
-                val todayAt15 = now.toLocalDate().atTime(15, 0)
+                    if (policy != null) {
-                val policyTypeDailyStartDate = if (now.toLocalTime().isBefore(todayAt15.toLocalTime())) {
+                        val policyType = policy.policyType
-                    now.toLocalDate().minusDays(1).atTime(15, 0)
+                        val todayAt15 = now.toLocalDate().atTime(15, 0)
-                } else {
+                        val policyTypeDailyStartDate = if (now.toLocalTime().isBefore(todayAt15.toLocalTime())) {
-                    todayAt15
+                            now.toLocalDate().minusDays(1).atTime(15, 0)
-                }
-
-                val order = if (contentId != null) {
-                    orderRepository.findByMemberIdAndContentId(
-                        memberId = memberId,
-                        contentId = contentId,
-                        createdAt = if (policyType == PolicyType.DAILY) policyTypeDailyStartDate else policy.startDate
-                    )
-                } else {
-                    null
-                }
-                if (actionType == ActionType.ORDER_CONTENT_COMMENT && order == null) return@launch
-
-                val actionCount = repository.countByMemberIdAndActionTypeAndCreatedAtBetween(
-                    memberId = memberId,
-                    actionType = actionType,
-                    startDate = if (policyType == PolicyType.DAILY) policyTypeDailyStartDate else policy.startDate,
-                    endDate = policy.endDate ?: now
-                )
-                if (actionCount < policy.threshold) return@launch
-
-                val grantedCount = grantLogRepository.countByMemberIdAndPolicyIdAndStartDate(
-                    memberId,
-                    policy.id!!,
-                    startDate = if (policyType == PolicyType.DAILY) policyTypeDailyStartDate else policy.startDate
-                )
-                if (grantedCount >= policy.availableCount) return@launch
-
-                grantLogRepository.save(
-                    PointGrantLog(
-                        memberId = memberId,
-                        point = if (actionType == ActionType.ORDER_CONTENT_COMMENT && order != null) {
-                            order.can
                         } else {
-                            policy.pointAmount
+                            todayAt15
-                        },
-                        actionType = actionType,
-                        policyId = policy.id!!,
-                        orderId = order?.id
-                    )
-                )
-
-                memberPointRepository.save(
-                    MemberPoint(
-                        memberId = memberId,
-                        point = if (actionType == ActionType.ORDER_CONTENT_COMMENT && order != null) {
-                            order.can
-                        } else {
-                            policy.pointAmount
-                        },
-                        actionType = actionType,
-                        expiresAt = now.plusDays(3)
-                    )
-                )
-
-                if (pushTokenList.isNotEmpty()) {
-                    fcmService.sendPointGranted(
-                        pushTokenList,
-                        if (actionType == ActionType.ORDER_CONTENT_COMMENT && order != null) {
-                            order.can
-                        } else {
-                            policy.pointAmount
                         }
-                    )
+
+                        val order = if (contentId != null) {
+                            orderRepository.findByMemberIdAndContentId(
+                                memberId = memberId,
+                                contentId = contentId,
+                                createdAt = if (policyType == PolicyType.DAILY) {
+                                    policyTypeDailyStartDate
+                                } else {
+                                    policy.startDate
+                                }
+                            )
+                        } else {
+                            null
+                        }
+                        if (actionType == ActionType.ORDER_CONTENT_COMMENT && order == null) return@execute
+
+                        val actionCount = repository.countByMemberIdAndActionTypeAndCreatedAtBetween(
+                            memberId = memberId,
+                            actionType = actionType,
+                            startDate = if (policyType == PolicyType.DAILY) {
+                                policyTypeDailyStartDate
+                            } else {
+                                policy.startDate
+                            },
+                            endDate = policy.endDate ?: now
+                        )
+                        if (actionCount < policy.threshold) return@execute
+
+                        val grantedCount = grantLogRepository.countByMemberIdAndPolicyIdAndStartDate(
+                            memberId,
+                            policy.id!!,
+                            startDate = if (policyType == PolicyType.DAILY) {
+                                policyTypeDailyStartDate
+                            } else {
+                                policy.startDate
+                            }
+                        )
+                        if (grantedCount >= policy.availableCount) return@execute
+
+                        grantLogRepository.save(
+                            PointGrantLog(
+                                memberId = memberId,
+                                point = if (actionType == ActionType.ORDER_CONTENT_COMMENT && order != null) {
+                                    order.can
+                                } else {
+                                    policy.pointAmount
+                                },
+                                actionType = actionType,
+                                policyId = policy.id!!,
+                                orderId = order?.id
+                            )
+                        )
+
+                        memberPointRepository.save(
+                            MemberPoint(
+                                memberId = memberId,
+                                point = if (actionType == ActionType.ORDER_CONTENT_COMMENT && order != null) {
+                                    order.can
+                                } else {
+                                    policy.pointAmount
+                                },
+                                actionType = actionType,
+                                expiresAt = now.plusDays(3)
+                            )
+                        )
+
+                        if (pushTokenList.isNotEmpty()) {
+                            fcmService.sendPointGranted(
+                                pushTokenList,
+                                if (actionType == ActionType.ORDER_CONTENT_COMMENT && order != null) {
+                                    order.can
+                                } else {
+                                    policy.pointAmount
+                                }
+                            )
+                        }
+                    }
                 }
+            } catch (e: Exception) {
+                logger.warn("포인트 지급 또는 알림 실패: ${e.message}")
             }
         }
     }
+
+    companion object {
+        private val logger = LoggerFactory.getLogger(UserActionService::class.java)
+    }
 }