Merge pull request #285 from Clokey-dev/feat/#269-search-sync-api

2ghrms · web-flow · commit 29c96ec0e499 · 2026-01-24T20:17:00.000-06:00
[feat/#259] 검색 탭 추천 API 개발
diff --git a/clokey-api/src/main/java/org/clokey/domain/history/repository/HistoryRepository.java b/clokey-api/src/main/java/org/clokey/domain/history/repository/HistoryRepository.java
@@ -2,6 +2,7 @@
 
 import java.util.List;
 import java.util.Optional;
+import java.util.Set;
 import org.clokey.history.entity.History;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Query;
@@ -29,6 +30,7 @@ and FUNCTION('MONTH', h.historyDate) = :month
     @Query("SELECT h.id FROM History h")
     List<Long> findAllIds();
 
+    @Deprecated
     @Query(
             """
         select new org.clokey.domain.history.repository.HistoryRepository$HistorySituationInfo(
@@ -41,4 +43,13 @@ and FUNCTION('MONTH', h.historyDate) = :month
     List<HistorySituationInfo> findSituationInfoByHistoryIds(List<Long> historyIds);
 
     record HistorySituationInfo(Long historyId, Long situationId, String situationName) {}
+
+    @Query(
+            """
+            SELECT h.id FROM History h
+            JOIN h.member m
+            WHERE h.id IN :historyIds
+            AND (h.banned = true OR m.memberStatus = 'BANNED')
+            """)
+    Set<Long> findBannedHistoryIdsAmong(List<Long> historyIds);
 }
diff --git a/clokey-api/src/main/java/org/clokey/domain/search/controller/SearchController.java b/clokey-api/src/main/java/org/clokey/domain/search/controller/SearchController.java
@@ -10,6 +10,7 @@
 import org.clokey.domain.cloth.dto.response.ClothListResponse;
 import org.clokey.domain.search.dto.response.SearchedHistoryResponse;
 import org.clokey.domain.search.dto.response.SearchedMemberResponse;
+import org.clokey.domain.search.dto.response.SearchingRecommendResponse;
 import org.clokey.domain.search.enums.HistorySearchSortType;
 import org.clokey.domain.search.service.SearchService;
 import org.clokey.global.annotation.PageSize;
@@ -126,16 +127,13 @@ public BaseResponse<Void> unSyncAllMembers() {
         return BaseResponse.onSuccess(GlobalBaseSuccessCode.OK, null);
     }
 
-    /* :TODO: 검색 탭 추천 API 추후 구현
     @GetMapping("/recommendations")
     @Operation(
             operationId = "Search_recommendInSearching",
             summary = "검색 탭 기록 추천",
             description = "검색탭에서 사용자가 시도하지 않은 스타일별/자주 착용한 카테고리/최근 태그한 해시태그별 1개씩의 기록울 추천하는 API입니다.")
     public BaseResponse<List<SearchingRecommendResponse>> recommendInSearching() {
-        List<SearchingRecommendResponse> response =
-                searchService.recommendInSearching();
+        List<SearchingRecommendResponse> response = searchService.recommendInSearching();
         return BaseResponse.onSuccess(GlobalBaseSuccessCode.OK, response);
     }
-    */
 }
diff --git a/clokey-api/src/main/java/org/clokey/domain/search/dto/response/SearchingRecommendResponse.java b/clokey-api/src/main/java/org/clokey/domain/search/dto/response/SearchingRecommendResponse.java
@@ -1,4 +1,9 @@
 package org.clokey.domain.search.dto.response;
 
 public record SearchingRecommendResponse(
-        Long historyId, String recommendType, String title, String subTitle, String imageUrl) {}
+        Long historyId,
+        Long memberId,
+        String recommendType,
+        String title,
+        String subTitle,
+        String imageUrl) {}
diff --git a/clokey-api/src/main/java/org/clokey/domain/search/enums/RecommendType.java b/clokey-api/src/main/java/org/clokey/domain/search/enums/RecommendType.java
@@ -1,7 +1,14 @@
 package org.clokey.domain.search.enums;
 
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@Getter
+@RequiredArgsConstructor
 public enum RecommendType {
-    STYLE,
-    SEASON,
-    RECENT_FREQUENT_CATEGORY
+    UNTRIED_STYLE("분위기 전환이 필요할 때"),
+    FREQUENTLY_WORN_CATEGORY("언제 입어도 찰떡인"),
+    RECENTLY_USED_HASHTAG("최근 자주 입으시는");
+
+    private final String title;
 }
diff --git a/clokey-api/src/main/java/org/clokey/domain/search/event/ClothDeleteEventListener.java b/clokey-api/src/main/java/org/clokey/domain/search/event/ClothDeleteEventListener.java
@@ -7,13 +7,15 @@
 import org.clokey.domain.search.document.HistoryDocument;
 import org.clokey.domain.search.repository.SearchRepository;
 import org.clokey.domain.search.service.SearchDocumentServiceImpl;
+import org.springframework.context.annotation.Profile;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.event.TransactionPhase;
 import org.springframework.transaction.event.TransactionalEventListener;
 
 @Slf4j
 @Component
 @RequiredArgsConstructor
+@Profile("prod")
 public class ClothDeleteEventListener {
 
     private final SearchRepository searchRepository;
diff --git a/clokey-api/src/main/java/org/clokey/domain/search/event/HistoryDeleteEventListener.java b/clokey-api/src/main/java/org/clokey/domain/search/event/HistoryDeleteEventListener.java
@@ -3,13 +3,15 @@
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.clokey.domain.search.repository.SearchRepository;
+import org.springframework.context.annotation.Profile;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.event.TransactionPhase;
 import org.springframework.transaction.event.TransactionalEventListener;
 
 @Slf4j
 @Component
 @RequiredArgsConstructor
+@Profile("prod")
 public class HistoryDeleteEventListener {
 
     private final SearchRepository searchRepository;
diff --git a/clokey-api/src/main/java/org/clokey/domain/search/event/MeiliSearchSyncEventListener.java b/clokey-api/src/main/java/org/clokey/domain/search/event/MeiliSearchSyncEventListener.java
@@ -7,6 +7,7 @@
 import org.clokey.domain.search.document.MemberDocument;
 import org.clokey.domain.search.repository.SearchRepository;
 import org.clokey.domain.search.service.SearchDocumentServiceImpl;
+import org.springframework.context.annotation.Profile;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.event.TransactionPhase;
@@ -15,6 +16,7 @@
 @Slf4j
 @Component
 @RequiredArgsConstructor
+@Profile("prod")
 public class MeiliSearchSyncEventListener {
 
     private final SearchRepository searchRepository;
diff --git a/clokey-api/src/main/java/org/clokey/domain/search/event/MemberDeleteEventListener.java b/clokey-api/src/main/java/org/clokey/domain/search/event/MemberDeleteEventListener.java
@@ -3,19 +3,19 @@
 import java.util.List;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.clokey.domain.history.repository.HistoryRepository;
 import org.clokey.domain.search.repository.SearchRepository;
+import org.springframework.context.annotation.Profile;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.event.TransactionPhase;
 import org.springframework.transaction.event.TransactionalEventListener;
 
 @Slf4j
 @Component
 @RequiredArgsConstructor
+@Profile("prod")
 public class MemberDeleteEventListener {
 
     private final SearchRepository searchRepository;
-    private final HistoryRepository historyRepository;
 
     @TransactionalEventListener(
             classes = MemberDeleteEvent.class,
diff --git a/clokey-api/src/main/java/org/clokey/domain/search/repository/RecommendHistoryRow.java b/clokey-api/src/main/java/org/clokey/domain/search/repository/RecommendHistoryRow.java
@@ -0,0 +1,3 @@
+package org.clokey.domain.search.repository;
+
+public record RecommendHistoryRow(Long historyId, String subTitle, Long memberId) {}
diff --git a/clokey-api/src/main/java/org/clokey/domain/search/repository/SearchRecommendRepositoryCustom.java b/clokey-api/src/main/java/org/clokey/domain/search/repository/SearchRecommendRepositoryCustom.java
@@ -0,0 +1,21 @@
+package org.clokey.domain.search.repository;
+
+import java.util.List;
+import java.util.Optional;
+import java.util.Set;
+
+public interface SearchRecommendRepositoryCustom {
+
+    Optional<RecommendHistoryRow> findBestHistoryForUntriedStyle(
+            List<Long> excludedMemberIds, Set<Long> userUsedStyleIds);
+
+    Optional<RecommendHistoryRow> findBestHistoryForCategory(
+            List<Long> excludedMemberIds, String categoryName);
+
+    Optional<RecommendHistoryRow> findBestHistoryForHashtag(
+            List<Long> excludedMemberIds, String hashtagName);
+
+    Optional<String> findTopCategoryNameByHistoryIds(List<Long> memberHistoryIds);
+
+    Optional<String> findMostRecentHashtagNameByMemberId(Long memberId);
+}
diff --git a/clokey-api/src/main/java/org/clokey/domain/search/repository/SearchRecommendRepositoryCustomImpl.java b/clokey-api/src/main/java/org/clokey/domain/search/repository/SearchRecommendRepositoryCustomImpl.java
@@ -0,0 +1,172 @@
+package org.clokey.domain.search.repository;
+
+import static org.clokey.category.entity.QCategory.category;
+import static org.clokey.cloth.entity.QCloth.cloth;
+import static org.clokey.history.entity.QHashtag.hashtag;
+import static org.clokey.history.entity.QHistory.history;
+import static org.clokey.history.entity.QHistoryClothTag.historyClothTag;
+import static org.clokey.history.entity.QHistoryHashtag.historyHashtag;
+import static org.clokey.history.entity.QHistoryImage.historyImage;
+import static org.clokey.history.entity.QHistoryStyle.historyStyle;
+import static org.clokey.history.entity.QStyle.style;
+import static org.clokey.like.entity.QMemberLike.memberLike;
+import static org.clokey.member.entity.QMember.member;
+
+import com.querydsl.core.types.Projections;
+import com.querydsl.core.types.dsl.BooleanExpression;
+import com.querydsl.core.types.dsl.Expressions;
+import com.querydsl.jpa.impl.JPAQueryFactory;
+import java.util.List;
+import java.util.Optional;
+import java.util.Set;
+import lombok.RequiredArgsConstructor;
+import org.clokey.member.enums.MemberStatus;
+import org.springframework.stereotype.Repository;
+
+@Repository
+@RequiredArgsConstructor
+public class SearchRecommendRepositoryCustomImpl implements SearchRecommendRepositoryCustom {
+
+    private final JPAQueryFactory queryFactory;
+
+    @Override
+    public Optional<RecommendHistoryRow> findBestHistoryForUntriedStyle(
+            List<Long> excludedMemberIds, Set<Long> userUsedStyleIds) {
+        RecommendHistoryRow row =
+                queryFactory
+                        .select(
+                                Projections.constructor(
+                                        RecommendHistoryRow.class,
+                                        history.id,
+                                        style.name.min(),
+                                        member.id))
+                        .from(history)
+                        .join(history.member, member)
+                        .join(historyStyle)
+                        .on(historyStyle.history.eq(history))
+                        .join(historyStyle.style, style)
+                        .leftJoin(memberLike)
+                        .on(memberLike.history.eq(history))
+                        .where(
+                                history.banned.isFalse(),
+                                member.memberStatus.ne(MemberStatus.BANNED),
+                                excludedMemberCondition(excludedMemberIds),
+                                untriedStyleCondition(userUsedStyleIds))
+                        .groupBy(history.id)
+                        .orderBy(memberLike.id.count().desc())
+                        .limit(1)
+                        .fetchOne();
+        return Optional.ofNullable(row);
+    }
+
+    @Override
+    public Optional<RecommendHistoryRow> findBestHistoryForCategory(
+            List<Long> excludedMemberIds, String categoryName) {
+        RecommendHistoryRow row =
+                queryFactory
+                        .select(
+                                Projections.constructor(
+                                        RecommendHistoryRow.class,
+                                        history.id,
+                                        Expressions.constant(categoryName),
+                                        member.id))
+                        .from(history)
+                        .join(history.member, member)
+                        .join(history.historyImages, historyImage)
+                        .join(historyClothTag)
+                        .on(historyClothTag.historyImage.eq(historyImage))
+                        .join(historyClothTag.cloth, cloth)
+                        .join(cloth.category, category)
+                        .leftJoin(memberLike)
+                        .on(memberLike.history.eq(history))
+                        .where(
+                                history.banned.isFalse(),
+                                member.memberStatus.ne(MemberStatus.BANNED),
+                                excludedMemberCondition(excludedMemberIds),
+                                category.name.eq(categoryName))
+                        .groupBy(history.id)
+                        .orderBy(memberLike.id.count().desc())
+                        .limit(1)
+                        .fetchOne();
+        return Optional.ofNullable(row);
+    }
+
+    @Override
+    public Optional<RecommendHistoryRow> findBestHistoryForHashtag(
+            List<Long> excludedMemberIds, String hashtagName) {
+        RecommendHistoryRow row =
+                queryFactory
+                        .select(
+                                Projections.constructor(
+                                        RecommendHistoryRow.class,
+                                        history.id,
+                                        Expressions.constant(hashtagName),
+                                        member.id))
+                        .from(history)
+                        .join(history.member, member)
+                        .join(historyHashtag)
+                        .on(historyHashtag.history.eq(history))
+                        .join(historyHashtag.hashtag, hashtag)
+                        .leftJoin(memberLike)
+                        .on(memberLike.history.eq(history))
+                        .where(
+                                history.banned.isFalse(),
+                                member.memberStatus.ne(MemberStatus.BANNED),
+                                excludedMemberCondition(excludedMemberIds),
+                                hashtag.name.eq(hashtagName))
+                        .groupBy(history.id)
+                        .orderBy(memberLike.id.count().desc())
+                        .limit(1)
+                        .fetchOne();
+        return Optional.ofNullable(row);
+    }
+
+    @Override
+    public Optional<String> findTopCategoryNameByHistoryIds(List<Long> memberHistoryIds) {
+        if (memberHistoryIds == null || memberHistoryIds.isEmpty()) {
+            return Optional.empty();
+        }
+        List<String> names =
+                queryFactory
+                        .select(category.name)
+                        .from(historyClothTag)
+                        .join(historyClothTag.historyImage, historyImage)
+                        .join(historyClothTag.cloth, cloth)
+                        .join(cloth.category, category)
+                        .where(historyImage.history.id.in(memberHistoryIds))
+                        .groupBy(category.id, category.name)
+                        .orderBy(category.id.count().desc())
+                        .limit(1)
+                        .fetch();
+        return names.isEmpty() ? Optional.empty() : Optional.of(names.get(0));
+    }
+
+    @Override
+    public Optional<String> findMostRecentHashtagNameByMemberId(Long memberId) {
+        List<String> names =
+                queryFactory
+                        .select(hashtag.name)
+                        .from(historyHashtag)
+                        .join(historyHashtag.history, history)
+                        .join(historyHashtag.hashtag, hashtag)
+                        .where(history.member.id.eq(memberId))
+                        .orderBy(historyHashtag.createdAt.desc())
+                        .limit(1)
+                        .fetch();
+        return names.isEmpty() ? Optional.empty() : Optional.of(names.get(0));
+    }
+
+    private BooleanExpression excludedMemberCondition(List<Long> excludedMemberIds) {
+        if (excludedMemberIds == null || excludedMemberIds.isEmpty()) {
+            return null;
+        }
+        return member.id.notIn(excludedMemberIds);
+    }
+
+    private BooleanExpression untriedStyleCondition(Set<Long> userUsedStyleIds) {
+        if (userUsedStyleIds == null || userUsedStyleIds.isEmpty()) {
+            return null;
+        }
+        return style.id.notIn(userUsedStyleIds);
+    }
+}
diff --git a/clokey-api/src/main/java/org/clokey/domain/search/service/SearchService.java b/clokey-api/src/main/java/org/clokey/domain/search/service/SearchService.java
@@ -5,6 +5,7 @@
 import org.clokey.domain.cloth.dto.response.ClothListResponse;
 import org.clokey.domain.search.dto.response.SearchedHistoryResponse;
 import org.clokey.domain.search.dto.response.SearchedMemberResponse;
+import org.clokey.domain.search.dto.response.SearchingRecommendResponse;
 import org.clokey.domain.search.enums.HistorySearchSortType;
 import org.clokey.global.paging.SortDirection;
 import org.clokey.response.SliceResponse;
@@ -33,6 +34,5 @@ SliceResponse<SearchedMemberResponse> searchUserByClokeyIdAndNickname(
 
     void unSyncAllMembers();
 
-    // TODO : 추천 검색어 기능 구현 후 주석 해제
-    //    List<SearchingRecommendResponse> recommendInSearching();
+    List<SearchingRecommendResponse> recommendInSearching();
 }
diff --git a/clokey-api/src/main/java/org/clokey/domain/search/service/SearchServiceImpl.java b/clokey-api/src/main/java/org/clokey/domain/search/service/SearchServiceImpl.java
diff --git a/documentation/feature/Redis 사용.md b/documentation/feature/Redis 사용.md

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+package org.clokey.domain.search.repository;`
	`2`	`+`
	`3`	`+public record RecommendHistoryRow(Long historyId, String subTitle, Long memberId) {}`