라이브 취소 푸시 발송 로직 추가

This commit is contained in:
Klaus 2023-09-01 17:29:57 +09:00
parent 896246d9ed
commit a285e30108
1 changed files with 11 additions and 15 deletions

View File

@ -361,29 +361,25 @@ class MemberQueryRepositoryImpl(
} }
override fun getPushTokenFromReservationList(roomId: Long): Map<String, List<List<String>>> { override fun getPushTokenFromReservationList(roomId: Long): Map<String, List<List<String>>> {
val query = queryFactory val where = liveRoom.id.eq(roomId)
.and(liveReservation.isActive.isTrue)
val aosPushTokens = queryFactory
.select(liveReservation.member.pushToken) .select(liveReservation.member.pushToken)
.from(liveReservation) .from(liveReservation)
.innerJoin(liveReservation.room, liveRoom) .innerJoin(liveReservation.room, liveRoom)
.innerJoin(liveReservation.member, member) .innerJoin(liveReservation.member, member)
.where(where.and(member.container.eq("aos")))
val where = liveRoom.id.eq(roomId)
.and(liveReservation.isActive.isTrue)
val aosPushTokens = query
.where(
where
.and(member.container.eq("aos"))
)
.fetch() .fetch()
.toSet() .toSet()
.chunked(500) .chunked(500)
val iosPushTokens = query val iosPushTokens = queryFactory
.where( .select(liveReservation.member.pushToken)
where .from(liveReservation)
.and(member.container.eq("ios")) .innerJoin(liveReservation.room, liveRoom)
) .innerJoin(liveReservation.member, member)
.where(where.and(member.container.eq("ios")))
.fetch() .fetch()
.toSet() .toSet()
.chunked(500) .chunked(500)