[feat] 알림센터 조회 api 개발

src/main/java/konkuk/thip/common/exception/code/ErrorCode.java

@@ -222,7 +222,13 @@ public enum ErrorCode implements ResponseCode {
     FCM_TOKEN_NOT_FOUND(HttpStatus.NOT_FOUND, 200000, "존재하지 않는 FCM TOKEN 입니다."),
     FCM_TOKEN_ENABLED_STATE_ALREADY(HttpStatus.BAD_REQUEST, 200001, "요청한 상태로 이미 푸쉬 알림 여부가 설정되어 있습니다."),
     FCM_TOKEN_ACCESS_FORBIDDEN(HttpStatus.FORBIDDEN, 200002, "토큰을 소유하고 있는 계정이 아닙니다."),
-    FIREBASE_SEND_ERROR(HttpStatus.INTERNAL_SERVER_ERROR, 200003, "FCM 푸쉬 알림 전송에 실패했습니다.")
+    FIREBASE_SEND_ERROR(HttpStatus.INTERNAL_SERVER_ERROR, 200003, "FCM 푸쉬 알림 전송에 실패했습니다."),
+
+
+    /**
+     * 205000 : notification error
+     */
+    INVALID_NOTIFICATION_TYPE(HttpStatus.BAD_REQUEST, 205000, "유효하지 않은 알림 타입입니다."),
 
     ;
 

src/main/java/konkuk/thip/common/swagger/SwaggerResponseDescription.java

@@ -373,6 +373,9 @@ public enum SwaggerResponseDescription {
     NOTIFICATION_GET_ENABLE_STATE(new LinkedHashSet<>(Set.of(
             FCM_TOKEN_NOT_FOUND
     ))),
+    NOTIFICATION_SHOW(new LinkedHashSet<>(Set.of(
+            INVALID_NOTIFICATION_TYPE
+    ))),
 
   ;
     private final Set<ErrorCode> errorCodeList;

src/main/java/konkuk/thip/notification/adapter/in/web/NotificationCommandController.java

@@ -11,9 +11,9 @@
 import konkuk.thip.notification.adapter.in.web.request.FcmTokenEnableStateChangeRequest;
 import konkuk.thip.notification.adapter.in.web.request.FcmTokenRegisterRequest;
 import konkuk.thip.notification.adapter.in.web.response.FcmTokenEnableStateChangeResponse;
-import konkuk.thip.notification.application.port.in.FcmDeleteUseCase;
-import konkuk.thip.notification.application.port.in.FcmEnableStateChangeUseCase;
-import konkuk.thip.notification.application.port.in.FcmRegisterUseCase;
+import konkuk.thip.notification.application.port.in.fcm.FcmDeleteUseCase;
+import konkuk.thip.notification.application.port.in.fcm.FcmEnableStateChangeUseCase;
+import konkuk.thip.notification.application.port.in.fcm.FcmRegisterUseCase;
 import lombok.RequiredArgsConstructor;
 import org.springframework.web.bind.annotation.*;
 

src/main/java/konkuk/thip/notification/adapter/in/web/NotificationQueryController.java

@@ -7,20 +7,25 @@
 import konkuk.thip.common.security.annotation.UserId;
 import konkuk.thip.common.swagger.annotation.ExceptionDescription;
 import konkuk.thip.notification.adapter.in.web.response.NotificationShowEnableStateResponse;
+import konkuk.thip.notification.adapter.in.web.response.NotificationShowResponse;
 import konkuk.thip.notification.application.port.in.NotificationShowEnableStateUseCase;
+import konkuk.thip.notification.application.port.in.NotificationShowUseCase;
+import konkuk.thip.notification.application.port.in.dto.NotificationType;
 import lombok.RequiredArgsConstructor;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 import static konkuk.thip.common.swagger.SwaggerResponseDescription.NOTIFICATION_GET_ENABLE_STATE;
+import static konkuk.thip.common.swagger.SwaggerResponseDescription.NOTIFICATION_SHOW;
 
 @Tag(name = "Notification Query API", description = "알림 조회 관련 API")
 @RestController
 @RequiredArgsConstructor
 public class NotificationQueryController {
 
     private final NotificationShowEnableStateUseCase notificationShowEnableStateUseCase;
+    private final NotificationShowUseCase notificationShowUseCase;
 
     @Operation(
             summary = "사용자 푸시알림 수신여부 조회 (마이페이지 -> 알림설정)",
@@ -35,4 +40,20 @@ public BaseResponse<NotificationShowEnableStateResponse> showNotificationEnableS
         return BaseResponse.ok(
                 NotificationShowEnableStateResponse.of(notificationShowEnableStateUseCase.getNotificationShowEnableState(userId,deviceId)));
     }
+
+    @Operation(
+            summary = "유저의 알림 조회",
+            description = "유저의 알림 목록을 조회합니다. 최신순으로 정렬합니다."
+    )
+    @ExceptionDescription(NOTIFICATION_SHOW)
+    @GetMapping("/notifications")
+    public BaseResponse<NotificationShowResponse> showNotifications(
+            @Parameter(hidden = true) @UserId final Long userId,
+            @Parameter(description = "커서 (첫번째 요청시 : null, 다음 요청시 : 이전 요청에서 반환받은 nextCursor 값)")
+            @RequestParam(value = "cursor", required = false) final String cursor,
+            @Parameter(description = "알림 타입. 해당 파라미터 값이 null인 경우에는 알림 타입을 구분하지 않고 조회합니다.", example = "feed or room")
+            @RequestParam(value = "type", required = false, defaultValue = "feedAndRoom") final String type
+    ) {
+        return BaseResponse.ok(notificationShowUseCase.showNotifications(userId, cursor, NotificationType.from(type)));
+    }
 }

src/main/java/konkuk/thip/notification/adapter/in/web/response/NotificationShowResponse.java

@@ -0,0 +1,18 @@
+package konkuk.thip.notification.adapter.in.web.response;
+
+import java.util.List;
+
+public record NotificationShowResponse(
+        List<NotificationOfUser> notifications,
+        String nextCursor,
+        boolean isLast
+) {
+    public record NotificationOfUser(
+            Long notificationId,
+            String title,
+            String content,
+            boolean isChecked,
+            String notificationType,
+            String postDate
+    ) {}
+}

src/main/java/konkuk/thip/notification/adapter/out/jpa/NotificationJpaEntity.java

@@ -2,6 +2,7 @@
 
 import jakarta.persistence.*;
 import konkuk.thip.common.entity.BaseJpaEntity;
+import konkuk.thip.notification.domain.value.NotificationCategory;
 import konkuk.thip.user.adapter.out.jpa.UserJpaEntity;
 import lombok.*;
 
@@ -23,9 +24,13 @@ public class NotificationJpaEntity extends BaseJpaEntity {
     @Column(length = 200, nullable = false)
     private String content;
 
-    @Column(name = "is_checked",nullable = false)
+    @Column(name = "is_checked", nullable = false)
     private boolean isChecked;
 
+    @Enumerated(EnumType.STRING)
+    @Column(name = "notification_category", length = 16, nullable = false)
+    private NotificationCategory notificationCategory;
+
     @ManyToOne(fetch = FetchType.LAZY, optional = false)
     @JoinColumn(name = "user_id", nullable = false)
     private UserJpaEntity userJpaEntity;

src/main/java/konkuk/thip/notification/adapter/out/mapper/NotificationMapper.java

@@ -13,6 +13,7 @@ public NotificationJpaEntity toJpaEntity(Notification notification, UserJpaEntit
                 .title(notification.getTitle())
                 .content(notification.getContent())
                 .isChecked(notification.isChecked())
+                .notificationCategory(notification.getNotificationCategory())
                 .userJpaEntity(userJpaEntity)
                 .build();
     }
@@ -23,6 +24,7 @@ public Notification toDomainEntity(NotificationJpaEntity notificationJpaEntity)
                 .title(notificationJpaEntity.getTitle())
                 .content(notificationJpaEntity.getContent())
                 .isChecked(notificationJpaEntity.isChecked())
+                .notificationCategory(notificationJpaEntity.getNotificationCategory())
                 .targetUserId(notificationJpaEntity.getUserJpaEntity().getUserId())
                 .createdAt(notificationJpaEntity.getCreatedAt())
                 .modifiedAt(notificationJpaEntity.getModifiedAt())

src/main/java/konkuk/thip/notification/adapter/out/persistence/NotificationQueryPersistenceAdapter.java

@@ -1,15 +1,56 @@
 package konkuk.thip.notification.adapter.out.persistence;
 
+import konkuk.thip.common.util.Cursor;
+import konkuk.thip.common.util.CursorBasedList;
 import konkuk.thip.notification.adapter.out.mapper.NotificationMapper;
+import konkuk.thip.notification.adapter.out.persistence.function.PrimaryKeyNotificationQueryFunction;
 import konkuk.thip.notification.adapter.out.persistence.repository.NotificationJpaRepository;
+import konkuk.thip.notification.application.port.out.NotificationQueryPort;
+import konkuk.thip.notification.application.port.out.dto.NotificationQueryDto;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Repository;
 
+import java.util.List;
+
 @Repository
 @RequiredArgsConstructor
-public class NotificationQueryPersistenceAdapter {
+public class NotificationQueryPersistenceAdapter implements NotificationQueryPort {
 
-    private final NotificationJpaRepository jpaRepository;
+    private final NotificationJpaRepository notificationJpaRepository;
     private final NotificationMapper notificationMapper;
 
+    @Override
+    public CursorBasedList<NotificationQueryDto> findFeedNotificationsByUserId(Long userId, Cursor cursor) {
+        return findNotificationsByPrimaryKeyCursor(cursor, ((lastNotificationId, pageSize) ->
+                notificationJpaRepository.findFeedNotificationsOrderByCreatedAtDesc(userId, lastNotificationId, pageSize)
+        ));
+    }
+
+    @Override
+    public CursorBasedList<NotificationQueryDto> findRoomNotificationsByUserId(Long userId, Cursor cursor) {
+        return findNotificationsByPrimaryKeyCursor(cursor, ((lastNotificationId, pageSize) ->
+                notificationJpaRepository.findRoomNotificationsOrderByCreatedAtDesc(userId, lastNotificationId, pageSize)
+        ));
+    }
+
+    @Override
+    public CursorBasedList<NotificationQueryDto> findFeedAndRoomNotificationsByUserId(Long userId, Cursor cursor) {
+        return findNotificationsByPrimaryKeyCursor(cursor, ((lastNotificationId, pageSize) ->
+                notificationJpaRepository.findFeedAndRoomNotificationsOrderByCreatedAtDesc(userId, lastNotificationId, pageSize)
+        ));
+    }
+
+    private CursorBasedList<NotificationQueryDto> findNotificationsByPrimaryKeyCursor(Cursor cursor, PrimaryKeyNotificationQueryFunction queryFunction) {
+        Long lastNotificationId = cursor.isFirstRequest() ? null : cursor.getLong(0);
+        int pageSize = cursor.getPageSize();
+
+        List<NotificationQueryDto> dtos = queryFunction.apply(lastNotificationId, pageSize);
+
+        return CursorBasedList.of(dtos, pageSize, dto -> {
+            Cursor nextCursor = new Cursor(List.of(
+                    dto.notificationId().toString()
+            ));
+            return nextCursor.toEncodedString();
+        });
+    }
 }

src/main/java/konkuk/thip/notification/adapter/out/persistence/function/PrimaryKeyNotificationQueryFunction.java

@@ -0,0 +1,11 @@
+package konkuk.thip.notification.adapter.out.persistence.function;
+
+import konkuk.thip.notification.application.port.out.dto.NotificationQueryDto;
+
+import java.util.List;
+
+@FunctionalInterface
+public interface PrimaryKeyNotificationQueryFunction {
+
+    List<NotificationQueryDto> apply(Long lastNotificationId, int pageSize);
+}

src/main/java/konkuk/thip/notification/adapter/out/persistence/repository/NotificationJpaRepository.java

@@ -3,5 +3,5 @@
 import konkuk.thip.notification.adapter.out.jpa.NotificationJpaEntity;
 import org.springframework.data.jpa.repository.JpaRepository;
 
-public interface NotificationJpaRepository extends JpaRepository<NotificationJpaEntity, Long> {
+public interface NotificationJpaRepository extends JpaRepository<NotificationJpaEntity, Long>, NotificationQueryRepository {
 }

src/main/java/konkuk/thip/notification/adapter/out/persistence/repository/NotificationQueryRepository.java

@@ -0,0 +1,14 @@
+package konkuk.thip.notification.adapter.out.persistence.repository;
+
+import konkuk.thip.notification.application.port.out.dto.NotificationQueryDto;
+
+import java.util.List;
+
+public interface NotificationQueryRepository {
+
+    List<NotificationQueryDto> findFeedNotificationsOrderByCreatedAtDesc(Long userId, Long lastNotificationId, int pageSize);
+
+    List<NotificationQueryDto> findRoomNotificationsOrderByCreatedAtDesc(Long userId, Long lastNotificationId, int pageSize);
+
+    List<NotificationQueryDto> findFeedAndRoomNotificationsOrderByCreatedAtDesc(Long userId, Long lastNotificationId, int pageSize);
+}

src/main/java/konkuk/thip/notification/adapter/out/persistence/repository/NotificationQueryRepositoryImpl.java

@@ -0,0 +1,72 @@
+package konkuk.thip.notification.adapter.out.persistence.repository;
+
+import com.querydsl.core.types.dsl.BooleanExpression;
+import com.querydsl.jpa.impl.JPAQueryFactory;
+import konkuk.thip.notification.adapter.out.jpa.QNotificationJpaEntity;
+import konkuk.thip.notification.application.port.out.dto.NotificationQueryDto;
+import konkuk.thip.notification.application.port.out.dto.QNotificationQueryDto;
+import konkuk.thip.notification.domain.value.NotificationCategory;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository
+@RequiredArgsConstructor
+public class NotificationQueryRepositoryImpl implements NotificationQueryRepository {
+
+    private final JPAQueryFactory queryFactory;
+
+    private final QNotificationJpaEntity notification = QNotificationJpaEntity.notificationJpaEntity;
+
+    @Override
+    public List<NotificationQueryDto> findFeedNotificationsOrderByCreatedAtDesc(Long userId, Long lastNotificationId, int pageSize) {
+        var where = notification.userJpaEntity.userId.eq(userId)
+                .and(notification.notificationCategory.eq(NotificationCategory.FEED));
+
+        where = applyCursor(lastNotificationId, where, notification);
+
+        return getNotificationQueryDtos(pageSize, notification, where);
+    }
+
+    @Override
+    public List<NotificationQueryDto> findRoomNotificationsOrderByCreatedAtDesc(Long userId, Long lastNotificationId, int pageSize) {
+        var where = notification.userJpaEntity.userId.eq(userId)
+                .and(notification.notificationCategory.eq(NotificationCategory.ROOM));
+        where = applyCursor(lastNotificationId, where, notification);
+
+        return getNotificationQueryDtos(pageSize, notification, where);
+    }
+
+    @Override
+    public List<NotificationQueryDto> findFeedAndRoomNotificationsOrderByCreatedAtDesc(Long userId, Long lastNotificationId, int pageSize) {
+        var where = notification.userJpaEntity.userId.eq(userId)
+                .and(notification.notificationCategory.in(NotificationCategory.FEED, NotificationCategory.ROOM));
+        where = applyCursor(lastNotificationId, where, notification);
+
+        return getNotificationQueryDtos(pageSize, notification, where);
+    }
+
+    private static BooleanExpression applyCursor(Long lastNotificationId, BooleanExpression where, QNotificationJpaEntity notification) {
+        if (lastNotificationId != null) {
+            where = where.and(notification.notificationId.lt(lastNotificationId));
+        }
+        return where;
+    }
+
+    private List<NotificationQueryDto> getNotificationQueryDtos(int pageSize, QNotificationJpaEntity notification, BooleanExpression where) {
+        return queryFactory.select(new QNotificationQueryDto(
+                        notification.notificationId,
+                        notification.title,
+                        notification.content,
+                        notification.isChecked,
+                        notification.notificationCategory,
+                        notification.createdAt
+                ))
+                .from(notification)
+                .where(where)
+                .orderBy(notification.notificationId.desc())    // PK 기준 내림차순 (= 최신순)
+                .limit(pageSize + 1)
+                .fetch();
+    }
+}

src/main/java/konkuk/thip/notification/application/mapper/NotificationQueryMapper.java

@@ -0,0 +1,29 @@
+package konkuk.thip.notification.application.mapper;
+
+import konkuk.thip.common.util.DateUtil;
+import konkuk.thip.notification.adapter.in.web.response.NotificationShowResponse;
+import konkuk.thip.notification.application.port.out.dto.NotificationQueryDto;
+import org.mapstruct.Mapper;
+import org.mapstruct.Mapping;
+import org.mapstruct.ReportingPolicy;
+
+import java.util.List;
+
+@Mapper(
+        componentModel = "spring",
+        imports = DateUtil.class,
+        unmappedTargetPolicy = ReportingPolicy.IGNORE       // 명시적으로 매핑하지 않은 필드를 무시하도록 설정
+)
+public interface NotificationQueryMapper {
+
+    // 단건 매핑
+    @Mapping(target = "notificationType",
+            expression = "java(dto.notificationCategory().getDisplay())")
+    @Mapping(target = "postDate",
+            expression = "java(DateUtil.formatBeforeTime(dto.createdAt()))")
+    NotificationShowResponse.NotificationOfUser toNotificationOfUser(NotificationQueryDto dto);
+
+    // 컬렉션 매핑
+    List<NotificationShowResponse.NotificationOfUser> toNotificationOfUsers(List<NotificationQueryDto> dtos);
+
+}

src/main/java/konkuk/thip/notification/application/port/in/NotificationShowUseCase.java

@@ -0,0 +1,9 @@
+package konkuk.thip.notification.application.port.in;
+
+import konkuk.thip.notification.adapter.in.web.response.NotificationShowResponse;
+import konkuk.thip.notification.application.port.in.dto.NotificationType;
+
+public interface NotificationShowUseCase {
+
+    NotificationShowResponse showNotifications(Long userId, String cursorStr, NotificationType notificationType);
+}

src/main/java/konkuk/thip/notification/application/port/in/dto/NotificationType.java

@@ -0,0 +1,28 @@
+package konkuk.thip.notification.application.port.in.dto;
+
+import konkuk.thip.common.exception.InvalidStateException;
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+import java.util.Arrays;
+
+import static konkuk.thip.common.exception.code.ErrorCode.INVALID_NOTIFICATION_TYPE;
+
+@Getter
+@RequiredArgsConstructor
+public enum NotificationType {
+    FEED("feed"),
+    ROOM("room"),
+    FEED_AND_ROOM("feedAndRoom");
+
+    private final String type;
+
+    public static NotificationType from(String type) {
+        return Arrays.stream(NotificationType.values())
+                .filter(param -> param.getType().equals(type))
+                .findFirst()
+                .orElseThrow(
+                        () -> new InvalidStateException(INVALID_NOTIFICATION_TYPE)
+                );
+    }
+}

src/main/java/konkuk/thip/notification/application/port/in/FcmDeleteUseCase.java → src/main/java/konkuk/thip/notification/application/port/in/fcm/FcmDeleteUseCase.java

@@ -1,4 +1,4 @@
-package konkuk.thip.notification.application.port.in;
+package konkuk.thip.notification.application.port.in.fcm;
 
 import konkuk.thip.notification.application.port.in.dto.FcmTokenDeleteCommand;
 

src/main/java/konkuk/thip/notification/application/port/in/FcmEnableStateChangeUseCase.java → src/main/java/konkuk/thip/notification/application/port/in/fcm/FcmEnableStateChangeUseCase.java

@@ -1,4 +1,4 @@
-package konkuk.thip.notification.application.port.in;
+package konkuk.thip.notification.application.port.in.fcm;
 
 import konkuk.thip.notification.application.port.in.dto.FcmEnableStateChangeCommand;
 

src/main/java/konkuk/thip/notification/application/port/in/FcmRegisterUseCase.java → src/main/java/konkuk/thip/notification/application/port/in/fcm/FcmRegisterUseCase.java

@@ -1,4 +1,4 @@
-package konkuk.thip.notification.application.port.in;
+package konkuk.thip.notification.application.port.in.fcm;
 
 import konkuk.thip.notification.application.port.in.dto.FcmTokenRegisterCommand;