[REFACTOR] 검색 디렉토리 분리 및 쿼리 리팩토링 (#341)

* refactor(search): 검색 기능 분리 및 elastic 서버 연결 유무에 따른 api 수정

- elastic search enabled = true -> elastic search 검색
- elastic search enabled = false -> rdb 검색
- elastic search healthcheck를 통한 서버 연결 확인 기능 추가

* test(search): 검색 기능 분리 및 elastic 서버 연결 유무에 따라 test 수정 및 추가

- elastic search enabled = true -> test 실행 (local에서 테스트 시 사용 예정)
- elastic search enabled = false -> test ignore

* test(search): import 수정

* test(search): controller test 수정

- elastic search 서버 연결 여부에 따른 분기 추가

* refactor(search): 커뮤니티 Document 필드 추가

- writerNickname, createdAt 필드 추가
- elastic search 검색 조건에 writerNickname 및 가중치 추가

* refactor(search): 커뮤니티 검색 쿼리 수정

- ResponseDto에 fromDocument 추가
- 기존) elastic search에서 검색 결과 글 id 반환 -> id로 rdb에서 검색 후 communityBoardView 반환
  수정) elastic search 검색 결과인 communityDocument 전체 반환

* test(search): 커뮤니티 검색 리팩토링에 따른 test 수정

* refactor(search): 커뮤니티 Document updatedAt 필드 추가

* refactor(search): 커뮤니티 게시글 findAll() -> findAllByDeletedFalse()

- elasticsearch 저장을 위한 전체 게시글 조회 메서드 변경

* refactor(search): 개행 수정

* refactor(search): 커뮤니티 검색 test를 위한 delete 메서드 수정

* feat(center): center id로 기관명 조회하는 로직 추가

* test(center): center id로 기관명 조회하는 로직 test 추가

* refactor(search): community elastic search 검색 메서드명 변경

* refactor(search): 커뮤니티 게시글 검색 쿼리 수정

- 유사어 검색 쿼리 추가

* refactor(search): 봉사활동 모집글 document 필드 추가 및 responseDto에 fromDocument 추가

- RecruitBoardWithCenterResponseDto, RecruitBoardDetailResponseDto에 포함되는 필드 모두 추가
- RecruitBoardWithCenterResponseDto, RecruitBoardDetailResponseDto에 fromDocument 추가

* refactor(recruit_board): 기존 findAll() -> findAllByDeletedFalse() 수정

- elasticsearch index 저장을 위한 전체 데이터 조회 시 deleted 조건 추가

* refactor(search): 봉사활동 모집글 검색 쿼리 리팩토링

- 기존) elastic search에서 검색 결과 글 id 반환 -> id로 rdb에서 검색 후 반환
  수정) elastic search 검색 결과인 recruitBoardDocument 전체 반환
- 근처 모집글 검색의 경우 elastic search의 geo_point로 매핑하여 검색하도록 리팩토링
- 유사어 검색 쿼리 추가

* test(search): scheduler test 수정

* refactor(search): 중복 코드 추출

* refactor(search): 미구현 코드 recruitboard로 이동

- 특정 기관 모집글 조회 RecruitBoardQueryApiController로 이동 (추후 개발 후 다시 이동)

* test(search): 봉사활동 모집글 검색 쿼리 리팩토링에 따른 test 수정

* fix(search): search 디렉토리 커버리지 제외

* refactor(search): 불필요한 코드 삭제

* refactor(search): 코드리뷰 사항 반영

- findDynamicField -> findDynamicFieldByCenterId 네이밍 수정
- recruitboard 조회 쿼리문 형식 수정
- elastic search 활성화 확인 어노테이션 생성 및 적용
- 검색 컨트롤러 else 제거
- elastic search 저장 scheduler 로직 순서 수정 (활성화 체크 우선)
-

* refactor(search): 소나큐브 반영

- 불필요한 import 제거
- null 처리 추가

Author: ayoung-dev

build.gradle

@@ -139,7 +139,8 @@ def jacocoExcludePatterns = [
         '**/event/**',
         '**/*Aspect*',
         '**/Aspect/*',
-        '**/utils/*'
+        '**/utils/*',
+        '**/search/**'
 ]
 
 def jacocoExcludePatternsForVerify = [
@@ -161,7 +162,8 @@ def jacocoExcludePatternsForVerify = [
         '*.*event*.*',
         '*.*Aspect*',
         '*.Aspect.*',
-        '*.utils.*'
+        '*.utils.*',
+        '*.search.*'
 ]
 
 jacocoTestReport {

src/main/java/com/somemore/domains/center/repository/center/CenterRepository.java

@@ -21,4 +21,6 @@ default boolean doesNotExistById(UUID id) {
     List<CenterOverviewInfo> findCenterOverviewsByIds(List<UUID> ids);
 
     void deleteAllInBatch();
+
+    String findNameById(UUID id);
 }

src/main/java/com/somemore/domains/center/repository/center/CenterRepositoryImpl.java

@@ -1,5 +1,6 @@
 package com.somemore.domains.center.repository.center;
 
+import com.querydsl.core.types.Path;
 import com.querydsl.core.types.Projections;
 import com.querydsl.core.types.dsl.BooleanExpression;
 import com.querydsl.jpa.impl.JPAQueryFactory;
@@ -66,7 +67,27 @@ public void deleteAllInBatch() {
         centerJpaRepository.deleteAllInBatch();
     }
 
+    @Override
+    public String findNameById(UUID id) {
+        return findDynamicFieldByCenterId(id, center.name)
+                .orElse(null);
+    }
+
     private static BooleanExpression isNotDeleted() {
         return center.deleted.isFalse();
     }
+
+    private <T> Optional<T> findDynamicFieldByCenterId(UUID id, Path<T> field) {
+
+        return Optional.ofNullable(
+                queryFactory
+                        .select(field)
+                        .from(center)
+                        .where(
+                                center.id.eq(id),
+                                isNotDeleted()
+                        )
+                        .fetchOne()
+        );
+    }
 }

src/main/java/com/somemore/domains/center/service/query/CenterQueryService.java

@@ -46,6 +46,17 @@ public void validateCenterExists(UUID id) {
         }
     }
 
+    @Override
+    public String getNameById(UUID id) {
+        String name = centerRepository.findNameById(id);
+
+        if (name == null || name.isBlank()) {
+            throw new BadRequestException(NOT_EXISTS_CENTER);
+        }
+
+        return name;
+    }
+
     private Center getCenterById(UUID centerId) {
         return centerRepository.findCenterById(centerId)
                 .orElseThrow(() -> new BadRequestException(NOT_EXISTS_CENTER.getMessage()));

src/main/java/com/somemore/domains/center/usecase/query/CenterQueryUseCase.java

@@ -12,4 +12,5 @@ public interface CenterQueryUseCase {
     List<CenterOverviewInfo> getCenterOverviewsByIds(List<UUID> centerIds);
 
     void validateCenterExists(UUID centerId);
+    String getNameById(UUID id);
 }

src/main/java/com/somemore/domains/community/controller/CommunityBoardQueryApiController.java

@@ -12,7 +12,6 @@
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.UUID;
@@ -24,7 +23,6 @@
 public class CommunityBoardQueryApiController {
 
     private final CommunityBoardQueryUseCase communityBoardQueryUseCase;
-//    private final CommunityBoardDocumentUseCase communityBoardDocumentUseCase;
 
     @GetMapping("/community-boards")
     @Operation(summary = "전체 커뮤니티 게시글 조회", description = "전체 커뮤니티 게시글 목록을 조회합니다.")
@@ -51,32 +49,6 @@ public ApiResponse<Page<CommunityBoardResponseDto>> getByWriterId(
         );
     }
 
-//    @GetMapping("/community-boards/search")
-//    @Operation(summary = "커뮤니티 게시글 키워드 검색", description = "키워드로 포함한 커뮤니티 게시글 목록을 조회합니다.")
-//    public ApiResponse<Page<CommunityBoardResponseDto>> getCommunityBoardsBySearch(
-//            String keyword,
-//            Pageable pageable
-//    ) {
-//        return ApiResponse.ok(
-//                200,
-//                communityBoardDocumentUseCase.getCommunityBoardBySearch(keyword, pageable.getPageNumber()),
-//                "커뮤니티 게시글 검색 리스트 조회 성공"
-//        );
-//    }
-
-    @GetMapping("/community-boards/search")
-    @Operation(summary = "커뮤니티 게시글 키워드 검색", description = "키워드를 포함한 커뮤니티 게시글 목록을 조회합니다.")
-    public ApiResponse<Page<CommunityBoardResponseDto>> getCommunityBoardsBySearch(
-            @RequestParam String keyword,
-            Pageable pageable
-    ) {
-        return ApiResponse.ok(
-                200,
-                communityBoardQueryUseCase.getCommunityBoards(keyword, pageable.getPageNumber()),
-                "커뮤니티 게시글 검색 리스트 조회 성공"
-        );
-    }
-
     @GetMapping("/community-board/{id}")
     @Operation(summary = "커뮤니티 게시글 상세 조회", description = "커뮤니티 게시글의 상세 정보를 조회합니다.")
     public ApiResponse<CommunityBoardDetailResponseDto> getById(

src/main/java/com/somemore/domains/community/domain/CommunityBoardDocument.java

@@ -17,7 +17,6 @@
 
 import static lombok.AccessLevel.PROTECTED;
 
-
 @Getter
 @NoArgsConstructor(access = PROTECTED)
 @Entity

src/main/java/com/somemore/domains/community/domain/CommunityComment.java

@@ -3,6 +3,7 @@
 import com.fasterxml.jackson.databind.PropertyNamingStrategies.SnakeCaseStrategy;
 import com.fasterxml.jackson.databind.annotation.JsonNaming;
 import com.somemore.domains.community.repository.mapper.CommunityBoardView;
+import com.somemore.domains.search.domain.CommunityBoardDocument;
 import io.swagger.v3.oas.annotations.media.Schema;
 
 import java.time.LocalDateTime;
@@ -12,9 +13,9 @@
 public record CommunityBoardResponseDto(
         @Schema(description = "커뮤니티 게시글 ID", example = "12")
         Long id,
-        @Schema(description = "커뮤니티 게시글 ID", example = "12")
+        @Schema(description = "커뮤니티 게시글 제목", example = "11/29 OO도서관 봉사 같이 갈 사람 모집합니다.")
         String title,
-        @Schema(description = "작성자(봉사자) ID", example = "123e4567-e89b-12d3-a456-426614174000")
+        @Schema(description = "작성자(봉사자) 닉네임", example = "나는야 봉사왕")
         String writerNickname,
         @Schema(description = "커뮤니티 게시글 생성 일시", example = "2023-12-02T11:00:00")
         LocalDateTime createdAt
@@ -27,5 +28,13 @@ public static CommunityBoardResponseDto from(CommunityBoardView board) {
                 board.communityBoard().getCreatedAt()
         );
     }
-}
 
+    public static CommunityBoardResponseDto fromDocument(CommunityBoardDocument board) {
+        return new CommunityBoardResponseDto(
+                board.getId(),
+                board.getTitle(),
+                board.getWriterNickname(),
+                board.getCreatedAt()
+        );
+    }
+}