Merge pull request #223 from prgrms-web-devcourse-final-project/feature/EA3-181-study-alarm

[EA3-181] feature: 스터디 연장 알림 기능 추가

Author: pia01190

src/main/java/grep/neogulcoder/domain/alram/service/AlarmService.java

@@ -8,8 +8,12 @@
 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;
+import grep.neogulcoder.domain.study.event.StudyExtendEvent;
+import grep.neogulcoder.domain.study.event.StudyExtensionReminderEvent;
 import grep.neogulcoder.domain.study.event.StudyInviteEvent;
 import grep.neogulcoder.domain.study.repository.StudyMemberQueryRepository;
+import grep.neogulcoder.domain.study.repository.StudyMemberRepository;
 import grep.neogulcoder.domain.study.repository.StudyRepository;
 import grep.neogulcoder.global.exception.business.BusinessException;
 import grep.neogulcoder.global.exception.business.NotFoundException;
@@ -20,8 +24,8 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import static grep.neogulcoder.domain.study.exception.code.StudyErrorCode.STUDY_NOT_FOUND;
-import static grep.neogulcoder.domain.studyapplication.exception.code.ApplicationErrorCode.APPLICATION_PARTICIPANT_LIMIT_EXCEEDED;
+import static grep.neogulcoder.domain.study.exception.code.StudyErrorCode.*;
+import static grep.neogulcoder.domain.studyapplication.exception.code.ApplicationErrorCode.*;
 
 @Service
 @RequiredArgsConstructor
@@ -32,6 +36,7 @@ public class AlarmService {
     private final MessageFinder messageFinder;
     private final StudyRepository studyRepository;
     private final StudyMemberQueryRepository studyMemberQueryRepository;
+    private final StudyMemberRepository studyMemberRepository;
 
     @Transactional
     public void saveAlarm(Long receiverId, AlarmType alarmType, DomainType domainType, Long domainId) {
@@ -87,6 +92,35 @@ public void rejectInvite(Long alarmId) {
         alarm.checkAlarm();
     }
 
+    @EventListener
+    public void handleStudyExtendEvent(StudyExtendEvent event) {
+        List<StudyMember> members = studyMemberRepository.findAllByStudyIdAndActivatedTrue(event.studyId());
+
+        for (StudyMember member : members) {
+            if (!member.isLeader()) {
+                saveAlarm(
+                    member.getUserId(),
+                    AlarmType.STUDY_EXTEND,
+                    DomainType.STUDY,
+                    event.studyId()
+                );
+            }
+        }
+    }
+
+    @EventListener
+    public void handleStudyExtensionReminderEvent(StudyExtensionReminderEvent event) {
+        StudyMember leader = studyMemberRepository.findByStudyIdAndRoleAndActivatedTrue(event.studyId(), StudyMemberRole.LEADER)
+            .orElseThrow(() -> new BusinessException(STUDY_LEADER_NOT_FOUND));
+
+        saveAlarm(
+            leader.getUserId(),
+            AlarmType.STUDY_EXTENSION_REMINDER,
+            DomainType.STUDY,
+            event.studyId()
+        );
+    }
+
     private Alarm findValidAlarm(Long alarmId) {
         return alarmRepository.findById(alarmId).orElseThrow(() -> new NotFoundException(AlarmErrorCode.ALARM_NOT_FOUND));
     }

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

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

src/main/java/grep/neogulcoder/domain/study/event/StudyExtendEvent.java

@@ -0,0 +1,4 @@
+package grep.neogulcoder.domain.study.event;
+
+public record StudyExtendEvent(Long studyId) {
+}

src/main/java/grep/neogulcoder/domain/study/event/StudyExtensionReminderEvent.java

@@ -0,0 +1,4 @@
+package grep.neogulcoder.domain.study.event;
+
+public record StudyExtensionReminderEvent(Long studyId) {
+}

src/main/java/grep/neogulcoder/domain/study/exception/code/StudyErrorCode.java

@@ -10,20 +10,21 @@ public enum StudyErrorCode implements ErrorCode {
     STUDY_NOT_FOUND("S001",HttpStatus.NOT_FOUND,"스터디를 찾을 수 없습니다."),
     STUDY_MEMBER_NOT_FOUND("S002", HttpStatus.NOT_FOUND, "스터디 멤버가 아닙니다."),
     EXTENDED_STUDY_NOT_FOUND("S003", HttpStatus.NOT_FOUND, "연장된 스터디를 찾을 수 없습니다."),
+    STUDY_LEADER_NOT_FOUND("S004", HttpStatus.NOT_FOUND, "스터디장을 찾을 수 없습니다."),
 
-    STUDY_CREATE_LIMIT_EXCEEDED("S004", HttpStatus.BAD_REQUEST, "종료되지 않은 스터디는 최대 10개까지만 생성할 수 있습니다."),
-    STUDY_ALREADY_STARTED("S005", HttpStatus.BAD_REQUEST, "이미 시작된 스터디의 시작일은 변경할 수 없습니다."),
-    STUDY_DELETE_NOT_ALLOWED("S006", HttpStatus.BAD_REQUEST, "스터디 멤버가 1명일 때만 삭제할 수 있습니다."),
-    STUDY_LOCATION_REQUIRED("S007", HttpStatus.BAD_REQUEST, "스터디 타입이 OFFLINE이나 HYBRID인 스터디는 지역 입력이 필수입니다."),
+    STUDY_CREATE_LIMIT_EXCEEDED("S005", HttpStatus.BAD_REQUEST, "종료되지 않은 스터디는 최대 10개까지만 생성할 수 있습니다."),
+    STUDY_ALREADY_STARTED("S006", HttpStatus.BAD_REQUEST, "이미 시작된 스터디의 시작일은 변경할 수 없습니다."),
+    STUDY_DELETE_NOT_ALLOWED("S007", HttpStatus.BAD_REQUEST, "스터디 멤버가 1명일 때만 삭제할 수 있습니다."),
+    STUDY_LOCATION_REQUIRED("S008", HttpStatus.BAD_REQUEST, "스터디 타입이 OFFLINE이나 HYBRID인 스터디는 지역 입력이 필수입니다."),
 
-    STUDY_EXTENSION_NOT_AVAILABLE("S008", HttpStatus.BAD_REQUEST, "스터디 연장은 스터디 종료일 7일 전부터 가능합니다."),
-    END_DATE_BEFORE_ORIGIN_STUDY("S009", HttpStatus.BAD_REQUEST, "연장 스터디 종료일은 기존 스터디 종료일 이후여야 합니다."),
-    ALREADY_EXTENDED_STUDY("S010", HttpStatus.BAD_REQUEST, "이미 연장된 스터디입니다."),
-    ALREADY_REGISTERED_PARTICIPATION("S011", HttpStatus.BAD_REQUEST, "연장 스터디 참여는 한 번만 등록할 수 있습니다."),
+    STUDY_EXTENSION_NOT_AVAILABLE("S009", HttpStatus.BAD_REQUEST, "스터디 연장은 스터디 종료일 7일 전부터 가능합니다."),
+    END_DATE_BEFORE_ORIGIN_STUDY("S010", HttpStatus.BAD_REQUEST, "연장 스터디 종료일은 기존 스터디 종료일 이후여야 합니다."),
+    ALREADY_EXTENDED_STUDY("S011", HttpStatus.BAD_REQUEST, "이미 연장된 스터디입니다."),
+    ALREADY_REGISTERED_PARTICIPATION("S012", HttpStatus.BAD_REQUEST, "연장 스터디 참여는 한 번만 등록할 수 있습니다."),
 
-    NOT_STUDY_LEADER("S012", HttpStatus.FORBIDDEN, "스터디장만 접근이 가능합니다."),
-    LEADER_CANNOT_LEAVE_STUDY("S013", HttpStatus.BAD_REQUEST, "스터디장은 스터디를 탈퇴할 수 없습니다."),
-    LEADER_CANNOT_DELEGATE_TO_SELF("S014", HttpStatus.BAD_REQUEST, "자기 자신에게는 스터디장 위임이 불가능합니다.");
+    NOT_STUDY_LEADER("S013", HttpStatus.FORBIDDEN, "스터디장만 접근이 가능합니다."),
+    LEADER_CANNOT_LEAVE_STUDY("S014", HttpStatus.BAD_REQUEST, "스터디장은 스터디를 탈퇴할 수 없습니다."),
+    LEADER_CANNOT_DELEGATE_TO_SELF("S015", HttpStatus.BAD_REQUEST, "자기 자신에게는 스터디장 위임이 불가능합니다.");
 
     private final String code;
     private final HttpStatus status;

src/main/java/grep/neogulcoder/global/provider/InviteMessageProvider.java renamed to src/main/java/grep/neogulcoder/domain/study/provider/InviteMessageProvider.java

@@ -1,11 +1,12 @@
-package grep.neogulcoder.global.provider;
+package grep.neogulcoder.domain.study.provider;
 
 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.exception.code.StudyErrorCode;
 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;
 

src/main/java/grep/neogulcoder/domain/study/provider/StudyExtendMessageProvider.java

@@ -0,0 +1,37 @@
+package grep.neogulcoder.domain.study.provider;
+
+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;
+
+import static grep.neogulcoder.domain.study.exception.code.StudyErrorCode.*;
+
+@Component
+@RequiredArgsConstructor
+public class StudyExtendMessageProvider implements MessageProvidable {
+
+    private final StudyRepository studyRepository;
+
+    @Override
+    public boolean isSupport(AlarmType alarmType) {
+        return alarmType == AlarmType.STUDY_EXTEND;
+    }
+
+    @Override
+    public String provideMessage(DomainType domainType, Long domainId) {
+        if (domainType != DomainType.STUDY) {
+            throw new IllegalArgumentException("스터디 연장 알림은 STUDY 도메인에만 해당됩니다.");
+        }
+
+        String studyName = studyRepository.findById(domainId)
+            .map(Study::getName)
+            .orElseThrow(() -> new NotFoundException(STUDY_NOT_FOUND));
+
+        return String.format("스터디 '%s'가 연장되었습니다.", studyName);
+    }
+}

src/main/java/grep/neogulcoder/domain/study/provider/StudyExtensionReminderMessageProvider.java

@@ -0,0 +1,37 @@
+package grep.neogulcoder.domain.study.provider;
+
+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;
+
+import static grep.neogulcoder.domain.study.exception.code.StudyErrorCode.*;
+
+@Component
+@RequiredArgsConstructor
+public class StudyExtensionReminderMessageProvider implements MessageProvidable {
+
+    private final StudyRepository studyRepository;
+
+    @Override
+    public boolean isSupport(AlarmType alarmType) {
+        return alarmType == AlarmType.STUDY_EXTENSION_REMINDER;
+    }
+
+    @Override
+    public String provideMessage(DomainType domainType, Long domainId) {
+        if (domainType != DomainType.STUDY) {
+            throw new IllegalArgumentException("스터디 종료 7일 전 연장 가능 알림은 STUDY 도메인에만 해당됩니다.");
+        }
+
+        String studyName = studyRepository.findById(domainId)
+            .map(Study::getName)
+            .orElseThrow(() -> new NotFoundException(STUDY_NOT_FOUND));
+
+        return String.format("스터디 '%s' 종료 7일 전 입니다. 스터디 연장이 가능합니다.", studyName);
+    }
+}

src/main/java/grep/neogulcoder/domain/study/repository/StudyMemberRepository.java

@@ -46,4 +46,6 @@ public interface StudyMemberRepository extends JpaRepository<StudyMember, Long>
     boolean existsByStudyIdAndUserId(Long studyId, Long id);
 
     boolean existsByStudyIdAndUserIdAndRole(Long studyId, Long userId, StudyMemberRole role);
+
+    Optional<StudyMember> findByStudyIdAndRoleAndActivatedTrue(Long studyId, StudyMemberRole role);
 }

src/main/java/grep/neogulcoder/domain/study/scheduler/StudyScheduler.java

@@ -16,7 +16,7 @@ public class StudyScheduler {
 
     @Scheduled(cron = "0 0 0 * * *")
     public void processEndingStudies() {
-        List<Study> studiesEndingIn7Days = studySchedulerService.findStudiesEndingIn7Days();
+        studySchedulerService.findStudiesEndingIn7Days();
 
         studySchedulerService.finalizeStudies();
     }