콘텐츠 댓글 알림 추가

src/main/kotlin/kr/co/vividnext/sodalive/content/comment/AudioContentCommentRepository.kt

@@ -1,6 +1,7 @@
 package kr.co.vividnext.sodalive.content.comment
 
 import com.querydsl.jpa.impl.JPAQueryFactory
+import kr.co.vividnext.sodalive.content.QAudioContent.audioContent
 import kr.co.vividnext.sodalive.content.comment.QAudioContentComment.audioContentComment
 import org.springframework.data.jpa.repository.JpaRepository
 import org.springframework.stereotype.Repository
@@ -28,6 +29,8 @@ interface AudioContentCommentQueryRepository {
         offset: Long,
         limit: Int
     ): List<GetAudioContentCommentListItem>
+
+    fun findPushTokenByContentCommentId(contentCommentId: Long): FindPushTokenByContentCommentIdResponse?
 }
 
 @Repository
@@ -138,4 +141,28 @@ class AudioContentCommentQueryRepositoryImpl(
             }
             .toList()
     }
+
+    override fun findPushTokenByContentCommentId(contentCommentId: Long): FindPushTokenByContentCommentIdResponse? {
+        val response = queryFactory
+            .selectFrom(audioContentComment)
+            .innerJoin(audioContentComment.audioContent, audioContent)
+            .where(audioContentComment.id.eq(contentCommentId))
+            .fetchFirst()
+
+        return if (response == null) {
+            null
+        } else {
+            if (response.parent != null) {
+                FindPushTokenByContentCommentIdResponse(
+                    pushToken = response.parent!!.member!!.pushToken ?: "",
+                    container = response.parent!!.member!!.container
+                )
+            } else {
+                FindPushTokenByContentCommentIdResponse(
+                    pushToken = response.audioContent!!.member!!.pushToken ?: "",
+                    container = response.audioContent!!.member!!.container
+                )
+            }
+        }
+    }
 }

src/main/kotlin/kr/co/vividnext/sodalive/content/comment/AudioContentCommentService.kt

@@ -2,8 +2,11 @@ package kr.co.vividnext.sodalive.content.comment
 
 import kr.co.vividnext.sodalive.common.SodaException
 import kr.co.vividnext.sodalive.content.AudioContentRepository
+import kr.co.vividnext.sodalive.fcm.FcmEvent
+import kr.co.vividnext.sodalive.fcm.FcmEventType
 import kr.co.vividnext.sodalive.member.Member
 import org.springframework.beans.factory.annotation.Value
+import org.springframework.context.ApplicationEventPublisher
 import org.springframework.data.domain.Pageable
 import org.springframework.data.repository.findByIdOrNull
 import org.springframework.stereotype.Service
@@ -14,6 +17,7 @@ import org.springframework.transaction.annotation.Transactional
 class AudioContentCommentService(
     private val repository: AudioContentCommentRepository,
     private val audioContentRepository: AudioContentRepository,
+    private val applicationEventPublisher: ApplicationEventPublisher,
 
     @Value("\${cloud.aws.cloud-front.host}")
     private val cloudFrontHost: String
@@ -38,6 +42,24 @@ class AudioContentCommentService(
         }
 
         repository.save(audioContentComment)
+
+        applicationEventPublisher.publishEvent(
+            FcmEvent(
+                type = FcmEventType.CREATE_CONTENT_COMMENT,
+                title = if (parent != null) {
+                    parent.member!!.nickname
+                } else {
+                    member.nickname
+                },
+                message = if (parent != null) {
+                    "댓글에 답글을 달았습니다.: ${audioContent.title}"
+                } else {
+                    "콘텐츠에 댓글을 달았습니다.: ${audioContent.title}"
+                },
+                contentId = audioContentId,
+                contentCommentId = audioContentComment.id!!
+            )
+        )
     }
 
     @Transactional

src/main/kotlin/kr/co/vividnext/sodalive/content/comment/FindPushTokenByContentCommentIdResponse.kt

@@ -0,0 +1,6 @@
+package kr.co.vividnext.sodalive.content.comment
+
+data class FindPushTokenByContentCommentIdResponse(
+    val pushToken: String,
+    val container: String
+)