diff --git a/src/main/java/com/interplug/qcast/batch/master/StoreJobConfiguration.java b/src/main/java/com/interplug/qcast/batch/master/StoreJobConfiguration.java index 472ea902..00c3b741 100644 --- a/src/main/java/com/interplug/qcast/batch/master/StoreJobConfiguration.java +++ b/src/main/java/com/interplug/qcast/batch/master/StoreJobConfiguration.java @@ -14,7 +14,6 @@ import org.springframework.batch.core.configuration.annotation.StepScope; import org.springframework.batch.core.job.builder.JobBuilder; import org.springframework.batch.core.repository.JobRepository; import org.springframework.batch.core.step.builder.StepBuilder; -import org.springframework.batch.item.ItemReader; import org.springframework.batch.item.ItemWriter; import org.springframework.batch.item.support.ListItemReader; import org.springframework.beans.factory.annotation.Value; @@ -44,16 +43,12 @@ public class StoreJobConfiguration implements JobExecutionListener { @Override public void beforeJob(JobExecution jobExecution) { - System.out.println("Job 시작: 초기화 메서드 호출 중..."); try { this.storeSyncResponse = interfaceQsp.callApiData( HttpMethod.GET, qspMasterStoreBatchUrl, null, StoreSyncResponse.class); - System.out.println( - "API 호출을 통해 storeSyncResponse 갱신 완료, 항목 수: " - + this.storeSyncResponse.getStoreList().size()); } catch (Exception e) { - System.err.println("storeSyncResponse를 갱신하는 중 오류 발생: " + e.getMessage()); + System.err.println("storeSyncResponse beforeJob 오류 발생: " + e.getMessage()); } } @@ -99,8 +94,7 @@ public class StoreJobConfiguration implements JobExecutionListener { @Bean @StepScope - public ItemReader storeListReader() { - System.out.println("storeListReader 호출됨..."); + public ListItemReader storeListReader() { return (storeSyncResponse != null && storeSyncResponse.getStoreList() != null) ? new ListItemReader<>(storeSyncResponse.getStoreList()) : new ListItemReader<>(Collections.emptyList()); @@ -108,8 +102,7 @@ public class StoreJobConfiguration implements JobExecutionListener { @Bean @StepScope - public ItemReader userListReader() { - System.out.println("userListReader 호출됨..."); + public ListItemReader userListReader() { return (storeSyncResponse != null && storeSyncResponse.getUserList() != null) ? new ListItemReader<>(storeSyncResponse.getUserList()) : new ListItemReader<>(Collections.emptyList()); @@ -117,8 +110,7 @@ public class StoreJobConfiguration implements JobExecutionListener { @Bean @StepScope - public ItemReader storeFavListReader() { - System.out.println("storeFavListReader 호출됨..."); + public ListItemReader storeFavListReader() { return (storeSyncResponse != null && storeSyncResponse.getStoreFavList() != null) ? new ListItemReader<>(storeSyncResponse.getStoreFavList()) : new ListItemReader<>(Collections.emptyList()); @@ -127,41 +119,25 @@ public class StoreJobConfiguration implements JobExecutionListener { @Bean public ItemWriter storeWriter() { return items -> { - try { - List storeRequestList = - (List) items.getItems(); // Chunk에서 List로 추출 - userService.setStoreBatch(storeRequestList); // 서비스에 List를 한 번에 전달 - System.out.println("storeWriter: " + items.size() + " items 처리 완료"); - } catch (Exception e) { - System.err.println("storeWriter 오류: " + e.getMessage()); - } + List storeRequestList = + (List) items.getItems(); // Chunk에서 List로 추출 + userService.setStoreBatch(storeRequestList); // 서비스에 List를 한 번에 전달 }; } @Bean public ItemWriter userWriter() { return items -> { - try { - List userRequestList = (List) items.getItems(); - userService.setUserBatch(userRequestList); - System.out.println("userWriter: " + items.size() + " items 처리 완료"); - } catch (Exception e) { - System.err.println("userWriter 오류: " + e.getMessage()); - } + List userRequestList = (List) items.getItems(); + userService.setUserBatch(userRequestList); }; } @Bean public ItemWriter favoriteWriter() { return items -> { - try { - List storeFavoriteList = - (List) items.getItems(); - storeFavService.setStoreFavoriteBatch(storeFavoriteList); - System.out.println("favoriteWriter: " + items.size() + " items 처리 완료"); - } catch (Exception e) { - System.err.println("favoriteWriter 오류: " + e.getMessage()); - } + List storeFavoriteList = (List) items.getItems(); + storeFavService.setStoreFavoriteBatch(storeFavoriteList); }; } }