diff --git a/src/main/java/com/interplug/qcast/batch/master/MaterialConfiguration.java b/src/main/java/com/interplug/qcast/batch/master/MaterialConfiguration.java index de859cbf..25227bb3 100644 --- a/src/main/java/com/interplug/qcast/batch/master/MaterialConfiguration.java +++ b/src/main/java/com/interplug/qcast/batch/master/MaterialConfiguration.java @@ -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 materialReader() throws Exception { - ItemSyncRequest itemSyncRequest = new ItemSyncRequest(); - itemSyncRequest.setAllYn("N"); this.itemSyncList = interfaceQsp.callApiData( HttpMethod.GET, - qspInterfaceUrl, - itemSyncRequest, + qspInterfaceUrl + "?allYn=N", + null, new TypeReference>() {}); return (itemSyncList != null) ? new ListItemReader<>(itemSyncList) diff --git a/src/main/java/com/interplug/qcast/batch/master/PriceJobConfiguration.java b/src/main/java/com/interplug/qcast/batch/master/PriceJobConfiguration.java index 46e0a145..1843cb04 100644 --- a/src/main/java/com/interplug/qcast/batch/master/PriceJobConfiguration.java +++ b/src/main/java/com/interplug/qcast/batch/master/PriceJobConfiguration.java @@ -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 modulePriceListReader() { return createReader( - priceSyncResponse != null ? priceSyncResponse.getModulePriceList() : null, "store"); + priceSyncResponse != null ? priceSyncResponse.getModulePriceList() : null, "module"); } @Bean @StepScope public ListItemReader bosPriceListReader() { return createReader( - priceSyncResponse != null ? priceSyncResponse.getBosPriceList() : null, "user"); + priceSyncResponse != null ? priceSyncResponse.getBosPriceList() : null, "bos"); } private ItemWriter createWriter(Consumer> processor, String writerName) {