🛠 :: (#809) 겨울인턴 알림 수정

jobis-application/src/main/java/team/retum/jobis/domain/intern/event/SingleWinterInternRegisteredEvent.java

@@ -1,4 +1,13 @@
 package team.retum.jobis.domain.intern.event;
 
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import team.retum.jobis.domain.recruitment.model.Recruitment;
+
+@Getter
+@AllArgsConstructor
 public class SingleWinterInternRegisteredEvent {
+
+    private final Recruitment recruitments;
+
 }

jobis-application/src/main/java/team/retum/jobis/domain/recruitment/usecase/ApplyRecruitmentUseCase.java

@@ -5,6 +5,7 @@
 import team.retum.jobis.common.spi.PublishEventPort;
 import team.retum.jobis.common.spi.SecurityPort;
 import team.retum.jobis.domain.company.model.Company;
+import team.retum.jobis.domain.intern.event.SingleWinterInternRegisteredEvent;
 import team.retum.jobis.domain.recruitment.dto.request.ApplyRecruitmentRequest;
 import team.retum.jobis.domain.recruitment.event.InterestedRecruitmentEvent;
 import team.retum.jobis.domain.recruitment.exception.RecruitmentAlreadyExistsException;
@@ -40,7 +41,7 @@ public void execute(ApplyRecruitmentRequest request) {
             .toList();
         commandRecruitAreaPort.saveAll(recruitAreas);
 
-        publishEventPort.publishEvent(new InterestedRecruitmentEvent(recruitment));
+        publishEventPort.publishEvent(new SingleWinterInternRegisteredEvent(recruitment));
     }
 
     public void executeInterestCodeMatch() {

jobis-infrastructure/src/main/java/team/retum/jobis/domain/notification/presentation/NotificationWebAdapter.java

@@ -30,7 +30,6 @@ public class NotificationWebAdapter {
     private final SubscribeAllTopicsByToggleUseCase subscribeAllTopicsByToggleUseCase;
     private final QueryTopicsUseCase queryTopicsUseCase;
 
-
     @GetMapping
     public QueryNotificationsResponse queryNotifications(@RequestParam(value = "is_new", required = false) Boolean isNew) {
         return queryNotificationsUseCase.execute(isNew);

jobis-infrastructure/src/main/java/team/retum/jobis/event/intern/WinterInternEventHandler.java

@@ -9,6 +9,7 @@
 import team.retum.jobis.domain.company.exception.CompanyNotFoundException;
 import team.retum.jobis.domain.company.model.Company;
 import team.retum.jobis.domain.company.spi.QueryCompanyPort;
+import team.retum.jobis.domain.intern.event.SingleWinterInternRegisteredEvent;
 import team.retum.jobis.domain.intern.event.WinterInternToggledEvent;
 import team.retum.jobis.domain.notification.model.Notification;
 import team.retum.jobis.domain.notification.model.Topic;
@@ -17,6 +18,7 @@
 import team.retum.jobis.domain.recruitment.model.RecruitStatus;
 import team.retum.jobis.domain.recruitment.model.Recruitment;
 import team.retum.jobis.domain.user.model.User;
+import team.retum.jobis.domain.user.persistence.repository.UserJpaRepository;
 import team.retum.jobis.domain.user.spi.QueryUserPort;
 import team.retum.jobis.thirdparty.fcm.FCMUtil;
 
@@ -30,6 +32,7 @@ public class WinterInternEventHandler {
     private final CommandNotificationPort commandNotificationPort;
     private final QueryUserPort queryUserPort;
     private final QueryCompanyPort queryCompanyPort;
+    private final UserJpaRepository userJpaRepository;
 
     @Async("asyncTaskExecutor")
     @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
@@ -90,4 +93,32 @@ public void onWinterInternRegistered(WinterInternRegisteredEvent event) {
             }
         }
     }
+
+    @Async("asyncTaskExecutor")
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    public void onSingleWinterInternRegistered(SingleWinterInternRegisteredEvent event) {
+        List<String> deviceTokens = queryUserPort.getDeviceTokenByTopic(Topic.WINTER_INTERN);
+
+        Company company = queryCompanyPort.getById(event.getRecruitments().getCompanyId())
+            .orElseThrow(() -> CompanyNotFoundException.EXCEPTION);
+
+        String companyName = company.getName();
+
+        for (String deviceToken : deviceTokens) {
+            User user = queryUserPort.getUserIdByDeviceToken(deviceToken);
+
+            Notification notification = Notification.builder()
+                .title(companyName + " 겨울 인턴십 모집 공고 ⛄️")
+                .content("겨울 인턴십 모집 의뢰서가 등록되었어요. 지금 확인해보세요!")
+                .userId(user.getId())
+                .detailId(event.getRecruitments().getId())
+                .topic(Topic.WINTER_INTERN)
+                .authority(Authority.STUDENT)
+                .isNew(true)
+                .build();
+
+            commandNotificationPort.save(notification);
+            fcmUtil.sendMessageToTopic(notification);
+        }
+    }
 }