Feat: 스프링 배치 스케줄링 적용

- BatchApplication.java: 배치 스케줄링 및 @EnableBatchProcessing 어노테이션 이동.
- DeleteExpiredEbookJobConfiguration.java: @EnableBatchProcessing  어노테이션 이동 및 쿼리문 내 별명 수정. 리턴 구문 단순화.
- BatchScheduler.java: 만료된 전자책 삭제 Job이 매일 0시 0분 0초에 수행되도록 스케줄링 설정.
- app-batch\src\main\resources\application.yaml: 배치 앱 실행 시 최초 수행을 막도록 batch.job.enabled: false 적용. 잘못된 프로파일명 수정.

app-batch/src/main/java/com/shacomiro/nesonnechek/batch/BatchApplication.java

@@ -1,10 +1,14 @@
 package com.shacomiro.nesonnechek.batch;
 
+import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.annotation.ComponentScan;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
+@EnableBatchProcessing
+@EnableScheduling
 @ComponentScan({
 		"com.shacomiro.nesonnechek.batch",
 		"com.shacomiro.nesonnechek.domain"

app-batch/src/main/java/com/shacomiro/nesonnechek/batch/job/DeleteExpiredEbookJobConfiguration.java

@@ -4,7 +4,6 @@
 
 import org.springframework.batch.core.Job;
 import org.springframework.batch.core.Step;
-import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
 import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
 import org.springframework.batch.core.configuration.annotation.JobScope;
 import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
@@ -27,7 +26,6 @@
 
 @Slf4j
 @Configuration
-@EnableBatchProcessing
 @RequiredArgsConstructor
 public class DeleteExpiredEbookJobConfiguration {
 	private static final int CHUNK_SIZE = 10;
@@ -62,7 +60,7 @@ public JpaPagingItemReader<Ebook> ebookReader() {
 				.name("expiredEbookReader")
 				.entityManagerFactory(emf)
 				.pageSize(CHUNK_SIZE)
-				.queryString("SELECT ef FROM Ebook ef")
+				.queryString("SELECT e FROM Ebook e")
 				.build();
 	}
 
@@ -88,9 +86,9 @@ public ItemProcessor<Ebook, Ebook> deleteExpiredEbookProcessor() {
 						ebook.getName(), ebook.getUuid(), ebook.isExist(), ebook.isExpired(), isDeleted);
 
 				return ebook;
-			} else {
-				return null;
 			}
+
+			return null;
 		};
 	}
 

app-batch/src/main/java/com/shacomiro/nesonnechek/batch/scheduler/BatchScheduler.java

@@ -0,0 +1,31 @@
+package com.shacomiro.nesonnechek.batch.scheduler;
+
+import org.springframework.batch.core.JobParametersBuilder;
+import org.springframework.batch.core.JobParametersInvalidException;
+import org.springframework.batch.core.launch.JobLauncher;
+import org.springframework.batch.core.repository.JobExecutionAlreadyRunningException;
+import org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException;
+import org.springframework.batch.core.repository.JobRestartException;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import com.shacomiro.nesonnechek.batch.job.DeleteExpiredEbookJobConfiguration;
+
+import lombok.RequiredArgsConstructor;
+
+@Component
+@RequiredArgsConstructor
+public class BatchScheduler {
+	private final JobLauncher jobLauncher;
+	private final DeleteExpiredEbookJobConfiguration deleteExpiredEbookJobConfiguration;
+
+	@Scheduled(cron = "0 0 0 * * *")
+	public void runDeleteExpiredEbookJob() throws
+			JobInstanceAlreadyCompleteException,
+			JobExecutionAlreadyRunningException,
+			JobParametersInvalidException,
+			JobRestartException {
+		jobLauncher.run(deleteExpiredEbookJobConfiguration.deleteExpiredEbookJob(),
+				new JobParametersBuilder().addLong("time", System.currentTimeMillis()).toJobParameters());
+	}
+}

app-batch/src/main/resources/application.yaml

@@ -6,7 +6,7 @@ spring:
     group:
       prod:
         - batch-app-prod
-        - domains-rds-prod
+        - domain-rds-prod
       dev:
         - batch-app-dev
         - domain-rds-dev
@@ -18,9 +18,7 @@ spring:
     active: ${profile}
   batch:
     job:
-      names: ${job.name:NONE}
-  main:
-    web-application-type: none
+      enabled: false
 ---
 spring:
   config: