feat: 코스 일정 푸시 알림 기능 구현

.env.example

@@ -7,3 +7,9 @@ NAVER_CLIENT_SECRET=
 AWS_S3_BUCKET=
 AWS_REGION=
 TOUR_SERVICE_KEY=
+FIREBASE_ENABLED=false
+FIREBASE_PROJECT_ID=
+GOOGLE_APPLICATION_CREDENTIALS=
+NOTIFICATION_ZONE=Asia/Seoul
+COURSE_REMINDER_CRON=0 0 9 * * *
+NOTIFICATION_DISPATCH_DELAY_MS=60000

README.md

@@ -15,6 +15,17 @@ Elastic Beanstalk EC2 Instance Profile을 포함한 AWS SDK 기본 자격 증명
 반환됩니다. 버킷 정책상 반환된 객체 URL을 클라이언트가 읽을 수 있도록 별도 접근 정책도
 배포 전에 준비해야 합니다.
 
+## Firebase Cloud Messaging 설정
+
+푸시 알림을 실제 발송하려면 `FIREBASE_ENABLED=true`와 `FIREBASE_PROJECT_ID`를 설정하고,
+Firebase 서비스 계정 파일 경로를 `GOOGLE_APPLICATION_CREDENTIALS`로 제공해야 합니다.
+서비스 계정 JSON은 저장소에 커밋하지 않습니다. 설정하지 않은 환경에서도 서버와 테스트는
+시작되지만 푸시 발송은 실패 상태로 기록되고 재시도됩니다.
+
+코스 D-1/D-0 알림은 기본적으로 `Asia/Seoul` 기준 매일 오전 9시에 생성됩니다.
+`NOTIFICATION_ZONE`, `COURSE_REMINDER_CRON`, `NOTIFICATION_DISPATCH_DELAY_MS` 환경변수로
+시간대, 생성 시각, 실패 알림 재시도 주기를 변경할 수 있습니다.
+
 ## 정책 문서
 
 `src/main/resources/policies`의 두 문서는 현재 출시 전 자리표시자입니다. 운영 배포 전에

build.gradle

@@ -56,6 +56,9 @@ dependencies {
 	// AWS S3
 	implementation platform('software.amazon.awssdk:bom:2.41.24')
 	implementation 'software.amazon.awssdk:s3'
+
+	// Firebase Cloud Messaging
+	implementation 'com.google.firebase:firebase-admin:9.10.0'
 }
 
 tasks.named('test') {

src/main/java/com/daytodo/domain/auth/service/AuthService.java

@@ -14,9 +14,11 @@
 import com.daytodo.domain.auth.repository.RefreshTokenRepository;
 import com.daytodo.domain.auth.repository.SocialAccountRepository;
 import com.daytodo.domain.user.entity.User;
+import com.daytodo.domain.user.entity.UserNotificationSetting;
 import com.daytodo.domain.user.enums.LoginType;
 import com.daytodo.domain.user.enums.UserStatus;
 import com.daytodo.domain.user.repository.UserRepository;
+import com.daytodo.domain.user.repository.UserNotificationSettingRepository;
 import com.daytodo.global.apiPayload.exception.ProjectException;
 import com.daytodo.global.security.JwtProperties;
 import com.daytodo.global.security.JwtTokenProvider;
@@ -46,6 +48,7 @@ public class AuthService {
     private static final long PASSWORD_RESET_EXPIRY_MINUTES = 10;
 
     private final UserRepository userRepository;
+    private final UserNotificationSettingRepository userNotificationSettingRepository;
     private final RefreshTokenRepository refreshTokenRepository;
     private final SocialAccountRepository socialAccountRepository;
     private final EmailVerificationTokenRepository emailVerificationTokenRepository;
@@ -88,6 +91,7 @@ public AuthResponse.SignUp signUp(AuthRequest.SignUp request) {
 
         // 이메일 인증 전까지는 INACTIVE 상태로 두고, 인증 완료 시 ACTIVE로 전환한다.
         user.changeStatus(UserStatus.INACTIVE);
+        userNotificationSettingRepository.save(new UserNotificationSetting(user));
         issueEmailVerificationToken(user);
         return new AuthResponse.SignUp(user.getId(), user.getEmail(), user.getNickname(), user.getCreatedAt());
     }
@@ -298,6 +302,7 @@ private User createUserFromNaverProfile(NaverApiClient.NaverProfileResponse prof
                 null,
                 LoginType.NAVER
         ));
+        userNotificationSettingRepository.save(new UserNotificationSetting(user));
         socialAccountRepository.save(new SocialAccount(user, SocialProvider.NAVER, profile.response().id()));
         return user;
     }
@@ -334,4 +339,4 @@ private String generateDefaultNickname() {
         long count = userRepository.count() + 1;
         return String.format("투두%02d", count);
     }
-}
+}

src/main/java/com/daytodo/domain/course/repository/CourseMemberRepository.java

@@ -2,13 +2,16 @@
 
 import com.daytodo.domain.course.entity.CourseMember;
 import com.daytodo.domain.course.enums.MemberStatus;
+import com.daytodo.domain.course.enums.CourseStatus;
+import com.daytodo.domain.user.enums.UserStatus;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.query.Param;
 
 import java.util.Collection;
 import java.util.List;
 import java.util.Optional;
+import java.time.LocalDate;
 
 
 public interface CourseMemberRepository extends JpaRepository<CourseMember, Long> {
@@ -18,6 +21,23 @@ public interface CourseMemberRepository extends JpaRepository<CourseMember, Long
 
     List<CourseMember> findByCourseCourseIdAndMemberStatus(Long courseId, MemberStatus memberStatus);
 
+    @Query("""
+            select cm from CourseMember cm
+            join fetch cm.course course
+            join fetch cm.user user
+            where course.courseDate = :courseDate
+              and course.courseStatus not in :excludedStatuses
+              and cm.memberStatus = :memberStatus
+              and user.userStatus = :userStatus
+            order by course.courseId asc, user.id asc
+            """)
+    List<CourseMember> findReminderCandidates(
+            @Param("courseDate") LocalDate courseDate,
+            @Param("excludedStatuses") Collection<CourseStatus> excludedStatuses,
+            @Param("memberStatus") MemberStatus memberStatus,
+            @Param("userStatus") UserStatus userStatus
+    );
+
     Optional<CourseMember> findByCourseCourseIdAndUserIdAndMemberStatus(Long courseId, Long targetUserId, MemberStatus memberStatus);
 
     /*

src/main/java/com/daytodo/domain/user/controller/UserController.java

@@ -3,6 +3,7 @@
 import com.daytodo.domain.user.dto.UserRequest;
 import com.daytodo.domain.user.dto.UserResponse;
 import com.daytodo.domain.user.service.FeedbackService;
+import com.daytodo.domain.user.service.FcmTokenService;
 import com.daytodo.domain.user.service.PolicyService;
 import com.daytodo.domain.user.service.ProfileService;
 import com.daytodo.domain.user.service.UserNotificationService;
@@ -34,6 +35,7 @@ public class UserController {
     private final UserNotificationService notificationService;
     private final FeedbackService feedbackService;
     private final PolicyService policyService;
+    private final FcmTokenService fcmTokenService;
 
     @Operation(summary = "프로필 조회")
     @GetMapping("/profile")
@@ -96,6 +98,26 @@ public UserResponse.NotificationSettings updateNotificationSettings(
         return notificationService.updateSettings(userId, request);
     }
 
+    @Operation(summary = "FCM 토큰 등록 또는 갱신")
+    @PostMapping("/fcm-token")
+    public ResponseEntity<Void> registerFcmToken(
+            @AuthenticationPrincipal Long userId,
+            @Valid @RequestBody UserRequest.RegisterFcmToken request
+    ) {
+        fcmTokenService.register(userId, request);
+        return ResponseEntity.noContent().build();
+    }
+
+    @Operation(summary = "FCM 토큰 삭제")
+    @DeleteMapping("/fcm-token")
+    public ResponseEntity<Void> deleteFcmToken(
+            @AuthenticationPrincipal Long userId,
+            @Valid @RequestBody UserRequest.DeleteFcmToken request
+    ) {
+        fcmTokenService.delete(userId, request);
+        return ResponseEntity.noContent().build();
+    }
+
     @Operation(summary = "의견 보내기")
     @PostMapping("/feedback")
     public ResponseEntity<Void> submitFeedback(

src/main/java/com/daytodo/domain/user/dto/UserRequest.java

@@ -1,7 +1,11 @@
 package com.daytodo.domain.user.dto;
 
 import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotBlank;
 import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Size;
+
+import com.daytodo.domain.user.enums.DevicePlatform;
 
 import java.util.List;
 
@@ -17,11 +21,23 @@ public record ReplaceInterestRegions(
 
     public record UpdateNotificationSettings(
             @NotNull(message = "앱 푸시 알림 설정은 필수입니다.")
-            Boolean pushEnabled,
-            @NotNull(message = "D-1 코스 알림 설정은 필수입니다.")
-            Boolean courseD1Enabled,
-            @NotNull(message = "D-0 코스 알림 설정은 필수입니다.")
-            Boolean courseD0Enabled
+            Boolean pushEnabled
+    ) {
+    }
+
+    public record RegisterFcmToken(
+            @NotBlank(message = "FCM 토큰은 필수입니다.")
+            @Size(max = 512, message = "FCM 토큰은 512자 이하여야 합니다.")
+            String token,
+            @NotNull(message = "기기 플랫폼은 필수입니다.")
+            DevicePlatform platform
+    ) {
+    }
+
+    public record DeleteFcmToken(
+            @NotBlank(message = "FCM 토큰은 필수입니다.")
+            @Size(max = 512, message = "FCM 토큰은 512자 이하여야 합니다.")
+            String token
     ) {
     }
 

src/main/java/com/daytodo/domain/user/dto/UserResponse.java

@@ -19,9 +19,7 @@ public record InterestRegions(List<InterestRegion> regions) {
     }
 
     public record NotificationSettings(
-            boolean pushEnabled,
-            boolean courseD1Enabled,
-            boolean courseD0Enabled
+            boolean pushEnabled
     ) {
     }
 

src/main/java/com/daytodo/domain/user/entity/FcmToken.java

@@ -0,0 +1,47 @@
+package com.daytodo.domain.user.entity;
+
+import com.daytodo.domain.common.BaseEntity;
+import com.daytodo.domain.user.enums.DevicePlatform;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
+import jakarta.persistence.FetchType;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.JoinColumn;
+import jakarta.persistence.ManyToOne;
+import jakarta.persistence.Table;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Entity
+@Table(name = "fcm_token")
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class FcmToken extends BaseEntity {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "fcm_token_id")
+    private Long id;
+
+    @ManyToOne(fetch = FetchType.LAZY, optional = false)
+    @JoinColumn(name = "user_id", nullable = false)
+    private User user;
+
+    @Column(name = "token", nullable = false, unique = true, length = 512)
+    private String token;
+
+    @Enumerated(EnumType.STRING)
+    @Column(name = "platform", nullable = false, length = 20)
+    private DevicePlatform platform;
+
+    public FcmToken(User user, String token, DevicePlatform platform) {
+        this.user = user;
+        this.token = token;
+        this.platform = platform;
+    }
+}

src/main/java/com/daytodo/domain/user/entity/Notification.java

@@ -1,5 +1,6 @@
 package com.daytodo.domain.user.entity;
 import com.daytodo.domain.user.enums.NotificationType;
+import com.daytodo.domain.user.enums.NotificationDeliveryStatus;
 import jakarta.persistence.Column;
 import jakarta.persistence.Entity;
 import jakarta.persistence.EntityListeners;
@@ -12,6 +13,7 @@
 import jakarta.persistence.JoinColumn;
 import jakarta.persistence.ManyToOne;
 import jakarta.persistence.Table;
+import jakarta.persistence.UniqueConstraint;
 import java.time.LocalDateTime;
 import lombok.AccessLevel;
 import lombok.Getter;
@@ -21,7 +23,13 @@
 
 @Getter
 @Entity
-@Table(name = "notification")
+@Table(
+        name = "notification",
+        uniqueConstraints = @UniqueConstraint(
+                name = "uk_notification_user_course_type",
+                columnNames = {"user_id", "course_id", "notification_type"}
+        )
+)
 @EntityListeners(AuditingEntityListener.class)
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
 public class Notification {
@@ -50,6 +58,22 @@ public class Notification {
     @Column(name = "is_read", nullable = false)
     private boolean read;
 
+    @Enumerated(EnumType.STRING)
+    @Column(name = "delivery_status", length = 20, nullable = false)
+    private NotificationDeliveryStatus deliveryStatus;
+
+    @Column(name = "attempt_count", nullable = false)
+    private int attemptCount;
+
+    @Column(name = "sent_at")
+    private LocalDateTime sentAt;
+
+    @Column(name = "next_retry_at")
+    private LocalDateTime nextRetryAt;
+
+    @Column(name = "last_error", length = 1000)
+    private String lastError;
+
     @CreatedDate
     @Column(name = "created_at", nullable = false, updatable = false)
     private LocalDateTime createdAt;
@@ -67,9 +91,26 @@ public Notification(
         this.title = title;
         this.body = body;
         this.read = false;
+        this.deliveryStatus = NotificationDeliveryStatus.PENDING;
+        this.attemptCount = 0;
     }
 
     public void markAsRead() {
         this.read = true;
     }
+
+    public void markSent(LocalDateTime sentAt) {
+        this.deliveryStatus = NotificationDeliveryStatus.SENT;
+        this.attemptCount++;
+        this.sentAt = sentAt;
+        this.nextRetryAt = null;
+        this.lastError = null;
+    }
+
+    public void markFailed(String error, LocalDateTime nextRetryAt) {
+        this.deliveryStatus = NotificationDeliveryStatus.FAILED;
+        this.attemptCount++;
+        this.nextRetryAt = nextRetryAt;
+        this.lastError = error == null ? null : error.substring(0, Math.min(error.length(), 1000));
+    }
 }

src/main/java/com/daytodo/domain/user/entity/UserNotificationSetting.java

@@ -53,28 +53,23 @@ public class UserNotificationSetting {
             name = "course_d1_enabled",
             nullable = false
     )
-    private boolean courseD1Enabled;
+    private boolean legacyCourseD1Enabled;
 
     @Column(
             name = "course_d0_enabled",
             nullable = false
     )
-    private boolean courseD0Enabled;
+    private boolean legacyCourseD0Enabled;
 
     public UserNotificationSetting(User user) {
         this.user = user;
         this.pushEnabled = true;
-        this.courseD1Enabled = true;
-        this.courseD0Enabled = true;
+        // 기존 DB의 NOT NULL 컬럼과 호환하기 위한 값이다. D-1/D-0는 개별 설정하지 않는다.
+        this.legacyCourseD1Enabled = true;
+        this.legacyCourseD0Enabled = true;
     }
 
-    public void updateSettings(
-            boolean pushEnabled,
-            boolean courseD1Enabled,
-            boolean courseD0Enabled
-    ) {
+    public void updatePushEnabled(boolean pushEnabled) {
         this.pushEnabled = pushEnabled;
-        this.courseD1Enabled = courseD1Enabled;
-        this.courseD0Enabled = courseD0Enabled;
     }
 }

src/main/java/com/daytodo/domain/user/enums/DevicePlatform.java

@@ -0,0 +1,6 @@
+package com.daytodo.domain.user.enums;
+
+public enum DevicePlatform {
+    ANDROID,
+    IOS
+}

src/main/java/com/daytodo/domain/user/enums/NotificationDeliveryStatus.java

@@ -0,0 +1,7 @@
+package com.daytodo.domain.user.enums;
+
+public enum NotificationDeliveryStatus {
+    PENDING,
+    SENT,
+    FAILED
+}