feat: 애플리케이션 재시작 시 PENDING 상태 알림 스케줄링 및 새벽 4시마다 지난 모임 삭제 기능 추가

backend/src/main/java/com/ody/common/config/ClockConfig.java

@@ -0,0 +1,19 @@
+package com.ody.common.config;
+
+import java.time.Clock;
+import java.time.ZoneId;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Slf4j
+@Configuration
+public class ClockConfig {
+
+    @Bean
+    public Clock clock() {
+        String zoneId = "Asia/Seoul";
+        log.info("시스템 타임 존 설정 : {}", zoneId);
+        return Clock.system(ZoneId.of(zoneId));
+    }
+}

backend/src/main/java/com/ody/common/domain/BaseEntity.java

@@ -7,15 +7,20 @@
 import java.time.LocalDateTime;
 import lombok.Getter;
 import org.springframework.data.annotation.CreatedDate;
+import org.springframework.data.annotation.LastModifiedDate;
 import org.springframework.data.jpa.domain.support.AuditingEntityListener;
 
 @MappedSuperclass
 @EntityListeners(AuditingEntityListener.class)
 @Getter
 public class BaseEntity {
 
-    @CreatedDate
     @Column(updatable = false)
     @NotNull
+    @CreatedDate
     private LocalDateTime createdAt;
+
+    @NotNull
+    @LastModifiedDate
+    private LocalDateTime updatedAt;
 }

backend/src/main/java/com/ody/mate/repository/MateRepository.java

@@ -13,15 +13,17 @@ public interface MateRepository extends JpaRepository<Mate, Long> {
             from Mate mate
             join fetch mate.meeting
             join fetch mate.member
-            where mate.id = :id
+            where mate.id = :id 
+            and mate.meeting.overdue = false
             """)
     Optional<Mate> findFetchedMateById(Long id);
 
     @Query("""
             select mate
             from Mate mate
             join fetch mate.member
-            where mate.meeting.id = :meetingId
+            where mate.meeting.id = :meetingId 
+            and mate.meeting.overdue = false
             """)
     List<Mate> findAllByMeetingId(Long meetingId);
 

backend/src/main/java/com/ody/mate/service/MateService.java

@@ -34,15 +34,16 @@ public class MateService {
     private final NotificationService notificationService;
     private final RouteService routeService;
 
+
     @Transactional
-    public MateSaveResponseV2 saveAndSendNotifications(
-            MateSaveRequestV2 mateSaveRequest,
-            Member member,
-            Meeting meeting
-    ) {
+    public MateSaveResponseV2 saveAndSendNotifications(MateSaveRequestV2 mateSaveRequest, Member member, Meeting meeting) {
         if (mateRepository.existsByMeetingIdAndMemberId(meeting.getId(), member.getId())) {
-            throw new OdyBadRequestException("약속에 이미 참여한 회원입니다.");
+            throw new OdyBadRequestException("약속방에 이미 참여한 회원입니다.");
+        }
+        if (meeting.isOverdue()) {
+            throw new OdyBadRequestException("참여 가능한 시간이 지난 약속방에 참여할 수 없습니다.");
         }
+
         Mate mate = saveMateAndEta(mateSaveRequest, member, meeting);
         notificationService.saveAndSendNotifications(meeting, mate, member.getDeviceToken());
         return MateSaveResponseV2.from(meeting);

backend/src/main/java/com/ody/meeting/domain/Meeting.java

@@ -18,8 +18,8 @@
 
 @Entity
 @Getter
-@AllArgsConstructor
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
 public class Meeting extends BaseEntity {
 
     @Id
@@ -42,8 +42,11 @@ public class Meeting extends BaseEntity {
     @NotNull
     private String inviteCode;
 
+    @NotNull
+    private boolean overdue;
+
     public Meeting(String name, LocalDate date, LocalTime time, Location target, String inviteCode) {
-        this(null, name, date, TimeUtil.trimSecondsAndNanos(time), target, inviteCode);
+        this(null, name, date, TimeUtil.trimSecondsAndNanos(time), target, inviteCode, false);
     }
 
     public void updateInviteCode(String inviteCode) {

backend/src/main/java/com/ody/meeting/repository/MeetingRepository.java

@@ -2,7 +2,9 @@
 
 import com.ody.meeting.domain.Meeting;
 import java.util.List;
+import java.util.Optional;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
 
 public interface MeetingRepository extends JpaRepository<Meeting, Long> {
@@ -12,7 +14,17 @@ public interface MeetingRepository extends JpaRepository<Meeting, Long> {
             from Meeting meeting
             right join Mate mate on meeting.id = mate.meeting.id
             where mate.member.id = :memberId
+            and meeting.overdue = false
             """
     )
     List<Meeting> findAllByMemberId(Long memberId);
+
+    @Modifying(clearAutomatically = true)
+    @Query("update Meeting m set m.overdue = true where m.overdue = false and m.date < CURRENT_DATE")
+    void updateAllByNotOverdueMeetings();
+
+    @Query("select m from Meeting m where m.overdue = true and CAST(m.updatedAt AS LOCALDATE) = CURRENT_DATE")
+    List<Meeting> findAllByUpdatedTodayAndOverdue();
+
+    Optional<Meeting> findByIdAndOverdueFalse(Long id);
 }

backend/src/main/java/com/ody/meeting/service/MeetingService.java

@@ -15,16 +15,20 @@
 import com.ody.meeting.dto.response.MeetingWithMatesResponse;
 import com.ody.meeting.repository.MeetingRepository;
 import com.ody.member.domain.Member;
+import com.ody.notification.service.NotificationService;
 import com.ody.util.InviteCodeGenerator;
 import com.ody.util.TimeUtil;
 import java.time.LocalDateTime;
 import java.util.Comparator;
 import java.util.List;
 import java.util.stream.Collectors;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+@Slf4j
 @Service
 @RequiredArgsConstructor
 @Transactional(readOnly = true)
@@ -35,6 +39,7 @@ public class MeetingService {
     private final MateService mateService;
     private final MeetingRepository meetingRepository;
     private final MateRepository mateRepository;
+    private final NotificationService notificationService;
 
     @Transactional
     public MeetingSaveResponseV1 saveV1(MeetingSaveRequestV1 meetingSaveRequestV1) {
@@ -58,7 +63,7 @@ public Meeting findByInviteCode(String inviteCode) {
     }
 
     public Meeting findById(Long meetingId) {
-        return meetingRepository.findById(meetingId)
+        return meetingRepository.findByIdAndOverdueFalse(meetingId)
                 .orElseThrow(() -> new OdyNotFoundException("존재하지 않는 모임입니다."));
     }
 
@@ -93,4 +98,12 @@ public MateSaveResponseV2 saveMateAndSendNotifications(MateSaveRequestV2 mateSav
         }
         return mateService.saveAndSendNotifications(mateSaveRequest, member, meeting);
     }
+
+    @Scheduled(cron = "0 0 4 * * *", zone = "Asia/Seoul")
+    public void scheduleOverdueMeetings() {
+        meetingRepository.updateAllByNotOverdueMeetings();
+        List<Meeting> meetings = meetingRepository.findAllByUpdatedTodayAndOverdue();
+        log.info("약속 시간이 지난 약속들 overdue = true로 update 쿼리 실행");
+        notificationService.unSubscribeTopic(meetings);
+    }
 }

backend/src/main/java/com/ody/notification/domain/FcmTopic.java

@@ -1,11 +1,18 @@
 package com.ody.notification.domain;
 
 import com.ody.meeting.domain.Meeting;
+import jakarta.persistence.Column;
+import jakarta.persistence.Embeddable;
+import lombok.AccessLevel;
 import lombok.Getter;
+import lombok.NoArgsConstructor;
 
 @Getter
+@Embeddable
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
 public class FcmTopic {
 
+    @Column(name = "fcm_topic")
     private String value;
 
     public FcmTopic(Meeting meeting) {

backend/src/main/java/com/ody/notification/domain/Notification.java

@@ -2,6 +2,8 @@
 
 import com.ody.common.domain.BaseEntity;
 import com.ody.mate.domain.Mate;
+import com.ody.member.domain.DeviceToken;
+import jakarta.persistence.Embedded;
 import jakarta.persistence.Entity;
 import jakarta.persistence.EnumType;
 import jakarta.persistence.Enumerated;
@@ -44,23 +46,46 @@ public class Notification extends BaseEntity {
     @NotNull
     private NotificationStatus status;
 
-    public Notification(Mate mate, NotificationType type, LocalDateTime sendAt, NotificationStatus status) {
-        this(null, mate, type, sendAt, status);
+    @Embedded
+    private FcmTopic fcmTopic;
+
+    public Notification(
+            Mate mate,
+            NotificationType type,
+            LocalDateTime sendAt,
+            NotificationStatus status,
+            FcmTopic fcmTopic
+    ) {
+        this(null, mate, type, sendAt, status, fcmTopic);
     }
 
     public static Notification createEntry(Mate mate) {
-        return new Notification(mate, NotificationType.ENTRY, LocalDateTime.now(), NotificationStatus.PENDING);
+        return new Notification(mate, NotificationType.ENTRY, LocalDateTime.now(), NotificationStatus.PENDING, null);
     }
 
-    public static Notification createDepartureReminder(Mate mate, LocalDateTime sendAt) {
-        return new Notification(mate, NotificationType.DEPARTURE_REMINDER, sendAt, NotificationStatus.PENDING);
+    public static Notification createDepartureReminder(Mate mate, LocalDateTime sendAt, FcmTopic fcmTopic) {
+        return new Notification(
+                mate,
+                NotificationType.DEPARTURE_REMINDER,
+                sendAt,
+                NotificationStatus.PENDING,
+                fcmTopic
+        );
     }
 
     public static Notification createNudge(Mate mate) {
-        return new Notification(mate, NotificationType.NUDGE, LocalDateTime.now(), NotificationStatus.PENDING);
+        return new Notification(mate, NotificationType.NUDGE, LocalDateTime.now(), NotificationStatus.PENDING, null);
     }
 
     public void updateStatusToDone() {
         this.status = NotificationStatus.DONE;
     }
+
+    public String getFcmTopicValue() {
+        return fcmTopic.getValue();
+    }
+
+    public DeviceToken getMateDeviceToken() {
+        return mate.getMemberDeviceToken();
+    }
 }

backend/src/main/java/com/ody/notification/domain/message/PushMessage.java

@@ -1,7 +1,6 @@
 package com.ody.notification.domain.message;
 
 import com.google.firebase.messaging.Message;
-import com.ody.notification.domain.FcmTopic;
 import com.ody.notification.domain.Notification;
 import lombok.Getter;
 
@@ -10,11 +9,11 @@ public class PushMessage {
 
     private final Message message;
 
-    public PushMessage(FcmTopic topic, Notification notification) {
+    public PushMessage(Notification notification) {
         this.message = Message.builder()
                 .putData("type", notification.getType().toString())
                 .putData("nickname", notification.getMate().getNicknameValue())
-                .setTopic(topic.getValue())
+                .setTopic(notification.getFcmTopicValue())
                 .build();
     }
 }

backend/src/main/java/com/ody/notification/dto/request/FcmSendRequest.java

@@ -1,8 +1,7 @@
 package com.ody.notification.dto.request;
 
-import com.ody.notification.domain.FcmTopic;
 import com.ody.notification.domain.Notification;
 
-public record FcmSendRequest(FcmTopic fcmTopic, Notification notification) {
+public record FcmSendRequest(Notification notification) {
 
 }

backend/src/main/java/com/ody/notification/repository/NotificationRepository.java

@@ -1,6 +1,8 @@
 package com.ody.notification.repository;
 
 import com.ody.notification.domain.Notification;
+import com.ody.notification.domain.NotificationStatus;
+import com.ody.notification.domain.NotificationType;
 import java.util.List;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Query;
@@ -16,4 +18,15 @@ public interface NotificationRepository extends JpaRepository<Notification, Long
             order by noti.sendAt asc
             """)
     List<Notification> findAllMeetingLogs(Long meetingId);
+
+    List<Notification> findAllByTypeAndStatus(NotificationType type, NotificationStatus status);
+
+    @Query("""
+            select noti
+            from Notification noti
+            join fetch Mate mate on noti.mate.id = mate.id and mate.meeting.id = :meetingId
+            join fetch Member member on mate.member.id = member.id
+            where noti.type = :type
+            """)
+    List<Notification> findAllMeetingIdAndType(Long meetingId, NotificationType type);
 }

backend/src/main/java/com/ody/notification/service/FcmPushSender.java

@@ -21,7 +21,7 @@ public class FcmPushSender {
     @Transactional
     public void sendPushNotification(FcmSendRequest fcmSendRequest) {
         Notification notification = fcmSendRequest.notification();
-        PushMessage pushMessage = new PushMessage(fcmSendRequest.fcmTopic(), notification);
+        PushMessage pushMessage = new PushMessage(notification);
         sendMessage(pushMessage.getMessage(), notification);
     }
 

backend/src/main/java/com/ody/notification/service/FcmSubscriber.java

@@ -19,7 +19,18 @@ public void subscribeTopic(FcmTopic fcmTopic, DeviceToken deviceToken) {
             log.info("주제 구독에 성공했습니다. -- TOKEN = {}, TOPIC = {}", deviceToken.getValue(), fcmTopic.getValue());
         } catch (Exception exception) {
             log.error("주제 구독에 실패했습니다. -- {}", exception.getMessage());
-            throw new OdyServerErrorException("모임 구독에 실패했습니다");
+            throw new OdyServerErrorException("약속방 알림 연결에 실패했습니다");
+        }
+    }
+
+    public void unSubscribeTopic(FcmTopic fcmTopic, DeviceToken deviceToken) {
+        try {
+            FirebaseMessaging.getInstance()
+                    .unsubscribeFromTopic(List.of(deviceToken.getValue()), fcmTopic.getValue());
+            log.info("주제 구독 취소에 성공 했습니다. -- TOKEN = {}, TOPIC = {}", deviceToken.getValue(), fcmTopic.getValue());
+        } catch (Exception exception) {
+            log.error("{} 주제 구독 취소에 실패했습니다. -- {}", fcmTopic.getValue(), exception.getMessage());
+            throw new OdyServerErrorException("약속방 알림 해제에 실패했습니다");
         }
     }
 }