[#57] ✨ Feature: add alarm ringing notifications

- add route to pre-alarm push data
- send periodic alarm ringing push notifications with route and alarm id
- query ringing alarms and handle invalid tokens
- cover repository with ringing notification target tests

- 해결: #57

Author: strongmhk

src/main/java/akuma/whiplash/domains/alarm/application/dto/etc/RingingPushInfo.java

@@ -0,0 +1,10 @@
+package akuma.whiplash.domains.alarm.application.dto.etc;
+
+import lombok.Builder;
+
+@Builder
+public record RingingPushInfo(
+    Long alarmId,
+    Long memberId
+) {
+}

src/main/java/akuma/whiplash/domains/alarm/application/dto/etc/RingingPushTargetDto.java

@@ -0,0 +1,11 @@
+package akuma.whiplash.domains.alarm.application.dto.etc;
+
+import lombok.Builder;
+
+@Builder
+public record RingingPushTargetDto(
+    String token,
+    Long alarmId,
+    Long memberId
+) {
+}

src/main/java/akuma/whiplash/domains/alarm/application/scheduler/AlarmRingingNotificationScheduler.java

@@ -0,0 +1,49 @@
+package akuma.whiplash.domains.alarm.application.scheduler;
+
+import akuma.whiplash.domains.alarm.application.dto.etc.RingingPushInfo;
+import akuma.whiplash.domains.alarm.application.dto.etc.RingingPushTargetDto;
+import akuma.whiplash.domains.alarm.domain.service.AlarmQueryService;
+import akuma.whiplash.infrastructure.firebase.FcmService;
+import akuma.whiplash.infrastructure.redis.RedisService;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class AlarmRingingNotificationScheduler {
+
+    private final AlarmQueryService alarmQueryService;
+    private final RedisService redisService;
+    private final FcmService fcmService;
+
+    // @Scheduled(fixedRate = 10000) // 10초 간격
+    public void sendRingingAlarmNotifications() {
+        log.info("[AlarmRingingNotificationScheduler.sendRingingAlarmNotifications] 알람 울림 푸시 알림 전송 스케줄러 시작");
+        try {
+            List<RingingPushInfo> infos = alarmQueryService.getRingingNotificationTargets();
+            if (infos.isEmpty()) {
+                return;
+            }
+
+            List<RingingPushTargetDto> targets = infos.stream()
+                .flatMap(info -> redisService.getFcmTokens(info.memberId()).stream()
+                    .map(token -> RingingPushTargetDto.builder()
+                        .token(token)
+                        .alarmId(info.alarmId())
+                        .memberId(info.memberId())
+                        .build()))
+                .toList();
+
+            if (targets.isEmpty()) {
+                return;
+            }
+
+            fcmService.sendRingingNotifications(targets);
+        } finally {
+            log.info("[AlarmRingingNotificationScheduler.sendRingingAlarmNotifications] 알람 울림 푸시 알림 전송 스케줄러 종료");
+        }
+    }
+}

src/main/java/akuma/whiplash/domains/alarm/domain/service/AlarmQueryService.java

@@ -1,6 +1,7 @@
 package akuma.whiplash.domains.alarm.domain.service;
 
 import akuma.whiplash.domains.alarm.application.dto.etc.OccurrencePushInfo;
+import akuma.whiplash.domains.alarm.application.dto.etc.RingingPushInfo;
 import akuma.whiplash.domains.alarm.application.dto.response.AlarmInfoPreviewResponse;
 import akuma.whiplash.domains.alarm.application.dto.response.AlarmRemainingOffCountResponse;
 import java.time.LocalDateTime;
@@ -10,4 +11,5 @@ public interface AlarmQueryService {
     List<AlarmInfoPreviewResponse> getAlarms(Long memberId);
     List<OccurrencePushInfo> getPreNotificationTargets(LocalDateTime startInclusive, LocalDateTime endInclusive);
     AlarmRemainingOffCountResponse getWeeklyRemainingOffCount(Long memberId);
+    List<RingingPushInfo> getRingingNotificationTargets();
 }

src/main/java/akuma/whiplash/domains/alarm/domain/service/AlarmQueryServiceImpl.java

@@ -1,6 +1,7 @@
 package akuma.whiplash.domains.alarm.domain.service;
 
 import akuma.whiplash.domains.alarm.application.dto.etc.OccurrencePushInfo;
+import akuma.whiplash.domains.alarm.application.dto.etc.RingingPushInfo;
 import akuma.whiplash.domains.alarm.application.dto.response.AlarmInfoPreviewResponse;
 import akuma.whiplash.domains.alarm.application.dto.response.AlarmRemainingOffCountResponse;
 import akuma.whiplash.domains.alarm.domain.constant.DeactivateType;
@@ -88,6 +89,11 @@ public List<OccurrencePushInfo> getPreNotificationTargets(LocalDateTime startInc
             ));
     }
 
+    @Override
+    public List<RingingPushInfo> getRingingNotificationTargets() {
+        return alarmOccurrenceRepository.findRingingNotificationTargets(DeactivateType.NONE);
+    }
+
     @Override
     public AlarmRemainingOffCountResponse getWeeklyRemainingOffCount(Long memberId) {
         memberRepository

src/main/java/akuma/whiplash/domains/alarm/persistence/repository/AlarmOccurrenceRepository.java

@@ -1,6 +1,7 @@
 package akuma.whiplash.domains.alarm.persistence.repository;
 
 import akuma.whiplash.domains.alarm.application.dto.etc.OccurrencePushInfo;
+import akuma.whiplash.domains.alarm.application.dto.etc.RingingPushInfo;
 import akuma.whiplash.domains.alarm.domain.constant.DeactivateType;
 import akuma.whiplash.domains.alarm.persistence.entity.AlarmOccurrenceEntity;
 import java.time.LocalDate;
@@ -122,4 +123,14 @@ List<OccurrencePushInfo> findPreNotificationTargetsUntilTime(
         WHERE o.id IN :ids AND o.reminderSent = false
     """)
     void markReminderSentIn(@Param("ids") Set<Long> ids);
+
+    @Query("""
+    SELECT new akuma.whiplash.domains.alarm.application.dto.etc.RingingPushInfo(a.id, m.id)
+    FROM AlarmOccurrenceEntity o
+    JOIN o.alarm a
+    JOIN a.member m
+    WHERE o.alarmRinging = true
+      AND o.deactivateType = :status
+    """)
+    List<RingingPushInfo> findRingingNotificationTargets(@Param("status") DeactivateType status);
 }

src/main/java/akuma/whiplash/infrastructure/firebase/FcmService.java

@@ -1,6 +1,7 @@
 package akuma.whiplash.infrastructure.firebase;
 
 import akuma.whiplash.domains.alarm.application.dto.etc.PushTargetDto;
+import akuma.whiplash.domains.alarm.application.dto.etc.RingingPushTargetDto;
 import akuma.whiplash.infrastructure.firebase.dto.FcmSendResult;
 import akuma.whiplash.infrastructure.redis.RedisService;
 import com.google.firebase.messaging.AndroidConfig;
@@ -33,6 +34,7 @@ public class FcmService {
 
     private static final int FCM_MULTICAST_LIMIT = 500;
     private static final String DEFAULT_TITLE = "눈 떠";
+    private static final String RINGING_BODY = "알람이 울리고 있어요! 앱으로 접속해서 알람을 꺼주세요!";
 
     private final RedisService redisService;
 
@@ -71,11 +73,12 @@ public FcmSendResult sendBulkNotification(List<PushTargetDto> targets) {
 
         for (Map.Entry<String, List<PushTargetDto>> entry : groupedByBody.entrySet()) {
             String body = entry.getKey();
-            List<PushTargetDto> group = dedupByToken(entry.getValue());
+            List<PushTargetDto> group = dedupByToken(entry.getValue(), PushTargetDto::token);
 
             Map<String, String> data = Map.of(
                 "title", DEFAULT_TITLE,
-                "body", body
+                "body", body,
+                "route", "MAIN_VIEW"
             );
 
             for (List<PushTargetDto> batch : partition(group, FCM_MULTICAST_LIMIT)) {
@@ -181,10 +184,10 @@ private boolean isTokenInvalid(FirebaseMessagingException e) {
     }
 
     // 같은 FCM 토큰 중복 제거
-    private List<PushTargetDto> dedupByToken(List<PushTargetDto> src) {
-        Map<String, PushTargetDto> map = new LinkedHashMap<>();
-        for (PushTargetDto d : src) {
-            map.putIfAbsent(d.token(), d);
+    private <T> List<T> dedupByToken(List<T> src, java.util.function.Function<T, String> tokenFn) {
+        Map<String, T> map = new LinkedHashMap<>();
+        for (T d : src) {
+            map.putIfAbsent(tokenFn.apply(d), d);
         }
         return new ArrayList<>(map.values());
     }
@@ -196,4 +199,61 @@ private <T> List<List<T>> partition(List<T> list, int size) {
         }
         return result;
     }
+
+    public void sendRingingNotifications(List<RingingPushTargetDto> targets) {
+        if (targets == null || targets.isEmpty()) {
+            return;
+        }
+
+        Map<Long, List<RingingPushTargetDto>> groupedByAlarm = targets.stream()
+            .collect(Collectors.groupingBy(RingingPushTargetDto::alarmId));
+
+        for (Map.Entry<Long, List<RingingPushTargetDto>> entry : groupedByAlarm.entrySet()) {
+            Long alarmId = entry.getKey();
+            List<RingingPushTargetDto> group = dedupByToken(entry.getValue(), RingingPushTargetDto::token);
+
+            Map<String, String> data = Map.of(
+                "title", DEFAULT_TITLE,
+                "body", RINGING_BODY,
+                "route", "ALARM_LINGING_VIEW",
+                "alarm_id", alarmId.toString()
+            );
+
+            for (List<RingingPushTargetDto> batch : partition(group, FCM_MULTICAST_LIMIT)) {
+                MulticastMessage message = MulticastMessage.builder()
+                    .addAllTokens(batch.stream().map(RingingPushTargetDto::token).toList())
+                    .putAllData(data)
+                    .setAndroidConfig(buildAndroidConfig(Duration.ofSeconds(30), Priority.HIGH))
+                    .setApnsConfig(buildApnsConfigAlert(DEFAULT_TITLE, RINGING_BODY, Duration.ofSeconds(30)))
+                    .build();
+
+                try {
+                    BatchResponse response = FirebaseMessaging.getInstance().sendEachForMulticast(message);
+                    handleRingingSendResult(response.getResponses(), batch);
+                } catch (FirebaseMessagingException e) {
+                    log.error("FCM 전송 실패(알람 울림)", e);
+                }
+            }
+        }
+    }
+
+    private void handleRingingSendResult(
+        List<SendResponse> responses,
+        List<RingingPushTargetDto> batch
+    ) {
+        for (int i = 0; i < responses.size(); i++) {
+            SendResponse res = responses.get(i);
+            RingingPushTargetDto dto = batch.get(i);
+
+            if (!res.isSuccessful()) {
+                Exception ex = res.getException();
+                FirebaseMessagingException fme = (ex instanceof FirebaseMessagingException) ? (FirebaseMessagingException) ex : null;
+                if (fme != null && isTokenInvalid(fme)) {
+                    redisService.removeInvalidToken(dto.memberId(), dto.token());
+                } else {
+                    log.warn("FCM 실패(알람 울림): token={}, ex={}", dto.token(), ex != null ? ex.getClass().getSimpleName() : "null");
+                }
+            }
+        }
+    }
 }

src/test/java/akuma/whiplash/domains/alarm/persistence/repository/AlarmOccurrenceRepositoryTest.java

@@ -0,0 +1,66 @@
+package akuma.whiplash.domains.alarm.persistence.repository;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import akuma.whiplash.common.config.PersistenceTest;
+import akuma.whiplash.common.fixture.AlarmFixture;
+import akuma.whiplash.common.fixture.MemberFixture;
+import akuma.whiplash.domains.alarm.application.dto.etc.RingingPushInfo;
+import akuma.whiplash.domains.alarm.domain.constant.DeactivateType;
+import akuma.whiplash.domains.alarm.persistence.entity.AlarmEntity;
+import akuma.whiplash.domains.alarm.persistence.entity.AlarmOccurrenceEntity;
+import akuma.whiplash.domains.alarm.persistence.repository.AlarmRepository;
+import akuma.whiplash.domains.member.persistence.entity.MemberEntity;
+import akuma.whiplash.domains.member.persistence.repository.MemberRepository;
+import java.time.LocalDate;
+import java.util.List;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+
+@PersistenceTest
+class AlarmOccurrenceRepositoryTest {
+
+    @Autowired
+    private AlarmOccurrenceRepository alarmOccurrenceRepository;
+    @Autowired
+    private AlarmRepository alarmRepository;
+    @Autowired
+    private MemberRepository memberRepository;
+
+    @DisplayName("알람이 울리고 있을 때 알람 울림 푸시 알림 대상을 조회하면 회원과 알람 정보가 반환된다")
+    @Test
+    void findRingingNotificationTargets_returnsInfo_whenAlarmRinging() {
+        // given
+        MemberEntity member = memberRepository.save(MemberFixture.MEMBER_7.toEntity());
+        AlarmEntity alarm = alarmRepository.save(AlarmFixture.ALARM_07.toEntity(member));
+        alarmOccurrenceRepository.save(AlarmOccurrenceEntity.builder()
+            .alarm(alarm)
+            .date(LocalDate.now())
+            .time(alarm.getTime())
+            .deactivateType(DeactivateType.NONE)
+            .alarmRinging(true)
+            .ringingCount(1)
+            .reminderSent(false)
+            .build());
+
+        // when
+        List<RingingPushInfo> infos = alarmOccurrenceRepository.findRingingNotificationTargets(DeactivateType.NONE);
+
+        // then
+        assertThat(infos).hasSize(1);
+        RingingPushInfo info = infos.get(0);
+        assertThat(info.alarmId()).isEqualTo(alarm.getId());
+        assertThat(info.memberId()).isEqualTo(member.getId());
+    }
+
+    @DisplayName("알람이 울리고 있지 않으면 알람 울림 푸시 알림 대상이 조회되지 않는다")
+    @Test
+    void findRingingNotificationTargets_returnsEmpty_whenNoRinging() {
+        // when
+        List<RingingPushInfo> infos = alarmOccurrenceRepository.findRingingNotificationTargets(DeactivateType.NONE);
+
+        // then
+        assertThat(infos).isEmpty();
+    }
+}