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 2ad3580..2d4d4cf 100644 --- a/src/main/kotlin/kr/co/vividnext/sodalive/member/MemberRepository.kt +++ b/src/main/kotlin/kr/co/vividnext/sodalive/member/MemberRepository.kt @@ -12,7 +12,6 @@ import kr.co.vividnext.sodalive.member.following.QCreatorFollowing.creatorFollow import kr.co.vividnext.sodalive.member.nickname.QNicknameChangeLog.nicknameChangeLog import kr.co.vividnext.sodalive.member.notification.QMemberNotification.memberNotification import kr.co.vividnext.sodalive.message.QMessage.message -import org.slf4j.LoggerFactory import org.springframework.data.jpa.repository.JpaRepository import org.springframework.stereotype.Repository @@ -35,6 +34,7 @@ interface MemberQueryRepository { fun getStartLiveRoomNotificationRecipientPushTokens( creatorId: Long, + roomId: Long, isAuth: Boolean, container: String ): List> @@ -59,7 +59,6 @@ class MemberQueryRepositoryImpl( private val queryFactory: JPAQueryFactory, private val blockMemberRepository: BlockMemberRepository ) : MemberQueryRepository { - private val logger = LoggerFactory.getLogger(this::class.java) override fun findByPushToken(pushToken: String): List { return queryFactory .selectFrom(member) @@ -148,6 +147,7 @@ class MemberQueryRepositoryImpl( override fun getStartLiveRoomNotificationRecipientPushTokens( creatorId: Long, + roomId: Long, isAuth: Boolean, container: String ): List> { @@ -172,16 +172,13 @@ class MemberQueryRepositoryImpl( .from(creatorFollowing) .where(where) .fetch() - .toSet() - .chunked(500) - logger.info("팔로잉 한 사람: $followingMemberPushToken") - - var where2 = liveReservation.isActive.isTrue + where = liveReservation.isActive.isTrue .and(liveReservation.member.notification.live.isTrue) .and(liveReservation.member.container.eq(container)) .and(liveReservation.member.email.notIn("admin@sodalive.net")) .and(liveReservation.member.pushToken.isNotNull) + .and(liveReservation.room.id.eq(roomId)) .and( liveReservation.member.id.notIn( blockMemberRepository.getBlockedMemberList(creatorId) @@ -189,20 +186,18 @@ class MemberQueryRepositoryImpl( ) if (isAuth) { - where2 = where2.and(liveReservation.member.auth.isNotNull) + where = where.and(liveReservation.member.auth.isNotNull) } val reservationMemberPushToken = queryFactory .select(liveReservation.member.pushToken) .from(liveReservation) - .where(where2) + .where(where) .fetch() + + return (followingMemberPushToken + reservationMemberPushToken) .toSet() .chunked(500) - - logger.info("예약한 사람: $reservationMemberPushToken") - - return followingMemberPushToken + reservationMemberPushToken } override fun getUploadContentNotificationRecipientPushTokens(