[Feat] 가장 많이 검색된 책 조회 api 개발 및 책 상세 검색 시 검색카운트 업데이트 로직 추가

.github/workflows/ci-workflow.yml

@@ -35,21 +35,26 @@ jobs:
           settings-path: ${{ github.workspace }} # location for the settings.xml file
 
 
-      - name: 🧾 Create application.yml from secret
+#      - name: 🧾 Create application.yml from secret
+#        run: |
+#          mkdir -p ${{ env.RESOURCE_PATH }}
+#          mkdir -p ${{ env.TEST_RESOURCE_PATH }}
+#          echo "${{ secrets.APPLICATION_YML_DEV }}" > ${{ env.RESOURCE_PATH }}/application.yml
+#          echo "${{ secrets.APPLICATION_YML_TEST }}" > ${{ env.TEST_RESOURCE_PATH }}/application-test.yml
+      - name: 🧾 Create application.yml from secret (base64)
         run: |
           mkdir -p ${{ env.RESOURCE_PATH }}
           mkdir -p ${{ env.TEST_RESOURCE_PATH }}
-          echo "${{ secrets.APPLICATION_YML_DEV }}" > ${{ env.RESOURCE_PATH }}/application.yml
-          echo "${{ secrets.APPLICATION_YML_TEST }}" > ${{ env.TEST_RESOURCE_PATH }}/application-test.yml
-
+          echo "${{ secrets.APPLICATION_YML_DEV }}" | base64 --decode > ${{ env.RESOURCE_PATH }}/application.yml
+          echo "${{ secrets.APPLICATION_YML_TEST }}" | base64 --decode > ${{ env.TEST_RESOURCE_PATH }}/application-test.yml
 
       - name: 👏🏻 grant execute permission for gradlew
         run: chmod +x gradlew
 
-#      - name: 🚀 Start Redis
-#        uses: supercharge/redis-github-action@1.7.0
-#        with:
-#          redis-version: 7
+      - name: 🚀 Start Redis
+        uses: supercharge/redis-github-action@1.7.0
+        with:
+          redis-version: 7
 
       - name: 🐘 build with Gradle
         run: ./gradlew build

src/main/java/konkuk/thip/ThipServerApplication.java

@@ -3,8 +3,12 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @EnableJpaAuditing
+@EnableScheduling
+@EnableAsync
 @SpringBootApplication
 public class ThipServerApplication {
 

src/main/java/konkuk/thip/book/adapter/in/web/BookQueryController.java

@@ -2,8 +2,10 @@
 
 import jakarta.validation.constraints.Pattern;
 import konkuk.thip.book.adapter.in.web.response.GetBookDetailSearchResponse;
+import konkuk.thip.book.adapter.in.web.response.GetBookMostSearchResponse;
 import konkuk.thip.book.adapter.in.web.response.GetBookSearchListResponse;
 import konkuk.thip.book.application.port.in.BookSearchUseCase;
+import konkuk.thip.book.application.port.in.BookMostSearchUseCase;
 import konkuk.thip.common.dto.BaseResponse;
 import konkuk.thip.common.security.annotation.UserId;
 import lombok.RequiredArgsConstructor;
@@ -16,6 +18,8 @@
 public class BookQueryController {
 
     private final BookSearchUseCase bookSearchUseCase;
+    private final BookMostSearchUseCase bookMostSearchUseCase;
+
 
     //책 검색결과 조회
     @GetMapping("/books")
@@ -36,4 +40,11 @@ public BaseResponse<GetBookDetailSearchResponse> getBookDetailSearch(@PathVariab
         return BaseResponse.ok(GetBookDetailSearchResponse.of(bookSearchUseCase.searchDetailBooks(isbn,userId)));
     }
 
+    //가장 많이 검색된 책 조회
+    @GetMapping("/books/most-searched")
+    public BaseResponse<GetBookMostSearchResponse> getMostSearchedBooks(@UserId final Long userId) {
+
+        return BaseResponse.ok(GetBookMostSearchResponse.of(bookMostSearchUseCase.getMostSearchedBooks(userId)));
+    }
+
 }

src/main/java/konkuk/thip/book/adapter/in/web/response/GetBookMostSearchResponse.java

@@ -0,0 +1,14 @@
+package konkuk.thip.book.adapter.in.web.response;
+
+import konkuk.thip.book.application.port.in.dto.BookMostSearchResult;
+import lombok.Builder;
+
+import java.util.List;
+
+public record GetBookMostSearchResponse(
+        List<BookMostSearchResult.BookRankInfo> bookList
+) {
+    public static GetBookMostSearchResponse of(BookMostSearchResult bookMostSearchResult) {
+        return new GetBookMostSearchResponse(bookMostSearchResult.bookList());
+    }
+}

src/main/java/konkuk/thip/book/adapter/out/api/BookApiNaverApiAdapter.java

@@ -19,7 +19,7 @@ public NaverBookParseResult findBooksByKeyword(String keyword, int start) {
     }
 
     @Override
-    public NaverDetailBookParseResult findDetailBookByKeyword(String isbn) {
+    public NaverDetailBookParseResult findDetailBookByIsbn(String isbn) {
         String xml = naverApiUtil.detailSearchBook(isbn); // 네이버 API 호출
         return NaverBookXmlParser.parseBookDetail(xml); // XML 파싱
     }

src/main/java/konkuk/thip/book/adapter/out/persistence/BookJpaRepository.java

@@ -3,8 +3,10 @@
 import konkuk.thip.book.adapter.out.jpa.BookJpaEntity;
 import org.springframework.data.jpa.repository.JpaRepository;
 
+import java.util.List;
 import java.util.Optional;
 
 public interface BookJpaRepository extends JpaRepository<BookJpaEntity, Long> {
     Optional<BookJpaEntity> findByIsbn(String isbn);
+    List<BookJpaEntity> findByIsbnIn(List<String> isbnList);
 }

src/main/java/konkuk/thip/book/adapter/out/persistence/BookQueryPersistenceAdapter.java

@@ -0,0 +1,15 @@
+package konkuk.thip.book.adapter.out.persistence;
+
+import konkuk.thip.book.adapter.out.mapper.BookMapper;
+import konkuk.thip.book.application.port.out.BookQueryPort;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Repository;
+
+@Repository
+@RequiredArgsConstructor
+public class BookQueryPersistenceAdapter implements BookQueryPort {
+
+    private final BookJpaRepository bookJpaRepository;
+    private final BookMapper bookMapper;
+
+}

src/main/java/konkuk/thip/book/adapter/out/persistence/BookRedisAdapter.java

@@ -0,0 +1,135 @@
+package konkuk.thip.book.adapter.out.persistence;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import konkuk.thip.book.application.port.in.dto.BookMostSearchResult;
+import konkuk.thip.book.application.port.out.BookRedisCommandPort;
+import konkuk.thip.book.application.port.out.BookRedisQueryPort;
+import konkuk.thip.common.exception.ExternalApiException;
+import konkuk.thip.common.exception.code.ErrorCode;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.ZSetOperations;
+import org.springframework.stereotype.Component;
+
+import java.time.Duration;
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+import static konkuk.thip.common.exception.code.ErrorCode.JSON_PROCESSING_ERROR;
+
+@Component
+@RequiredArgsConstructor
+public class BookRedisAdapter implements BookRedisQueryPort, BookRedisCommandPort {
+
+    private final RedisTemplate<String, String> redisTemplate;
+    private final DateTimeFormatter DAILY_KEY_FORMATTER =
+            DateTimeFormatter.ofPattern("yyyyMMdd");
+
+    @Value("${app.redis.search-count-prefix}")
+    private String searchCountPrefix;
+
+    @Value("${app.redis.search-rank-prefix}")
+    private String searchRankPrefix;
+
+    @Value("${app.redis.search-rank-detail-prefix}")
+    private String searchRankDetailPrefix;
+
+    private final ObjectMapper objectMapper;
+
+    @Override
+    public List<Map.Entry<String, Double>> getBookSearchRank(LocalDate date, int topN) {
+        return getTopNFromZSet(searchRankPrefix, date, topN);
+    }
+
+    @Override
+    public List<Map.Entry<String, Double>> getBookSearchCountTopN(LocalDate date, int topN) {
+        return getTopNFromZSet(searchCountPrefix, date, topN);
+    }
+
+    private List<Map.Entry<String, Double>> getTopNFromZSet(String prefix, LocalDate date, int topN) {
+        String dateStr = date.format(DAILY_KEY_FORMATTER);
+        String redisKey = prefix + dateStr;
+        Set<ZSetOperations.TypedTuple<String>> topNSet = redisTemplate.opsForZSet()
+                .reverseRangeWithScores(redisKey, 0, topN - 1);
+
+        if (topNSet == null) return Collections.emptyList();
+        return topNSet.stream()
+                .map(tuple -> Map.entry(tuple.getValue(), tuple.getScore()))
+                .collect(Collectors.toList());
+    }
+
+    @Override
+    public List<BookMostSearchResult.BookRankInfo> getYesterdayBookRankInfos(LocalDate date) {
+        String redisKey = searchRankDetailPrefix + date.format(DAILY_KEY_FORMATTER);
+        String json = redisTemplate.opsForValue().get(redisKey);
+
+        if (json == null || json.isBlank()) {
+            return List.of();
+        }
+        try {
+            return objectMapper.readValue(
+                    json,
+                    new TypeReference<List<BookMostSearchResult.BookRankInfo>>() {}
+            );
+        } catch (JsonProcessingException e) {
+            throw new ExternalApiException(ErrorCode.JSON_PROCESSING_ERROR);
+        }
+    }
+
+    @Override
+    public void incrementBookSearchCount(String isbn, LocalDate date) {
+        String redisKey = makeRedisKey(searchCountPrefix, date);
+        redisTemplate.opsForZSet().incrementScore(redisKey, isbn, 1.0);
+    }
+
+    @Override
+    public void saveBookSearchRank(List<String> isbns, List<Double> scores, LocalDate date) {
+        String redisKey = makeRedisKey(searchRankPrefix, date);
+        for (int i = 0; i < isbns.size(); i++) {
+            redisTemplate.opsForZSet().add(redisKey, isbns.get(i), scores.get(i));
+        }
+        redisTemplate.expire(redisKey, Duration.ofDays(7));
+    }
+
+    @Override
+    public void saveBookSearchRankDetail(List<BookMostSearchResult.BookRankInfo> bookRankDetails, LocalDate date) {
+        String redisKey = makeRedisKey(searchRankDetailPrefix, date);
+        String detailJson;
+        try {
+            detailJson = objectMapper.writeValueAsString(bookRankDetails);
+        } catch (JsonProcessingException e) {
+            throw new ExternalApiException(JSON_PROCESSING_ERROR);
+        }
+        redisTemplate.opsForValue().set(redisKey, detailJson);
+    }
+
+    @Override
+    public void deleteBookSearchRank(LocalDate date) {
+        deleteZSetKey(searchRankPrefix, date);
+    }
+
+    @Override
+    public void deleteBookSearchCount(LocalDate date) { deleteZSetKey(searchCountPrefix, date); }
+
+    @Override
+    public void deleteBookSearchRankDetail(LocalDate date) { deleteZSetKey(searchRankDetailPrefix, date); }
+
+    private void deleteZSetKey(String prefix, LocalDate date) {
+        String redisKey = makeRedisKey(prefix, date);
+        redisTemplate.delete(redisKey);
+    }
+
+    private String makeRedisKey(String prefix, LocalDate date) {
+        String dateStr = date.format(DAILY_KEY_FORMATTER);
+        return prefix + dateStr;
+    }
+
+}

src/main/java/konkuk/thip/book/application/port/in/BookMostSearchUseCase.java

@@ -0,0 +1,7 @@
+package konkuk.thip.book.application.port.in;
+
+import konkuk.thip.book.application.port.in.dto.BookMostSearchResult;
+
+public interface BookMostSearchUseCase {
+    BookMostSearchResult getMostSearchedBooks(Long userId);
+}

src/main/java/konkuk/thip/book/application/port/in/dto/BookMostSearchResult.java

@@ -0,0 +1,22 @@
+package konkuk.thip.book.application.port.in.dto;
+
+import konkuk.thip.book.adapter.in.web.response.GetBookMostSearchResponse;
+import lombok.Builder;
+
+import java.util.List;
+
+public record BookMostSearchResult(
+        List<BookRankInfo> bookList
+) {
+    @Builder
+    public record BookRankInfo(
+            int rank,
+            String title,
+            String imageUrl,
+            String isbn
+    ) {}
+
+    public static BookMostSearchResult of(List<BookRankInfo> bookList) {
+        return new BookMostSearchResult(bookList);
+    }
+}

src/main/java/konkuk/thip/book/application/port/out/BookApiQueryPort.java

@@ -5,5 +5,5 @@
 
 public interface BookApiQueryPort {
     NaverBookParseResult findBooksByKeyword(String keyword, int start);
-    NaverDetailBookParseResult findDetailBookByKeyword(String isbn);
+    NaverDetailBookParseResult findDetailBookByIsbn(String isbn);
 }

src/main/java/konkuk/thip/book/application/port/out/BookQueryPort.java

@@ -1,5 +1,4 @@
 package konkuk.thip.book.application.port.out;
 
 public interface BookQueryPort {
-
 }

src/main/java/konkuk/thip/book/application/port/out/BookRedisCommandPort.java

@@ -0,0 +1,15 @@
+package konkuk.thip.book.application.port.out;
+
+import konkuk.thip.book.application.port.in.dto.BookMostSearchResult;
+
+import java.time.LocalDate;
+import java.util.List;
+
+public interface BookRedisCommandPort {
+    void incrementBookSearchCount(String isbn, LocalDate date);
+    void saveBookSearchRank(List<String> isbns, List<Double> scores, LocalDate date);
+    void saveBookSearchRankDetail(List<BookMostSearchResult.BookRankInfo> bookRankDetails, LocalDate date);
+    void deleteBookSearchRank(LocalDate date);
+    void deleteBookSearchCount(LocalDate date);
+    void deleteBookSearchRankDetail(LocalDate date);
+}

src/main/java/konkuk/thip/book/application/port/out/BookRedisQueryPort.java

@@ -0,0 +1,13 @@
+package konkuk.thip.book.application.port.out;
+
+import konkuk.thip.book.application.port.in.dto.BookMostSearchResult;
+
+import java.time.LocalDate;
+import java.util.List;
+import java.util.Map;
+
+public interface BookRedisQueryPort {
+    List<Map.Entry<String, Double>> getBookSearchRank(LocalDate date, int topN);
+    List<Map.Entry<String, Double>> getBookSearchCountTopN(LocalDate date, int topN);
+    List<BookMostSearchResult.BookRankInfo> getYesterdayBookRankInfos(LocalDate date);
+}