feat: 알림 발송 서비스 및 테스트 컨트롤러 추가

Author: JangInho

src/main/java/com/semosan/api/common/status/SuccessStatus.java

@@ -20,7 +20,14 @@ public enum SuccessStatus implements BaseStatus {
     /**
      * User
      */
-    WITHDRAW_SUCCESS(HttpStatus.OK, "USER_200_1", "회원 탈퇴가 완료되었습니다.");
+    WITHDRAW_SUCCESS(HttpStatus.OK, "USER_200_1", "회원 탈퇴가 완료되었습니다."),
+
+    /**
+     * FCM / Notification
+     */
+    FCM_TOKEN_REGISTER_SUCCESS(HttpStatus.OK, "FCM_200_1", "FCM 토큰이 등록되었습니다."),
+    FCM_TOKEN_DELETE_SUCCESS(HttpStatus.OK, "FCM_200_2", "FCM 토큰이 삭제되었습니다."),
+    NOTIFICATION_SEND_SUCCESS(HttpStatus.OK, "NOTIF_200_1", "알림 발송 요청에 성공했습니다.");
 
     private final HttpStatus httpStatus;
     private final String code;

src/main/java/com/semosan/api/domain/notification/controller/NotificationTestController.java

@@ -0,0 +1,34 @@
+package com.semosan.api.domain.notification.controller;
+
+import com.semosan.api.common.response.ApiResponse;
+import com.semosan.api.common.status.SuccessStatus;
+import com.semosan.api.domain.notification.dto.NotificationTestRequest;
+import com.semosan.api.domain.notification.service.NotificationService;
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+import org.springframework.context.annotation.Profile;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * 알림 테스트용 컨트롤러. local 프로필에서만 활성화 (운영 배포 시 자동 비활성화).
+ */
+@Profile("local")
+@RestController
+@RequestMapping("/api/notifications")
+@RequiredArgsConstructor
+public class NotificationTestController {
+
+    private final NotificationService notificationService;
+
+    @PostMapping("/test")
+    public ResponseEntity<ApiResponse<Void>> send(
+            @Valid @RequestBody NotificationTestRequest request
+    ) {
+        notificationService.send(request.receiverId(), request.type(), request.params());
+        return ApiResponse.success(SuccessStatus.NOTIFICATION_SEND_SUCCESS);
+    }
+}

src/main/java/com/semosan/api/domain/notification/dto/NotificationTestRequest.java

@@ -0,0 +1,13 @@
+package com.semosan.api.domain.notification.dto;
+
+import com.semosan.api.domain.notification.enums.NotificationType;
+import jakarta.validation.constraints.NotNull;
+
+import java.util.Map;
+
+public record NotificationTestRequest(
+        @NotNull Long receiverId,
+        @NotNull NotificationType type,
+        Map<String, Object> params
+) {
+}

src/main/java/com/semosan/api/domain/notification/service/NotificationService.java

@@ -0,0 +1,74 @@
+package com.semosan.api.domain.notification.service;
+
+import com.semosan.api.common.exception.GeneralException;
+import com.semosan.api.common.status.ErrorStatus;
+import com.semosan.api.domain.notification.dispatcher.NotificationDispatchCommand;
+import com.semosan.api.domain.notification.dispatcher.NotificationDispatcher;
+import com.semosan.api.domain.notification.entity.FcmToken;
+import com.semosan.api.domain.notification.entity.Notification;
+import com.semosan.api.domain.notification.enums.NotificationType;
+import com.semosan.api.domain.notification.repository.FcmTokenRepository;
+import com.semosan.api.domain.notification.repository.NotificationRepository;
+import com.semosan.api.domain.user.repository.UserRepository;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Map;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class NotificationService {
+
+    private final NotificationDispatcher dispatcher;
+    private final NotificationRepository notificationRepository;
+    private final FcmTokenRepository fcmTokenRepository;
+    private final UserRepository userRepository;
+
+    /**
+     * 서비스로 어디서든 한 줄로 알림 발송 가능
+     */
+    @Transactional
+    public void send(Long receiverId, NotificationType type, Map<String, Object> params) {
+        // 1. 받는 사람 검증
+        if (!userRepository.existsById(receiverId)) {
+            throw new GeneralException(ErrorStatus.USER_NOT_FOUND);
+        }
+
+        // 2. 파라미터 검증 (NotificationType별 필수 키)
+        type.validate(params);
+
+        // 3. 템플릿 처리
+        String title = type.formatTitle(params);
+        String body = type.formatBody(params);
+
+        // 4. 이력 저장
+        Notification notification = notificationRepository.save(
+                Notification.create(receiverId, type, title, body, params)
+        );
+
+        // 5. 토큰 조회, 없으면 정상 종료 (유저가 알림 거부/로그아웃 등 정상 케이스)
+        List<String> tokens = fcmTokenRepository.findAllByUserId(receiverId).stream()
+                .map(FcmToken::getToken)
+                .toList();
+
+        if (tokens.isEmpty()) {
+            log.info("발송 대상 토큰 없음 (userId={}, type={})", receiverId, type);
+            return;
+        }
+
+        // 6. 비동기 발송 위임
+        dispatcher.dispatch(new NotificationDispatchCommand(
+                notification.getId(),
+                receiverId,
+                type,
+                title,
+                body,
+                params,
+                tokens
+        ));
+    }
+}