Compare commits
No commits in common. "fc6916fc2de4c28203b5aa6ecb9426819914365f" and "39b27b2a17d68f856b18d51c5338990db3a848b7" have entirely different histories.
fc6916fc2d
...
39b27b2a17
|
@ -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) {
|
||||||
|
|
|
@ -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!!,
|
||||||
|
|
Loading…
Reference in New Issue