src/main/kotlin/kr/co/vividnext/sodalive/can/charge/ChargeRepository.kt

@@ -17,7 +17,7 @@ interface ChargeRepository : JpaRepository<Charge, Long>, ChargeQueryRepository
 interface ChargeQueryRepository {
     fun getOldestChargeWhereRewardCanGreaterThan0(chargeId: Long, memberId: Long, container: String): Charge?
     fun getOldestChargeWhereChargeCanGreaterThan0(chargeId: Long, memberId: Long, container: String): Charge?
-    fun getChargeCountAfterDate(memberId: Long, date: LocalDateTime): Int
+    fun getChargeCountAfterDate(date: LocalDateTime): Int
 }
 
 class ChargeQueryRepositoryImpl(private val queryFactory: JPAQueryFactory) : ChargeQueryRepository {
@@ -61,19 +61,8 @@ class ChargeQueryRepositoryImpl(private val queryFactory: JPAQueryFactory) : Cha
             .fetchFirst()
     }
 
-    override fun getChargeCountAfterDate(memberId: Long, date: LocalDateTime): Int {
+    override fun getChargeCountAfterDate(date: LocalDateTime): Int {
-        return queryFactory
+        return 0
-            .select(charge.id)
-            .from(charge)
-            .innerJoin(charge.payment, payment)
-            .where(
-                charge.member.id.eq(memberId)
-                    .and(charge.createdAt.after(date))
-                    .and(charge.status.eq(ChargeStatus.CHARGE))
-                    .and(payment.status.`in`(PaymentStatus.COMPLETE, PaymentStatus.RETURN))
-            )
-            .fetch()
-            .size
     }
 
     private fun getPaymentGatewayCondition(container: String): BooleanExpression? {

src/main/kotlin/kr/co/vividnext/sodalive/can/charge/event/ChargeEventService.kt

@@ -10,7 +10,6 @@ import kr.co.vividnext.sodalive.common.SodaException
 import kr.co.vividnext.sodalive.fcm.FcmEvent
 import kr.co.vividnext.sodalive.fcm.FcmEventType
 import kr.co.vividnext.sodalive.member.Member
-import kr.co.vividnext.sodalive.member.auth.AuthRepository
 import org.springframework.context.ApplicationEventPublisher
 import org.springframework.data.repository.findByIdOrNull
 import org.springframework.stereotype.Service
@@ -21,7 +20,6 @@ import kotlin.math.round
 @Service
 class ChargeEventService(
     private val repository: ChargeEventRepository,
-    private val authRepository: AuthRepository,
     private val chargeRepository: ChargeRepository,
     private val chargeEventRepository: ChargeEventRepository,
     private val applicationEventPublisher: ApplicationEventPublisher
@@ -32,13 +30,8 @@ class ChargeEventService(
             ?: throw SodaException("이벤트가 적용되지 않았습니다.")
 
         if (member.auth != null) {
-            val authDate = authRepository.getOldestCreatedAtByDi(member.auth!!.di)
+            val authDate = member.auth!!.createdAt!!
-            val memberIds = authRepository.getMemberIdsByDi(member.auth!!.di)
+            val chargeCount = chargeRepository.getChargeCountAfterDate(authDate)
-
-            var chargeCount = 0
-            for (memberId in memberIds) {
-                chargeCount += chargeRepository.getChargeCountAfterDate(memberId = memberId, authDate)
-            }
 
             if (chargeCount > 0) {
                 applyOtherEvent(charge, member)

src/main/kotlin/kr/co/vividnext/sodalive/member/auth/AuthRepository.kt

@@ -1,36 +1,7 @@
 package kr.co.vividnext.sodalive.member.auth
 
-import com.querydsl.jpa.impl.JPAQueryFactory
-import kr.co.vividnext.sodalive.member.QMember.member
-import kr.co.vividnext.sodalive.member.auth.QAuth.auth
 import org.springframework.data.jpa.repository.JpaRepository
 import org.springframework.stereotype.Repository
-import java.time.LocalDateTime
 
 @Repository
-interface AuthRepository : JpaRepository<Auth, Long>, AuthQueryRepository
+interface AuthRepository : JpaRepository<Auth, Long>
-
-interface AuthQueryRepository {
-    fun getOldestCreatedAtByDi(di: String): LocalDateTime
-    fun getMemberIdsByDi(di: String): List<Long>
-}
-
-class AuthQueryRepositoryImpl(private val queryFactory: JPAQueryFactory) : AuthQueryRepository {
-    override fun getOldestCreatedAtByDi(di: String): LocalDateTime {
-        return queryFactory
-            .select(auth.createdAt)
-            .from(auth)
-            .where(auth.di.eq(di))
-            .orderBy(auth.createdAt.asc())
-            .fetchFirst()
-    }
-
-    override fun getMemberIdsByDi(di: String): List<Long> {
-        return queryFactory
-            .select(member.id)
-            .from(member)
-            .leftJoin(member.auth, auth)
-            .where(auth.di.eq(di))
-            .fetch()
-    }
-}