refactor: 구독 생성 조회 시 알림 채널을 포함하도록 변경

Author: kim-se-hee

src/main/java/ksh/backendserver/subscription/dto/request/SubscriptionCreationRequestDto.java

@@ -1,6 +1,8 @@
 package ksh.backendserver.subscription.dto.request;
 
 import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotEmpty;
+import ksh.backendserver.notification.enums.NotificationType;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 
@@ -19,4 +21,8 @@ public class SubscriptionCreationRequestDto {
 
     @Schema(description = "구독할 직군 ID 목록", example = "[1, 2, 3]")
     private List<Long> positionIds;
+
+    @NotEmpty(message = "알림 수단을 최소 1개 이상 선택해야 합니다.")
+    @Schema(description = "알림 수단 목록 (EMAIL, SLACK)", example = "[\"EMAIL\", \"SLACK\"]")
+    private List<NotificationType> notificationTypes;
 }

src/main/java/ksh/backendserver/subscription/dto/response/SubscriptionResponseDto.java

@@ -1,6 +1,7 @@
 package ksh.backendserver.subscription.dto.response;
 
 import io.swagger.v3.oas.annotations.media.Schema;
+import ksh.backendserver.notification.enums.NotificationType;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 
@@ -20,7 +21,15 @@ public class SubscriptionResponseDto {
     @Schema(description = "구독 중인 직군 이름 목록", example = "[\"백엔드 개발자\", \"프론트엔드 개발자\"]")
     private List<String> positionNames;
 
-    public static SubscriptionResponseDto of(List<String> companyNames, List<String> skillNames, List<String> positionNames) {
-        return new SubscriptionResponseDto(companyNames, skillNames, positionNames);
+    @Schema(description = "알림 수단 목록", example = "[\"EMAIL\", \"SLACK\"]")
+    private List<NotificationType> channels;
+
+    public static SubscriptionResponseDto of(
+        List<String> companyNames,
+        List<String> skillNames,
+        List<String> positionNames,
+        List<NotificationType> notificationTypes
+    ) {
+        return new SubscriptionResponseDto(companyNames, skillNames, positionNames, notificationTypes);
     }
-}
+}

src/main/java/ksh/backendserver/subscription/service/SubscriptionService.java

@@ -8,6 +8,8 @@
 import ksh.backendserver.group.entity.SubscriptionPosition;
 import ksh.backendserver.group.repository.PositionRepository;
 import ksh.backendserver.group.repository.SubscriptionPositionRepository;
+import ksh.backendserver.notification.entity.NotificationPreference;
+import ksh.backendserver.notification.repository.NotificationPreferenceRepository;
 import ksh.backendserver.post.model.PostSkillRequirement;
 import ksh.backendserver.skill.entity.Skill;
 import ksh.backendserver.skill.entity.SubscriptionSkill;
@@ -35,6 +37,7 @@ public class SubscriptionService {
     private final SubscriptionSkillRepository subscriptionSkillRepository;
     private final SubscriptionPositionRepository subscriptionPositionRepository;
     private final SubscriptionCompanyRepository subscriptionCompanyRepository;
+    private final NotificationPreferenceRepository notificationPreferenceRepository;
 
     private final CompanyRepository companyRepository;
     private final SkillRepository skillRepository;
@@ -65,26 +68,38 @@ public void save(SubscriptionCreationRequestDto request, Long memberId) {
                 .build())
             .toList();
 
+        List<NotificationPreference> notificationPreferences = request.getNotificationTypes()
+            .stream()
+            .map(notificationType -> NotificationPreference.builder()
+                .memberId(memberId)
+                .notificationType(notificationType)
+                .build())
+            .toList();
+
         subscriptionCompanyRepository.saveAll(companies);
         subscriptionSkillRepository.saveAll(skills);
         subscriptionPositionRepository.saveAll(positions);
+        notificationPreferenceRepository.saveAll(notificationPreferences);
     }
 
     @Transactional
     public void cancel(Long memberId) {
         List<SubscriptionCompany> companies = subscriptionCompanyRepository.findByUserId(memberId);
         List<SubscriptionSkill> skills = subscriptionSkillRepository.findByUserId(memberId);
         List<SubscriptionPosition> positions = subscriptionPositionRepository.findByUserId(memberId);
+        List<NotificationPreference> notificationPreferences = notificationPreferenceRepository.findByMemberId(memberId);
 
         subscriptionCompanyRepository.deleteAll(companies);
         subscriptionSkillRepository.deleteAll(skills);
         subscriptionPositionRepository.deleteAll(positions);
+        notificationPreferenceRepository.deleteAll(notificationPreferences);
     }
 
     public SubscriptionResponseDto findByMemberId(Long memberId) {
         List<SubscriptionCompany> subscriptionCompanies = subscriptionCompanyRepository.findByUserId(memberId);
         List<SubscriptionSkill> subscriptionSkills = subscriptionSkillRepository.findByUserId(memberId);
         List<SubscriptionPosition> subscriptionPositions = subscriptionPositionRepository.findByUserId(memberId);
+        List<NotificationPreference> notificationPreferences = notificationPreferenceRepository.findByMemberId(memberId);
 
         List<Long> companyIds = subscriptionCompanies.stream()
             .map(SubscriptionCompany::getCompanyId)
@@ -114,7 +129,11 @@ public SubscriptionResponseDto findByMemberId(Long memberId) {
             .map(Position::getName)
             .toList();
 
-        return SubscriptionResponseDto.of(companyNames, skillNames, positionNames);
+        var notificationTypes = notificationPreferences.stream()
+            .map(NotificationPreference::getNotificationType)
+            .toList();
+
+        return SubscriptionResponseDto.of(companyNames, skillNames, positionNames, notificationTypes);
     }
 
     public Map<UserSubscription, List<PostSkillRequirement>> findMatchingSubscription(