|
@@ -0,0 +1,190 @@
|
|
|
|
|
+package com.style24.batch.biz.job.shoplinker;
|
|
|
|
|
+
|
|
|
|
|
+import java.io.File;
|
|
|
|
|
+import java.io.IOException;
|
|
|
|
|
+import java.net.URLEncoder;
|
|
|
|
|
+import java.util.Collection;
|
|
|
|
|
+
|
|
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
|
+import org.springframework.core.env.Environment;
|
|
|
|
|
+import org.springframework.stereotype.Component;
|
|
|
|
|
+
|
|
|
|
|
+import com.gagaframework.shoplinker.GagaShoplinkertUtil;
|
|
|
|
|
+import com.gagaframework.shoplinker.env.GagaShoplinkerConstants;
|
|
|
|
|
+import com.gagaframework.web.util.GagaDateUtil;
|
|
|
|
|
+import com.gagaframework.web.util.GagaFileUtil;
|
|
|
|
|
+import com.style24.batch.biz.job.TsbAbstractJob;
|
|
|
|
|
+import com.style24.batch.biz.service.TsbShoplinkerService;
|
|
|
|
|
+import com.style24.persistence.domain.ShoplinkerGoods;
|
|
|
|
|
+
|
|
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+/**
|
|
|
|
|
+ * 샵링커 재고전송
|
|
|
|
|
+ *
|
|
|
|
|
+ * @author jmh
|
|
|
|
|
+ * @since 2021.06.22
|
|
|
|
|
+*/
|
|
|
|
|
+@Component
|
|
|
|
|
+@Slf4j
|
|
|
|
|
+public class TsbShoplinkerStockJob extends TsbAbstractJob<Collection<ShoplinkerGoods>, Collection<ShoplinkerGoods>, String>{
|
|
|
|
|
+
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private TsbShoplinkerService shoplinkerService;
|
|
|
|
|
+
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private Environment env;
|
|
|
|
|
+
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public Collection<ShoplinkerGoods> read() throws Exception {
|
|
|
|
|
+
|
|
|
|
|
+ // 재고 변경정보 수정
|
|
|
|
|
+ shoplinkerService.updateSyncStock();
|
|
|
|
|
+
|
|
|
|
|
+ // 재고 변경 목록
|
|
|
|
|
+ return shoplinkerService.getSyncStockList();
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public Collection<ShoplinkerGoods> process(Collection<ShoplinkerGoods> stockList) throws Exception {
|
|
|
|
|
+ return stockList;
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public String write(Collection<ShoplinkerGoods> stockList) throws Exception {
|
|
|
|
|
+ ShoplinkerGoods regMap = new ShoplinkerGoods();
|
|
|
|
|
+
|
|
|
|
|
+ // xml 생성경로
|
|
|
|
|
+ String xmlPath = env.getProperty("shoplinker.xml.path");
|
|
|
|
|
+
|
|
|
|
|
+ // 샵링커 기본폴더 존재여부 확인
|
|
|
|
|
+ String slFolder = GagaFileUtil.getConcatenationPath(xmlPath);
|
|
|
|
|
+ File slPath = new File(slFolder);
|
|
|
|
|
+ if (!slPath.exists()) {
|
|
|
|
|
+ slPath.mkdir();
|
|
|
|
|
+ }
|
|
|
|
|
+ //하위폴더존재확인(상품등록)
|
|
|
|
|
+ slFolder = GagaFileUtil.getConcatenationPath(xmlPath+"/stock");
|
|
|
|
|
+ slPath = new File(slFolder);
|
|
|
|
|
+ if (!slPath.exists()) {
|
|
|
|
|
+ slPath.mkdir();
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ if (stockList != null && !stockList.isEmpty()) {
|
|
|
|
|
+
|
|
|
|
|
+ // 1. 재고 마스터 테이블 전송여부 Y로 일괄 변경(실패건이 거의 없으므로 실패건만 개별로 업데이트 시킨다.)
|
|
|
|
|
+ regMap.setSendYn("Y");
|
|
|
|
|
+ regMap.setAllUpdYn("Y");
|
|
|
|
|
+ shoplinkerService.updateStockInfo(regMap);
|
|
|
|
|
+
|
|
|
|
|
+ // 2. xml 파일 정보세팅
|
|
|
|
|
+ String toDtTime = GagaDateUtil.getTodayDateTime();
|
|
|
|
|
+ String customerId = env.getProperty("shoplinker.customer_id");
|
|
|
|
|
+ regMap.setSendYn("N"); // 성공이 아닐경우만 개별업데이트
|
|
|
|
|
+ regMap.setAllUpdYn("N"); // 성공이 아닐경우만 개별업데이트
|
|
|
|
|
+ regMap.setApiType("STOCK");
|
|
|
|
|
+ regMap.setApiSubUrl(env.getProperty("shoplinker.url.stock"));
|
|
|
|
|
+ regMap.setXmlPath(env.getProperty("shoplinker.xml.path")+"/stock"); // xml 생성경로
|
|
|
|
|
+ regMap.setDomainUrl(env.getProperty("shoplinker.xml.view")+"/stock"); // xml 확인domain url
|
|
|
|
|
+
|
|
|
|
|
+ try {
|
|
|
|
|
+ StringBuilder sbRequest;
|
|
|
|
|
+ int opCnt = 0;
|
|
|
|
|
+ for (ShoplinkerGoods map : stockList) {
|
|
|
|
|
+ opCnt ++;
|
|
|
|
|
+
|
|
|
|
|
+ // xml 데이터 세팅
|
|
|
|
|
+ sbRequest = new StringBuilder();
|
|
|
|
|
+ sbRequest.append("<?xml version=\"1.0\" encoding=\"euc-kr\"?>\n");
|
|
|
|
|
+ sbRequest.append("<shoplinker>\n");
|
|
|
|
|
+ sbRequest.append(" <product>\n");
|
|
|
|
|
+
|
|
|
|
|
+ sbRequest.append(" <customer_id>").append(customerId).append("</customer_id>\n");
|
|
|
|
|
+ sbRequest.append(" <mall_update_yn>N</mall_update_yn>\n");
|
|
|
|
|
+ sbRequest.append(" <partner_product_id><![CDATA[").append(map.getOptCd()).append("]]></partner_product_id>\n");
|
|
|
|
|
+ sbRequest.append(" <quantity>").append(map.getQuantity()).append("</quantity>\n");
|
|
|
|
|
+
|
|
|
|
|
+ sbRequest.append(" </product>\n");
|
|
|
|
|
+ sbRequest.append("</shoplinker>\n");
|
|
|
|
|
+
|
|
|
|
|
+ regMap.setGoodsCd(map.getGoodsCd());
|
|
|
|
|
+ regMap.setOptCd(map.getOptCd());
|
|
|
|
|
+ regMap.setQuantity(map.getQuantity());
|
|
|
|
|
+
|
|
|
|
|
+ // 3. api 호출 및 결과 history 저장
|
|
|
|
|
+ callGoodsRegApi(regMap , sbRequest, map.getOptCd());
|
|
|
|
|
+ //callGoodsRegApi(regMap , sbRequest, map.getOptCd()+"_"+toDtTime);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ }catch(Exception e) {
|
|
|
|
|
+ log.error("xml 생성오류 ", e);
|
|
|
|
|
+ regMap.setApiResult("error");
|
|
|
|
|
+ regMap.setApiMessage("xml 생성오류");
|
|
|
|
|
+ shoplinkerService.insertShoplinerApiHst(regMap);
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ return "OK";
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public void notify(String result) throws Exception {
|
|
|
|
|
+ // Do nothing
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ private int callGoodsRegApi(ShoplinkerGoods map, StringBuilder sbRequest, String fileNm) throws IOException {
|
|
|
|
|
+
|
|
|
|
|
+ int succCnt = 0;
|
|
|
|
|
+ com.gagaframework.shoplinker.domain.goods.result.Shoplinker shoplinkerResult;
|
|
|
|
|
+ com.gagaframework.shoplinker.domain.goods.result.ResultMessage resultMsg;
|
|
|
|
|
+
|
|
|
|
|
+ try {
|
|
|
|
|
+ GagaShoplinkertUtil shoplinkerUtil = new GagaShoplinkertUtil("MS949");
|
|
|
|
|
+
|
|
|
|
|
+ // XML 파일 생성
|
|
|
|
|
+ StringBuilder xmlFileName = new StringBuilder();
|
|
|
|
|
+ xmlFileName.append("stock_"+fileNm).append(".xml");
|
|
|
|
|
+ String xmlPath = GagaFileUtil.getConcatenationPath(map.getXmlPath(), xmlFileName.toString());
|
|
|
|
|
+ shoplinkerUtil.makeRequestXmlFile(sbRequest.toString(), xmlPath);
|
|
|
|
|
+ String xmlUrl = GagaFileUtil.getConcatenationPath(map.getDomainUrl(), xmlFileName.toString());
|
|
|
|
|
+
|
|
|
|
|
+ // API 호출URL
|
|
|
|
|
+ String apiUrl = GagaShoplinkerConstants.API_DOMAIN + map.getApiSubUrl() + URLEncoder.encode(xmlUrl);
|
|
|
|
|
+
|
|
|
|
|
+ // API 호출결과
|
|
|
|
|
+ String responseXmlData = shoplinkerUtil.callShoplinkerApiByGet(apiUrl, "");
|
|
|
|
|
+
|
|
|
|
|
+ // response 결과
|
|
|
|
|
+ shoplinkerResult = (com.gagaframework.shoplinker.domain.goods.result.Shoplinker)shoplinkerUtil.unmarshal(com.gagaframework.shoplinker.domain.goods.result.Shoplinker.class, responseXmlData);
|
|
|
|
|
+ resultMsg = shoplinkerResult.getResultMessage();
|
|
|
|
|
+ map.setXmlTxt(sbRequest.toString());
|
|
|
|
|
+ map.setApiProductId(resultMsg.getProductId());
|
|
|
|
|
+ map.setApiResult(resultMsg.getResult());
|
|
|
|
|
+ map.setApiMessage(resultMsg.getMessage());
|
|
|
|
|
+
|
|
|
|
|
+ if( "true".equals(resultMsg.getResult())){
|
|
|
|
|
+ succCnt = 1;
|
|
|
|
|
+ }else {
|
|
|
|
|
+ // 실패 전송이력 N으로 수정
|
|
|
|
|
+ shoplinkerService.updateStockInfo(map);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ // 생성 파일삭제
|
|
|
|
|
+ // GagaFileUtil.deleteFile(GagaFileUtil.getConcatenationPath(map.getXmlPath(), xmlFileName.toString()));
|
|
|
|
|
+
|
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
|
+ log.error("error", e);
|
|
|
|
|
+ map.setXmlTxt(sbRequest.toString());
|
|
|
|
|
+ map.setApiResult("error");
|
|
|
|
|
+ map.setApiMessage("API 통신오류");
|
|
|
|
|
+
|
|
|
|
|
+ shoplinkerService.updateStockInfo(map);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ // 전송이력 저장
|
|
|
|
|
+ shoplinkerService.insertShoplinerApiHst(map);
|
|
|
|
|
+
|
|
|
|
|
+ return succCnt;
|
|
|
|
|
+ }
|
|
|
|
|
+}
|