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

dev #373

Merged
ysCha merged 2 commits from dev into dev-deploy 2026-02-05 14:55:01 +09:00
Conversation 0 Commits 2 Files Changed 2 +138 -72
2 changed files with 138 additions and 72 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -4,8 +4,11 @@ import com.fasterxml.jackson.core.type.TypeReference;
import com.interplug.qcast.biz.displayItem.DisplayItemService; import com.interplug.qcast.biz.displayItem.DisplayItemService;
import com.interplug.qcast.biz.displayItem.dto.ItemSyncResponse; import com.interplug.qcast.biz.displayItem.dto.ItemSyncResponse;
import com.interplug.qcast.util.InterfaceQsp; import com.interplug.qcast.util.InterfaceQsp;
import java.util.ArrayList;
import java.util.Collections; import java.util.Collections;
import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map;
import org.springframework.batch.core.Job; import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobExecutionListener; import org.springframework.batch.core.JobExecutionListener;
import org.springframework.batch.core.Step; import org.springframework.batch.core.Step;
@ -34,6 +37,9 @@ public class MaterialConfiguration implements JobExecutionListener {
@Value("${qsp.master-material-batch-url}") @Value("${qsp.master-material-batch-url}")
private String qspInterfaceUrl; private String qspInterfaceUrl;
@Value("${qsp.master-material-batch-page-size:1000}")
private int pageSize;
public MaterialConfiguration(DisplayItemService displayItemService, InterfaceQsp interfaceQsp) { public MaterialConfiguration(DisplayItemService displayItemService, InterfaceQsp interfaceQsp) {
this.displayItemService = displayItemService; this.displayItemService = displayItemService;
this.interfaceQsp = interfaceQsp; this.interfaceQsp = interfaceQsp;
@ -58,12 +64,32 @@ public class MaterialConfiguration implements JobExecutionListener {
@Bean @Bean
@StepScope @StepScope
public ListItemReader<ItemSyncResponse> materialReader() throws Exception { public ListItemReader<ItemSyncResponse> materialReader() throws Exception {
this.itemSyncList = List<ItemSyncResponse> aggregated = new ArrayList<>();
interfaceQsp.callApiData( int page = 1;
HttpMethod.GET, while (true) {
qspInterfaceUrl + "?allYn=N", Map<String, Object> params = new HashMap<>();
null, params.put("allYn", "N");
new TypeReference<List<ItemSyncResponse>>() {}); params.put("page", page);
params.put("size", pageSize);
List<ItemSyncResponse> pageItems =
interfaceQsp.callApiData(
HttpMethod.GET,
qspInterfaceUrl,
params,
new TypeReference<List<ItemSyncResponse>>() {});
if (pageItems == null || pageItems.isEmpty()) {
break;
}
aggregated.addAll(pageItems);
if (pageItems.size() < pageSize) {
break;
}
page++;
}
this.itemSyncList = aggregated;
return (itemSyncList != null) return (itemSyncList != null)
? new ListItemReader<>(itemSyncList) ? new ListItemReader<>(itemSyncList)
: new ListItemReader<>(Collections.emptyList()); : new ListItemReader<>(Collections.emptyList());

172
src/main/java/com/interplug/qcast/util/InterfaceQsp.java
View File

@ -37,34 +37,41 @@ public class InterfaceQsp {
* @return String * @return String
* @throws Exception * @throws Exception
*/ */
public String callApi(HttpMethod httpMethod, String apiPath, Object requestObject) public String callApi(HttpMethod httpMethod, String apiPath, Object requestObject)
throws Exception { throws Exception {
URL url = null; URL url = null;
HttpURLConnection con = null; HttpURLConnection con = null;
OutputStreamWriter osw = null; OutputStreamWriter osw = null;
BufferedReader br = null; BufferedReader br = null;
StringBuilder sb = null; StringBuilder sb = null;
long startAt = System.currentTimeMillis();
try { String requestType = requestObject == null ? "none" : requestObject.getClass().getSimpleName();
// GET 요청 시 requestObject를 쿼리 스트링으로 변환 try {
if (HttpMethod.GET.equals(httpMethod) && requestObject != null) {
// GET 요청 시 requestObject를 쿼리 스트링으로 변환
if (HttpMethod.GET.equals(httpMethod) && requestObject != null) {
ObjectMapper om = new ObjectMapper(); ObjectMapper om = new ObjectMapper();
Map<String, Object> params = om.convertValue(requestObject, Map.class); // Object -> Map 변환 Map<String, Object> params = om.convertValue(requestObject, Map.class); // Object -> Map 변환
String queryString = String queryString =
params.entrySet().stream() params.entrySet().stream()
.map(entry -> entry.getKey() + "=" + entry.getValue()) .map(entry -> entry.getKey() + "=" + entry.getValue())
.reduce((p1, p2) -> p1 + "&" + p2) .reduce((p1, p2) -> p1 + "&" + p2)
.orElse(""); .orElse("");
apiPath += "?" + queryString; // 쿼리 스트링 추가 apiPath += "?" + queryString; // 쿼리 스트링 추가
} }
url = new URL(apiPath); log.debug(
con = (HttpURLConnection) url.openConnection(); "QSP API call start: method={}, url={}, requestType={}",
con.setConnectTimeout(120000); // 서버에 연결되는 Timeout 시간 설정 httpMethod,
con.setReadTimeout(120000); // InputStream 읽어 오는 Timeout 시간 설정 apiPath,
con.setRequestMethod(httpMethod.toString()); requestType);
url = new URL(apiPath);
con = (HttpURLConnection) url.openConnection();
con.setConnectTimeout(120000); // 서버에 연결되는 Timeout 시간 설정
con.setReadTimeout(120000); // InputStream 읽어 오는 Timeout 시간 설정
con.setRequestMethod(httpMethod.toString());
con.setRequestProperty("Content-Type", "application/json"); con.setRequestProperty("Content-Type", "application/json");
con.setRequestProperty("Referer", frontUrl); con.setRequestProperty("Referer", frontUrl);
con.setDoInput(true); con.setDoInput(true);
@ -84,20 +91,33 @@ public class InterfaceQsp {
} }
sb = new StringBuilder(); sb = new StringBuilder();
if (con.getResponseCode() == HttpURLConnection.HTTP_OK) { int status = con.getResponseCode();
br = new BufferedReader(new InputStreamReader(con.getInputStream(), "utf-8")); if (status == HttpURLConnection.HTTP_OK) {
br = new BufferedReader(new InputStreamReader(con.getInputStream(), "utf-8"));
String line;
while ((line = br.readLine()) != null) { String line;
sb.append(line); while ((line = br.readLine()) != null) {
} sb.append(line);
} }
} catch (Exception e) { }
throw e; log.debug(
} finally { "QSP API call end: method={}, url={}, status={}, durationMs={}",
try { httpMethod,
if (osw != null) osw.close(); apiPath,
if (br != null) br.close(); status,
System.currentTimeMillis() - startAt);
} catch (Exception e) {
log.error(
"QSP API call failed: method={}, url={}, durationMs={}",
httpMethod,
apiPath,
System.currentTimeMillis() - startAt,
e);
throw e;
} finally {
try {
if (osw != null) osw.close();
if (br != null) br.close();
} catch (Exception e) { } catch (Exception e) {
throw e; throw e;
} }
@ -156,23 +176,30 @@ public class InterfaceQsp {
* @return String * @return String
* @throws Exception * @throws Exception
*/ */
public byte[] callApi( public byte[] callApi(
HttpMethod httpMethod, String apiPath, Object requestObject, Map<String, String> result) HttpMethod httpMethod, String apiPath, Object requestObject, Map<String, String> result)
throws Exception { throws Exception {
URL url = null; URL url = null;
HttpURLConnection con = null; HttpURLConnection con = null;
OutputStreamWriter osw = null; OutputStreamWriter osw = null;
BufferedReader br = null; BufferedReader br = null;
byte[] bt = null; byte[] bt = null;
long startAt = System.currentTimeMillis();
try { String requestType = requestObject == null ? "none" : requestObject.getClass().getSimpleName();
url = new URL(apiPath);
con = (HttpURLConnection) url.openConnection(); try {
con.setConnectTimeout(30000); // 서버에 연결되는 Timeout 시간 설정 log.debug(
con.setReadTimeout(30000); // InputStream 읽어 오는 Timeout 시간 설정 "QSP API call start: method={}, url={}, requestType={}",
con.setRequestMethod(httpMethod.toString()); httpMethod,
apiPath,
requestType);
url = new URL(apiPath);
con = (HttpURLConnection) url.openConnection();
con.setConnectTimeout(30000); // 서버에 연결되는 Timeout 시간 설정
con.setReadTimeout(30000); // InputStream 읽어 오는 Timeout 시간 설정
con.setRequestMethod(httpMethod.toString());
con.setRequestProperty("Content-Type", "application/json"); con.setRequestProperty("Content-Type", "application/json");
con.setRequestProperty("Referer", frontUrl); con.setRequestProperty("Referer", frontUrl);
con.setDoInput(true); con.setDoInput(true);
@ -190,27 +217,40 @@ public class InterfaceQsp {
osw.flush(); osw.flush();
} }
} }
if (con.getResponseCode() == HttpURLConnection.HTTP_OK) { int status = con.getResponseCode();
// response 헤더 값 결과 셋팅 if (status == HttpURLConnection.HTTP_OK) {
result.put("type", con.getHeaderField("Content-Type")); // response 헤더 값 결과 셋팅
result.put("disposition", con.getHeaderField("Content-Disposition")); result.put("type", con.getHeaderField("Content-Type"));
result.put("disposition", con.getHeaderField("Content-Disposition"));
InputStream inputStream = con.getInputStream();
InputStream inputStream = con.getInputStream();
ByteArrayOutputStream outputStream = new ByteArrayOutputStream(); ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
byte[] buffer = new byte[4096]; byte[] buffer = new byte[4096];
int bytesRead; int bytesRead;
while ((bytesRead = inputStream.read(buffer)) != -1) { while ((bytesRead = inputStream.read(buffer)) != -1) {
outputStream.write(buffer, 0, bytesRead); outputStream.write(buffer, 0, bytesRead);
} }
bt = outputStream.toByteArray(); // 파일 데이터 반환 bt = outputStream.toByteArray(); // 파일 데이터 반환
} }
} catch (Exception e) { log.debug(
throw e; "QSP API call end: method={}, url={}, status={}, durationMs={}",
} finally { httpMethod,
try { apiPath,
if (osw != null) osw.close(); status,
if (br != null) br.close(); System.currentTimeMillis() - startAt);
} catch (Exception e) {
log.error(
"QSP API call failed: method={}, url={}, durationMs={}",
httpMethod,
apiPath,
System.currentTimeMillis() - startAt,
e);
throw e;
} finally {
try {
if (osw != null) osw.close();
if (br != null) br.close();
} catch (Exception e) { } catch (Exception e) {
throw e; throw e;
} }