Merge pull request #252 from techeer-sv/BE/#251

Be/#251 : 쪽지 목록 조회 API 구현

backend/src/main/java/com/graphy/backend/domain/message/controller/MessageController.java

@@ -4,18 +4,23 @@
 import com.graphy.backend.domain.member.domain.Member;
 import com.graphy.backend.domain.message.dto.request.CreateMessageRequest;
 import com.graphy.backend.domain.message.dto.response.GetMessageDetailResponse;
+import com.graphy.backend.domain.message.dto.response.GetMessageResponse;
 import com.graphy.backend.domain.message.service.MessageService;
+import com.graphy.backend.global.common.PageRequest;
 import com.graphy.backend.global.result.ResultCode;
 import com.graphy.backend.global.result.ResultResponse;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.AccessLevel;
 import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Pageable;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.List;
+
 @Tag(name = "MessageController", description = "쪽지 관련 API")
 @RestController
 @RequestMapping("api/v1/messages")
@@ -37,4 +42,13 @@ public ResponseEntity<ResultResponse> messageDetails(@PathVariable Long messageI
         GetMessageDetailResponse result = messageService.findMessageById(messageId);
         return ResponseEntity.ok(ResultResponse.of(ResultCode.MESSAGE_GET_SUCCESS, result));
     }
+
+    @Operation(summary = "findMessageList", description = "쪽지 목록 조회")
+    @GetMapping
+    public ResponseEntity<ResultResponse> messageList(@CurrentUser Member loginUser,
+                                                      PageRequest pageRequest) {
+        Pageable pageable = pageRequest.of();
+        List<GetMessageResponse> result = messageService.findMessageList(loginUser, pageable);
+        return ResponseEntity.ok(ResultResponse.of(ResultCode.MESSAGE_PAGING_GET_SUCCESS, result));
+    }
 }

backend/src/main/java/com/graphy/backend/domain/message/dto/response/GetMessageResponse.java

@@ -0,0 +1,26 @@
+package com.graphy.backend.domain.message.dto.response;
+
+import com.querydsl.core.annotations.QueryProjection;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDateTime;
+
+@Getter
+@Builder
+@NoArgsConstructor
+public class GetMessageResponse {
+    private Long senderId;
+    private String memberNickname;
+    private String content;
+    private LocalDateTime sentAt;
+
+    @QueryProjection
+    public GetMessageResponse(Long senderId, String memberNickname, String content, LocalDateTime sentAt) {
+        this.senderId = senderId;
+        this.memberNickname = memberNickname;
+        this.content = content;
+        this.sentAt = sentAt;
+    }
+}

backend/src/main/java/com/graphy/backend/domain/message/repository/MessageCustomRepository.java

@@ -0,0 +1,11 @@
+package com.graphy.backend.domain.message.repository;
+
+import com.graphy.backend.domain.message.dto.response.GetMessageResponse;
+import org.springframework.data.domain.Pageable;
+
+import java.util.List;
+
+public interface MessageCustomRepository {
+    List<GetMessageResponse> findMessages(Pageable pageable, Long memberId);
+
+}

backend/src/main/java/com/graphy/backend/domain/message/repository/MessageRepository.java

@@ -3,6 +3,6 @@
 import com.graphy.backend.domain.message.domain.Message;
 import org.springframework.data.jpa.repository.JpaRepository;
 
-public interface MessageRepository extends JpaRepository<Message, Long> {
+public interface MessageRepository extends JpaRepository<Message, Long>, MessageCustomRepository {
 
 }

backend/src/main/java/com/graphy/backend/domain/message/repository/custom/MessageCustomRepositoryImpl.java

@@ -0,0 +1,36 @@
+package com.graphy.backend.domain.message.repository.custom;
+
+import com.graphy.backend.domain.message.dto.response.GetMessageResponse;
+import com.graphy.backend.domain.message.dto.response.QGetMessageResponse;
+import com.graphy.backend.domain.message.repository.MessageCustomRepository;
+import com.querydsl.jpa.impl.JPAQueryFactory;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Pageable;
+
+import java.util.List;
+
+import static com.graphy.backend.domain.member.domain.QMember.member;
+import static com.graphy.backend.domain.message.domain.QMessage.message;
+
+@RequiredArgsConstructor
+public class MessageCustomRepositoryImpl implements MessageCustomRepository {
+    private final JPAQueryFactory jpaQueryFactory;
+
+    @Override
+    public List<GetMessageResponse> findMessages(Pageable pageable, Long memberId) {
+        return jpaQueryFactory
+                .select(new QGetMessageResponse(
+                        member.id,
+                        member.nickname,
+                        message.content,
+                        message.createdAt
+                ))
+                .from(message)
+                .join(message.sender, member)
+                .where(message.receiver.id.eq(memberId))
+                .offset(pageable.getOffset())
+                .limit(pageable.getPageSize())
+                .fetch();
+    }
+
+}

backend/src/main/java/com/graphy/backend/domain/message/service/MessageService.java

@@ -5,17 +5,22 @@
 import com.graphy.backend.domain.message.domain.Message;
 import com.graphy.backend.domain.message.dto.request.CreateMessageRequest;
 import com.graphy.backend.domain.message.dto.response.GetMessageDetailResponse;
+import com.graphy.backend.domain.message.dto.response.GetMessageResponse;
 import com.graphy.backend.domain.message.repository.MessageRepository;
 import com.graphy.backend.domain.notification.domain.NotificationType;
 import com.graphy.backend.domain.notification.dto.NotificationDto;
 import com.graphy.backend.domain.notification.service.NotificationService;
 import com.graphy.backend.global.error.ErrorCode;
 import com.graphy.backend.global.error.exception.EmptyResultException;
 import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Pageable;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.List;
+
 @Service
+@Transactional(readOnly = true)
 @RequiredArgsConstructor
 public class MessageService {
     private final MessageRepository messageRepository;
@@ -37,11 +42,17 @@ public void addMessage(CreateMessageRequest request, Member loginUser) {
         notificationService.addNotification(notificationDto, receiver.getId());
     }
 
-    @Transactional(readOnly = true)
     public GetMessageDetailResponse findMessageById(Long messageId) {
         Message message = messageRepository.findById(messageId).orElseThrow(
                 () -> new EmptyResultException(ErrorCode.MESSAGE_NOT_EXIST)
         );
         return GetMessageDetailResponse.from(message);
     }
+
+    public List<GetMessageResponse> findMessageList(Member loginUser, Pageable pageable) {
+        List<GetMessageResponse> messages = messageRepository.findMessages(pageable, loginUser.getId());
+
+        if (messages.isEmpty()) throw new EmptyResultException(ErrorCode.MESSAGE_NOT_EXIST);
+        else return messages;
+    }
 }

backend/src/main/java/com/graphy/backend/global/result/ResultCode.java

@@ -57,7 +57,8 @@ public enum ResultCode {
 
     // Message
     MESSAGE_CREATE_SUCCESS("MSG001", "쪽지 전송 성공"),
-    MESSAGE_GET_SUCCESS("MSG002", "쪽지 단건 조회 성공");
+    MESSAGE_GET_SUCCESS("MSG002", "쪽지 단건 조회 성공"),
+    MESSAGE_PAGING_GET_SUCCESS("MSG003", "쪽지 페이징 조회 성공");
 
     private final String code;
     private final String message;