[feat] 책 삭제 스케줄러 도입

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

@@ -15,6 +15,7 @@
 import org.springframework.stereotype.Repository;
 
 import java.util.Optional;
+import java.util.Set;
 
 import static konkuk.thip.common.exception.code.ErrorCode.*;
 
@@ -86,4 +87,9 @@ public void saveSavedBook(Long userId, Long bookId) {
     public void deleteSavedBook(Long userId, Long bookId) {
         savedBookJpaRepository.deleteByUserIdAndBookId(userId, bookId);
     }
+
+    @Override
+    public void deleteAllByIdInBatch(Set<Long> unusedBookIds) {
+        bookJpaRepository.deleteAllByIdInBatch(unusedBookIds);
+    }
 }

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

@@ -12,6 +12,7 @@
 import org.springframework.stereotype.Repository;
 
 import java.util.List;
+import java.util.Set;
 import java.util.stream.Collectors;
 
 import static konkuk.thip.common.exception.code.ErrorCode.USER_NOT_FOUND;
@@ -55,4 +56,9 @@ public List<Book> findJoiningRoomsBooksByUserId(Long userId) {
                 .map(bookMapper::toDomainEntity)
                 .collect(Collectors.toList());
     }
+
+    @Override
+    public Set<Long> findUnusedBookIds() {
+        return bookJpaRepository.findUnusedBookIds();
+    }
 }

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

@@ -6,6 +6,7 @@
 
 import java.util.List;
 import java.util.Optional;
+import java.util.Set;
 
 public interface BookJpaRepository extends JpaRepository<BookJpaEntity, Long> {
     Optional<BookJpaEntity> findByIsbn(String isbn);
@@ -28,4 +29,23 @@ public interface BookJpaRepository extends JpaRepository<BookJpaEntity, Long> {
     List<BookJpaEntity> findJoiningRoomsBooksByUserId(Long userId);
 
     boolean existsByIsbn(String isbn);
+
+    // Room, Feed, SavedBook에 모두 참조되지 않은 책 ID만 찾는 쿼리
+    @Query(
+            "SELECT b.bookId " +
+            "FROM BookJpaEntity b " +
+            "WHERE NOT EXISTS ( " +
+            "    SELECT 1 FROM RoomJpaEntity r " +
+            "    WHERE r.bookJpaEntity = b " +
+            ") " +
+            "AND NOT EXISTS ( " +
+            "    SELECT 1 FROM FeedJpaEntity f " +
+            "    WHERE f.bookJpaEntity = b " +
+            ") " +
+            "AND NOT EXISTS ( " +
+            "    SELECT 1 FROM SavedBookJpaEntity s " +
+            "    WHERE s.bookJpaEntity = b " +
+            ")"
+    )
+    Set<Long> findUnusedBookIds();
 }

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

@@ -0,0 +1,5 @@
+package konkuk.thip.book.application.port.in;
+
+public interface BookCleanUpUseCase {
+    void deleteUnusedBooks();
+}

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

@@ -6,6 +6,7 @@
 import konkuk.thip.common.exception.code.ErrorCode;
 
 import java.util.Optional;
+import java.util.Set;
 
 public interface BookCommandPort {
 
@@ -27,4 +28,5 @@ default Book getByIsbnOrThrow(String isbn){
     void saveSavedBook(Long userId, Long bookId);
     void deleteSavedBook(Long userId, Long bookId);
 
+    void deleteAllByIdInBatch(Set<Long> unusedBookIds);
 }

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

@@ -3,6 +3,7 @@
 import konkuk.thip.book.domain.Book;
 
 import java.util.List;
+import java.util.Set;
 
 public interface BookQueryPort {
 
@@ -13,4 +14,6 @@ public interface BookQueryPort {
     List<Book> findSavedBooksByUserId(Long userId);
 
     List<Book> findJoiningRoomsBooksByUserId(Long userId);
+
+    Set<Long> findUnusedBookIds();
 }

src/main/java/konkuk/thip/book/application/service/BookCleanUpService.java

@@ -0,0 +1,30 @@
+package konkuk.thip.book.application.service;
+
+import konkuk.thip.book.application.port.in.BookCleanUpUseCase;
+import konkuk.thip.book.application.port.out.BookCommandPort;
+import konkuk.thip.book.application.port.out.BookQueryPort;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Set;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class BookCleanUpService implements BookCleanUpUseCase {
+
+    private final BookCommandPort bookCommandPort;
+    private final BookQueryPort bookQueryPort;
+
+    @Async
+    @Override
+    @Transactional
+    public void deleteUnusedBooks() {
+        Set<Long> unusedBookIds = bookQueryPort.findUnusedBookIds();
+        log.info("삭제할 사용되지 않는 Book IDs: {}", unusedBookIds);
+        bookCommandPort.deleteAllByIdInBatch(unusedBookIds);
+    }
+}

src/main/java/konkuk/thip/common/scheduler/BookDeleteScheduler.java

@@ -0,0 +1,23 @@
+package konkuk.thip.common.scheduler;
+
+import konkuk.thip.book.application.port.in.BookCleanUpUseCase;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class BookDeleteScheduler {
+
+    private final BookCleanUpUseCase bookCleanUpUseCase;
+
+    // 매일 새벽 4시 실행
+    @Scheduled(cron = "0 0 4 * * *", zone = "Asia/Seoul")
+    public void cleanUpUnusedBooks() {
+        log.info("[스케줄러] 사용되지 않는 Book 데이터 삭제 시작");
+        bookCleanUpUseCase.deleteUnusedBooks();
+        log.info("[스케줄러] 사용되지 않는 Book 데이터 삭제 완료");
+    }
+}

src/test/java/konkuk/thip/common/scheduler/BookDeleteSchedulerTest.java

@@ -0,0 +1,80 @@
+package konkuk.thip.common.scheduler;
+
+import konkuk.thip.book.adapter.out.jpa.BookJpaEntity;
+import konkuk.thip.book.adapter.out.persistence.repository.BookJpaRepository;
+import konkuk.thip.book.adapter.out.persistence.repository.SavedBookJpaRepository;
+import konkuk.thip.book.application.port.in.BookCleanUpUseCase;
+import konkuk.thip.common.util.TestEntityFactory;
+import konkuk.thip.feed.adapter.out.persistence.repository.FeedJpaRepository;
+import konkuk.thip.room.adapter.out.persistence.repository.RoomJpaRepository;
+import konkuk.thip.user.adapter.out.jpa.UserJpaEntity;
+import konkuk.thip.user.adapter.out.persistence.repository.UserJpaRepository;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.ActiveProfiles;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+@SpringBootTest
+@ActiveProfiles("test")
+@Transactional
+@DisplayName("[통합] Book 삭제 스케줄러 기능 테스트")
+class BookDeleteSchedulerTest {
+
+    @Autowired
+    private BookJpaRepository bookJpaRepository;
+
+    @Autowired
+    private RoomJpaRepository roomJpaRepository;
+
+    @Autowired
+    private FeedJpaRepository feedJpaRepository;
+
+    @Autowired
+    private SavedBookJpaRepository savedBookJpaRepository;
+
+    @Autowired
+    private UserJpaRepository userJpaRepository;
+
+    @Autowired
+    private BookCleanUpUseCase bookCleanUpUseCase;
+
+    @Test
+    @DisplayName("Room, Feed, SavedBook 어디에도 연결되지 않은 Book은 삭제된다")
+    void deleteUnusedBooks_success() {
+        // given
+        // 사용되지 않는 Book
+        BookJpaEntity unusedBook = bookJpaRepository.save(TestEntityFactory.createBookWithBookTitle("고아책"));
+
+        // Room에 연결된 Book
+        BookJpaEntity roomBook = bookJpaRepository.save(TestEntityFactory.createBookWithBookTitle("방책"));
+        roomJpaRepository.save(TestEntityFactory.createRoom(roomBook, TestEntityFactory.createLiteratureCategory()));
+
+        // Feed에 연결된 Book
+        BookJpaEntity feedBook = bookJpaRepository.save(TestEntityFactory.createBookWithBookTitle("피드책"));
+        UserJpaEntity feedUser = userJpaRepository.save(TestEntityFactory.createUser(TestEntityFactory.createLiteratureAlias()));
+        feedJpaRepository.save(TestEntityFactory.createFeed(feedUser, feedBook, true));
+
+        // SavedBook에 연결된 Book
+        BookJpaEntity savedBook = bookJpaRepository.save(TestEntityFactory.createBookWithBookTitle("저장책"));
+        UserJpaEntity savedUser = userJpaRepository.save(TestEntityFactory.createUser(TestEntityFactory.createLiteratureAlias(), "저장유저"));
+        savedBookJpaRepository.save(TestEntityFactory.createSavedBook(savedUser, savedBook));
+
+        // when
+        bookCleanUpUseCase.deleteUnusedBooks();
+
+        // then
+        List<BookJpaEntity> remainingBooks = bookJpaRepository.findAll();
+
+        // 삭제되지 않은 책의 제목만 수집
+        List<String> remainingTitles = remainingBooks.stream().map(BookJpaEntity::getTitle).toList();
+
+        assertThat(remainingTitles).contains("방책", "피드책", "저장책");
+        assertThat(remainingTitles).doesNotContain("고아책");
+    }
+}

src/test/java/konkuk/thip/config/TestAsyncConfig.java

@@ -0,0 +1,18 @@
+package konkuk.thip.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+import org.springframework.core.task.SyncTaskExecutor;
+
+import java.util.concurrent.Executor;
+
+@Configuration
+@Profile("test")
+public class TestAsyncConfig {
+    @Bean(name = "taskExecutor")
+    public Executor taskExecutor() {
+        return new SyncTaskExecutor(); // 동기 실행
+    }
+}
+