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

배치 파라메터 수정

Browse Source
This commit is contained in:
rjy1537 2024-11-12 14:43:18 +09:00
parent 282fa9bfb0
commit 5faedebb8b
2 changed files with 5 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/com/interplug/qcast/batch/master/MaterialConfiguration.java
View File

@ -2,7 +2,6 @@ package com.interplug.qcast.batch.master;
import com.fasterxml.jackson.core.type.TypeReference;
import com.interplug.qcast.biz.displayItem.DisplayItemService;
import com.interplug.qcast.biz.displayItem.dto.ItemSyncRequest;
import com.interplug.qcast.biz.displayItem.dto.ItemSyncResponse;
import com.interplug.qcast.util.InterfaceQsp;
import java.util.Collections;
@ -59,13 +58,11 @@ public class MaterialConfiguration implements JobExecutionListener {
@Bean
@StepScope
public ListItemReader<ItemSyncResponse> materialReader() throws Exception {
ItemSyncRequest itemSyncRequest = new ItemSyncRequest();
itemSyncRequest.setAllYn("N");
this.itemSyncList =
interfaceQsp.callApiData(
HttpMethod.GET,
qspInterfaceUrl,
itemSyncRequest,
qspInterfaceUrl + "?allYn=N",
null,
new TypeReference<List<ItemSyncResponse>>() {});
return (itemSyncList != null)
? new ListItemReader<>(itemSyncList)

10
src/main/java/com/interplug/qcast/batch/master/PriceJobConfiguration.java
View File

@ -2,7 +2,6 @@ package com.interplug.qcast.batch.master;
import com.interplug.qcast.biz.displayItem.DisplayItemService;
import com.interplug.qcast.biz.displayItem.dto.PriceItemSyncResponse;
import com.interplug.qcast.biz.displayItem.dto.PriceSyncRequest;
import com.interplug.qcast.biz.displayItem.dto.PriceSyncResponse;
import com.interplug.qcast.util.InterfaceQsp;
import java.util.Collections;
@ -45,12 +44,9 @@ public class PriceJobConfiguration implements JobExecutionListener {
public void beforeJob(JobExecution jobExecution) {
log.info("Job 시작: 초기화 메서드 호출 중...");
try {
PriceSyncRequest priceSyncRequest = new PriceSyncRequest();
priceSyncRequest.setAllYn("Y");
this.priceSyncResponse =
interfaceQsp.callApiData(
HttpMethod.GET, qspInterfaceUrl, priceSyncRequest, PriceSyncResponse.class);
HttpMethod.GET, qspInterfaceUrl + "?allYn=N", null, PriceSyncResponse.class);
log.info("API 호출 완료, 항목 수: {}", this.priceSyncResponse.getModulePriceList().size());
} catch (Exception e) {
log.error("priceSyncResponse 갱신 중 오류: {}", e.getMessage());
@ -132,14 +128,14 @@ public class PriceJobConfiguration implements JobExecutionListener {
@StepScope
public ListItemReader<PriceItemSyncResponse> modulePriceListReader() {
return createReader(
priceSyncResponse != null ? priceSyncResponse.getModulePriceList() : null, "store");
priceSyncResponse != null ? priceSyncResponse.getModulePriceList() : null, "module");
}
@Bean
@StepScope
public ListItemReader<PriceItemSyncResponse> bosPriceListReader() {
return createReader(
priceSyncResponse != null ? priceSyncResponse.getBosPriceList() : null, "user");
priceSyncResponse != null ? priceSyncResponse.getBosPriceList() : null, "bos");
}
private <T> ItemWriter<T> createWriter(Consumer<List<T>> processor, String writerName) {