[IDLE-400] 채용 공고 지원자 발생 시, 센터 관리자에게 알림을 발송한다.

.github/workflows/dev-server-deployer.yaml

@@ -44,9 +44,9 @@ jobs:
               --cidr ${{ steps.publicip.outputs.ip }}/32
 
       - name: Set Up Firebase Service Key
-        run : |
-          mkdir ./src/main/resources/firebase
-          echo ${{ secrets.FIREBASE_SERVICE_KEY_BASE64_ENCODE }} | base64 -d > ./src/main/resources/firebase/adminkey.json
+        run: |
+          mkdir ./idle-infrastructure/fcm/src/main/resources/firebase
+          echo ${{ secrets.FIREBASE_SERVICE_KEY_BASE64_ENCODE }} | base64 -d > /idle-infrastructure/fcm/src/main/resources/firebase/adminkey.json
 
       - name: Copy Docker Compose file to server
         uses: appleboy/scp-action@master

.github/workflows/dev-server-integrator.yaml

@@ -3,7 +3,7 @@ name: Develop Server Integrator (CI)
 on:
   push:
     branches:
-      - develop
+      - feat/IDLE-400
 
 jobs:
   build_and_push:

.github/workflows/prod-server-deployer.yaml

@@ -75,8 +75,8 @@ jobs:
 
       - name: Set Up Firebase Service Key
         run: |
-          mkdir ./idle-infrastructure/fcm/main/resources/firebase
-          echo ${{ secrets.FIREBASE_SERVICE_KEY_BASE64_ENCODE }} | base64 -d > /idle-infrastructure/fcm/main/resources/firebase/adminkey.json
+          mkdir ./idle-infrastructure/fcm/src/main/resources/firebase
+          echo ${{ secrets.FIREBASE_SERVICE_KEY_BASE64_ENCODE }} | base64 -d > ./idle-infrastructure/fcm/src/main/resources/firebase/adminkey.json
 
       - name: Run Docker
         uses: appleboy/ssh-action@master

idle-application/build.gradle.kts

@@ -10,6 +10,7 @@ dependencies {
     implementation(project(":idle-infrastructure:aws"))
     implementation(project(":idle-infrastructure:client"))
     implementation(project(":idle-infrastructure:sms"))
+    implementation(project(":idle-infrastructure:fcm"))
     implementation(project(":idle-support:common"))
     implementation(project(":idle-support:security"))
     implementation(project(":idle-support:transfer"))

idle-application/src/main/kotlin/com/swm/idle/application/applys/domain/CarerApplyEventPublisher.kt

@@ -0,0 +1,16 @@
+package com.swm.idle.application.applys.domain
+
+import com.swm.idle.domain.applys.event.ApplyEvent
+import org.springframework.context.ApplicationEventPublisher
+import org.springframework.stereotype.Service
+
+@Service
+class CarerApplyEventPublisher(
+    private val eventPublisher: ApplicationEventPublisher,
+) {
+
+    fun publish(applyEvent: ApplyEvent) {
+        eventPublisher.publishEvent(applyEvent)
+    }
+
+}

idle-application/src/main/kotlin/com/swm/idle/application/applys/domain/CarerApplyService.kt

@@ -15,8 +15,8 @@ class CarerApplyService(
         jobPostingId: UUID,
         carerId: UUID,
         applyMethodType: ApplyMethodType,
-    ) {
-        carerApplyJpaRepository.save(
+    ): Applys {
+        return carerApplyJpaRepository.save(
             Applys(
                 jobPostingId = jobPostingId,
                 carerId = carerId,

idle-application/src/main/kotlin/com/swm/idle/application/applys/facade/CarerApplyFacadeService.kt

@@ -1,39 +1,101 @@
 package com.swm.idle.application.applys.facade
 
+import com.swm.idle.application.applys.domain.CarerApplyEventPublisher
 import com.swm.idle.application.applys.domain.CarerApplyService
+import com.swm.idle.application.applys.vo.CarerApplyNotificationInfo
 import com.swm.idle.application.common.security.getUserAuthentication
+import com.swm.idle.application.jobposting.domain.JobPostingService
+import com.swm.idle.application.notification.domain.DeviceTokenService
+import com.swm.idle.application.notification.domain.NotificationService
+import com.swm.idle.application.user.carer.domain.CarerService
+import com.swm.idle.application.user.center.service.domain.CenterManagerService
+import com.swm.idle.application.user.center.service.domain.CenterService
+import com.swm.idle.domain.applys.event.ApplyEvent
 import com.swm.idle.domain.applys.exception.ApplyException
+import com.swm.idle.domain.common.enums.EntityStatus
+import com.swm.idle.domain.jobposting.entity.jpa.JobPosting
 import com.swm.idle.domain.jobposting.enums.ApplyMethodType
+import com.swm.idle.domain.notification.enums.NotificationType
+import com.swm.idle.domain.user.center.enums.CenterManagerAccountStatus
+import com.swm.idle.domain.user.center.vo.BusinessRegistrationNumber
+import com.swm.idle.domain.user.common.vo.BirthYear
 import org.springframework.stereotype.Service
+import org.springframework.transaction.annotation.Propagation
 import org.springframework.transaction.annotation.Transactional
 import java.util.*
 
 @Service
 @Transactional(readOnly = true)
 class CarerApplyFacadeService(
     private val carerApplyService: CarerApplyService,
+    private val carerApplyEventPublisher: CarerApplyEventPublisher,
+    private val deviceTokenService: DeviceTokenService,
+    private val jobPostingService: JobPostingService,
+    private val carerService: CarerService,
+    private val centerManagerService: CenterManagerService,
+    private val centerService: CenterService,
+    private val notificationService: NotificationService,
 ) {
 
-    @Transactional
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
     fun createApply(
         jobPostingId: UUID,
         applyMethodType: ApplyMethodType,
     ) {
-        val carerId = getUserAuthentication().userId
+        val carer = getUserAuthentication().userId.let {
+            carerService.getById(it)
+        }
+        val jobPosting = jobPostingService.getById(jobPostingId)
 
-        if (carerApplyService.existsByJobPostingIdAndCarerId(
-                jobPostingId = jobPostingId,
-                carerId = carerId,
-            )
-        ) {
+        if (carerApplyService.existsByJobPostingIdAndCarerId(jobPostingId, carer.id)) {
             throw ApplyException.AlreadyApplied()
         }
 
-        carerApplyService.create(
-            jobPostingId = jobPostingId,
-            carerId = carerId,
-            applyMethodType = applyMethodType,
-        )
+        val centerManagers = centerService.getById(jobPosting.centerId).let {
+            centerManagerService.findAllByCenterBusinessRegistrationNumber(
+                BusinessRegistrationNumber(it.businessRegistrationNumber)
+            )?.filter { centerManager ->
+                centerManager.status == CenterManagerAccountStatus.APPROVED && centerManager.entityStatus == EntityStatus.ACTIVE
+            }
+        }
+
+        centerManagers?.map { centerManager ->
+            val deviceToken = deviceTokenService.findByUserId(centerManager.id)
+
+            if (deviceToken != null) {
+                val notificationInfo = CarerApplyNotificationInfo(
+                    title = "${carer.name} 님이 공고에 지원하였습니다.",
+                    body = createBodyMessage(jobPosting),
+                    receiverId = centerManager.id,
+                    notificationType = NotificationType.APPLICANT,
+                    imageUrl = carer.profileImageUrl,
+                    notificationDetails = mapOf(
+                        "jobPostingId" to jobPostingId,
+                    )
+                )
+
+                val notification = notificationService.create(notificationInfo)
+
+                ApplyEvent.createApplyEvent(
+                    deviceToken = deviceToken,
+                    notificationId = notification.id,
+                    notificationInfo = notificationInfo
+                ).also {
+                    carerApplyEventPublisher.publish(it)
+                }
+            }
+        }
+        carerApplyService.create(jobPostingId, carer.id, applyMethodType)
     }
 
+    private fun createBodyMessage(jobPosting: JobPosting): String {
+        val filteredLotNumberAddress = jobPosting.lotNumberAddress.split(" ")
+            .take(3)
+            .joinToString(" ")
+
+        return "$filteredLotNumberAddress " +
+                "${jobPosting.careLevel}등급 " +
+                "${BirthYear.calculateAge(jobPosting.birthYear)}세 " +
+                jobPosting.gender.value
+    }
 }

idle-application/src/main/kotlin/com/swm/idle/application/applys/vo/CarerApplyNotificationInfo.kt

@@ -0,0 +1,41 @@
+package com.swm.idle.application.applys.vo
+
+import com.swm.idle.domain.notification.enums.NotificationType
+import com.swm.idle.domain.notification.jpa.NotificationInfo
+import java.util.*
+
+data class CarerApplyNotificationInfo(
+    override val title: String,
+    override val body: String,
+    override val receiverId: UUID,
+    override val notificationType: NotificationType,
+    override val imageUrl: String?,
+    override val notificationDetails: Map<String, Any>?,
+) : NotificationInfo {
+
+    companion object {
+
+        fun create(
+            title: String,
+            body: String,
+            receiverId: UUID,
+            notificationType: NotificationType,
+            imageUrl: String?,
+            jobPostingId: UUID,
+        ): CarerApplyNotificationInfo {
+            val notificationDetails = mapOf(
+                "jobPostingId" to jobPostingId,
+            )
+            return CarerApplyNotificationInfo(
+                title,
+                body,
+                receiverId,
+                notificationType,
+                imageUrl,
+                notificationDetails,
+            )
+        }
+
+    }
+
+}

idle-application/src/main/kotlin/com/swm/idle/application/jobposting/facade/CarerJobPostingFacadeService.kt

@@ -13,10 +13,10 @@ import com.swm.idle.application.user.center.service.domain.CenterService
 import com.swm.idle.domain.common.dto.JobPostingPreviewDto
 import com.swm.idle.domain.common.enums.EntityStatus
 import com.swm.idle.domain.user.carer.entity.jpa.Carer
+import com.swm.idle.support.transfer.common.CursorScrollRequest
 import com.swm.idle.support.transfer.jobposting.carer.CarerAppliedJobPostingScrollResponse
 import com.swm.idle.support.transfer.jobposting.carer.CarerJobPostingResponse
 import com.swm.idle.support.transfer.jobposting.carer.CarerJobPostingScrollResponse
-import com.swm.idle.support.transfer.jobposting.carer.CursorScrollRequest
 import com.swm.idle.support.transfer.jobposting.carer.JobPostingFavoriteResponse
 import org.locationtech.jts.geom.Point
 import org.springframework.stereotype.Service

idle-application/src/main/kotlin/com/swm/idle/application/jobposting/facade/CrawlingJobPostingFacadeService.kt

@@ -8,9 +8,9 @@ import com.swm.idle.application.user.carer.domain.CarerService
 import com.swm.idle.domain.common.dto.CrawlingJobPostingPreviewDto
 import com.swm.idle.domain.user.carer.entity.jpa.Carer
 import com.swm.idle.infrastructure.client.geocode.service.GeoCodeService
+import com.swm.idle.support.transfer.common.CursorScrollRequest
 import com.swm.idle.support.transfer.jobposting.carer.CrawlingJobPostingFavoriteResponse
 import com.swm.idle.support.transfer.jobposting.carer.CrawlingJobPostingScrollResponse
-import com.swm.idle.support.transfer.jobposting.carer.CursorScrollRequest
 import com.swm.idle.support.transfer.jobposting.common.CrawlingJobPostingResponse
 import org.locationtech.jts.geom.Point
 import org.springframework.stereotype.Service

idle-application/src/main/kotlin/com/swm/idle/application/jobposting/facade/JobPostingFavoriteFacadeService.kt

@@ -19,7 +19,12 @@ data class JobPostingFavoriteFacadeService(
         carerId: UUID,
         jobPostingType: JobPostingType,
     ) {
-        jobPostingFavoriteService.create(
+        jobPostingFavoriteService.findByJobPostingIdAndCarerId(
+            jobPostingId = jobPostingId,
+            carerId = carerId,
+        )?.let {
+            it.active()
+        } ?: jobPostingFavoriteService.create(
             jobPostingId = jobPostingId,
             carerId = carerId,
             jobPostingType = jobPostingType,

idle-application/src/main/kotlin/com/swm/idle/application/notification/domain/DeviceTokenService.kt

@@ -1,7 +1,7 @@
 package com.swm.idle.application.notification.domain
 
 import com.swm.idle.domain.notification.jpa.DeviceToken
-import com.swm.idle.domain.notification.repository.DeviceTokenJpaRepository
+import com.swm.idle.domain.notification.repository.jpa.DeviceTokenJpaRepository
 import com.swm.idle.domain.user.common.enum.UserType
 import org.springframework.stereotype.Service
 import org.springframework.transaction.annotation.Transactional
@@ -17,6 +17,10 @@ class DeviceTokenService(
         return deviceTokenJpaRepository.findByDeviceToken(deviceToken)
     }
 
+    fun findByUserId(userId: UUID): DeviceToken? {
+        return deviceTokenJpaRepository.findByUserId(userId)
+    }
+
     @Transactional
     fun updateDeviceTokenUserId(
         deviceToken: DeviceToken,

idle-application/src/main/kotlin/com/swm/idle/application/notification/domain/NotificationService.kt

@@ -0,0 +1,61 @@
+package com.swm.idle.application.notification.domain
+
+import com.swm.idle.domain.common.dto.NotificationQueryDto
+import com.swm.idle.domain.common.exception.PersistenceException
+import com.swm.idle.domain.notification.jpa.Notification
+import com.swm.idle.domain.notification.jpa.NotificationInfo
+import com.swm.idle.domain.notification.repository.jpa.NotificationJpaRepository
+import com.swm.idle.domain.notification.repository.querydsl.NotificationQueryRepository
+import org.springframework.data.repository.findByIdOrNull
+import org.springframework.stereotype.Service
+import org.springframework.transaction.annotation.Transactional
+import java.util.*
+
+@Service
+class NotificationService(
+    private val notificationJpaRepository: NotificationJpaRepository,
+    private val notificationQueryRepository: NotificationQueryRepository,
+) {
+
+    @Transactional
+    fun create(notificationInfo: NotificationInfo): Notification {
+        return notificationJpaRepository.save(
+            Notification(
+                isRead = false,
+                title = notificationInfo.title,
+                body = notificationInfo.body,
+                notificationType = notificationInfo.notificationType,
+                receiverId = notificationInfo.receiverId,
+                imageUrl = notificationInfo.imageUrl,
+                notificationDetails = notificationInfo.notificationDetails
+            )
+        )
+    }
+
+    fun getById(notificationId: UUID): Notification {
+        return notificationJpaRepository.findByIdOrNull(notificationId)
+            ?: throw PersistenceException.ResourceNotFound("Notification(=$notificationId) 를 찾을 수 없습니다.")
+    }
+
+    @Transactional
+    fun read(notification: Notification) {
+        notification.read()
+    }
+
+    fun countUnreadNotificationByUserId(userId: UUID): Int {
+        return notificationJpaRepository.countByUserIdWithUnreadStatus(userId)
+    }
+
+    fun findAllByUserId(
+        next: UUID?,
+        limit: Long,
+        userId: UUID,
+    ): List<NotificationQueryDto> {
+        return notificationQueryRepository.findAllByUserId(
+            next = next,
+            limit = limit,
+            userId = userId,
+        )
+    }
+
+}