qcast3/qcast-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

배치주석제거

Browse Source
This commit is contained in:
DESKTOP-6ARNG1Q\dlsgk 2024-11-08 15:13:13 +09:00
parent ae88b2a95a
commit 3088641e84
1 changed files with 11 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
src/main/java/com/interplug/qcast/batch/master/StoreJobConfiguration.java
View File

@ -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<StoreRequest> storeListReader() {
System.out.println("storeListReader 호출됨...");
public ListItemReader<StoreRequest> 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<UserRequest> userListReader() {
System.out.println("userListReader 호출됨...");
public ListItemReader<UserRequest> 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<StoreFavoriteRequest> storeFavListReader() {
System.out.println("storeFavListReader 호출됨...");
public ListItemReader<StoreFavoriteRequest> 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<StoreRequest> storeWriter() {
return items -> {
try {
List<StoreRequest> storeRequestList =
(List<StoreRequest>) 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<StoreRequest> storeRequestList =
(List<StoreRequest>) items.getItems(); // Chunk에서 List로 추출
userService.setStoreBatch(storeRequestList); // 서비스에 List를 한 번에 전달
};
}
@Bean
public ItemWriter<UserRequest> userWriter() {
return items -> {
try {
List<UserRequest> userRequestList = (List<UserRequest>) items.getItems();
userService.setUserBatch(userRequestList);
System.out.println("userWriter: " + items.size() + " items 처리 완료");
} catch (Exception e) {
System.err.println("userWriter 오류: " + e.getMessage());
}
List<UserRequest> userRequestList = (List<UserRequest>) items.getItems();
userService.setUserBatch(userRequestList);
};
}
@Bean
public ItemWriter<StoreFavoriteRequest> favoriteWriter() {
return items -> {
try {
List<StoreFavoriteRequest> storeFavoriteList =
(List<StoreFavoriteRequest>) items.getItems();
storeFavService.setStoreFavoriteBatch(storeFavoriteList);
System.out.println("favoriteWriter: " + items.size() + " items 처리 완료");
} catch (Exception e) {
System.err.println("favoriteWriter 오류: " + e.getMessage());
}
List<StoreFavoriteRequest> storeFavoriteList = (List<StoreFavoriteRequest>) items.getItems();
storeFavService.setStoreFavoriteBatch(storeFavoriteList);
};
}
}