Merge pull request #218 from prgrms-web-devcourse-final-project/feature/EA3-134-study-optimal-time-vote

[EA3-134] feature : 시간 투표 기간 생성 시 팀원에게 알림 전송 기능 추가

Author: hyeunS-P

src/main/java/grep/neogulcoder/domain/alram/exception/code/AlarmErrorCode.java

@@ -9,7 +9,6 @@ public enum AlarmErrorCode implements ErrorCode {
 
     ALARM_NOT_FOUND("A001",HttpStatus.NOT_FOUND,"알람을 찾을 수 없습니다.");
 
-
     private final String code;
     private final HttpStatus status;
     private final String message;

src/main/java/grep/neogulcoder/domain/alram/type/AlarmType.java

@@ -1,7 +1,5 @@
 package grep.neogulcoder.domain.alram.type;
 
 public enum AlarmType {
-
-    INVITE
-
+    INVITE, TIME_VOTE_REQUEST
 }

src/main/java/grep/neogulcoder/domain/alram/type/DomainType.java

@@ -1,5 +1,5 @@
 package grep.neogulcoder.domain.alram.type;
 
 public enum DomainType {
-    STUDY
+    STUDY, TIME_VOTE
 }

src/main/java/grep/neogulcoder/domain/timevote/dto/response/TimeVotePeriodResponse.java

@@ -3,6 +3,7 @@
 import grep.neogulcoder.domain.timevote.entity.TimeVotePeriod;
 import io.swagger.v3.oas.annotations.media.Schema;
 import java.time.LocalDateTime;
+import java.util.List;
 import lombok.Builder;
 import lombok.Getter;
 
@@ -19,18 +20,24 @@ public class TimeVotePeriodResponse {
   @Schema(description = "종료일", example = "2025-07-30T23:59:59")
   private LocalDateTime endDate;
 
+  @Schema(description = "알림이 전송된 팀원 멤버 ID 목록", example = "[11, 12, 13]")
+  private List<Long> notifiedMemberIds;
+
   @Builder
-  private TimeVotePeriodResponse(Long studyId, LocalDateTime startDate, LocalDateTime endDate) {
+  private TimeVotePeriodResponse(Long studyId, LocalDateTime startDate, LocalDateTime endDate, List<Long> notifiedMemberIds) {
     this.studyId = studyId;
     this.startDate = startDate;
     this.endDate = endDate;
+    this.notifiedMemberIds = notifiedMemberIds;
   }
 
-  public static TimeVotePeriodResponse from(TimeVotePeriod timeVotePeriod) {
+  public static TimeVotePeriodResponse from(TimeVotePeriod timeVotePeriod, List<Long> notifiedMemberIds) {
     return TimeVotePeriodResponse.builder()
         .studyId(timeVotePeriod.getStudyId())
         .startDate(timeVotePeriod.getStartDate())
         .endDate(timeVotePeriod.getEndDate())
+        .notifiedMemberIds(notifiedMemberIds)
         .build();
   }
 }
+

src/main/java/grep/neogulcoder/domain/timevote/provider/TimeVoteMessageProvider.java

@@ -0,0 +1,36 @@
+package grep.neogulcoder.domain.timevote.provider;
+
+import static grep.neogulcoder.domain.timevote.exception.code.TimeVoteErrorCode.STUDY_NOT_FOUND;
+
+import grep.neogulcoder.domain.alram.type.AlarmType;
+import grep.neogulcoder.domain.alram.type.DomainType;
+import grep.neogulcoder.domain.study.Study;
+import grep.neogulcoder.domain.study.repository.StudyRepository;
+import grep.neogulcoder.global.exception.business.NotFoundException;
+import grep.neogulcoder.global.provider.MessageProvidable;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class TimeVoteMessageProvider implements MessageProvidable {
+
+  private final StudyRepository studyRepository;
+
+  @Override
+  public boolean isSupport(AlarmType alarmType) {
+    return alarmType == AlarmType.TIME_VOTE_REQUEST;
+  }
+
+  @Override
+  public String provideMessage(DomainType domainType, Long domainId) {
+    if (domainType != DomainType.TIME_VOTE) {
+      throw new IllegalArgumentException("시간 투표 요청은 TIME_VOTE 도메인에만 해당됩니다.");
+    }
+
+    Study study = studyRepository.findById(domainId)
+        .orElseThrow(() -> new NotFoundException(STUDY_NOT_FOUND));
+
+    return String.format("[%s] 스터디장이 모임 일정 조율을 위한 투표를 요청했습니다.", study.getName());
+  }
+}

src/main/java/grep/neogulcoder/domain/timevote/service/TimeVotePeriodService.java

@@ -1,7 +1,15 @@
 package grep.neogulcoder.domain.timevote.service;
 
-import static grep.neogulcoder.domain.timevote.exception.code.TimeVoteErrorCode.*;
-
+import static grep.neogulcoder.domain.timevote.exception.code.TimeVoteErrorCode.FORBIDDEN_TIME_VOTE_CREATE;
+import static grep.neogulcoder.domain.timevote.exception.code.TimeVoteErrorCode.INVALID_TIME_VOTE_PERIOD;
+import static grep.neogulcoder.domain.timevote.exception.code.TimeVoteErrorCode.STUDY_MEMBER_NOT_FOUND;
+import static grep.neogulcoder.domain.timevote.exception.code.TimeVoteErrorCode.STUDY_NOT_FOUND;
+import static grep.neogulcoder.domain.timevote.exception.code.TimeVoteErrorCode.TIME_VOTE_INVALID_DATE_RANGE;
+import static grep.neogulcoder.domain.timevote.exception.code.TimeVoteErrorCode.TIME_VOTE_PERIOD_START_DATE_IN_PAST;
+
+import grep.neogulcoder.domain.alram.service.AlarmService;
+import grep.neogulcoder.domain.alram.type.AlarmType;
+import grep.neogulcoder.domain.alram.type.DomainType;
 import grep.neogulcoder.domain.study.Study;
 import grep.neogulcoder.domain.study.StudyMember;
 import grep.neogulcoder.domain.study.enums.StudyMemberRole;
@@ -14,9 +22,12 @@
 import grep.neogulcoder.domain.timevote.repository.TimeVoteRepository;
 import grep.neogulcoder.domain.timevote.repository.TimeVoteStatRepository;
 import grep.neogulcoder.global.exception.business.BusinessException;
+import grep.neogulcoder.global.provider.finder.MessageFinder;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.time.temporal.ChronoUnit;
+import java.util.ArrayList;
+import java.util.List;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -31,6 +42,8 @@ public class TimeVotePeriodService {
   private final TimeVoteStatRepository timeVoteStatRepository;
   private final StudyRepository studyRepository;
   private final StudyMemberRepository studyMemberRepository;
+  private final AlarmService alarmService;
+  private final MessageFinder messageFinder;
 
   public TimeVotePeriodResponse createTimeVotePeriodAndReturn(TimeVotePeriodCreateRequest request, Long studyId, Long userId) {
     StudyMember studyMember = getValidStudyMember(studyId, userId);
@@ -48,7 +61,20 @@ public TimeVotePeriodResponse createTimeVotePeriodAndReturn(TimeVotePeriodCreate
 
     TimeVotePeriod savedPeriod = timeVotePeriodRepository.save(request.toEntity(studyId, adjustedEndDate));
 
-    return TimeVotePeriodResponse.from(savedPeriod);
+    getValidStudy(studyId);
+    messageFinder.findMessage(AlarmType.TIME_VOTE_REQUEST, DomainType.TIME_VOTE, studyId);
+
+    List<StudyMember> members = studyMemberRepository.findAllByStudyIdAndActivatedTrue(studyId);
+    List<Long> notifiedUserIds = new ArrayList<>();
+    for (StudyMember member : members) {
+      if (!member.getUserId().equals(userId)) {
+        alarmService.saveAlarm(member.getUserId(), AlarmType.TIME_VOTE_REQUEST,
+            DomainType.TIME_VOTE, studyId);
+        notifiedUserIds.add(member.getId());
+      }
+    }
+
+    return TimeVotePeriodResponse.from(savedPeriod, notifiedUserIds);
   }
 
   public void deleteAllTimeVoteDate(Long studyId) {