Merge pull request #89 from SWYP-mingling/fix/SW-94-cacheable-runtime-exception

[SW-94] fix: 장소추천 API 런타임 오류 수정

Author: Yongseok-2

src/main/java/swyp/mingling/domain/meeting/dto/response/midpoint/GetMidPointResponse.java

@@ -23,6 +23,12 @@ public class GetMidPointResponse {
     @Schema(description = "경도", example = "126.9236")
     private double longitude;
 
+    @Schema(description = "장소가 가장 많은지 여부")
+    private boolean isHot;
+
+    @Schema(description = "주변 장소 개수")
+    private Integer placeCount;
+
     @Schema(description = "사용자 목록")
     List<UserRouteDto> userRoutes;
 }

src/main/java/swyp/mingling/domain/meeting/dto/response/midpoint/MidPointCandidate.java

@@ -2,14 +2,21 @@
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;
-import java.util.List;
 import swyp.mingling.domain.subway.dto.SubwayRouteInfo;
 
+import java.util.List;
+
 @Getter
 @AllArgsConstructor
 public class MidPointCandidate {
 
     private List<SubwayRouteInfo> routes; // 해당 번화가로 가는 모든 사람의 경로
     private int deviation;                // 이동시간 편차
     private int avgTime;                  // 평균 이동시간 or 총합
+    private boolean isHot;                // 가장 장소가 많은 곳
+    private int placeCount;               // 주변 장소 개수
+
+    public void setHot(boolean hot) {
+        isHot = hot;
+    }
 }

src/main/java/swyp/mingling/domain/meeting/repository/MeetingRepository.java

@@ -7,6 +7,7 @@
 import swyp.mingling.domain.meeting.entity.Meeting;
 
 import java.util.List;
+import java.util.Optional;
 import java.util.UUID;
 
 /**
@@ -21,4 +22,10 @@ public interface MeetingRepository extends JpaRepository<Meeting, UUID> {
         WHERE m.id = :meetingId and p.departure is not null
     """)
      List<DepartureListResponse> findDeparturesAndNicknameByMeetingId(@Param("meetingId") UUID meetingId);
+
+     @Query("SELECT mp.name FROM Meeting m " +
+             "JOIN m.purposeMappings mpm " +
+             "JOIN mpm.purpose mp " +
+             "WHERE m.id = :meetingId")
+     Optional<String> findPurposeNamesByMeetingId(@Param("meetingId") UUID meetingId);
 }

src/main/java/swyp/mingling/domain/meeting/service/MidPointAsyncUseCase.java

@@ -114,7 +114,7 @@ public List<GetMidPointResponse> execute(UUID meetingId) {
             int avgTime = sum / routes.size();
 
             candidates.add(
-                    new MidPointCandidate(routes, deviation, avgTime)
+                    new MidPointCandidate(routes, deviation, avgTime, false, 0)
             );
         }
 
@@ -173,6 +173,7 @@ public List<GetMidPointResponse> execute(UUID meetingId) {
                             .endStation(endStationName)
                             .latitude(findStationCoordinateUseCase.excute(endStationName).getLatitude())
                             .longitude(findStationCoordinateUseCase.excute(endStationName).getLongitude())
+
                             .userRoutes(userRouteDtos)
                             .build();
                 })

src/main/java/swyp/mingling/domain/meeting/service/MidPointUseCase.java

@@ -1,8 +1,5 @@
 package swyp.mingling.domain.meeting.service;
 
-import java.util.Arrays;
-import java.util.List;
-import java.util.Optional;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -14,6 +11,10 @@
 import swyp.mingling.global.enums.KakaoCategoryGroupCode;
 import swyp.mingling.global.exception.BusinessException;
 
+import java.util.Arrays;
+import java.util.List;
+import java.util.Optional;
+
 /**
  * 장소 추천 UseCase
  */
@@ -130,8 +131,10 @@ static Optional<Category> from(String category) {
                 return Optional.empty();
             }
 
+            String categoryWithoutSpaces = category.replaceAll("\\s+", "");
+
             return Arrays.stream(values())
-                .filter(c -> c.categoryName.equals(category))
+                .filter(c -> c.categoryName.equals(categoryWithoutSpaces))
                 .findFirst();
         }
     }

src/main/java/swyp/mingling/domain/meeting/service/RecommendPlaceUseCase.java

@@ -0,0 +1,94 @@
+package swyp.mingling.domain.meeting.service;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import swyp.mingling.external.KakaoPlaceClient;
+import swyp.mingling.external.dto.response.KakaoPlaceSearchResponse;
+import swyp.mingling.global.enums.KakaoCategoryGroupCode;
+import swyp.mingling.global.exception.BusinessException;
+
+import java.util.Arrays;
+import java.util.Optional;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class SearchPlaceCountUseCase {
+
+    private final KakaoPlaceClient kakaoPlaceClient;
+
+    public KakaoPlaceSearchResponse execute(String midPlace, String category, int page, int size) {
+
+    log.info("[CACHE MISS] Call Kakao place search API - midPlace: {}, category: {}, page: {}, size: {}"
+                    , midPlace, category, page, size);
+
+    // 1. 카테고리 한글명을 카카오 카테고리 그룹 코드로 변환
+        SearchPlaceCountUseCase.Categorysub categoryEnum = SearchPlaceCountUseCase.Categorysub.from(category)
+            .orElseThrow(BusinessException::purposeNotFound);
+
+    // 2. 검색어 생성
+    String query = buildSearchQuery(midPlace, categoryEnum);
+
+    // 3. 카카오 장소 검색 API 호출
+     KakaoPlaceSearchResponse response =
+            kakaoPlaceClient.search(
+                    query,
+                    categoryEnum.getKakaoCode(),
+                    page,
+                    size
+            );
+
+     return response;
+    }
+    /**
+     * 중간 지점 키워드와 카테고리를 조합해 카카오 장소 검색에 사용할 검색어를 생성
+     *
+     * @param midPlace 중간 지점 키워드 (예: "합정역")
+     * @param category 모임 목적 카테고리
+     * @return 카카오 장소 검색에 사용할 검색 쿼리 문자열
+     */
+    private String buildSearchQuery(String midPlace, SearchPlaceCountUseCase.Categorysub category) {
+        return midPlace + " " + category.getQueryKeyword();
+    }
+
+    /**
+     * 모임 목적 카테고리
+     * 외부에서 전달된 한글 카테고리를 기준으로 카카오 장소 검색 API 에서 사용할 category_group_code 로 변환하기 위한 내부 ENUM
+     */
+    @Getter
+    @RequiredArgsConstructor
+    private enum Categorysub {
+
+        RESTAURANT("식당", "맛집", KakaoCategoryGroupCode.RESTAURANT.getCode()),
+        CAFE("카페", "카페", KakaoCategoryGroupCode.CAFE.getCode()),
+        BAR("술집", "술집", KakaoCategoryGroupCode.RESTAURANT.getCode()),
+        STUDY_CAFE("스터디카페", "스터디카페", null),
+        SPACE_RENTAL("장소대여", "모임공간", null),
+        ENTERTAINMENT("놀거리", "실내데이트", null);
+
+        private final String categoryName;
+        private final String queryKeyword;
+        private final String kakaoCode;
+
+        /**
+         * 외부에서 전달된 카테고리 문자열을 Category 를 enum 으로 변환
+         *
+         * @param category 외부 요청으로 전달된 카테고리 문자열
+         * @return 일치하는 Optional<Category>
+         */
+        static Optional<SearchPlaceCountUseCase.Categorysub> from(String category) {
+            if (category == null || category.isBlank()) {
+                return Optional.empty();
+            }
+
+            String categoryWithoutSpaces = category.replaceAll("\\s+", "");
+
+            return Arrays.stream(values())
+                    .filter(c -> c.categoryName.equals(categoryWithoutSpaces))
+                    .findFirst();
+        }
+    }
+}
+

src/main/java/swyp/mingling/domain/meeting/service/SearchPlaceCountUseCase.java

@@ -60,8 +60,9 @@ public void execute(UUID meetingId,
         } else {
             // 새로운 참여자인 경우, 실제 참여자 수 체크
             long currentParticipantCount = participantRepository.countByMeetingAndIsDeletedFalse(meeting);
+            long maxParticipants = meeting.getCount();
 
-            if(currentParticipantCount >= 10) { // 참여자 MAX 값
+            if(currentParticipantCount >= maxParticipants) { // 참여자 MAX 값
                 throw BusinessException.capacityExceeded();
             }
 

src/main/java/swyp/mingling/domain/participant/service/EnterMeetingUseCase.java

@@ -21,6 +21,7 @@ public class SubwayRouteInfo {
     private final String endStation;
     private final String endStationLine;
     private final Integer totalTravelTime;
+    private final Integer placeCount;
     private final Double totalDistance;
     private final Integer transferCount;
     private final List<TransferInfo> transferPath;

src/main/java/swyp/mingling/domain/subway/dto/SubwayRouteInfo.java

@@ -30,12 +30,12 @@ public SubwayRouteInfo parse(SeoulMetroRouteResponse response) {
 
         List<SeoulMetroRouteResponse.PathInfo> pathList = response.getPathInfoList();
 
-        // 출발역 = 첫 번째 경로의 출발역
-        String startStation = pathList.get(0).getDptreStn().getStnNm();
+        // 출발역 = 첫 번째 경로의 출발역 (역 이름 정규화: "역" 제거)
+        String startStation = normalizeStationName(pathList.get(0).getDptreStn().getStnNm());
         String startStationLine = formatLineNumber(pathList.get(0).getDptreStn().getLineNm());
 
-        // 도착역 = 마지막 경로의 도착역
-        String endStation = pathList.get(pathList.size() - 1).getArvlStn().getStnNm();
+        // 도착역 = 마지막 경로의 도착역 (역 이름 정규화: "역" 제거)
+        String endStation = normalizeStationName(pathList.get(pathList.size() - 1).getArvlStn().getStnNm());
         String endStationLine = formatLineNumber(pathList.get(pathList.size() - 1).getArvlStn().getLineNm());
 
         // 총 이동 시간 (초 → 분 변환)
@@ -82,7 +82,7 @@ private List<SubwayRouteInfo.StationInfo> buildStationInfoList(
             // 출발역 추가 (첫 번째 경로일 때만)
             if (i == 0) {
                 stations.add(SubwayRouteInfo.StationInfo.builder()
-                        .stationName(path.getDptreStn().getStnNm())
+                        .stationName(normalizeStationName(path.getDptreStn().getStnNm()))
                         .lineNumber(formatLineNumber(path.getDptreStn().getLineNm()))
                         .travelTime(0)
                         .isTransfer(false)
@@ -94,12 +94,15 @@ private List<SubwayRouteInfo.StationInfo> buildStationInfoList(
             Integer travelTimeInSeconds = path.getReqHr();
             Integer travelTimeInMinutes = travelTimeInSeconds != null ? travelTimeInSeconds / 60 : 0;
 
+            String arrivalStationName = normalizeStationName(path.getArvlStn().getStnNm());
+            boolean isTransfer = "Y".equalsIgnoreCase(path.getTrsitYn());
+
             stations.add(SubwayRouteInfo.StationInfo.builder()
-                    .stationName(path.getArvlStn().getStnNm())
+                    .stationName(arrivalStationName)
                     .lineNumber(formatLineNumber(path.getArvlStn().getLineNm()))
                     .travelTime(travelTimeInMinutes)
-                    .isTransfer("Y".equalsIgnoreCase(path.getTrsitYn()))
-                    .transferStationName("Y".equalsIgnoreCase(path.getTrsitYn()) ? path.getArvlStn().getStnNm() : null)
+                    .isTransfer(isTransfer)
+                    .transferStationName(isTransfer ? arrivalStationName : null)
                     .build());
         }
 
@@ -126,7 +129,7 @@ private List<SubwayRouteInfo.TransferInfo> buildTransferPath(List<SeoulMetroRout
         // 각 경로의 도착역 호선 확인하여 변경 시 환승 정보 추가
         for (SeoulMetroRouteResponse.PathInfo path : pathList) {
             String arrivalLine = path.getArvlStn().getLineNm();
-            String arrivalStation = path.getArvlStn().getStnNm();
+            String arrivalStation = normalizeStationName(path.getArvlStn().getStnNm());
 
             // 호선이 변경되었을 때 = 환승이 발생한 경우
             if (!arrivalLine.equals(currentLine)) {
@@ -166,4 +169,21 @@ private String formatLineNumber(String lineNumber) {
         // 특수 노선 (경의중앙선, 공항철도 등)은 그대로 반환
         return lineNumber;
     }
+
+    /**
+     * @param stationName 역 이름
+     * @return 정규화된 역 이름 ("역" 제거)
+     */
+    private String normalizeStationName(String stationName) {
+        if (stationName == null || stationName.isEmpty()) {
+            return stationName;
+        }
+
+        // "역"이 끝에 붙어있으면 제거
+        if (stationName.endsWith("역")) {
+            return stationName.substring(0, stationName.length() - 1);
+        }
+
+        return stationName;
+    }
 }