라이브 시작 알림 - 알림 받을 유저 조회에서 에러가 발생하는 버그 수정 #36
| @@ -2,7 +2,6 @@ package kr.co.vividnext.sodalive.fcm | |||||||
|  |  | ||||||
| import kr.co.vividnext.sodalive.content.comment.AudioContentCommentRepository | import kr.co.vividnext.sodalive.content.comment.AudioContentCommentRepository | ||||||
| import kr.co.vividnext.sodalive.member.MemberRepository | import kr.co.vividnext.sodalive.member.MemberRepository | ||||||
| import org.slf4j.LoggerFactory |  | ||||||
| import org.springframework.scheduling.annotation.Async | import org.springframework.scheduling.annotation.Async | ||||||
| import org.springframework.stereotype.Component | import org.springframework.stereotype.Component | ||||||
| import org.springframework.transaction.annotation.Propagation | import org.springframework.transaction.annotation.Propagation | ||||||
| @@ -35,8 +34,6 @@ class FcmSendListener( | |||||||
|     private val memberRepository: MemberRepository, |     private val memberRepository: MemberRepository, | ||||||
|     private val contentCommentRepository: AudioContentCommentRepository |     private val contentCommentRepository: AudioContentCommentRepository | ||||||
| ) { | ) { | ||||||
|     private val logger = LoggerFactory.getLogger(this::class.java) |  | ||||||
|  |  | ||||||
|     @Async |     @Async | ||||||
|     @TransactionalEventListener |     @TransactionalEventListener | ||||||
|     @Transactional(propagation = Propagation.REQUIRES_NEW) |     @Transactional(propagation = Propagation.REQUIRES_NEW) | ||||||
| @@ -125,7 +122,6 @@ class FcmSendListener( | |||||||
|                         container = fcmEvent.container |                         container = fcmEvent.container | ||||||
|                     ) |                     ) | ||||||
|  |  | ||||||
|                     logger.info("토큰 - $pushTokens") |  | ||||||
|                     for (tokens in pushTokens) { |                     for (tokens in pushTokens) { | ||||||
|                         pushService.send( |                         pushService.send( | ||||||
|                             tokens = tokens, |                             tokens = tokens, | ||||||
|   | |||||||
| @@ -152,6 +152,9 @@ class MemberQueryRepositoryImpl( | |||||||
|         isAuth: Boolean, |         isAuth: Boolean, | ||||||
|         container: String |         container: String | ||||||
|     ): List<List<String>> { |     ): List<List<String>> { | ||||||
|  |         val member = QMember.member | ||||||
|  |         val creator = QMember.member | ||||||
|  |  | ||||||
|         var where = creatorFollowing.isActive.isTrue |         var where = creatorFollowing.isActive.isTrue | ||||||
|             .and(creatorFollowing.creator.id.eq(creatorId)) |             .and(creatorFollowing.creator.id.eq(creatorId)) | ||||||
|             .and(creatorFollowing.member.notification.live.isTrue) |             .and(creatorFollowing.member.notification.live.isTrue) | ||||||
| @@ -163,7 +166,7 @@ class MemberQueryRepositoryImpl( | |||||||
|                 ) |                 ) | ||||||
|             ) |             ) | ||||||
|             .and(creatorFollowing.member.pushToken.isNotNull) |             .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) { |         if (isAuth) { | ||||||
|             where = where.and(creatorFollowing.member.auth.isNotNull) |             where = where.and(creatorFollowing.member.auth.isNotNull) | ||||||
| @@ -172,6 +175,10 @@ class MemberQueryRepositoryImpl( | |||||||
|         val followingMemberPushToken = queryFactory |         val followingMemberPushToken = queryFactory | ||||||
|             .select(creatorFollowing.member.pushToken) |             .select(creatorFollowing.member.pushToken) | ||||||
|             .from(creatorFollowing) |             .from(creatorFollowing) | ||||||
|  |             .innerJoin(creatorFollowing.creator, creator) | ||||||
|  |             .innerJoin(creatorFollowing.member, member) | ||||||
|  |             .innerJoin(member.notification, memberNotification) | ||||||
|  |             .leftJoin(member.auth, auth) | ||||||
|             .where(where) |             .where(where) | ||||||
|             .fetch() |             .fetch() | ||||||
|  |  | ||||||
| @@ -194,6 +201,9 @@ class MemberQueryRepositoryImpl( | |||||||
|         val reservationMemberPushToken = queryFactory |         val reservationMemberPushToken = queryFactory | ||||||
|             .select(liveReservation.member.pushToken) |             .select(liveReservation.member.pushToken) | ||||||
|             .from(liveReservation) |             .from(liveReservation) | ||||||
|  |             .innerJoin(liveReservation.member, member) | ||||||
|  |             .innerJoin(member.notification, memberNotification) | ||||||
|  |             .leftJoin(member.auth, auth) | ||||||
|             .where(where) |             .where(where) | ||||||
|             .fetch() |             .fetch() | ||||||
|  |  | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user