Compare commits

..

No commits in common. "afe529a11692629b190119f36147460d75810f1b" and "2d015d0a3329bbe399045b8f026b4166e23b59dd" have entirely different histories.

4 changed files with 44 additions and 41 deletions

View File

@ -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)
} }
} }

View File

@ -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 {
// 묶음 콘텐츠 조회 // 묶음 콘텐츠 조회

View File

@ -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) {

View File

@ -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(