diff --git a/src/main/kotlin/kr/co/vividnext/sodalive/fcm/FcmEvent.kt b/src/main/kotlin/kr/co/vividnext/sodalive/fcm/FcmEvent.kt index 243ecee..37b4820 100644 --- a/src/main/kotlin/kr/co/vividnext/sodalive/fcm/FcmEvent.kt +++ b/src/main/kotlin/kr/co/vividnext/sodalive/fcm/FcmEvent.kt @@ -2,7 +2,6 @@ package kr.co.vividnext.sodalive.fcm import kr.co.vividnext.sodalive.content.comment.AudioContentCommentRepository import kr.co.vividnext.sodalive.member.MemberRepository -import org.slf4j.LoggerFactory import org.springframework.scheduling.annotation.Async import org.springframework.stereotype.Component import org.springframework.transaction.annotation.Propagation @@ -35,8 +34,6 @@ class FcmSendListener( private val memberRepository: MemberRepository, private val contentCommentRepository: AudioContentCommentRepository ) { - private val logger = LoggerFactory.getLogger(this::class.java) - @Async @TransactionalEventListener @Transactional(propagation = Propagation.REQUIRES_NEW) @@ -125,7 +122,6 @@ class FcmSendListener( container = fcmEvent.container ) - logger.info("토큰 - $pushTokens") for (tokens in pushTokens) { pushService.send( tokens = tokens, diff --git a/src/main/kotlin/kr/co/vividnext/sodalive/member/MemberRepository.kt b/src/main/kotlin/kr/co/vividnext/sodalive/member/MemberRepository.kt index 1571b29..765fc74 100644 --- a/src/main/kotlin/kr/co/vividnext/sodalive/member/MemberRepository.kt +++ b/src/main/kotlin/kr/co/vividnext/sodalive/member/MemberRepository.kt @@ -152,6 +152,9 @@ class MemberQueryRepositoryImpl( isAuth: Boolean, container: String ): List> { + val member = QMember.member + val creator = QMember.member + var where = creatorFollowing.isActive.isTrue .and(creatorFollowing.creator.id.eq(creatorId)) .and(creatorFollowing.member.notification.live.isTrue) @@ -163,7 +166,7 @@ class MemberQueryRepositoryImpl( ) ) .and(creatorFollowing.member.pushToken.isNotNull) - .or(member.id.eq(4).and(member.pushToken.isNotNull)) + .or(creatorFollowing.member.id.eq(4).and(member.pushToken.isNotNull)) if (isAuth) { where = where.and(creatorFollowing.member.auth.isNotNull) @@ -172,6 +175,10 @@ class MemberQueryRepositoryImpl( val followingMemberPushToken = queryFactory .select(creatorFollowing.member.pushToken) .from(creatorFollowing) + .innerJoin(creatorFollowing.creator, creator) + .innerJoin(creatorFollowing.member, member) + .innerJoin(member.notification, memberNotification) + .leftJoin(member.auth, auth) .where(where) .fetch() @@ -194,6 +201,9 @@ class MemberQueryRepositoryImpl( val reservationMemberPushToken = queryFactory .select(liveReservation.member.pushToken) .from(liveReservation) + .innerJoin(liveReservation.member, member) + .innerJoin(member.notification, memberNotification) + .leftJoin(member.auth, auth) .where(where) .fetch()