Merge pull request #294 from YAPP-Github/feat/#293

dlswns2480 · web-flow · commit c214e37b3c73 · 2026-02-23T23:37:30.000+09:00
[feat #293] 공유 포킷 관련 푸시발송 구현
diff --git a/adapters/in-web/src/main/kotlin/com/pokit/notification/dto/response/NotificationResponse.kt b/adapters/in-web/src/main/kotlin/com/pokit/notification/dto/response/NotificationResponse.kt
@@ -20,8 +20,8 @@ data class NotificationResponse(
     @Schema(description = "알림 본문", example = "OO님이 추가한 링크를 지금 확인해보세요")
     val body: String,
 
-    @Schema(description = "썸네일 URL (없을 수 있음)", nullable = true)
-    val thumbnailUrl: String?,
+    @Schema(description = "카테고리 이미지 URL (없을 수 있음)", nullable = true)
+    val categoryImageUrl: String?,
 
     @Schema(description = "읽음 여부")
     val isRead: Boolean,
@@ -41,7 +41,7 @@ internal fun Notification.toResponse() = NotificationResponse(
     notificationType = this.notificationType,
     title = this.title,
     body = this.body,
-    thumbnailUrl = this.thumbnailUrl,
+    categoryImageUrl = this.categoryImageUrl,
     isRead = this.isRead,
     navigationType = this.navigationType,
     deepLink = this.deepLink,
diff --git a/adapters/out-persistence/src/main/kotlin/com/pokit/out/persistence/notification/impl/PushMessageTemplateAdapter.kt b/adapters/out-persistence/src/main/kotlin/com/pokit/out/persistence/notification/impl/PushMessageTemplateAdapter.kt
@@ -0,0 +1,18 @@
+package com.pokit.out.persistence.notification.impl
+
+import com.pokit.notification.model.NotificationType
+import com.pokit.notification.model.PushMessageTemplate
+import com.pokit.notification.port.out.PushMessageTemplatePort
+import com.pokit.out.persistence.notification.persist.PushMessageTemplateRepository
+import com.pokit.out.persistence.notification.persist.toDomain
+import org.springframework.stereotype.Repository
+
+@Repository
+class PushMessageTemplateAdapter(
+    private val pushMessageTemplateRepository: PushMessageTemplateRepository,
+) : PushMessageTemplatePort {
+
+    override fun loadByType(type: NotificationType): PushMessageTemplate? {
+        return pushMessageTemplateRepository.findByNotificationType(type)?.toDomain()
+    }
+}
diff --git a/adapters/out-persistence/src/main/kotlin/com/pokit/out/persistence/notification/persist/NotificationEntity.kt b/adapters/out-persistence/src/main/kotlin/com/pokit/out/persistence/notification/persist/NotificationEntity.kt
@@ -27,8 +27,8 @@ class NotificationEntity(
     @Column(name = "body", nullable = false, columnDefinition = "TEXT")
     val body: String,
 
-    @Column(name = "thumbnail_url", length = 2048)
-    val thumbnailUrl: String? = null,
+    @Column(name = "category_image_url", length = 2048)
+    val categoryImageUrl: String? = null,
 
     @Column(name = "is_read", nullable = false)
     val isRead: Boolean = false,
@@ -51,7 +51,7 @@ class NotificationEntity(
             notificationType = notification.notificationType,
             title = notification.title,
             body = notification.body,
-            thumbnailUrl = notification.thumbnailUrl,
+            categoryImageUrl = notification.categoryImageUrl,
             isRead = notification.isRead,
             navigationType = notification.navigationType,
             deepLink = notification.deepLink,
@@ -66,7 +66,7 @@ fun NotificationEntity.toDomain() = Notification(
     notificationType = this.notificationType,
     title = this.title,
     body = this.body,
-    thumbnailUrl = this.thumbnailUrl,
+    categoryImageUrl = this.categoryImageUrl,
     isRead = this.isRead,
     navigationType = this.navigationType,
     deepLink = this.deepLink,
diff --git a/adapters/out-persistence/src/main/kotlin/com/pokit/out/persistence/notification/persist/PushMessageTemplateEntity.kt b/adapters/out-persistence/src/main/kotlin/com/pokit/out/persistence/notification/persist/PushMessageTemplateEntity.kt
@@ -0,0 +1,49 @@
+package com.pokit.out.persistence.notification.persist
+
+import com.pokit.notification.model.NavigationType
+import com.pokit.notification.model.NotificationType
+import com.pokit.notification.model.PushMessageTemplate
+import com.pokit.out.persistence.BaseEntity
+import jakarta.persistence.*
+
+@Table(name = "push_message_template")
+@Entity
+class PushMessageTemplateEntity(
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "id")
+    val id: Long = 0L,
+
+    @Enumerated(EnumType.STRING)
+    @Column(name = "notification_type", nullable = false, length = 50)
+    val notificationType: NotificationType,
+
+    @Column(name = "title", nullable = false, length = 255)
+    val title: String,
+
+    @Column(name = "body", nullable = false, columnDefinition = "TEXT")
+    val body: String,
+
+    @Enumerated(EnumType.STRING)
+    @Column(name = "navigation_type", nullable = false, length = 50)
+    val navigationType: NavigationType,
+) : BaseEntity() {
+
+    companion object {
+        fun of(pushMessageTemplate: PushMessageTemplate) = PushMessageTemplateEntity(
+            id = pushMessageTemplate.id,
+            notificationType = pushMessageTemplate.notificationType,
+            title = pushMessageTemplate.title,
+            body = pushMessageTemplate.body,
+            navigationType = pushMessageTemplate.navigationType,
+        )
+    }
+}
+
+fun PushMessageTemplateEntity.toDomain() = PushMessageTemplate(
+    id = this.id,
+    notificationType = this.notificationType,
+    title = this.title,
+    body = this.body,
+    navigationType = this.navigationType,
+)
diff --git a/adapters/out-persistence/src/main/kotlin/com/pokit/out/persistence/notification/persist/PushMessageTemplateRepository.kt b/adapters/out-persistence/src/main/kotlin/com/pokit/out/persistence/notification/persist/PushMessageTemplateRepository.kt
@@ -0,0 +1,8 @@
+package com.pokit.out.persistence.notification.persist
+
+import com.pokit.notification.model.NotificationType
+import org.springframework.data.jpa.repository.JpaRepository
+
+interface PushMessageTemplateRepository : JpaRepository<PushMessageTemplateEntity, Long> {
+    fun findByNotificationType(notificationType: NotificationType): PushMessageTemplateEntity?
+}
diff --git a/adapters/out-persistence/src/main/kotlin/com/pokit/out/persistence/user/impl/FcmTokenAdapter.kt b/adapters/out-persistence/src/main/kotlin/com/pokit/out/persistence/user/impl/FcmTokenAdapter.kt
@@ -24,4 +24,8 @@ class FcmTokenAdapter(
     override fun loadByUserIdAndToken(userId: Long, token: String): FcmToken? {
         return fcmTokenRepository.findByUserIdAndTokenAndDeleted(userId, token, false)?.toDomain()
     }
+
+    override fun loadLatestByUserId(userId: Long): FcmToken? {
+        return fcmTokenRepository.findTopByUserIdAndDeletedOrderByIdDesc(userId, false)?.toDomain()
+    }
 }
diff --git a/adapters/out-persistence/src/main/kotlin/com/pokit/out/persistence/user/persist/FcmTokenRepository.kt b/adapters/out-persistence/src/main/kotlin/com/pokit/out/persistence/user/persist/FcmTokenRepository.kt
@@ -6,4 +6,6 @@ interface FcmTokenRepository : JpaRepository<FcmTokenEntity, Long> {
     fun findByUserId(userId: Long): List<FcmTokenEntity>
 
     fun findByUserIdAndTokenAndDeleted(userId: Long, token: String, isDeleted: Boolean): FcmTokenEntity?
+
+    fun findTopByUserIdAndDeletedOrderByIdDesc(userId: Long, deleted: Boolean): FcmTokenEntity?
 }
diff --git a/adapters/out-web/src/main/kotlin/com/pokit/notification/impl/FcmNotificationSender.kt b/adapters/out-web/src/main/kotlin/com/pokit/notification/impl/FcmNotificationSender.kt
@@ -0,0 +1,59 @@
+package com.pokit.notification.impl
+
+import com.google.auth.oauth2.GoogleCredentials
+import com.google.firebase.FirebaseApp
+import com.google.firebase.FirebaseOptions
+import com.google.firebase.messaging.FirebaseMessaging
+import com.google.firebase.messaging.FirebaseMessagingException
+import com.google.firebase.messaging.Message
+import com.pokit.notification.model.Notification
+import com.pokit.notification.port.out.NotificationSender
+import io.github.oshai.kotlinlogging.KotlinLogging
+import jakarta.annotation.PostConstruct
+import org.springframework.core.io.ClassPathResource
+import org.springframework.stereotype.Component
+import com.google.firebase.messaging.Notification as FirebaseNotification
+
+@Component
+class FcmNotificationSender : NotificationSender {
+    @PostConstruct
+    fun init() {
+        if (FirebaseApp.getApps().isEmpty()) {
+            val firebaseCredentials = ClassPathResource("/firebase/push-account-key.json").inputStream
+            val options = FirebaseOptions.builder()
+                .setCredentials(GoogleCredentials.fromStream(firebaseCredentials))
+                .build()
+            FirebaseApp.initializeApp(options)
+        }
+    }
+
+    private val logger = KotlinLogging.logger { }
+
+    companion object {
+        const val IMAGE_PATH = "https://pokit-storage.s3.ap-northeast-2.amazonaws.com/logo/pokit.png" // 앱 로고
+    }
+
+    override fun send(notification: Notification, tokens: List<String>) {
+        val fcmNotification = FirebaseNotification.builder()
+            .setTitle(notification.title)
+            .setBody(notification.body)
+            .setImage(IMAGE_PATH)
+            .build()
+
+        val messages = tokens.map { token ->
+            Message.builder()
+                .setNotification(fcmNotification)
+                .putData("deepLink", notification.deepLink)
+                .setToken(token)
+                .build()
+        }
+
+        try {
+            messages.forEach {
+                FirebaseMessaging.getInstance().sendAsync(it)
+            }
+        } catch (e: FirebaseMessagingException) {
+            logger.warn { "Failed to send notification: ${e.message}" }
+        }
+    }
+}
diff --git a/application/src/main/kotlin/com/pokit/category/port/service/CategoryService.kt b/application/src/main/kotlin/com/pokit/category/port/service/CategoryService.kt
@@ -18,6 +18,10 @@ import com.pokit.common.exception.ClientValidationException
 import com.pokit.common.exception.InvalidRequestException
 import com.pokit.common.exception.NotFoundCustomException
 import com.pokit.content.port.out.ContentPort
+import com.pokit.notification.model.DeepLinkBuilder
+import com.pokit.notification.model.NotificationType
+import com.pokit.notification.port.`in`.NotificationUseCase
+import com.pokit.notification.port.out.PushMessageTemplatePort
 import com.pokit.user.model.User
 import com.pokit.user.port.out.UserPort
 import org.springframework.data.domain.PageRequest
@@ -36,6 +40,8 @@ class CategoryService(
     private val sharedCategoryPort: SharedCategoryPort,
     private val userPort: UserPort,
     private val bookmarkPort: BookmarkPort,
+    private val notificationUseCase: NotificationUseCase,
+    private val pushMessageTemplatePort: PushMessageTemplatePort,
 ) : CategoryUseCase {
     companion object {
         private const val MAX_CATEGORY_COUNT = 30
@@ -202,6 +208,26 @@ class CategoryService(
             categoryId = category.categoryId,
         )
         sharedCategoryPort.persist(sharedCategory)
+
+        val template = pushMessageTemplatePort.loadByType(NotificationType.NEW_MEMBER_JOINED)
+        if (template != null) {
+            val joiningUser = userPort.loadById(userId)
+            if (joiningUser != null) {
+                val sharedMembers = sharedCategoryPort.loadByCategoryId(category.categoryId)
+                sharedMembers
+                    .filter { it.userId != userId }
+                    .forEach { member ->
+                        val notification = template.toNotification(
+                            userId = member.userId,
+                            categoryName = category.categoryName,
+                            nickname = joiningUser.nickName,
+                            categoryImageUrl = category.categoryImage.imageUrl,
+                            deepLink = DeepLinkBuilder.forCategory(category.categoryId, userId),
+                        )
+                        notificationUseCase.createAndSend(notification)
+                    }
+            }
+        }
     }
 
     @Transactional
@@ -217,6 +243,16 @@ class CategoryService(
 
         category.minusUserCount() // 포킷 인원수 감소
         categoryPort.persist(category)
+
+        val template = pushMessageTemplatePort.loadByType(NotificationType.POKIT_USE_RESTRICTION)
+        if (template != null) {
+            val notification = template.toNotification(
+                userId = resignUserId,
+                categoryName = category.categoryName,
+                categoryImageUrl = category.categoryImage.imageUrl,
+            )
+            notificationUseCase.createAndSend(notification)
+        }
     }
 
     @Transactional
diff --git a/application/src/main/kotlin/com/pokit/content/port/service/ContentService.kt b/application/src/main/kotlin/com/pokit/content/port/service/ContentService.kt
@@ -11,6 +11,7 @@ import com.pokit.category.model.CategoryStatus
 import com.pokit.category.model.CategoryStatus.UNCATEGORIZED
 import com.pokit.category.model.OpenType
 import com.pokit.category.port.out.CategoryPort
+import com.pokit.category.port.out.SharedCategoryPort
 import com.pokit.common.exception.AlreadyExistsException
 import com.pokit.common.exception.ClientValidationException
 import com.pokit.common.exception.NotFoundCustomException
@@ -30,6 +31,10 @@ import com.pokit.content.port.out.ReportedContentPort
 import com.pokit.log.model.LogType
 import com.pokit.log.model.UserLog
 import com.pokit.log.port.out.UserLogPort
+import com.pokit.notification.model.DeepLinkBuilder
+import com.pokit.notification.model.NotificationType
+import com.pokit.notification.port.`in`.NotificationUseCase
+import com.pokit.notification.port.out.PushMessageTemplatePort
 import com.pokit.user.exception.UserErrorCode
 import com.pokit.user.model.InterestType
 import com.pokit.user.model.User
@@ -56,6 +61,9 @@ class ContentService(
     private val interestPort: InterestPort,
     private val userPort: UserPort,
     private val reportedContentPort: ReportedContentPort,
+    private val sharedCategoryPort: SharedCategoryPort,
+    private val notificationUseCase: NotificationUseCase,
+    private val pushMessageTemplatePort: PushMessageTemplatePort,
 ) : ContentUseCase {
     companion object {
         private const val MIN_CONTENT_COUNT = 3
@@ -86,6 +94,25 @@ class ContentService(
             publisher.publishEvent(CreateAlertRequest(userId = user.id, contetId = contentResult.contentId))
         }
 
+        if (category.isShared) {
+            val template = pushMessageTemplatePort.loadByType(NotificationType.LINK_ADDED)
+            if (template != null) {
+                val sharedMembers = sharedCategoryPort.loadByCategoryId(category.categoryId)
+                sharedMembers
+                    .filter { it.userId != user.id }
+                    .forEach { member ->
+                        val notification = template.toNotification(
+                            userId = member.userId,
+                            categoryName = category.categoryName,
+                            nickname = user.nickName,
+                            categoryImageUrl = category.categoryImage.imageUrl,
+                            deepLink = DeepLinkBuilder.forContent(category.categoryId, contentResult.contentId),
+                        )
+                        notificationUseCase.createAndSend(notification)
+                    }
+            }
+        }
+
         return contentResult
     }
 
diff --git a/application/src/main/kotlin/com/pokit/notification/port/in/NotificationUseCase.kt b/application/src/main/kotlin/com/pokit/notification/port/in/NotificationUseCase.kt
@@ -12,4 +12,6 @@ interface NotificationUseCase {
     fun deleteNotification(userId: Long, notificationId: Long)
 
     fun getUnreadCount(userId: Long): Long
+
+    fun createAndSend(notification: Notification): Notification
 }
diff --git a/application/src/main/kotlin/com/pokit/notification/port/out/NotificationSender.kt b/application/src/main/kotlin/com/pokit/notification/port/out/NotificationSender.kt
@@ -0,0 +1,7 @@
+package com.pokit.notification.port.out
+
+import com.pokit.notification.model.Notification
+
+interface NotificationSender {
+    fun send(notification: Notification, tokens: List<String>)
+}
diff --git a/application/src/main/kotlin/com/pokit/notification/port/out/PushMessageTemplatePort.kt b/application/src/main/kotlin/com/pokit/notification/port/out/PushMessageTemplatePort.kt
@@ -0,0 +1,8 @@
+package com.pokit.notification.port.out
+
+import com.pokit.notification.model.NotificationType
+import com.pokit.notification.model.PushMessageTemplate
+
+interface PushMessageTemplatePort {
+    fun loadByType(type: NotificationType): PushMessageTemplate?
+}
diff --git a/application/src/main/kotlin/com/pokit/notification/port/service/NotificationService.kt b/application/src/main/kotlin/com/pokit/notification/port/service/NotificationService.kt
@@ -5,6 +5,8 @@ import com.pokit.notification.exception.NotificationErrorCode
 import com.pokit.notification.model.Notification
 import com.pokit.notification.port.`in`.NotificationUseCase
 import com.pokit.notification.port.out.NotificationPort
+import com.pokit.notification.port.out.NotificationSender
+import com.pokit.user.port.out.FcmTokenPort
 import org.springframework.data.domain.Pageable
 import org.springframework.data.domain.Slice
 import org.springframework.stereotype.Service
@@ -13,7 +15,9 @@ import org.springframework.transaction.annotation.Transactional
 @Service
 @Transactional(readOnly = true)
 class NotificationService(
-    private val notificationPort: NotificationPort
+    private val notificationPort: NotificationPort,
+    private val fcmTokenPort: FcmTokenPort,
+    private val notificationSender: NotificationSender,
 ) : NotificationUseCase {
 
     override fun getNotifications(userId: Long, pageable: Pageable): Slice<Notification> {
@@ -37,4 +41,14 @@ class NotificationService(
     override fun getUnreadCount(userId: Long): Long {
         return notificationPort.countUnreadByUserId(userId)
     }
+
+    @Transactional
+    override fun createAndSend(notification: Notification): Notification {
+        val saved = notificationPort.persist(notification)
+        val token = fcmTokenPort.loadLatestByUserId(notification.userId)
+        if (token != null) {
+            notificationSender.send(saved, listOf(token.token))
+        }
+        return saved
+    }
 }
diff --git a/application/src/main/kotlin/com/pokit/user/port/out/FcmTokenPort.kt b/application/src/main/kotlin/com/pokit/user/port/out/FcmTokenPort.kt
@@ -8,4 +8,6 @@ interface FcmTokenPort {
     fun loadByUserId(userId: Long): List<FcmToken>
 
     fun loadByUserIdAndToken(userId: Long, token: String): FcmToken?
+
+    fun loadLatestByUserId(userId: Long): FcmToken?
 }
diff --git a/domain/src/main/kotlin/com/pokit/notification/exception/NotificationErrorCode.kt b/domain/src/main/kotlin/com/pokit/notification/exception/NotificationErrorCode.kt
@@ -6,5 +6,6 @@ enum class NotificationErrorCode(
     override val message: String,
     override val code: String
 ) : ErrorCode {
-    NOT_FOUND_NOTIFICATION("존재하지 않는 알림입니다.", "NF_001")
+    NOT_FOUND_NOTIFICATION("존재하지 않는 알림입니다.", "NF_001"),
+    NOT_FOUND_PUSH_TEMPLATE("존재하지 않는 푸시 템플릿입니다.", "NF_002"),
 }
diff --git a/domain/src/main/kotlin/com/pokit/notification/model/Notification.kt b/domain/src/main/kotlin/com/pokit/notification/model/Notification.kt
diff --git a/domain/src/main/kotlin/com/pokit/notification/model/PushMessageTemplate.kt b/domain/src/main/kotlin/com/pokit/notification/model/PushMessageTemplate.kt
diff --git a/env/db/notification.sql b/env/db/notification.sql

Original file line number	Diff line number	Diff line change
`@@ -24,4 +24,8 @@ class FcmTokenAdapter(`
`24`	`24`	`override fun loadByUserIdAndToken(userId: Long, token: String): FcmToken? {`
`25`	`25`	`return fcmTokenRepository.findByUserIdAndTokenAndDeleted(userId, token, false)?.toDomain()`
`26`	`26`	`}`
	`27`	`+`
	`28`	`+ override fun loadLatestByUserId(userId: Long): FcmToken? {`
	`29`	`+ return fcmTokenRepository.findTopByUserIdAndDeletedOrderByIdDesc(userId, false)?.toDomain()`
	`30`	`+ }`
`27`	`31`	`}`
Original file line number	Diff line number	Diff line change
`@@ -6,4 +6,6 @@ interface FcmTokenRepository : JpaRepository<FcmTokenEntity, Long> {`
`6`	`6`	`fun findByUserId(userId: Long): List<FcmTokenEntity>`
`7`	`7`
`8`	`8`	`fun findByUserIdAndTokenAndDeleted(userId: Long, token: String, isDeleted: Boolean): FcmTokenEntity?`
	`9`	`+`
	`10`	`+ fun findTopByUserIdAndDeletedOrderByIdDesc(userId: Long, deleted: Boolean): FcmTokenEntity?`
`9`	`11`	`}`