Feature/156 봉사자와 기관의 자신에게 온 쪽지 목록 (#184)

7zrv · web-flow · commit fc0916356348 · 2024-12-07T20:07:15.000+09:00
diff --git a/src/main/java/com/somemore/global/common/entity/BaseEntity.java b/src/main/java/com/somemore/global/common/entity/BaseEntity.java
@@ -24,7 +24,7 @@ public class BaseEntity {
     @Column(name = "updated_at")
     private LocalDateTime updatedAt;
 
-    @Column(name = "deleted")
+    @Column(name = "deleted", nullable = false)
     private Boolean deleted;
 
     @PrePersist
diff --git a/src/main/java/com/somemore/note/controller/NoteQueryApiController.java b/src/main/java/com/somemore/note/controller/NoteQueryApiController.java
@@ -0,0 +1,46 @@
+package com.somemore.note.controller;
+
+import com.somemore.auth.annotation.CurrentUser;
+import com.somemore.global.common.response.ApiResponse;
+import com.somemore.note.repository.mapper.NoteReceiverViewForCenter;
+import com.somemore.note.repository.mapper.NoteReceiverViewForVolunteer;
+import com.somemore.note.usecase.NoteQueryUseCase;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.security.access.annotation.Secured;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.UUID;
+
+@Tag(name = "Note Query API", description = "쪽지 조회 API")
+@RequiredArgsConstructor
+@RequestMapping("/api/note")
+@RestController
+public class NoteQueryApiController {
+
+    private final NoteQueryUseCase noteQueryUseCase;
+
+    @Secured("ROLE_CENTER")
+    @Operation(summary = "기관의 자신에게 온 쪽지 조회")
+    @GetMapping("/center")
+    public ApiResponse<Page<NoteReceiverViewForCenter>> getNotesByCenterId(@CurrentUser UUID centerId, Pageable pageable) {
+
+        Page<NoteReceiverViewForCenter> response = noteQueryUseCase.getNotesForCenter(centerId, pageable);
+
+        return ApiResponse.ok(200, response, "내 쪽지 조회 성공");
+    }
+
+    @Secured("ROLE_VOLUNTEER")
+    @Operation(summary = "봉사자의 자신에게 온 쪽지 조회")
+    @GetMapping("/volunteer")
+    public ApiResponse<Page<NoteReceiverViewForVolunteer>> getNotesByVolunteerId(@CurrentUser UUID volunteerId, Pageable pageable) {
+
+        Page<NoteReceiverViewForVolunteer> response = noteQueryUseCase.getNotesForVolunteer(volunteerId, pageable);
+
+        return ApiResponse.ok(200, response, "내 쪽지 조회 성공");
+    }
+
+}
diff --git a/src/main/java/com/somemore/note/repository/NoteRepository.java b/src/main/java/com/somemore/note/repository/NoteRepository.java
@@ -1,8 +1,15 @@
 package com.somemore.note.repository;
 
 import com.somemore.note.domain.Note;
+import com.somemore.note.repository.mapper.NoteReceiverViewForCenter;
+import com.somemore.note.repository.mapper.NoteReceiverViewForVolunteer;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
 
-public interface NoteRepository {
+import java.util.UUID;
 
+public interface NoteRepository {
     Note save(Note note);
+    Page<NoteReceiverViewForCenter> findNotesByReceiverIsCenter(UUID centerId, Pageable pageable);
+    Page<NoteReceiverViewForVolunteer> findNotesByReceiverIsVolunteer(UUID volunteerId, Pageable pageable);
 }
diff --git a/src/main/java/com/somemore/note/repository/NoteRepositoryImpl.java b/src/main/java/com/somemore/note/repository/NoteRepositoryImpl.java
@@ -1,18 +1,101 @@
 package com.somemore.note.repository;
 
+import com.querydsl.core.types.Projections;
+import com.querydsl.core.types.dsl.BooleanExpression;
+import com.querydsl.jpa.impl.JPAQuery;
+import com.querydsl.jpa.impl.JPAQueryFactory;
+import com.somemore.center.domain.QCenter;
 import com.somemore.note.domain.Note;
+import com.somemore.note.domain.QNote;
+import com.somemore.note.repository.mapper.NoteReceiverViewForCenter;
+import com.somemore.note.repository.mapper.NoteReceiverViewForVolunteer;
+import com.somemore.volunteer.domain.QVolunteer;
 import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.support.PageableExecutionUtils;
 import org.springframework.stereotype.Repository;
 
+import java.util.List;
+import java.util.UUID;
+
 @RequiredArgsConstructor
 @Repository
 public class NoteRepositoryImpl implements NoteRepository {
 
+    private final JPAQueryFactory queryFactory;
     private final NoteJpaRepository noteJpaRepository;
 
+    private static final QNote note = QNote.note;
+    private static final QVolunteer volunteer = QVolunteer.volunteer;
+    private static final QCenter center = QCenter.center;
+
     @Override
     public Note save(Note note) {
         return noteJpaRepository.save(note);
     }
 
+    @Override
+    public Page<NoteReceiverViewForCenter> findNotesByReceiverIsCenter(UUID centerId, Pageable pageable) {
+
+        BooleanExpression activeVolunteer = volunteer.deleted.eq(false);
+        BooleanExpression condition = note.receiverId.eq(centerId)
+                .and(note.deleted.eq(false));
+
+        List<NoteReceiverViewForCenter> results = queryFactory
+                .select(Projections.constructor(
+                        NoteReceiverViewForCenter.class,
+                        note.id,
+                        note.title,
+                        volunteer.id.as("senderId"),
+                        volunteer.nickname.as("senderName"),
+                        note.isRead
+                ))
+                .from(note)
+                .join(volunteer).on(note.senderId.eq(volunteer.id).and(activeVolunteer))
+                .where(condition)
+                .offset(pageable.getOffset())
+                .limit(pageable.getPageSize())
+                .orderBy(note.createdAt.desc())
+                .fetch();
+
+        JPAQuery<Long> count = queryFactory
+                .select(note.count())
+                .from(note)
+                .where(condition);
+
+        return PageableExecutionUtils.getPage(results, pageable, count::fetchOne);
+    }
+
+    @Override
+    public Page<NoteReceiverViewForVolunteer> findNotesByReceiverIsVolunteer(UUID volunteerId, Pageable pageable) {
+        BooleanExpression activeCenter = center.deleted.eq(false);
+        BooleanExpression condition = note.receiverId.eq(volunteerId)
+                .and(note.deleted.eq(false));
+
+        List<NoteReceiverViewForVolunteer> results = queryFactory
+                .select(Projections.constructor(
+                        NoteReceiverViewForVolunteer.class,
+                        note.id,
+                        note.title,
+                        center.id.as("senderId"),
+                        center.name.as("senderName"),
+                        note.isRead
+                ))
+                .from(note)
+                .join(center).on(note.senderId.eq(center.id).and(activeCenter))
+                .where(condition)
+                .offset(pageable.getOffset())
+                .limit(pageable.getPageSize())
+                .orderBy(note.createdAt.desc())
+                .fetch();
+
+        JPAQuery<Long> count = queryFactory
+                .select(note.count())
+                .from(note)
+                .where(condition);
+
+        return PageableExecutionUtils.getPage(results, pageable, count::fetchOne);
+    }
+
 }
diff --git a/src/main/java/com/somemore/note/repository/mapper/NoteReceiverViewForCenter.java b/src/main/java/com/somemore/note/repository/mapper/NoteReceiverViewForCenter.java
@@ -0,0 +1,24 @@
+package com.somemore.note.repository.mapper;
+
+import com.fasterxml.jackson.databind.PropertyNamingStrategies;
+import com.fasterxml.jackson.databind.annotation.JsonNaming;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Builder;
+
+import java.util.UUID;
+
+@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
+@Builder
+public record NoteReceiverViewForCenter(
+        @Schema(description = "쪽지 ID", example = "1111")
+        Long id,
+        @Schema(description = "쪽지 제목", example = "문의 드립니다.")
+        String title,
+        @Schema(description = "송신자 id", example = "1342134-32423-35345")
+        UUID senderId,
+        @Schema(description = "송신 봉사자 닉네임", example = "봉사왕")
+        String senderName,
+        @Schema(description = "읽음 여부", example = "true = 읽음, false = 안읽음")
+        boolean isRead
+) {
+}
diff --git a/src/main/java/com/somemore/note/repository/mapper/NoteReceiverViewForVolunteer.java b/src/main/java/com/somemore/note/repository/mapper/NoteReceiverViewForVolunteer.java
@@ -0,0 +1,24 @@
+package com.somemore.note.repository.mapper;
+
+import com.fasterxml.jackson.databind.PropertyNamingStrategies;
+import com.fasterxml.jackson.databind.annotation.JsonNaming;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Builder;
+
+import java.util.UUID;
+
+@JsonNaming(PropertyNamingStrategies.SnakeCaseStrategy.class)
+@Builder
+public record NoteReceiverViewForVolunteer(
+        @Schema(description = "쪽지 ID", example = "1111")
+        Long id,
+        @Schema(description = "쪽지 제목", example = "답변 드립니다..")
+        String title,
+        @Schema(description = "송신한 기관 id", example = "1342134-32423-35345")
+        UUID senderId,
+        @Schema(description = "송신 기관 닉네임", example = "서울 도서관")
+        String senderName,
+        @Schema(description = "읽음 여부", example = "true = 읽음, false = 안읽음")
+        boolean isRead
+) {
+}
diff --git a/src/main/java/com/somemore/note/service/NoteQueryService.java b/src/main/java/com/somemore/note/service/NoteQueryService.java
@@ -0,0 +1,31 @@
+package com.somemore.note.service;
+
+import com.somemore.note.repository.NoteRepository;
+import com.somemore.note.repository.mapper.NoteReceiverViewForCenter;
+import com.somemore.note.repository.mapper.NoteReceiverViewForVolunteer;
+import com.somemore.note.usecase.NoteQueryUseCase;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.UUID;
+
+@RequiredArgsConstructor
+@Service
+@Transactional(readOnly = true)
+public class NoteQueryService implements NoteQueryUseCase {
+
+    private final NoteRepository noteRepository;
+
+    @Override
+    public Page<NoteReceiverViewForCenter> getNotesForCenter(UUID centerId, Pageable pageable) {
+        return noteRepository.findNotesByReceiverIsCenter(centerId, pageable);
+    }
+
+    @Override
+    public Page<NoteReceiverViewForVolunteer> getNotesForVolunteer(UUID volunteerId, Pageable pageable) {
+        return noteRepository.findNotesByReceiverIsVolunteer(volunteerId, pageable);
+    }
+}
diff --git a/src/main/java/com/somemore/note/usecase/NoteQueryUseCase.java b/src/main/java/com/somemore/note/usecase/NoteQueryUseCase.java
@@ -0,0 +1,13 @@
+package com.somemore.note.usecase;
+
+import com.somemore.note.repository.mapper.NoteReceiverViewForCenter;
+import com.somemore.note.repository.mapper.NoteReceiverViewForVolunteer;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+
+import java.util.UUID;
+
+public interface NoteQueryUseCase {
+    Page<NoteReceiverViewForCenter> getNotesForCenter(UUID centerId, Pageable pageable);
+    Page<NoteReceiverViewForVolunteer> getNotesForVolunteer(UUID volunteerId, Pageable pageable);
+}
diff --git a/src/test/java/com/somemore/note/controller/NoteQueryApiControllerTest.java b/src/test/java/com/somemore/note/controller/NoteQueryApiControllerTest.java
@@ -0,0 +1,125 @@
+package com.somemore.note.controller;
+
+import com.somemore.ControllerTestSupport;
+import com.somemore.WithMockCustomUser;
+import com.somemore.note.repository.mapper.NoteReceiverViewForCenter;
+import com.somemore.note.repository.mapper.NoteReceiverViewForVolunteer;
+import com.somemore.note.usecase.NoteQueryUseCase;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.mock.mockito.MockBean;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageImpl;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.http.MediaType;
+
+import java.util.List;
+import java.util.UUID;
+
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.eq;
+import static org.mockito.Mockito.when;
+import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.get;
+import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.jsonPath;
+import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
+
+class NoteQueryApiControllerTest extends ControllerTestSupport {
+
+    @MockBean
+    private NoteQueryUseCase noteQueryUseCase;
+
+    @DisplayName("기관은 자신에게 온 쪽지를 페이지 형태로 확인할 수 있다. (Controller)")
+    @Test
+    @WithMockCustomUser(role = "CENTER")
+    void getNotesByCenterId() throws Exception {
+        // given
+        Pageable pageable = PageRequest.of(0, 6);
+        List<NoteReceiverViewForCenter> notes = List.of(
+                NoteReceiverViewForCenter.builder()
+                        .id(1L)
+                        .title("문의 드립니다.")
+                        .senderName("봉사왕")
+                        .isRead(false)
+                        .build(),
+                NoteReceiverViewForCenter.builder()
+                        .id(2L)
+                        .title("긴급 문의")
+                        .senderName("지원자")
+                        .isRead(true)
+                        .build()
+        );
+        Page<NoteReceiverViewForCenter> mockResponse = new PageImpl<>(notes, pageable, notes.size());
+
+        when(noteQueryUseCase.getNotesForCenter(any(UUID.class), eq(pageable)))
+                .thenReturn(mockResponse);
+
+        // When & Then
+        mockMvc.perform(get("/api/note/center")
+                        .param("page", "0")
+                        .param("size", "6")
+                        .accept(MediaType.APPLICATION_JSON))
+                .andExpect(status().isOk())
+                .andExpect(jsonPath("$.code").value(200))
+                .andExpect(jsonPath("$.message").value("내 쪽지 조회 성공"))
+                .andExpect(jsonPath("$.data.content").isArray())
+                .andExpect(jsonPath("$.data.content[0].id").value(1))
+                .andExpect(jsonPath("$.data.content[0].title").value("문의 드립니다."))
+                .andExpect(jsonPath("$.data.content[0].sender_name").value("봉사왕"))
+                .andExpect(jsonPath("$.data.content[0].is_read").value(false))
+                .andExpect(jsonPath("$.data.content[1].id").value(2))
+                .andExpect(jsonPath("$.data.content[1].title").value("긴급 문의"))
+                .andExpect(jsonPath("$.data.content[1].sender_name").value("지원자"))
+                .andExpect(jsonPath("$.data.content[1].is_read").value(true))
+                .andExpect(jsonPath("$.data.pageable.pageNumber").value(0))
+                .andExpect(jsonPath("$.data.pageable.pageSize").value(6))
+                .andExpect(jsonPath("$.data.totalElements").value(2));
+    }
+
+    @DisplayName("봉사자는 자신에게 온 쪽지를 페이지 형태로 확인할 수 있다. (Controller)")
+    @Test
+    @WithMockCustomUser
+    void getNotesByVolunteerId() throws Exception {
+        // given
+        Pageable pageable = PageRequest.of(0, 6);
+        List<NoteReceiverViewForVolunteer> notes = List.of(
+                NoteReceiverViewForVolunteer.builder()
+                        .id(1L)
+                        .title("답변 드립니다.")
+                        .senderName("서울 도서관")
+                        .isRead(false)
+                        .build(),
+                NoteReceiverViewForVolunteer.builder()
+                        .id(2L)
+                        .title("요양원 입니다.")
+                        .senderName("서울 요양원")
+                        .isRead(true)
+                        .build()
+        );
+        Page<NoteReceiverViewForVolunteer> mockResponse = new PageImpl<>(notes, pageable, notes.size());
+
+        when(noteQueryUseCase.getNotesForVolunteer(any(UUID.class), eq(pageable)))
+                .thenReturn(mockResponse);
+
+        // When & Then
+        mockMvc.perform(get("/api/note/volunteer")
+                        .param("page", "0")
+                        .param("size", "6")
+                        .accept(MediaType.APPLICATION_JSON))
+                .andExpect(status().isOk())
+                .andExpect(jsonPath("$.code").value(200))
+                .andExpect(jsonPath("$.message").value("내 쪽지 조회 성공"))
+                .andExpect(jsonPath("$.data.content").isArray())
+                .andExpect(jsonPath("$.data.content[0].id").value(1))
+                .andExpect(jsonPath("$.data.content[0].title").value("답변 드립니다."))
+                .andExpect(jsonPath("$.data.content[0].sender_name").value("서울 도서관"))
+                .andExpect(jsonPath("$.data.content[0].is_read").value(false))
+                .andExpect(jsonPath("$.data.content[1].id").value(2))
+                .andExpect(jsonPath("$.data.content[1].title").value("요양원 입니다."))
+                .andExpect(jsonPath("$.data.content[1].sender_name").value("서울 요양원"))
+                .andExpect(jsonPath("$.data.content[1].is_read").value(true))
+                .andExpect(jsonPath("$.data.pageable.pageNumber").value(0))
+                .andExpect(jsonPath("$.data.pageable.pageSize").value(6))
+                .andExpect(jsonPath("$.data.totalElements").value(2));
+    }
+}
diff --git a/src/test/java/com/somemore/note/repository/NoteRepositoryImplTest.java b/src/test/java/com/somemore/note/repository/NoteRepositoryImplTest.java
diff --git a/src/test/java/com/somemore/note/service/NoteQueryServiceTest.java b/src/test/java/com/somemore/note/service/NoteQueryServiceTest.java
