[Book][Refactor] Search -> BookSave 흐름 가독성 향상 및 크롤러 포함된 동시성 로직 개선

src/main/java/book/book/bestseller/repository/BestSellerRepository.java

@@ -9,10 +9,10 @@
 
 public interface BestSellerRepository extends JpaRepository<BestSeller, Long> {
 
-    boolean existsByBook(Book book);
-
     void deleteByBookId(Long bookId);
 
     @Query("SELECT b FROM BestSeller b JOIN FETCH b.book ORDER BY b.id ASC")
     List<BestSeller> findTop(Pageable pageable);
+
+    List<BestSeller> findAllByBookIn(List<Book> books);
 }

src/main/java/book/book/bestseller/scheduler/BestsellerScheduler.java

@@ -27,7 +27,6 @@ public class BestsellerScheduler {
      */
     @Scheduled(cron = "0 0 2 * * *") // 매일 새벽 2시
     public void fetchBestsellers() {
-        int totalSaved = 0;
         // 1페이지부터 20페이지까지 (페이지당 50권)
         for (int page = 1; page <= 20; page++) {
             try {
@@ -36,19 +35,12 @@ public void fetchBestsellers() {
                     continue;
                 }
 
-                for (AladinSearchResponse.SearchItem item : response.getItem()) {
-                    try {
-                        bestsellerService.saveBestSeller(item);
-                        totalSaved++;
-                    } catch (Exception e) {
-                        log.error("베스트셀러 저장 중 오류 발생: {}", item.getTitle(), e);
-                    }
-                }
+                bestsellerService.saveBestSellers(response.getItem());
             } catch (Exception e) {
                 log.error("알라딘 베스트셀러 API 호출 중 오류 발생 (page={})", page, e);
             }
         }
-        log.info("일요일 베스트셀러 수집 완료. 신규 저장: {}권", totalSaved);
+        log.info("일요일 베스트셀러 수집 완료");
     }
 
     /**

src/main/java/book/book/bestseller/service/BestsellerService.java

@@ -4,13 +4,19 @@
 import book.book.bestseller.repository.BestSellerRepository;
 import book.book.book.entity.Book;
 import book.book.book.entity.Chapter;
+import book.book.book.repository.BookRepository;
 import book.book.book.repository.ChapterRepository;
 import book.book.book.service.BookService;
 import book.book.quiz.service.QuizGenerationService;
 import book.book.search.dto.aladin.AladinSearchResponse;
 import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.function.Function;
+import java.util.stream.Collectors;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.stereotype.Service;
 
@@ -23,16 +29,45 @@ public class BestsellerService {
     private final BookService bookService;
     private final QuizGenerationService quizGenerationService;
     private final ChapterRepository chapterRepository;
+    private final BookRepository bookRepository;
 
     private static final int CHUNK_SIZE = 60;
 
-    public void saveBestSeller(AladinSearchResponse.SearchItem item) {
-        Book book = bookService.findOrElseSaveBook(item);
-        if (!bestSellerRepository.existsByBook(book)) {
-            bestSellerRepository.save(BestSeller.builder()
-                    .book(book)
-                    .retryCount(0)
-                    .build());
+    @Transactional
+    public void saveBestSellers(List<AladinSearchResponse.SearchItem> items) {
+        // 1. 이미 저장된 책 조회 (Bulk Read)
+        List<Integer> itemIds = items.stream()
+                .map(AladinSearchResponse.SearchItem::getItemId)
+                .toList();
+
+        Map<Integer, Book> existingBooksMap = bookRepository.findByAladingBookIdIn(itemIds).stream()
+                .collect(Collectors.toMap(Book::getAladingBookId, Function.identity()));
+
+        // 2. 없는 책만 선별
+        List<AladinSearchResponse.SearchItem> missingItems = items.stream()
+                .filter(item -> !existingBooksMap.containsKey(item.getItemId()))
+                .toList();
+
+        // 3. 없는 책 병렬 저장
+        List<Book> savedBooks = bookService.saveBooksParallel(missingItems);
+
+        // 4. 이미 베스트셀러로 등록된 책 조회 (Bulk Read)
+        // savedBooks 중에서도 Race Condition 등으로 이미 BestSeller에 있을 수 있으므로 체크
+        Set<Book> existingBestSellers = bestSellerRepository.findAllByBookIn(savedBooks).stream()
+                .map(BestSeller::getBook)
+                .collect(Collectors.toSet());
+
+        // 5. 없는 베스트셀러만 선별 및 저장
+        List<BestSeller> newBestSellers = savedBooks.stream()
+                .filter(book -> !existingBestSellers.contains(book))
+                .map(book -> BestSeller.builder()
+                        .book(book)
+                        .retryCount(0)
+                        .build())
+                .toList();
+
+        if (!newBestSellers.isEmpty()) {
+            bestSellerRepository.saveAll(newBestSellers);
         }
     }
 

src/main/java/book/book/book/entity/Book.java

@@ -28,7 +28,9 @@
  */
 @Entity
 @Table(name = "book", indexes = {
-        @Index(name = "idx_book_quiz_status_updated_date", columnList = "quizStatus, updatedDate")
+        @Index(name = "idx_book_quiz_status_updated_date", columnList = "quizStatus, updatedDate"),
+        @Index(name = "idx_book_alading_book_id", columnList = "aladingBookId"),
+        @Index(name = "idx_book_category_id", columnList = "category_id")
 })
 @Getter
 @Builder
@@ -84,6 +86,10 @@ public class Book extends BaseTimeEntity {
     @Builder.Default
     private Integer generatedQuizCount = 0; // 퀴즈가 생성된 챕터 수
 
+    public void resetQuizStatus() {
+        this.quizStatus = null;
+        this.generatedQuizCount = 0;
+    }
     public void updateQuizStatus(QuizStatus quizStatus) {
         this.quizStatus = quizStatus;
     }

src/main/java/book/book/book/repository/BookLikeRepository.java

@@ -1,25 +1,23 @@
 package book.book.book.repository;
 
 import book.book.book.entity.BookLike;
-import book.book.member.entity.Member;
-import java.util.List;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 public interface BookLikeRepository extends JpaRepository<BookLike, Long>, BookLikeRepositoryCustom {
 
+    @Modifying
+    @Query("delete from BookLike bl where bl.member.id = :memberId and bl.book.id = :bookId")
     void deleteByMemberIdAndBookId(Long memberId, Long bookId);
 
+    @Modifying
+    @Query("delete from BookLike bl where bl.member.id = :memberId")
     void deleteAllByMemberId(Long memberId);
 
-    @Query("SELECT bl FROM BookLike bl JOIN FETCH bl.book WHERE bl.member = :member")
-    List<BookLike> findAllByMemberWithBook(@Param("member") Member member);
-
-    @Query("SELECT bl FROM BookLike bl JOIN FETCH bl.book b JOIN FETCH bl.member m")
-    List<BookLike> findAllWithBookAndMember();
-
     boolean existsByMemberIdAndBookId(Long memberId, Long bookId);
 
+    @Modifying
+    @Query("delete from BookLike bl where bl.book.id = :bookId")
     void deleteByBookId(Long bookId);
 }

src/main/java/book/book/book/repository/BookRepository.java

@@ -6,9 +6,12 @@
 import book.book.quiz.domain.QuizStatus;
 import java.time.LocalDateTime;
 import java.util.List;
+import java.util.Map;
 import java.util.Optional;
+import java.util.stream.Collectors;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
 
 public interface BookRepository extends JpaRepository<Book, Long> {
@@ -24,6 +27,13 @@ default Book findByIdOrElseThrow(Long id) {
 
     Optional<Book> findByAladingBookId(int aladingBookId);
 
+    default Map<Integer, Book> getBookMapByAladinBookIds(List<Integer> aladingBookIds) {
+        List<Book> books = findByAladingBookIdIn(aladingBookIds);
+        return books.stream().collect(Collectors.toMap(Book::getAladingBookId, book -> book));
+    }
+
+    List<Book> findByAladingBookIdIn(List<Integer> aladingBookIds);
+
     default Book findByIsbn13OrElseThrow(String isbn) {
         return findByIsbn13(isbn)
                 .orElseThrow(() -> new CustomException(ErrorCode.BOOK_NOT_FOUND));
@@ -46,4 +56,14 @@ default Book findByIsbn13OrElseThrow(String isbn) {
 
     @Query("SELECT DISTINCT b FROM Book b JOIN Chapter c ON b.id = c.book.id LEFT JOIN Quiz q ON c.id = q.chapter.id WHERE c.hasQuiz = true AND q.id IS NULL")
     List<Book> findBooksWithMissingQuizzes();
+
+    @Modifying
+    @Query(value = "INSERT IGNORE INTO book (alading_book_id, title, author, isbn, isbn13, category_id, description, publisher, published_date, image_url, aladin_url, aladin_star_rating, chapter_count, diary_count, book_size, weight, generated_quiz_count, created_date, updated_date, page) "
+            +
+            "VALUES (:#{#book.aladingBookId}, :#{#book.title}, :#{#book.author}, :#{#book.isbn}, :#{#book.isbn13}, :#{#book.category.id}, :#{#book.description}, :#{#book.publisher}, :#{#book.publishedDate}, :#{#book.imageUrl}, :#{#book.aladinUrl}, :#{#book.aladinStarRating}, :#{#book.chapterCount}, 0, :#{#book.bookSize}, :#{#book.weight}, 0, NOW(), NOW(), :#{#book.page})", nativeQuery = true)
+    int saveIfAbsent(Book book);
+
+    @Modifying
+    @Query("UPDATE Book b SET b.quizStatus = null, b.generatedQuizCount = 0 WHERE b.id IN :bookIds")
+    void updateQuizStatusNullByBookIds(List<Long> bookIds);
 }

src/main/java/book/book/book/repository/ChapterRepository.java

@@ -5,15 +5,22 @@
 import book.book.common.ErrorCode;
 import java.util.List;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
 
-public interface ChapterRepository extends JpaRepository<Chapter, Long> {
+public interface ChapterRepository extends JpaRepository<Chapter, Long>, ChapterRepositoryCustom {
 
     default Chapter findByIdOrElseThrow(Long id) {
         return findById(id).orElseThrow(() -> new CustomException(ErrorCode.CHAPTER_NOT_FOUND));
     }
 
     List<Chapter> findByBookIdOrderByChapterNumber(Long bookId);
 
+    @Modifying
+    @Query("delete from Chapter c where c.book.id = :bookId")
     void deleteByBookId(Long bookId);
 
+    @Modifying
+    @Query("UPDATE Chapter c SET c.hasQuiz = false WHERE c.id IN :chapterIds")
+    void updateHasQuizFalseByChapterIds(List<Long> chapterIds);
 }

src/main/java/book/book/book/repository/ChapterRepositoryCustom.java

@@ -0,0 +1,12 @@
+package book.book.book.repository;
+
+import book.book.book.entity.Chapter;
+import java.util.List;
+
+public interface ChapterRepositoryCustom {
+    void batchInsertChapters(List<Chapter> chapters);
+
+    void batchUpdateChapters(List<Chapter> chapters);
+
+    void batchDeleteChapters(List<Chapter> chapters);
+}

src/main/java/book/book/book/repository/ChapterRepositoryImpl.java

@@ -0,0 +1,77 @@
+package book.book.book.repository;
+
+import book.book.book.entity.Chapter;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Repository;
+
+@Repository
+@RequiredArgsConstructor
+public class ChapterRepositoryImpl implements ChapterRepositoryCustom {
+
+    private final JdbcTemplate jdbcTemplate;
+
+    @Override
+    public void batchInsertChapters(List<Chapter> chapters) {
+        String sql = "INSERT INTO chapter (book_id, chapter_number, title, has_quiz, created_date, updated_date) " +
+                "VALUES (?, ?, ?, ?, NOW(), NOW())";
+
+        jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {
+            @Override
+            public void setValues(PreparedStatement ps, int i) throws SQLException {
+                Chapter chapter = chapters.get(i);
+                ps.setLong(1, chapter.getBook().getId());
+                ps.setInt(2, chapter.getChapterNumber());
+                ps.setString(3, chapter.getTitle());
+                ps.setBoolean(4, chapter.getHasQuiz());
+            }
+
+            @Override
+            public int getBatchSize() {
+                return chapters.size();
+            }
+        });
+    }
+
+    @Override
+    public void batchUpdateChapters(List<Chapter> chapters) {
+        String sql = "UPDATE chapter SET title = ?, chapter_number = ?, updated_date = NOW() WHERE id = ?";
+
+        jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {
+            @Override
+            public void setValues(PreparedStatement ps, int i) throws SQLException {
+                Chapter chapter = chapters.get(i);
+                ps.setString(1, chapter.getTitle());
+                ps.setInt(2, chapter.getChapterNumber());
+                ps.setLong(3, chapter.getId());
+            }
+
+            @Override
+            public int getBatchSize() {
+                return chapters.size();
+            }
+        });
+    }
+
+    @Override
+    public void batchDeleteChapters(List<Chapter> chapters) {
+        String sql = "DELETE FROM chapter WHERE id = ?";
+
+        jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {
+            @Override
+            public void setValues(PreparedStatement ps, int i) throws SQLException {
+                Chapter chapter = chapters.get(i);
+                ps.setLong(1, chapter.getId());
+            }
+
+            @Override
+            public int getBatchSize() {
+                return chapters.size();
+            }
+        });
+    }
+}