Compare commits
No commits in common. "afe529a11692629b190119f36147460d75810f1b" and "2d015d0a3329bbe399045b8f026b4166e23b59dd" have entirely different histories.
afe529a116
...
2d015d0a33
|
@ -25,7 +25,10 @@ import java.time.temporal.TemporalAdjusters
|
||||||
|
|
||||||
@RestController
|
@RestController
|
||||||
@RequestMapping("/audio-content")
|
@RequestMapping("/audio-content")
|
||||||
class AudioContentController(private val service: AudioContentService) {
|
class AudioContentController(
|
||||||
|
private val service: AudioContentService,
|
||||||
|
private val repository: AudioContentRepository
|
||||||
|
) {
|
||||||
@PostMapping
|
@PostMapping
|
||||||
@PreAuthorize("hasRole('CREATOR')")
|
@PreAuthorize("hasRole('CREATOR')")
|
||||||
fun createAudioContent(
|
fun createAudioContent(
|
||||||
|
@ -194,6 +197,12 @@ class AudioContentController(private val service: AudioContentService) {
|
||||||
@PostMapping("/release")
|
@PostMapping("/release")
|
||||||
@PreAuthorize("hasRole('BOT')")
|
@PreAuthorize("hasRole('BOT')")
|
||||||
fun releaseContent() = run {
|
fun releaseContent() = run {
|
||||||
ApiResponse.ok(service.releaseContent())
|
val contentIdList = repository.getNotReleaseContentId()
|
||||||
|
|
||||||
|
for (contentId in contentIdList) {
|
||||||
|
service.releaseContent(contentId)
|
||||||
|
}
|
||||||
|
|
||||||
|
ApiResponse.ok(null)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -387,10 +387,7 @@ class AudioContentService(
|
||||||
}
|
}
|
||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
fun releaseContent() {
|
fun releaseContent(contentId: Long) {
|
||||||
val contentIdList = repository.getNotReleaseContentId()
|
|
||||||
|
|
||||||
for (contentId in contentIdList) {
|
|
||||||
val audioContent = repository.findByIdOrNull(contentId)
|
val audioContent = repository.findByIdOrNull(contentId)
|
||||||
?: throw SodaException("잘못된 요청입니다.")
|
?: throw SodaException("잘못된 요청입니다.")
|
||||||
|
|
||||||
|
@ -420,7 +417,6 @@ class AudioContentService(
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
fun getDetail(id: Long, member: Member, timezone: String): GetAudioContentDetailResponse {
|
fun getDetail(id: Long, member: Member, timezone: String): GetAudioContentDetailResponse {
|
||||||
// 묶음 콘텐츠 조회
|
// 묶음 콘텐츠 조회
|
||||||
|
|
|
@ -186,7 +186,6 @@ class FcmSendListener(
|
||||||
FcmEventType.SEND_MESSAGE -> {
|
FcmEventType.SEND_MESSAGE -> {
|
||||||
val response = memberRepository.getMessageRecipientPushToken(messageId = fcmEvent.messageId!!)
|
val response = memberRepository.getMessageRecipientPushToken(messageId = fcmEvent.messageId!!)
|
||||||
|
|
||||||
if (response != null) {
|
|
||||||
pushService.send(
|
pushService.send(
|
||||||
tokens = listOf(response.pushToken),
|
tokens = listOf(response.pushToken),
|
||||||
title = fcmEvent.title,
|
title = fcmEvent.title,
|
||||||
|
@ -195,7 +194,6 @@ class FcmSendListener(
|
||||||
messageId = fcmEvent.messageId
|
messageId = fcmEvent.messageId
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
FcmEventType.CHANGE_NOTICE -> {
|
FcmEventType.CHANGE_NOTICE -> {
|
||||||
if (fcmEvent.creatorId != null) {
|
if (fcmEvent.creatorId != null) {
|
||||||
|
|
|
@ -45,7 +45,7 @@ interface MemberQueryRepository {
|
||||||
container: String
|
container: String
|
||||||
): List<List<String>>
|
): List<List<String>>
|
||||||
|
|
||||||
fun getMessageRecipientPushToken(messageId: Long): GetMessageRecipientPushTokenResponse?
|
fun getMessageRecipientPushToken(messageId: Long): GetMessageRecipientPushTokenResponse
|
||||||
fun getIndividualRecipientPushTokens(recipients: List<Long>, isAuth: Boolean?): Map<String, List<List<String>>>
|
fun getIndividualRecipientPushTokens(recipients: List<Long>, isAuth: Boolean?): Map<String, List<List<String>>>
|
||||||
fun getChangeNicknamePrice(memberId: Long): GetChangeNicknamePriceResponse
|
fun getChangeNicknamePrice(memberId: Long): GetChangeNicknamePriceResponse
|
||||||
fun getMemberByEmail(email: String): Member?
|
fun getMemberByEmail(email: String): Member?
|
||||||
|
@ -259,7 +259,7 @@ class MemberQueryRepositoryImpl(
|
||||||
.chunked(500)
|
.chunked(500)
|
||||||
}
|
}
|
||||||
|
|
||||||
override fun getMessageRecipientPushToken(messageId: Long): GetMessageRecipientPushTokenResponse? {
|
override fun getMessageRecipientPushToken(messageId: Long): GetMessageRecipientPushTokenResponse {
|
||||||
return queryFactory
|
return queryFactory
|
||||||
.select(
|
.select(
|
||||||
QGetMessageRecipientPushTokenResponse(
|
QGetMessageRecipientPushTokenResponse(
|
||||||
|
|
Loading…
Reference in New Issue