Compare commits
No commits in common. "ef917ecc25fea8972f76b6ab73e3bb6f4fce48ab" and "a93faad951ae6429f459cdf4faab04c65a3fb62f" have entirely different histories.
ef917ecc25
...
a93faad951
|
@ -351,10 +351,6 @@ class ExplorerQueryRepository(
|
||||||
where = where.and(liveRoom.isAdult.isFalse)
|
where = where.and(liveRoom.isAdult.isFalse)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (userMember.role == MemberRole.CREATOR) {
|
|
||||||
where = where.and(liveRoom.isAvailableJoinCreator.isTrue)
|
|
||||||
}
|
|
||||||
|
|
||||||
val result = mutableListOf<LiveRoom>()
|
val result = mutableListOf<LiveRoom>()
|
||||||
|
|
||||||
if (offset == 0L) {
|
if (offset == 0L) {
|
||||||
|
|
|
@ -26,8 +26,7 @@ class FcmEvent(
|
||||||
val messageId: Long? = null,
|
val messageId: Long? = null,
|
||||||
val creatorId: Long? = null,
|
val creatorId: Long? = null,
|
||||||
val commentParentId: Long? = null,
|
val commentParentId: Long? = null,
|
||||||
val myMemberId: Long? = null,
|
val myMemberId: Long? = null
|
||||||
val isAvailableJoinCreator: Boolean? = null
|
|
||||||
)
|
)
|
||||||
|
|
||||||
@Component
|
@Component
|
||||||
|
@ -100,7 +99,6 @@ class FcmSendListener(
|
||||||
val pushTokens = memberRepository.getCreateLiveRoomNotificationRecipientPushTokens(
|
val pushTokens = memberRepository.getCreateLiveRoomNotificationRecipientPushTokens(
|
||||||
creatorId = fcmEvent.creatorId!!,
|
creatorId = fcmEvent.creatorId!!,
|
||||||
isAuth = fcmEvent.isAuth ?: false,
|
isAuth = fcmEvent.isAuth ?: false,
|
||||||
isAvailableJoinCreator = fcmEvent.isAvailableJoinCreator ?: false,
|
|
||||||
container = fcmEvent.container
|
container = fcmEvent.container
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -122,7 +120,6 @@ class FcmSendListener(
|
||||||
creatorId = fcmEvent.creatorId!!,
|
creatorId = fcmEvent.creatorId!!,
|
||||||
roomId = fcmEvent.roomId!!,
|
roomId = fcmEvent.roomId!!,
|
||||||
isAuth = fcmEvent.isAuth ?: false,
|
isAuth = fcmEvent.isAuth ?: false,
|
||||||
isAvailableJoinCreator = fcmEvent.isAvailableJoinCreator ?: false,
|
|
||||||
container = fcmEvent.container
|
container = fcmEvent.container
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
|
@ -53,7 +53,6 @@ class LiveRecommendRepository(
|
||||||
fun getOnAirRecommendChannelList(
|
fun getOnAirRecommendChannelList(
|
||||||
memberId: Long,
|
memberId: Long,
|
||||||
isBlocked: (Long) -> Boolean,
|
isBlocked: (Long) -> Boolean,
|
||||||
isCreator: Boolean,
|
|
||||||
isAdult: Boolean
|
isAdult: Boolean
|
||||||
): List<GetRecommendChannelResponse> {
|
): List<GetRecommendChannelResponse> {
|
||||||
var where = member.role.eq(MemberRole.CREATOR)
|
var where = member.role.eq(MemberRole.CREATOR)
|
||||||
|
@ -63,10 +62,6 @@ class LiveRecommendRepository(
|
||||||
where = where.and(liveRoom.isAdult.isFalse)
|
where = where.and(liveRoom.isAdult.isFalse)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (isCreator) {
|
|
||||||
where = where.and(liveRoom.isAvailableJoinCreator.isTrue)
|
|
||||||
}
|
|
||||||
|
|
||||||
return queryFactory
|
return queryFactory
|
||||||
.select(
|
.select(
|
||||||
Projections.constructor(
|
Projections.constructor(
|
||||||
|
@ -118,13 +113,14 @@ class LiveRecommendRepository(
|
||||||
.orderBy(Expressions.numberTemplate(Double::class.java, "function('rand')").asc())
|
.orderBy(Expressions.numberTemplate(Double::class.java, "function('rand')").asc())
|
||||||
.limit(limit)
|
.limit(limit)
|
||||||
.fetch()
|
.fetch()
|
||||||
|
.asSequence()
|
||||||
.filter { !isBlocked(it.creatorId) }
|
.filter { !isBlocked(it.creatorId) }
|
||||||
|
.toList()
|
||||||
}
|
}
|
||||||
|
|
||||||
fun getOnAirFollowingChannelList(
|
fun getOnAirFollowingChannelList(
|
||||||
memberId: Long,
|
memberId: Long,
|
||||||
isBlocked: (Long) -> Boolean,
|
isBlocked: (Long) -> Boolean,
|
||||||
isCreator: Boolean,
|
|
||||||
isAdult: Boolean
|
isAdult: Boolean
|
||||||
): List<GetRecommendChannelResponse> {
|
): List<GetRecommendChannelResponse> {
|
||||||
var where = member.role.eq(MemberRole.CREATOR)
|
var where = member.role.eq(MemberRole.CREATOR)
|
||||||
|
@ -134,10 +130,6 @@ class LiveRecommendRepository(
|
||||||
where = where.and(liveRoom.isAdult.isFalse)
|
where = where.and(liveRoom.isAdult.isFalse)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (isCreator) {
|
|
||||||
where = where.and(liveRoom.isAvailableJoinCreator.isTrue)
|
|
||||||
}
|
|
||||||
|
|
||||||
return queryFactory
|
return queryFactory
|
||||||
.select(
|
.select(
|
||||||
Projections.constructor(
|
Projections.constructor(
|
||||||
|
|
|
@ -1,7 +1,6 @@
|
||||||
package kr.co.vividnext.sodalive.live.recommend
|
package kr.co.vividnext.sodalive.live.recommend
|
||||||
|
|
||||||
import kr.co.vividnext.sodalive.member.Member
|
import kr.co.vividnext.sodalive.member.Member
|
||||||
import kr.co.vividnext.sodalive.member.MemberRole
|
|
||||||
import kr.co.vividnext.sodalive.member.block.BlockMemberRepository
|
import kr.co.vividnext.sodalive.member.block.BlockMemberRepository
|
||||||
import org.springframework.data.domain.Pageable
|
import org.springframework.data.domain.Pageable
|
||||||
import org.springframework.stereotype.Service
|
import org.springframework.stereotype.Service
|
||||||
|
@ -24,7 +23,6 @@ class LiveRecommendService(
|
||||||
val onAirChannelList = repository.getOnAirRecommendChannelList(
|
val onAirChannelList = repository.getOnAirRecommendChannelList(
|
||||||
member.id!!,
|
member.id!!,
|
||||||
isBlocked = { blockMemberRepository.isBlocked(blockedMemberId = member.id!!, memberId = it) },
|
isBlocked = { blockMemberRepository.isBlocked(blockedMemberId = member.id!!, memberId = it) },
|
||||||
isCreator = member.role == MemberRole.CREATOR,
|
|
||||||
isAdult = member.auth != null
|
isAdult = member.auth != null
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -32,7 +30,9 @@ class LiveRecommendService(
|
||||||
return onAirChannelList
|
return onAirChannelList
|
||||||
}
|
}
|
||||||
|
|
||||||
val onAirCreatorIdList = onAirChannelList.map { it.creatorId }
|
val onAirCreatorIdList = onAirChannelList.asSequence()
|
||||||
|
.map { it.creatorId }
|
||||||
|
.toList()
|
||||||
|
|
||||||
val notOnAirCreatorList = repository.getRecommendChannelList(
|
val notOnAirCreatorList = repository.getRecommendChannelList(
|
||||||
member.id!!,
|
member.id!!,
|
||||||
|
@ -48,7 +48,6 @@ class LiveRecommendService(
|
||||||
val onAirFollowingChannelList = repository.getOnAirFollowingChannelList(
|
val onAirFollowingChannelList = repository.getOnAirFollowingChannelList(
|
||||||
memberId = member.id!!,
|
memberId = member.id!!,
|
||||||
isBlocked = { blockMemberRepository.isBlocked(blockedMemberId = member.id!!, memberId = it) },
|
isBlocked = { blockMemberRepository.isBlocked(blockedMemberId = member.id!!, memberId = it) },
|
||||||
isCreator = member.role == MemberRole.CREATOR,
|
|
||||||
isAdult = member.auth != null
|
isAdult = member.auth != null
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -56,7 +55,9 @@ class LiveRecommendService(
|
||||||
return onAirFollowingChannelList
|
return onAirFollowingChannelList
|
||||||
}
|
}
|
||||||
|
|
||||||
val onAirCreatorIdList = onAirFollowingChannelList.map { it.creatorId }
|
val onAirCreatorIdList = onAirFollowingChannelList.asSequence()
|
||||||
|
.map { it.creatorId }
|
||||||
|
.toList()
|
||||||
|
|
||||||
val notOnAirFollowingChannelList = repository.getFollowingChannelList(
|
val notOnAirFollowingChannelList = repository.getFollowingChannelList(
|
||||||
memberId = member.id!!,
|
memberId = member.id!!,
|
||||||
|
|
|
@ -14,6 +14,5 @@ data class CreateLiveRoomRequest(
|
||||||
val password: String? = null,
|
val password: String? = null,
|
||||||
val menuPanId: Long = 0,
|
val menuPanId: Long = 0,
|
||||||
val menuPan: String = "",
|
val menuPan: String = "",
|
||||||
val isActiveMenuPan: Boolean = false,
|
val isActiveMenuPan: Boolean = false
|
||||||
val isAvailableJoinCreator: Boolean = true
|
|
||||||
)
|
)
|
||||||
|
|
|
@ -28,7 +28,6 @@ data class LiveRoom(
|
||||||
var bgImage: String? = null,
|
var bgImage: String? = null,
|
||||||
var isAdult: Boolean,
|
var isAdult: Boolean,
|
||||||
val price: Int = 0,
|
val price: Int = 0,
|
||||||
val isAvailableJoinCreator: Boolean = true,
|
|
||||||
@Enumerated(value = EnumType.STRING)
|
@Enumerated(value = EnumType.STRING)
|
||||||
val type: LiveRoomType = LiveRoomType.OPEN,
|
val type: LiveRoomType = LiveRoomType.OPEN,
|
||||||
@Column(nullable = true)
|
@Column(nullable = true)
|
||||||
|
|
|
@ -20,30 +20,16 @@ import java.time.ZoneId
|
||||||
interface LiveRoomRepository : JpaRepository<LiveRoom, Long>, LiveRoomQueryRepository
|
interface LiveRoomRepository : JpaRepository<LiveRoom, Long>, LiveRoomQueryRepository
|
||||||
|
|
||||||
interface LiveRoomQueryRepository {
|
interface LiveRoomQueryRepository {
|
||||||
fun getLiveRoomListNow(
|
fun getLiveRoomListNow(offset: Long, limit: Long, timezone: String, isAdult: Boolean): List<LiveRoom>
|
||||||
offset: Long,
|
|
||||||
limit: Long,
|
|
||||||
timezone: String,
|
|
||||||
memberId: Long,
|
|
||||||
isCreator: Boolean,
|
|
||||||
isAdult: Boolean
|
|
||||||
): List<LiveRoom>
|
|
||||||
|
|
||||||
fun getLiveRoomListReservationWithDate(
|
fun getLiveRoomListReservationWithDate(
|
||||||
date: LocalDateTime,
|
date: LocalDateTime,
|
||||||
offset: Long,
|
offset: Long,
|
||||||
limit: Long,
|
limit: Long,
|
||||||
memberId: Long,
|
|
||||||
isCreator: Boolean,
|
|
||||||
isAdult: Boolean
|
isAdult: Boolean
|
||||||
): List<LiveRoom>
|
): List<LiveRoom>
|
||||||
|
|
||||||
fun getLiveRoomListReservationWithoutDate(
|
fun getLiveRoomListReservationWithoutDate(timezone: String, memberId: Long, isAdult: Boolean): List<LiveRoom>
|
||||||
timezone: String,
|
|
||||||
memberId: Long,
|
|
||||||
isCreator: Boolean,
|
|
||||||
isAdult: Boolean
|
|
||||||
): List<LiveRoom>
|
|
||||||
|
|
||||||
fun getLiveRoom(id: Long): LiveRoom?
|
fun getLiveRoom(id: Long): LiveRoom?
|
||||||
fun getLiveRoomAndAccountId(roomId: Long, memberId: Long): LiveRoom?
|
fun getLiveRoomAndAccountId(roomId: Long, memberId: Long): LiveRoom?
|
||||||
|
@ -54,14 +40,7 @@ interface LiveRoomQueryRepository {
|
||||||
}
|
}
|
||||||
|
|
||||||
class LiveRoomQueryRepositoryImpl(private val queryFactory: JPAQueryFactory) : LiveRoomQueryRepository {
|
class LiveRoomQueryRepositoryImpl(private val queryFactory: JPAQueryFactory) : LiveRoomQueryRepository {
|
||||||
override fun getLiveRoomListNow(
|
override fun getLiveRoomListNow(offset: Long, limit: Long, timezone: String, isAdult: Boolean): List<LiveRoom> {
|
||||||
offset: Long,
|
|
||||||
limit: Long,
|
|
||||||
timezone: String,
|
|
||||||
memberId: Long,
|
|
||||||
isCreator: Boolean,
|
|
||||||
isAdult: Boolean
|
|
||||||
): List<LiveRoom> {
|
|
||||||
var where = liveRoom.channelName.isNotNull
|
var where = liveRoom.channelName.isNotNull
|
||||||
.and(liveRoom.channelName.isNotEmpty)
|
.and(liveRoom.channelName.isNotEmpty)
|
||||||
.and(liveRoom.isActive.isTrue)
|
.and(liveRoom.isActive.isTrue)
|
||||||
|
@ -71,13 +50,6 @@ class LiveRoomQueryRepositoryImpl(private val queryFactory: JPAQueryFactory) : L
|
||||||
where = where.and(liveRoom.isAdult.isFalse)
|
where = where.and(liveRoom.isAdult.isFalse)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (isCreator) {
|
|
||||||
where = where.and(
|
|
||||||
liveRoom.isAvailableJoinCreator.isTrue
|
|
||||||
.or(liveRoom.member.id.eq(memberId))
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
return queryFactory
|
return queryFactory
|
||||||
.selectFrom(liveRoom)
|
.selectFrom(liveRoom)
|
||||||
.innerJoin(liveRoom.member, member)
|
.innerJoin(liveRoom.member, member)
|
||||||
|
@ -98,8 +70,6 @@ class LiveRoomQueryRepositoryImpl(private val queryFactory: JPAQueryFactory) : L
|
||||||
date: LocalDateTime,
|
date: LocalDateTime,
|
||||||
offset: Long,
|
offset: Long,
|
||||||
limit: Long,
|
limit: Long,
|
||||||
memberId: Long,
|
|
||||||
isCreator: Boolean,
|
|
||||||
isAdult: Boolean
|
isAdult: Boolean
|
||||||
): List<LiveRoom> {
|
): List<LiveRoom> {
|
||||||
var where = liveRoom.beginDateTime.goe(date)
|
var where = liveRoom.beginDateTime.goe(date)
|
||||||
|
@ -115,13 +85,6 @@ class LiveRoomQueryRepositoryImpl(private val queryFactory: JPAQueryFactory) : L
|
||||||
where = where.and(liveRoom.isAdult.isFalse)
|
where = where.and(liveRoom.isAdult.isFalse)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (isCreator) {
|
|
||||||
where = where.and(
|
|
||||||
liveRoom.isAvailableJoinCreator.isTrue
|
|
||||||
.or(liveRoom.member.id.eq(memberId))
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
return queryFactory
|
return queryFactory
|
||||||
.selectFrom(liveRoom)
|
.selectFrom(liveRoom)
|
||||||
.innerJoin(liveRoom.member, member)
|
.innerJoin(liveRoom.member, member)
|
||||||
|
@ -135,7 +98,6 @@ class LiveRoomQueryRepositoryImpl(private val queryFactory: JPAQueryFactory) : L
|
||||||
override fun getLiveRoomListReservationWithoutDate(
|
override fun getLiveRoomListReservationWithoutDate(
|
||||||
timezone: String,
|
timezone: String,
|
||||||
memberId: Long,
|
memberId: Long,
|
||||||
isCreator: Boolean,
|
|
||||||
isAdult: Boolean
|
isAdult: Boolean
|
||||||
): List<LiveRoom> {
|
): List<LiveRoom> {
|
||||||
var where = liveRoom.beginDateTime.gt(
|
var where = liveRoom.beginDateTime.gt(
|
||||||
|
@ -155,13 +117,6 @@ class LiveRoomQueryRepositoryImpl(private val queryFactory: JPAQueryFactory) : L
|
||||||
where = where.and(liveRoom.isAdult.isFalse)
|
where = where.and(liveRoom.isAdult.isFalse)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (isCreator) {
|
|
||||||
where = where.and(
|
|
||||||
liveRoom.isAvailableJoinCreator.isTrue
|
|
||||||
.or(liveRoom.member.id.eq(memberId))
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
return queryFactory
|
return queryFactory
|
||||||
.selectFrom(liveRoom)
|
.selectFrom(liveRoom)
|
||||||
.innerJoin(liveRoom.member, member)
|
.innerJoin(liveRoom.member, member)
|
||||||
|
|
|
@ -118,26 +118,17 @@ class LiveRoomService(
|
||||||
timezone: String
|
timezone: String
|
||||||
): List<GetRoomListResponse> {
|
): List<GetRoomListResponse> {
|
||||||
val roomList = if (status == LiveRoomStatus.NOW) {
|
val roomList = if (status == LiveRoomStatus.NOW) {
|
||||||
getLiveRoomListNow(
|
getLiveRoomListNow(pageable, timezone, isAdult = member.auth != null)
|
||||||
pageable,
|
|
||||||
timezone,
|
|
||||||
memberId = member.id!!,
|
|
||||||
isCreator = member.role == MemberRole.CREATOR,
|
|
||||||
isAdult = member.auth != null
|
|
||||||
)
|
|
||||||
} else if (dateString != null) {
|
} else if (dateString != null) {
|
||||||
getLiveRoomListReservationWithDate(
|
getLiveRoomListReservationWithDate(
|
||||||
dateString,
|
dateString,
|
||||||
pageable,
|
pageable,
|
||||||
timezone,
|
timezone,
|
||||||
memberId = member.id!!,
|
|
||||||
isCreator = member.role == MemberRole.CREATOR,
|
|
||||||
isAdult = member.auth != null
|
isAdult = member.auth != null
|
||||||
)
|
)
|
||||||
} else {
|
} else {
|
||||||
getLiveRoomListReservationWithoutDate(
|
getLiveRoomListReservationWithoutDate(
|
||||||
timezone,
|
timezone,
|
||||||
isCreator = member.role == MemberRole.CREATOR,
|
|
||||||
memberId = member.id!!,
|
memberId = member.id!!,
|
||||||
isAdult = member.auth != null
|
isAdult = member.auth != null
|
||||||
)
|
)
|
||||||
|
@ -195,19 +186,11 @@ class LiveRoomService(
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private fun getLiveRoomListNow(
|
private fun getLiveRoomListNow(pageable: Pageable, timezone: String, isAdult: Boolean): List<LiveRoom> {
|
||||||
pageable: Pageable,
|
|
||||||
timezone: String,
|
|
||||||
memberId: Long,
|
|
||||||
isCreator: Boolean,
|
|
||||||
isAdult: Boolean
|
|
||||||
): List<LiveRoom> {
|
|
||||||
return repository.getLiveRoomListNow(
|
return repository.getLiveRoomListNow(
|
||||||
offset = pageable.offset,
|
offset = pageable.offset,
|
||||||
limit = pageable.pageSize.toLong(),
|
limit = pageable.pageSize.toLong(),
|
||||||
timezone = timezone,
|
timezone = timezone,
|
||||||
memberId = memberId,
|
|
||||||
isCreator = isCreator,
|
|
||||||
isAdult = isAdult
|
isAdult = isAdult
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
@ -216,8 +199,6 @@ class LiveRoomService(
|
||||||
dateString: String,
|
dateString: String,
|
||||||
pageable: Pageable,
|
pageable: Pageable,
|
||||||
timezone: String,
|
timezone: String,
|
||||||
memberId: Long,
|
|
||||||
isCreator: Boolean,
|
|
||||||
isAdult: Boolean
|
isAdult: Boolean
|
||||||
): List<LiveRoom> {
|
): List<LiveRoom> {
|
||||||
val dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd")
|
val dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd")
|
||||||
|
@ -230,8 +211,6 @@ class LiveRoomService(
|
||||||
date = date,
|
date = date,
|
||||||
offset = pageable.offset,
|
offset = pageable.offset,
|
||||||
limit = pageable.pageSize.toLong(),
|
limit = pageable.pageSize.toLong(),
|
||||||
memberId = memberId,
|
|
||||||
isCreator = isCreator,
|
|
||||||
isAdult = isAdult
|
isAdult = isAdult
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
@ -239,10 +218,9 @@ class LiveRoomService(
|
||||||
private fun getLiveRoomListReservationWithoutDate(
|
private fun getLiveRoomListReservationWithoutDate(
|
||||||
timezone: String,
|
timezone: String,
|
||||||
memberId: Long,
|
memberId: Long,
|
||||||
isCreator: Boolean,
|
|
||||||
isAdult: Boolean
|
isAdult: Boolean
|
||||||
): List<LiveRoom> {
|
): List<LiveRoom> {
|
||||||
return repository.getLiveRoomListReservationWithoutDate(timezone, memberId, isCreator, isAdult)
|
return repository.getLiveRoomListReservationWithoutDate(timezone, memberId, isAdult)
|
||||||
}
|
}
|
||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
|
@ -299,8 +277,7 @@ class LiveRoomService(
|
||||||
request.price
|
request.price
|
||||||
},
|
},
|
||||||
type = request.type,
|
type = request.type,
|
||||||
password = request.password,
|
password = request.password
|
||||||
isAvailableJoinCreator = request.isAvailableJoinCreator
|
|
||||||
)
|
)
|
||||||
room.member = member
|
room.member = member
|
||||||
|
|
||||||
|
@ -376,7 +353,6 @@ class LiveRoomService(
|
||||||
"라이브를 예약했습니다. - ${createdRoom.title}"
|
"라이브를 예약했습니다. - ${createdRoom.title}"
|
||||||
},
|
},
|
||||||
isAuth = createdRoom.isAdult,
|
isAuth = createdRoom.isAdult,
|
||||||
isAvailableJoinCreator = createdRoom.isAvailableJoinCreator,
|
|
||||||
roomId = createdRoom.id,
|
roomId = createdRoom.id,
|
||||||
creatorId = createdRoom.member!!.id,
|
creatorId = createdRoom.member!!.id,
|
||||||
container = "ios"
|
container = "ios"
|
||||||
|
@ -393,7 +369,6 @@ class LiveRoomService(
|
||||||
"라이브를 예약했습니다. - ${createdRoom.title}"
|
"라이브를 예약했습니다. - ${createdRoom.title}"
|
||||||
},
|
},
|
||||||
isAuth = createdRoom.isAdult,
|
isAuth = createdRoom.isAdult,
|
||||||
isAvailableJoinCreator = createdRoom.isAvailableJoinCreator,
|
|
||||||
roomId = createdRoom.id,
|
roomId = createdRoom.id,
|
||||||
creatorId = createdRoom.member!!.id,
|
creatorId = createdRoom.member!!.id,
|
||||||
container = "aos"
|
container = "aos"
|
||||||
|
@ -536,7 +511,6 @@ class LiveRoomService(
|
||||||
title = room.member!!.nickname,
|
title = room.member!!.nickname,
|
||||||
message = "라이브를 시작했습니다 - ${room.title}",
|
message = "라이브를 시작했습니다 - ${room.title}",
|
||||||
isAuth = room.isAdult,
|
isAuth = room.isAdult,
|
||||||
isAvailableJoinCreator = room.isAvailableJoinCreator,
|
|
||||||
roomId = room.id,
|
roomId = room.id,
|
||||||
creatorId = room.member!!.id,
|
creatorId = room.member!!.id,
|
||||||
container = "ios"
|
container = "ios"
|
||||||
|
@ -549,7 +523,6 @@ class LiveRoomService(
|
||||||
title = room.member!!.nickname,
|
title = room.member!!.nickname,
|
||||||
message = "라이브를 시작했습니다 - ${room.title}",
|
message = "라이브를 시작했습니다 - ${room.title}",
|
||||||
isAuth = room.isAdult,
|
isAuth = room.isAdult,
|
||||||
isAvailableJoinCreator = room.isAvailableJoinCreator,
|
|
||||||
roomId = room.id,
|
roomId = room.id,
|
||||||
creatorId = room.member!!.id,
|
creatorId = room.member!!.id,
|
||||||
container = "aos"
|
container = "aos"
|
||||||
|
|
|
@ -29,7 +29,6 @@ interface MemberQueryRepository {
|
||||||
fun getCreateLiveRoomNotificationRecipientPushTokens(
|
fun getCreateLiveRoomNotificationRecipientPushTokens(
|
||||||
creatorId: Long,
|
creatorId: Long,
|
||||||
isAuth: Boolean,
|
isAuth: Boolean,
|
||||||
isAvailableJoinCreator: Boolean,
|
|
||||||
container: String
|
container: String
|
||||||
): List<List<String>>
|
): List<List<String>>
|
||||||
|
|
||||||
|
@ -37,7 +36,6 @@ interface MemberQueryRepository {
|
||||||
creatorId: Long,
|
creatorId: Long,
|
||||||
roomId: Long,
|
roomId: Long,
|
||||||
isAuth: Boolean,
|
isAuth: Boolean,
|
||||||
isAvailableJoinCreator: Boolean,
|
|
||||||
container: String
|
container: String
|
||||||
): List<List<String>>
|
): List<List<String>>
|
||||||
|
|
||||||
|
@ -122,7 +120,6 @@ class MemberQueryRepositoryImpl(
|
||||||
override fun getCreateLiveRoomNotificationRecipientPushTokens(
|
override fun getCreateLiveRoomNotificationRecipientPushTokens(
|
||||||
creatorId: Long,
|
creatorId: Long,
|
||||||
isAuth: Boolean,
|
isAuth: Boolean,
|
||||||
isAvailableJoinCreator: Boolean,
|
|
||||||
container: String
|
container: String
|
||||||
): List<List<String>> {
|
): List<List<String>> {
|
||||||
val member = QMember.member
|
val member = QMember.member
|
||||||
|
@ -145,10 +142,6 @@ class MemberQueryRepositoryImpl(
|
||||||
where = where.and(auth.isNotNull)
|
where = where.and(auth.isNotNull)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!isAvailableJoinCreator) {
|
|
||||||
where = where.and(creatorFollowing.member.role.ne(MemberRole.CREATOR))
|
|
||||||
}
|
|
||||||
|
|
||||||
return queryFactory
|
return queryFactory
|
||||||
.select(creatorFollowing.member.pushToken)
|
.select(creatorFollowing.member.pushToken)
|
||||||
.from(creatorFollowing)
|
.from(creatorFollowing)
|
||||||
|
@ -166,7 +159,6 @@ class MemberQueryRepositoryImpl(
|
||||||
creatorId: Long,
|
creatorId: Long,
|
||||||
roomId: Long,
|
roomId: Long,
|
||||||
isAuth: Boolean,
|
isAuth: Boolean,
|
||||||
isAvailableJoinCreator: Boolean,
|
|
||||||
container: String
|
container: String
|
||||||
): List<List<String>> {
|
): List<List<String>> {
|
||||||
val member = QMember.member
|
val member = QMember.member
|
||||||
|
@ -189,10 +181,6 @@ class MemberQueryRepositoryImpl(
|
||||||
where = where.and(auth.isNotNull)
|
where = where.and(auth.isNotNull)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!isAvailableJoinCreator) {
|
|
||||||
where = where.and(creatorFollowing.member.role.ne(MemberRole.CREATOR))
|
|
||||||
}
|
|
||||||
|
|
||||||
val followingMemberPushToken = queryFactory
|
val followingMemberPushToken = queryFactory
|
||||||
.select(creatorFollowing.member.pushToken)
|
.select(creatorFollowing.member.pushToken)
|
||||||
.from(creatorFollowing)
|
.from(creatorFollowing)
|
||||||
|
|
Loading…
Reference in New Issue