Merge pull request #103 from TeamMiso/feat/notification-alarm

🔀 :: 푸시 알림 로직 추가

src/main/kotlin/andreas311/miso/domain/inquiry/adapter/input/InquiryAdapter.kt

@@ -21,7 +21,7 @@ class InquiryAdapter(
     private val writeInquiryUseCase: WriteInquiryUseCase,
     private val detailInquiryUseCase: DetailInquiryUseCase,
     private val listFilterInquiryUseCase: ListFilterInquiryUseCase,
-    private val writeInquiryRespondUseCase: WriteInquiryRespondUseCase
+    private val inquiryRespondUseCase: InquiryRespondUseCase
 ) {
     @PostMapping
     fun write(
@@ -51,6 +51,6 @@ class InquiryAdapter(
 
     @PatchMapping("/respond/{id}")
     fun respond(@PathVariable id: Long, @RequestBody @Valid writeInquiryRespondRequest: WriteInquiryRespondRequest): ResponseEntity<Void> =
-        writeInquiryRespondUseCase.execute(id, inquiryDataMapper toDto writeInquiryRespondRequest)
+        inquiryRespondUseCase.execute(id, inquiryDataMapper toDto writeInquiryRespondRequest)
             .let { ResponseEntity.status(HttpStatus.OK).build() }
 }

src/main/kotlin/andreas311/miso/domain/inquiry/application/port/input/WriteInquiryRespondUseCase.kt → src/main/kotlin/andreas311/miso/domain/inquiry/application/port/input/InquiryRespondUseCase.kt

@@ -2,6 +2,6 @@ package andreas311.miso.domain.inquiry.application.port.input
 
 import andreas311.miso.domain.inquiry.application.port.input.dto.WriteInquiryRespondDto
 
-interface WriteInquiryRespondUseCase {
+interface InquiryRespondUseCase {
     fun execute(id: Long, writeInquiryRespondDto: WriteInquiryRespondDto)
 }

src/main/kotlin/andreas311/miso/domain/inquiry/application/service/WriteInquiryRespondService.kt → src/main/kotlin/andreas311/miso/domain/inquiry/application/service/InquiryRespondService.kt

@@ -3,27 +3,33 @@ package andreas311.miso.domain.inquiry.application.service
 import andreas311.miso.common.annotation.RollbackService
 import andreas311.miso.domain.auth.application.port.output.UserSecurityPort
 import andreas311.miso.domain.inquiry.application.exception.InquiryNotFoundException
-import andreas311.miso.domain.inquiry.application.port.input.WriteInquiryRespondUseCase
+import andreas311.miso.domain.inquiry.application.port.input.InquiryRespondUseCase
 import andreas311.miso.domain.inquiry.application.port.input.dto.WriteInquiryRespondDto
 import andreas311.miso.domain.inquiry.application.port.output.CommandInquiryPort
 import andreas311.miso.domain.inquiry.application.port.output.QueryInquiryPort
 import andreas311.miso.domain.inquiry.domain.InquiryStatus
+import andreas311.miso.domain.notification.application.port.input.InquiryNotificationSendUseCase
 import andreas311.miso.domain.notification.application.port.output.CommandNotificationPort
+import andreas311.miso.domain.notification.application.port.output.QueryDeviceTokenPort
 import andreas311.miso.domain.notification.domain.Notification
 
 @RollbackService
-class WriteInquiryRespondService(
+class InquiryRespondService(
     private val userSecurityPort: UserSecurityPort,
     private val queryInquiryPort: QueryInquiryPort,
     private val commandInquiryPort: CommandInquiryPort,
-    private val commandNotificationPort: CommandNotificationPort
-) : WriteInquiryRespondUseCase {
+    private val queryDeviceTokenPort: QueryDeviceTokenPort,
+    private val commandNotificationPort: CommandNotificationPort,
+    private val inquiryNotificationSendUseCase: InquiryNotificationSendUseCase
+) : InquiryRespondUseCase {
     override fun execute(id: Long, writeInquiryRespondDto: WriteInquiryRespondDto) {
         val user = userSecurityPort.currentUser()
 
         val inquiry = queryInquiryPort.findByIdOrNull(id)
             ?: throw InquiryNotFoundException()
 
+        val deviceToken = queryDeviceTokenPort.findByUserIdOrNull(user.id)
+
         commandInquiryPort.saveInquiry(inquiry.updateInquiryStatus(InquiryStatus.COMPLETE))
 
         commandNotificationPort.saveNotification(
@@ -34,5 +40,7 @@ class WriteInquiryRespondService(
                 inquiry = inquiry
             )
         )
+
+        deviceToken?.let { inquiryNotificationSendUseCase.execute(inquiry, deviceToken.deviceToken) }
     }
 }

src/main/kotlin/andreas311/miso/domain/inquiry/application/service/WriteInquiryService.kt

@@ -8,6 +8,8 @@ import andreas311.miso.domain.inquiry.application.port.output.CommandInquiryPort
 import andreas311.miso.domain.inquiry.application.port.output.DiscordMessageSendPort
 import andreas311.miso.domain.inquiry.domain.Inquiry
 import andreas311.miso.domain.inquiry.domain.InquiryStatus
+import andreas311.miso.domain.notification.application.port.input.InquiryNotificationSendUseCase
+import andreas311.miso.domain.notification.application.port.output.QueryDeviceTokenPort
 import andreas311.miso.thirdparty.aws.s3.util.S3Util
 import org.springframework.web.multipart.MultipartFile
 import java.time.LocalDateTime
@@ -17,7 +19,9 @@ class WriteInquiryService(
     private val s3Util: S3Util,
     private val userSecurityPort: UserSecurityPort,
     private val commandInquiryPort: CommandInquiryPort,
-    private val discordMessageSendPort: DiscordMessageSendPort
+    private val queryDeviceTokenPort: QueryDeviceTokenPort,
+    private val discordMessageSendPort: DiscordMessageSendPort,
+    private val inquiryNotificationSendUseCase: InquiryNotificationSendUseCase
 ) : WriteInquiryUseCase {
     override fun execute(writeInquiryDto: WriteInquiryDto, multipartFile: MultipartFile?) {
         val user = userSecurityPort.currentUser()
@@ -27,8 +31,9 @@ class WriteInquiryService(
                 s3Util.execute(multipartFile)
             } else null
 
-        commandInquiryPort.saveInquiry(
-            Inquiry(
+        val deviceToken = queryDeviceTokenPort.findByUserIdOrNull(user.id)
+
+        val inquiry = Inquiry(
                 id = 0L,
                 title = writeInquiryDto.title,
                 content = writeInquiryDto.content,
@@ -37,12 +42,15 @@ class WriteInquiryService(
                 user = user,
                 createdDate = LocalDateTime.now()
             )
-        )
+
+        commandInquiryPort.saveInquiry(inquiry)
+
         sendDiscordMessage(writeInquiryDto.title)
+
+        deviceToken?.let { inquiryNotificationSendUseCase.execute(inquiry, deviceToken.deviceToken) }
     }
 
     private fun sendDiscordMessage(title: String) {
-
         val inquiryMessage = discordMessageSendPort.createInquiryMessage(title)
 
         discordMessageSendPort.sendDiscordMessage(inquiryMessage)

src/main/kotlin/andreas311/miso/domain/notification/adapter/output/persistence/QueryDeviceTokenPersistenceAdapter.kt

@@ -16,4 +16,9 @@ class QueryDeviceTokenPersistenceAdapter(
         val deviceTokenEntity = deviceTokenRepository.findByUserId(id)
         return deviceTokenMapper toDomain deviceTokenEntity
     }
+
+    override fun findAll(): List<DeviceToken> {
+        val deviceTokenList = deviceTokenRepository.findAll()
+        return deviceTokenList.map { deviceTokenMapper.toDomain(it)!! }
+    }
 }

src/main/kotlin/andreas311/miso/domain/notification/application/port/input/EnvironmentNotificationSendUseCase.kt

@@ -0,0 +1,5 @@
+package andreas311.miso.domain.notification.application.port.input
+
+interface EnvironmentNotificationSendUseCase {
+    fun execute()
+}

src/main/kotlin/andreas311/miso/domain/notification/application/port/input/InquiryNotificationSendUseCase.kt

@@ -0,0 +1,7 @@
+package andreas311.miso.domain.notification.application.port.input
+
+import andreas311.miso.domain.inquiry.domain.Inquiry
+
+interface InquiryNotificationSendUseCase {
+    fun execute(inquiry: Inquiry, token: String)
+}

src/main/kotlin/andreas311/miso/domain/notification/application/port/output/QueryDeviceTokenPort.kt

@@ -5,4 +5,5 @@ import java.util.UUID
 
 interface QueryDeviceTokenPort {
     fun findByUserIdOrNull(id: UUID): DeviceToken?
+    fun findAll(): List<DeviceToken>
 }

src/main/kotlin/andreas311/miso/domain/notification/application/scheduler/EnvironmentNotificationScheduler.kt

@@ -0,0 +1,15 @@
+package andreas311.miso.domain.notification.application.scheduler
+
+import andreas311.miso.domain.notification.application.port.input.EnvironmentNotificationSendUseCase
+import org.springframework.scheduling.annotation.Scheduled
+import org.springframework.stereotype.Component
+
+@Component
+class EnvironmentNotificationScheduler(
+    private val environmentNotificationSendUseCase: EnvironmentNotificationSendUseCase
+) {
+    @Scheduled(cron = "0 0 13 * * ?")
+    fun sendEnvironmentNotification() {
+        environmentNotificationSendUseCase.execute()
+    }
+}

src/main/kotlin/andreas311/miso/domain/notification/application/service/EnvironmentNotificationSendService.kt

@@ -0,0 +1,31 @@
+package andreas311.miso.domain.notification.application.service
+
+import andreas311.miso.domain.notification.application.port.input.EnvironmentNotificationSendUseCase
+import andreas311.miso.domain.notification.application.port.output.FcmNotificationPort
+import andreas311.miso.domain.notification.application.port.output.QueryDeviceTokenPort
+import andreas311.miso.domain.notification.domain.NotificationAlarm
+import andreas311.miso.domain.notification.domain.NotificationType
+import org.springframework.stereotype.Component
+
+@Component
+class EnvironmentNotificationSendService(
+    private val fcmNotificationPort: FcmNotificationPort,
+    private val queryDeviceTokenPort: QueryDeviceTokenPort
+) : EnvironmentNotificationSendUseCase {
+    override fun execute() {
+
+        runCatching {
+            fcmNotificationPort.sendEnvironmentNotification(
+                deviceTokens = queryDeviceTokenPort.findAll().map { it.deviceToken },
+                notificationAlarm = NotificationAlarm(
+                    title = NotificationType.ENVIRONMENT.title,
+                    content = NotificationType.ENVIRONMENT.content,
+                    writer = "미소"
+                )
+            )
+
+        }.onFailure {
+            it.printStackTrace()
+        }
+    }
+}

src/main/kotlin/andreas311/miso/domain/notification/application/service/InquiryNotificationSendService.kt

@@ -0,0 +1,35 @@
+package andreas311.miso.domain.notification.application.service
+
+import andreas311.miso.common.annotation.RollbackService
+import andreas311.miso.domain.inquiry.domain.Inquiry
+import andreas311.miso.domain.inquiry.domain.InquiryStatus
+import andreas311.miso.domain.notification.application.port.input.InquiryNotificationSendUseCase
+import andreas311.miso.domain.notification.application.port.output.FcmNotificationPort
+import andreas311.miso.domain.notification.domain.NotificationAlarm
+import andreas311.miso.domain.notification.domain.NotificationType
+
+@RollbackService
+class InquiryNotificationSendService(
+    private val fcmNotificationPort: FcmNotificationPort
+) : InquiryNotificationSendUseCase {
+    override fun execute(inquiry: Inquiry, token: String) {
+        val notificationType = when (inquiry.inquiryStatus) {
+            InquiryStatus.WAIT -> NotificationType.INQUIRY_WAIT
+            InquiryStatus.COMPLETE -> NotificationType.INQUIRY_COMPLETE
+        }
+
+        runCatching {
+            fcmNotificationPort.sendInquiryNotification(
+                deviceToken = token,
+                notificationAlarm = NotificationAlarm(
+                    title = notificationType.title,
+                    content = notificationType.content,
+                    writer = "미소"
+                )
+            )
+
+        }.onFailure {
+            it.printStackTrace()
+        }
+    }
+}

src/main/kotlin/andreas311/miso/domain/notification/domain/NotificationType.kt

@@ -0,0 +1,22 @@
+package andreas311.miso.domain.notification.domain
+
+enum class NotificationType(
+    val title: String,
+    val content: String
+) {
+
+    INQUIRY_WAIT(
+        title = "Miso 문의사항 등록 완료!",
+        content = "최대한 빠르게 답변 드릴테니 기다려주세요 :)"
+    ),
+
+    INQUIRY_COMPLETE(
+        title = "Miso 문의사항 답변 도착!",
+        content = "내 문의 내역에서 답변을 확인해주세요 :)"
+    ),
+
+    ENVIRONMENT(
+        title = "오늘의 환경 지식을 알고 싶다면?",
+        content = "Miso 에서 오늘의 환경 지식을 확인해보세요 :)"
+    )
+}

src/main/kotlin/andreas311/miso/thirdparty/firebase/adapter/FcmNotificationAdapter.kt

@@ -6,7 +6,9 @@ import com.google.firebase.messaging.FirebaseMessaging
 import com.google.firebase.messaging.Message
 import com.google.firebase.messaging.MulticastMessage
 import com.google.firebase.messaging.Notification
+import org.springframework.stereotype.Component
 
+@Component
 class FcmNotificationAdapter : FcmNotificationPort {
     private val firebaseInstance: FirebaseMessaging
         get() = FirebaseMessaging.getInstance()