[feature] React Native 알림 기능 구현 API

.github/workflows/pr-test.yml

@@ -36,6 +36,11 @@ jobs:
         run: | 
           cd ./backend/src/main/resources
           echo "${{ secrets.APPLICATION_PR_TEST }}" > ./application.properties
+
+      - name: make firebase.json
+        run: |
+          cd ./backend/src/main/resources
+          echo "${{ secrets.FIREBASE_PR_TEST }}" | base64 -d > ./firebase.json
 
       - name: create-json
         id: create-json

backend/.gitignore

@@ -39,3 +39,4 @@ out/
 
 application.properties
 moadong.json
+firebase.json

backend/build.gradle

@@ -32,6 +32,8 @@ dependencies {
 	implementation 'org.springframework.boot:spring-boot-starter-web'
 	implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
 	implementation 'org.springframework.boot:spring-boot-starter-validation'
+	implementation 'org.springframework.boot:spring-boot-starter-aop'
+	implementation 'org.springframework.retry:spring-retry'
 	implementation 'com.google.cloud:spring-cloud-gcp-storage:5.8.0'
 	implementation 'io.jsonwebtoken:jjwt-api:0.11.5'
 	implementation 'io.jsonwebtoken:jjwt-impl:0.11.5'
@@ -56,7 +58,7 @@ dependencies {
 	implementation 'net.coobird:thumbnailator:0.4.14'
 	implementation 'org.springframework:spring-test'
 
-
+	implementation 'com.google.firebase:firebase-admin:9.7.0'
 
 }
 

backend/src/main/java/moadong/MoadongApplication.java

@@ -4,11 +4,13 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
+import org.springframework.retry.annotation.EnableRetry;
 import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
 @RequiredArgsConstructor
 @EnableScheduling
+@EnableRetry
 public class MoadongApplication {
 
     public static void main(String[] args) {

backend/src/main/java/moadong/club/entity/Club.java

@@ -1,10 +1,18 @@
 package moadong.club.entity;
 
+import java.time.format.DateTimeFormatter;
 import java.util.List;
+import java.util.Locale;
 import java.util.Map;
+
+import com.google.firebase.messaging.FirebaseMessaging;
+import com.google.firebase.messaging.FirebaseMessagingException;
+import com.google.firebase.messaging.Message;
+import com.google.firebase.messaging.Notification;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Getter;
+import lombok.extern.slf4j.Slf4j;
 import moadong.club.enums.ClubRecruitmentStatus;
 import moadong.club.enums.ClubState;
 import moadong.club.payload.request.ClubInfoRequest;
@@ -17,6 +25,7 @@
 import org.springframework.data.mongodb.core.mapping.Document;
 import org.springframework.data.mongodb.core.mapping.Field;
 
+@Slf4j
 @Document("clubs")
 @AllArgsConstructor
 @Getter
@@ -119,6 +128,14 @@ public void updateRecruitmentStatus(ClubRecruitmentStatus clubRecruitmentStatus)
         this.clubRecruitmentInformation.updateRecruitmentStatus(clubRecruitmentStatus);
     }
 
+    public void sendPushNotification(Message message) {
+        try {
+            FirebaseMessaging.getInstance().send(message);
+        } catch (FirebaseMessagingException e) {
+            log.error("FirebaseSendNotificationError: {}", e.getMessage());
+        }
+    }
+
     @Override
     public boolean isNew() {
         return this.version == null;

backend/src/main/java/moadong/club/repository/ClubRepository.java

@@ -14,4 +14,6 @@ public interface ClubRepository extends MongoRepository<Club, String> {
 
     Optional<Club> findClubByUserId(String userId);
     List<Club> findAllByName(List<String> clubs);
+
+    Long countByIdIn(List<String> id);
 }

backend/src/main/java/moadong/club/service/RecruitmentStateChecker.java

@@ -1,8 +1,16 @@
 package moadong.club.service;
 
 import java.time.ZonedDateTime;
+import java.time.format.DateTimeFormatter;
 import java.util.List;
+import java.util.Locale;
+
+import com.google.firebase.messaging.FirebaseMessaging;
+import com.google.firebase.messaging.FirebaseMessagingException;
+import com.google.firebase.messaging.Message;
+import com.google.firebase.messaging.Notification;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import moadong.club.entity.Club;
 import moadong.club.entity.ClubRecruitmentInformation;
 import moadong.club.enums.ClubRecruitmentStatus;
@@ -12,14 +20,15 @@
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+@Slf4j
 @Component
 @RequiredArgsConstructor
 @ConditionalOnProperty(name = "scheduling.enabled", havingValue = "true", matchIfMissing = true)
 public class RecruitmentStateChecker {
 
     private final ClubRepository clubRepository;
 
-    @Scheduled(fixedRate = 60 * 60 * 1000) // 5분마다 실행
+    @Scheduled(fixedRate = 60 * 60 * 1000) // 1시간마다 실행
     public void performTask() {
         List<Club> clubs = clubRepository.findAll();
         for (Club club : clubs) {
@@ -30,6 +39,7 @@ public void performTask() {
                 continue;
             }
             RecruitmentStateCalculator.calculate(club, recruitmentStartDate, recruitmentEndDate);
+
             clubRepository.save(club);
         }
     }

backend/src/main/java/moadong/club/util/RecruitmentStateCalculator.java

@@ -2,36 +2,75 @@
 
 import java.time.ZoneId;
 import java.time.ZonedDateTime;
+import java.time.format.DateTimeFormatter;
 import java.time.temporal.ChronoUnit;
+import java.util.Locale;
+
+import com.google.firebase.messaging.Message;
+import com.google.firebase.messaging.Notification;
 import moadong.club.entity.Club;
+import moadong.club.entity.ClubRecruitmentInformation;
 import moadong.club.enums.ClubRecruitmentStatus;
 
 public class RecruitmentStateCalculator {
     public static final int ALWAYS_RECRUIT_YEAR = 2999;
 
     public static void calculate(Club club, ZonedDateTime recruitmentStartDate, ZonedDateTime recruitmentEndDate) {
+        ClubRecruitmentStatus newStatus = calculateRecruitmentStatus(recruitmentStartDate, recruitmentEndDate);
+        club.updateRecruitmentStatus(newStatus);
+
+        Message message = buildRecruitmentMessage(club, newStatus);
+        club.sendPushNotification(message);
+    }
+
+    public static ClubRecruitmentStatus calculateRecruitmentStatus(ZonedDateTime recruitmentStartDate, ZonedDateTime recruitmentEndDate) {
         if (recruitmentStartDate == null || recruitmentEndDate == null) {
-            club.updateRecruitmentStatus(ClubRecruitmentStatus.CLOSED);
-            return;
+            return ClubRecruitmentStatus.CLOSED;
         }
+
         if (recruitmentEndDate.getYear() == ALWAYS_RECRUIT_YEAR) {
-            club.updateRecruitmentStatus(ClubRecruitmentStatus.ALWAYS);
-            return;
+            return ClubRecruitmentStatus.ALWAYS;
         }
-        ZonedDateTime now = ZonedDateTime.now(ZoneId.of("Asia/Seoul"));
 
+        ZonedDateTime now = ZonedDateTime.now(ZoneId.of("Asia/Seoul"));
 
         if (now.isBefore(recruitmentStartDate)) {
-            long between = ChronoUnit.DAYS.between(recruitmentStartDate, now);
-            if (between <= 14) {
-                club.updateRecruitmentStatus(ClubRecruitmentStatus.UPCOMING);
-            } else {
-                club.updateRecruitmentStatus(ClubRecruitmentStatus.CLOSED);
-            }
-        } else if (now.isAfter(recruitmentStartDate) && now.isBefore(recruitmentEndDate)) {
-            club.updateRecruitmentStatus(ClubRecruitmentStatus.OPEN);
-        } else if (now.isAfter(recruitmentEndDate)) {
-            club.updateRecruitmentStatus(ClubRecruitmentStatus.CLOSED);
+            long daysUntilStart = ChronoUnit.DAYS.between(now, recruitmentStartDate);
+            return (daysUntilStart <= 14)
+                    ? ClubRecruitmentStatus.UPCOMING
+                    : ClubRecruitmentStatus.CLOSED;
         }
+
+        if (now.isAfter(recruitmentStartDate) && now.isBefore(recruitmentEndDate)) {
+            return ClubRecruitmentStatus.OPEN;
+        }
+
+        return ClubRecruitmentStatus.CLOSED;
+    }
+
+    public static Message buildRecruitmentMessage(Club club, ClubRecruitmentStatus status) {
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("M월 d일 a h시 m분", Locale.KOREAN);
+        ClubRecruitmentInformation info = club.getClubRecruitmentInformation();
+
+        String bodyMessage = switch (status) {
+            case ALWAYS -> "상시 모집 중입니다. 언제든지 지원해주세요!";
+            case OPEN -> {
+                String formattedEndTime = info.getRecruitmentEnd().format(formatter);
+                yield formattedEndTime + "까지 모집 중이니 서둘러 지원하세요!";
+            }
+            case UPCOMING -> {
+                String formattedStartTime = info.getRecruitmentStart().format(formatter);
+                yield formattedStartTime + "부터 모집이 시작될 예정이에요. 조금만 기다려주세요!";
+            }
+            case CLOSED -> "모집이 마감되었습니다. 다음 모집을 기대해주세요.";
+        };
+
+        return Message.builder()
+                .setNotification(Notification.builder()
+                        .setTitle(club.getName())
+                        .setBody(bodyMessage)
+                        .build())
+                .setTopic(club.getId())
+                .build();
     }
 }

backend/src/main/java/moadong/fcm/controller/FcmController.java

@@ -0,0 +1,42 @@
+package moadong.fcm.controller;
+
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.validation.constraints.NotNull;
+import lombok.AllArgsConstructor;
+import moadong.fcm.payload.request.ClubSubscribeRequest;
+import moadong.fcm.payload.request.FcmSaveRequest;
+import moadong.fcm.service.FcmService;
+import moadong.global.payload.Response;
+import org.springframework.http.ResponseEntity;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequestMapping("/api/fcm")
+@AllArgsConstructor
+@Tag(name = "FCM", description = "FCM 토큰 관리 및 알림 전송 기능 API")
+public class FcmController {
+    private final FcmService fcmService;
+
+    @Operation(summary = "FCM 토큰 저장", description = "FCM 토큰을 서버에 저장합니다.")
+    @PostMapping
+    public ResponseEntity<?> saveFcmToken(@RequestBody @Validated FcmSaveRequest request) {
+        fcmService.saveFcmToken(request.fcmToken());
+        return Response.ok("success save fcm token");
+    }
+
+    @Operation(summary = "동아리 모집정보 알림 구독", description = "특정 동아리들의 모집 정보가 변경되면저거 하면  알림을 받도록 구독합니다.")
+    @PutMapping("/subscribe")
+    public ResponseEntity<?> subscribeRecruitment(@RequestBody @Validated ClubSubscribeRequest request) {
+        fcmService.subscribeClubs(request.fcmToken(), request.clubIds());
+        return Response.ok("success subscribe club");
+    }
+
+    @Operation(summary = "구독한 동아리 목록 조회", description = "FCM 토큰을 기준으로 구독중인 동아리 목록을 조회합니다.")
+    @GetMapping("/subscribe")
+    public ResponseEntity<?> getSubscribedClubs(@RequestParam("fcmToken")
+                                                @Validated @NotNull String fcmToken) {
+        return Response.ok(fcmService.getSubscribeClubs(fcmToken));
+    }
+}

backend/src/main/java/moadong/fcm/entity/FcmToken.java

@@ -0,0 +1,40 @@
+package moadong.fcm.entity;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+
+@Document("fcm_tokens")
+@AllArgsConstructor
+@NoArgsConstructor
+@Getter
+@Builder
+public class FcmToken {
+
+    @Id
+    private String id;
+
+    private String token;
+
+    @Builder.Default
+    private List<String> clubIds = new ArrayList<>();
+
+    @Builder.Default
+    private LocalDateTime timestamp = LocalDateTime.now();
+
+    public void updateTimestamp() {
+        this.timestamp = LocalDateTime.now();
+    }
+
+    public void updateClubIds(List<String> clubIds) {
+        this.clubIds.clear();
+        this.clubIds.addAll(clubIds);
+    }
+}

backend/src/main/java/moadong/fcm/payload/request/ClubSubscribeRequest.java

@@ -0,0 +1,13 @@
+package moadong.fcm.payload.request;
+
+import jakarta.validation.constraints.NotNull;
+
+import java.util.ArrayList;
+
+public record ClubSubscribeRequest(
+        @NotNull
+        String fcmToken,
+        @NotNull
+        ArrayList<String> clubIds
+) {
+}

backend/src/main/java/moadong/fcm/payload/request/FcmSaveRequest.java

@@ -0,0 +1,9 @@
+package moadong.fcm.payload.request;
+
+import jakarta.validation.constraints.NotNull;
+
+public record FcmSaveRequest(
+        @NotNull
+        String fcmToken
+) {
+}

backend/src/main/java/moadong/fcm/payload/response/ClubSubscribeListResponse.java

@@ -0,0 +1,8 @@
+package moadong.fcm.payload.response;
+
+import java.util.List;
+
+public record ClubSubscribeListResponse(
+        List<String> clubIds
+) {
+}

backend/src/main/java/moadong/fcm/repository/FcmTokenRepository.java

@@ -0,0 +1,10 @@
+package moadong.fcm.repository;
+
+import moadong.fcm.entity.FcmToken;
+import org.springframework.data.mongodb.repository.MongoRepository;
+
+import java.util.Optional;
+
+public interface FcmTokenRepository extends MongoRepository<FcmToken, String> {
+    Optional<FcmToken> findFcmTokenByToken(String fcmToken);
+}