djb-eapim/eapim-online
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Inbound async ack 줄때 in header를 그대로 ack header에 보내줌(카뱅)

Browse Source
This commit is contained in:
jaewohong
2026-02-05 15:28:56 +09:00
parent bb8172dd6b
commit a212144a0a
1 changed files with 280 additions and 279 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/eactive/eai/adapter/controller/ApiAdapterController.java
+252 -251
View File
@@ -1,6 +1,7 @@
package com.eactive.eai.adapter.controller; package com.eactive.eai.adapter.controller;
import java.util.Date; import java.util.Date;
import java.util.Enumeration;
import java.util.Properties; import java.util.Properties;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
@@ -46,301 +47,301 @@ import java.util.Map;
@RestController @RestController
public class ApiAdapterController implements HttpAdapterServiceKey { public class ApiAdapterController implements HttpAdapterServiceKey {
static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER); static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER);
@Autowired @Autowired
ApiAdapterService service; ApiAdapterService service;
/** /**
* KJBANK 요구사항으로 /mapi/oauth2/token 과 같은 형태로 토큰 발급거래를 수행해야해서 예외처리함 * KJBANK 요구사항으로 /mapi/oauth2/token 과 같은 형태로 토큰 발급거래를 수행해야해서 예외처리함
* @See com.eactive.eai.authserver.config.AuthorizationServerConfig.configure(AuthorizationServerEndpointsConfigurer endpoints) *
*/ * @See com.eactive.eai.authserver.config.AuthorizationServerConfig.configure(AuthorizationServerEndpointsConfigurer
@RequestMapping(value = {"/api/*", "/mapi/*", "/api/*/{path:^(?!.*oauth).*$}/**", "/mapi/{path:^(?!.*oauth2).*$}/**"}) * endpoints)
*/
@RequestMapping(value = { "/api/*", "/mapi/*", "/api/*/{path:^(?!.*oauth).*$}/**",
"/mapi/{path:^(?!.*oauth2).*$}/**" })
// @RequestMapping(value = {"/api/**"}) // @RequestMapping(value = {"/api/**"})
public ResponseEntity<String> callApi(HttpServletRequest servletRequest, HttpServletResponse servletResponse) throws Exception { public ResponseEntity<String> callApi(HttpServletRequest servletRequest, HttpServletResponse servletResponse)
// /ONLWeb/api/v1/public/getUserInfo.svc throws Exception {
String apiUri = servletRequest.getRequestURI(); // /ONLWeb/api/v1/public/getUserInfo.svc
// /api/v1/public/getUserInfo.svc String apiUri = servletRequest.getRequestURI();
apiUri = StringUtils.removeStart(apiUri, servletRequest.getContextPath()); // /api/v1/public/getUserInfo.svc
apiUri = StringUtils.removeEnd(apiUri, "/"); apiUri = StringUtils.removeStart(apiUri, servletRequest.getContextPath());
apiUri = StringUtils.removeEnd(apiUri, "/");
//** jwhong TSEAIHS04의 api full path와 비교하여 adapter를 가져온다 // ** jwhong TSEAIHS04의 api full path와 비교하여 adapter를 가져온다
String methodAndUri = servletRequest.getMethod() + "|" + apiUri; String methodAndUri = servletRequest.getMethod() + "|" + apiUri;
HttpDynamicInAdapterUri adptUri = null; HttpDynamicInAdapterUri adptUri = null;
String bzwkSvcKeyName = ""; // Adapter Group별 Action Class에 따라 구성이 달라짐. 예) _AGW_IN_RST_SyS:POST/account/{acc_no} String bzwkSvcKeyName = ""; // Adapter Group별 Action Class에 따라 구성이 달라짐. 예)
String adapterGrpName = ""; // Adapter Group명 예) _AGW_IN_RST_SyS : API_PATH(/api/test) // _AGW_IN_RST_SyS:POST/account/{acc_no}
String apiSvcCode = ""; // eaiSvcCd 예) LONNCHCON00005S2 String adapterGrpName = ""; // Adapter Group명 예) _AGW_IN_RST_SyS : API_PATH(/api/test)
String apiFullPathKey = ""; // 예) POST|/api/test/account/list, POST|/api/test/account/{acc_no} String apiSvcCode = ""; // eaiSvcCd 예) LONNCHCON00005S2
Map<String, String> pathVariables = null; String apiFullPathKey = ""; // 예) POST|/api/test/account/list, POST|/api/test/account/{acc_no}
try { Map<String, String> pathVariables = null;
// PathVariable(ex:/api/test/account/{acc_no}) 대응 및 DAO조회 제거. try {
// /api/test/account/1234567 호출시 /api/test/account/{acc_no} API 로 식별. // PathVariable(ex:/api/test/account/{acc_no}) 대응 및 DAO조회 제거.
STDMessageManager manager = STDMessageManager.getInstance(); // /api/test/account/1234567 호출시 /api/test/account/{acc_no} API 로 식별.
STDMsgInfoAddOnVO stdMsgInfo = manager.getStdMsgInfoAddOn(methodAndUri); STDMessageManager manager = STDMessageManager.getInstance();
bzwkSvcKeyName = stdMsgInfo.getBzwksvckeyname(); STDMsgInfoAddOnVO stdMsgInfo = manager.getStdMsgInfoAddOn(methodAndUri);
apiSvcCode = stdMsgInfo.getEaiSvcCd(); bzwkSvcKeyName = stdMsgInfo.getBzwksvckeyname();
adapterGrpName = stdMsgInfo.gAdapterGroupName(); apiSvcCode = stdMsgInfo.getEaiSvcCd();
apiFullPathKey = stdMsgInfo.getApiFullPath(); adapterGrpName = stdMsgInfo.gAdapterGroupName();
if (STDMessageManager.isPathVariable(apiFullPathKey)) { apiFullPathKey = stdMsgInfo.getApiFullPath();
pathVariables = new AntPathMatcher().extractUriTemplateVariables(apiFullPathKey, methodAndUri); if (STDMessageManager.isPathVariable(apiFullPathKey)) {
} pathVariables = new AntPathMatcher().extractUriTemplateVariables(apiFullPathKey, methodAndUri);
}
adptUri = findAdptUri(apiUri, HttpDynamicInAdapterManager.getInstance(), adapterGrpName); adptUri = findAdptUri(apiUri, HttpDynamicInAdapterManager.getInstance(), adapterGrpName);
} catch (Exception e) { } catch (Exception e) {
adptUri = null; adptUri = null;
} }
//*** // ***
if (logger.isDebug()) { if (logger.isDebug()) {
logger.debug("ApiAdapterController] service request uri : " + servletRequest.getRequestURI()); logger.debug("ApiAdapterController] service request uri : " + servletRequest.getRequestURI());
} }
if (adptUri == null) { if (adptUri == null) {
logError(servletRequest); logError(servletRequest);
String errorMsg = MessageUtil.makeJsonErrorMessage(MessageUtil.ERROR_CODE_SERVICE_NOT_FOUND, "can not find Adapter Uri"); String errorMsg = MessageUtil.makeJsonErrorMessage(MessageUtil.ERROR_CODE_SERVICE_NOT_FOUND,
return ResponseEntity.status(HttpStatus.NOT_FOUND) "can not find Adapter Uri");
.contentType(MediaType.APPLICATION_JSON) return ResponseEntity.status(HttpStatus.NOT_FOUND).contentType(MediaType.APPLICATION_JSON).body(errorMsg);
.body(errorMsg); }
}
//Received time , jwhong // Received time , jwhong
long receivedTimeMillis = System.currentTimeMillis(); // 밀리세컨 단위로 보내야함 long receivedTimeMillis = System.currentTimeMillis(); // 밀리세컨 단위로 보내야함
String receivedTimeStr = String.valueOf(receivedTimeMillis); String receivedTimeStr = String.valueOf(receivedTimeMillis);
String adapterGroupName = adptUri.getAdptGrpName(); String adapterGroupName = adptUri.getAdptGrpName();
String adapterName = adptUri.getAdptName(); String adapterName = adptUri.getAdptName();
AdapterGroupVO adapterGroupVO = AdapterManager.getInstance().getAdapterGroupVO(adapterGroupName); AdapterGroupVO adapterGroupVO = AdapterManager.getInstance().getAdapterGroupVO(adapterGroupName);
AdapterVO adapterVO = AdapterManager.getInstance().getAdapterVO(adapterGroupName, adapterName); AdapterVO adapterVO = AdapterManager.getInstance().getAdapterVO(adapterGroupName, adapterName);
if (adapterVO == null) { if (adapterVO == null) {
String errorMsg = MessageUtil.makeJsonErrorMessage(MessageUtil.ERROR_CODE_AP_ERROR, "Adapter not found error"); String errorMsg = MessageUtil.makeJsonErrorMessage(MessageUtil.ERROR_CODE_AP_ERROR,
return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR) "Adapter not found error");
.contentType(MediaType.APPLICATION_JSON) return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).contentType(MediaType.APPLICATION_JSON)
.body(errorMsg); .body(errorMsg);
} }
Properties httpProp = AdapterPropManager.getInstance().getProperties(adapterVO.getPropGroupName()); Properties httpProp = AdapterPropManager.getInstance().getProperties(adapterVO.getPropGroupName());
String adptMsgType = adapterVO.getAdapterGroupVO().getMessageType(); String adptMsgType = adapterVO.getAdapterGroupVO().getMessageType();
String encode = StringUtils.defaultIfBlank(adapterGroupVO.getMessageEncode(), "UTF-8"); String encode = StringUtils.defaultIfBlank(adapterGroupVO.getMessageEncode(), "UTF-8");
MediaType mediaType = MediaType.valueOf("application/json;charset=" + encode); MediaType mediaType = MediaType.valueOf("application/json;charset=" + encode);
String errorResponseFormat = httpProp.getProperty(ERROR_RESPONSE_FORMAT); String errorResponseFormat = httpProp.getProperty(ERROR_RESPONSE_FORMAT);
String responseType = httpProp.getProperty(RESPONSE_TYPE, "SYNC"); String responseType = httpProp.getProperty(RESPONSE_TYPE, "SYNC");
ResponseEntity responseEntity = null; ResponseEntity responseEntity = null;
Properties transactionProp = new Properties(); Properties transactionProp = new Properties();
// jwhong, put api received time, eaiSvcCode // jwhong, put api received time, eaiSvcCode
transactionProp.put(INBOUND_REQUESTED_TIME, receivedTimeStr); transactionProp.put(INBOUND_REQUESTED_TIME, receivedTimeStr);
transactionProp.put(API_SERVICE_CODE, apiSvcCode); transactionProp.put(API_SERVICE_CODE, apiSvcCode);
if (pathVariables != null) { if (pathVariables != null) {
transactionProp.put(INBOUND_PATH_VARIABLES, pathVariables); transactionProp.put(INBOUND_PATH_VARIABLES, pathVariables);
} }
try { try {
String responseData = service.callApi(servletRequest, servletResponse, httpProp, adapterGroupVO, adapterVO, transactionProp); String responseData = service.callApi(servletRequest, servletResponse, httpProp, adapterGroupVO, adapterVO,
// if (RESPONSE_TYPE_ASYNC.equals(responseType)) { // table의 값이 ASYNC 로 들어가 있는데 response_type_async는 ASYN 로 되어 있어 아래처럼 비교함 jwhong 2025 transactionProp);
if ("ASYNC".equals(responseType)) { // if (RESPONSE_TYPE_ASYNC.equals(responseType)) { // table의 값이 ASYNC 로 들어가 있는데
//responseEntity = ResponseEntity.ok("dummy"); // comment by jwhong // response_type_async는 ASYN 로 되어 있어 아래처럼 비교함 jwhong 2025
//servletResponse.addHeader("traceId", responseData); // uuid를 response header에 if ("ASYNC".equals(responseType)) {
servletResponse.addHeader("traceId", transactionProp.getProperty(TransactionContextKeys.TRANSACTION_UUID)); // uuid를 response header에 // responseEntity = ResponseEntity.ok("dummy"); // comment by jwhong
int httpStatus = servletResponse.getStatus(); // servletResponse.addHeader("traceId", responseData); // uuid를 response header에
if (httpStatus == 200) { servletResponse.addHeader("traceId",
// 업체별 aync response message 가 다르다. transactionProp.getProperty(TransactionContextKeys.TRANSACTION_UUID)); // uuid를 response header에
String asyncMsgStyle = httpProp.getProperty("ASYNC_RTNMSG_TYPE", ""); int httpStatus = servletResponse.getStatus();
String responseBody =""; if (httpStatus == 200) {
boolean encryptAsyncAckApply = StringUtils.equalsIgnoreCase(httpProp.getProperty("ASYNC_ENCRYPT_ACK", "N"), "Y"); // 업체별 aync response message 가 다르다.
String asyncMsgStyle = httpProp.getProperty("ASYNC_RTNMSG_TYPE", "");
String responseBody = "";
boolean encryptAsyncAckApply = StringUtils
.equalsIgnoreCase(httpProp.getProperty("ASYNC_ENCRYPT_ACK", "N"), "Y");
if (asyncMsgStyle == null || asyncMsgStyle.trim().isEmpty()) { if (asyncMsgStyle == null || asyncMsgStyle.trim().isEmpty()) {
responseBody = makeResponseBodyMsg(); responseBody = makeResponseBodyMsg();
} else { } else {
responseBody = asyncMsgStyle; responseBody = asyncMsgStyle;
} }
if ( encryptAsyncAckApply) { if (encryptAsyncAckApply) {
responseBody = service.doPostEncryption(responseBody, transactionProp, servletRequest); responseBody = service.doPostEncryption(responseBody, transactionProp, servletRequest);
} }
// In 으로 들어온 http header를 ack 줄때 다시 넘겨줌 jwhong, 특히 kakaobank.
Enumeration<String> headerNames = servletRequest.getHeaderNames();
while (headerNames.hasMoreElements()) {
String headerName = headerNames.nextElement();
String headerValue = servletRequest.getHeader(headerName);
servletResponse.setHeader(headerName, headerValue);
}
responseEntity = ResponseEntity.status(httpStatus).contentType(mediaType).body(responseBody); responseEntity = ResponseEntity.status(httpStatus).contentType(mediaType).body(responseBody);
// jwhong // jwhong
} else { } else {
responseEntity = ResponseEntity.status(httpStatus).contentType(mediaType).body(responseData); responseEntity = ResponseEntity.status(httpStatus).contentType(mediaType).body(responseData);
} }
} else { } else {
// responseEntity = ResponseEntity.ok().contentType(mediaType).body(responseData); // responseEntity = ResponseEntity.ok().contentType(mediaType).body(responseData);
// 버즈빌 포인트 적립 처리하기 위하여 정상응답이더라도 응답코드(apiRsltCd) 값이 200이 아닌 경우 처리를 위하여 수정 // 버즈빌 포인트 적립 처리하기 위하여 정상응답이더라도 응답코드(apiRsltCd) 값이 200이 아닌 경우 처리를 위하여 수정
// Filter에서 설정한 response status값을 responseEntity 생성시 적용 modify by lwk 2025.03.24 // Filter에서 설정한 response status값을 responseEntity 생성시 적용 modify by lwk 2025.03.24
servletResponse.addHeader("traceId", transactionProp.getProperty(TransactionContextKeys.TRANSACTION_UUID)); // uuid를 response header에 servletResponse.addHeader("traceId",
int httpStatus = servletResponse.getStatus(); transactionProp.getProperty(TransactionContextKeys.TRANSACTION_UUID)); // uuid를 response header에
if (httpStatus != 200) { int httpStatus = servletResponse.getStatus();
responseEntity = ResponseEntity.status(httpStatus).contentType(mediaType).body(responseData); if (httpStatus != 200) {
} else { responseEntity = ResponseEntity.status(httpStatus).contentType(mediaType).body(responseData);
responseEntity = ResponseEntity.ok().contentType(mediaType).body(responseData); } else {
} responseEntity = ResponseEntity.ok().contentType(mediaType).body(responseData);
} }
}
} catch (HttpStatusException e) { } catch (HttpStatusException e) {
logger.warn("ApiAdapterController] " + adapterGroupName + "-" + adapterName + ">>" + e.getMessage()); logger.warn("ApiAdapterController] " + adapterGroupName + "-" + adapterName + ">>" + e.getMessage());
String errorMsg = MessageUtil.makeErrorMessageByMessageType(adptMsgType, encode, MessageUtil.ERROR_CODE_AP_ERROR, String errorMsg = MessageUtil.makeErrorMessageByMessageType(adptMsgType, encode,
e.getMessage(), errorResponseFormat); MessageUtil.ERROR_CODE_AP_ERROR, e.getMessage(), errorResponseFormat);
responseEntity = ResponseEntity.status(e.getStatus()).contentType(mediaType).body(errorMsg); responseEntity = ResponseEntity.status(e.getStatus()).contentType(mediaType).body(errorMsg);
} catch (JwtAuthException e) { } catch (JwtAuthException e) {
logger.error(adapterGroupName + "-" + adapterName + ">>" + e.getMessage(), e); logger.error(adapterGroupName + "-" + adapterName + ">>" + e.getMessage(), e);
String errorMsg = MessageUtil.makeErrorMessageByMessageType(adptMsgType, encode, MessageUtil.ERROR_CODE_AUTH_FAIL, String errorMsg = MessageUtil.makeErrorMessageByMessageType(adptMsgType, encode,
e.getMessage(), errorResponseFormat); MessageUtil.ERROR_CODE_AUTH_FAIL, e.getMessage(), errorResponseFormat);
responseEntity = ResponseEntity.status(HttpStatus.UNAUTHORIZED).contentType(mediaType).body(errorMsg); responseEntity = ResponseEntity.status(HttpStatus.UNAUTHORIZED).contentType(mediaType).body(errorMsg);
} catch (Exception e) { } catch (Exception e) {
logger.error(adapterGroupName + "-" + adapterName + ">>" + e.getMessage(), e); logger.error(adapterGroupName + "-" + adapterName + ">>" + e.getMessage(), e);
String errorMsg = MessageUtil.makeErrorMessageByMessageType(adptMsgType, encode, MessageUtil.ERROR_CODE_AP_ERROR, String errorMsg = MessageUtil.makeErrorMessageByMessageType(adptMsgType, encode,
e.getMessage(), errorResponseFormat); MessageUtil.ERROR_CODE_AP_ERROR, e.getMessage(), errorResponseFormat);
responseEntity = ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).contentType(mediaType).body(errorMsg); responseEntity = ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).contentType(mediaType)
} finally { .body(errorMsg);
/** } finally {
* 로깅 인터셉터에 데이터를 전달하기 위한 처리 /**
* 이미 거래처리가 끝나서 영향도가 없을만한 servletRequest에 Attribute로 전달 * 로깅 인터셉터에 데이터를 전달하기 위한 처리 이미 거래처리가 끝나서 영향도가 없을만한 servletRequest에 Attribute로 전달
* 추후 더 좋은방법이 생길경우 개선 요망 * 추후 더 좋은방법이 생길경우 개선 요망
*/ */
servletRequest.setAttribute(TransactionContextKeys.TRANSACTION_PROP, transactionProp); servletRequest.setAttribute(TransactionContextKeys.TRANSACTION_PROP, transactionProp);
if (!"ASYNC".equals(responseType)) { if (!"ASYNC".equals(responseType)) {
String uuid = transactionProp.getProperty(TransactionContextKeys.TRANSACTION_UUID); String uuid = transactionProp.getProperty(TransactionContextKeys.TRANSACTION_UUID);
String url = transactionProp.getProperty(HttpClientAdapterServiceKey.INBOUND_EXTURI); String url = transactionProp.getProperty(HttpClientAdapterServiceKey.INBOUND_EXTURI);
String method = transactionProp.getProperty(HttpClientAdapterServiceKey.INBOUND_METHOD); String method = transactionProp.getProperty(HttpClientAdapterServiceKey.INBOUND_METHOD);
int httpStatusCode = servletResponse.getStatus(); int httpStatusCode = servletResponse.getStatus();
Map<Object, Object> headerMap = new HashMap<>(); Map<Object, Object> headerMap = new HashMap<>();
// 응답 헤더 로깅 // 응답 헤더 로깅
for (String headerName : servletResponse.getHeaderNames()) { for (String headerName : servletResponse.getHeaderNames()) {
String headerValue = servletResponse.getHeader(headerName); String headerValue = servletResponse.getHeader(headerName);
logger.debug(String.format( "httpHeader logging headerKey=%s, headerValue=%s", headerName, headerValue)); logger.debug(
headerMap.put(headerName, headerValue); String.format("httpHeader logging headerKey=%s, headerValue=%s", headerName, headerValue));
} headerMap.put(headerName, headerValue);
HttpAdapterExtraLogUtil.insertHttpAdapterExtraLog(uuid, 400, adapterGroupName, adapterName, headerMap, url, method, httpStatusCode); }
} HttpAdapterExtraLogUtil.insertHttpAdapterExtraLog(uuid, 400, adapterGroupName, adapterName, headerMap,
} url, method, httpStatusCode);
return responseEntity; }
} }
return responseEntity;
}
/**
* url에서 뒤쪽 /이후를 제거하면서 찾는다.<br>
* /api/v1/public/getUserInfo.svc
*
* @param apiUri
* @return
*/
private HttpDynamicInAdapterUri findAdptUri(String apiUri, HttpDynamicInAdapterManager manager,
String adapterGrpName) throws Exception {
if (StringUtils.isBlank(apiUri)) {
return null;
}
// * manager 출력
logger.warn("===== adptUriMap 상세 내용 =====");
for (Map.Entry<String, HttpDynamicInAdapterUri> entry : manager.adptUriMap.entrySet()) {
HttpDynamicInAdapterUri uriObj = entry.getValue();
logger.warn("GroupName=" + uriObj.getAdptGrpName() + ", AdapterName=" + uriObj.getAdptName() + ", URI="
+ uriObj.getUri());
}
logger.warn("================================");
/** //
* url에서 뒤쪽 /이후를 제거하면서 찾는다.<br> for (int i = 0; i < 10; i++) {
* /api/v1/public/getUserInfo.svc HttpDynamicInAdapterUri adptUri = manager.getAdptUri(apiUri);
* if (adptUri != null) {
* @param apiUri if (adptUri.getAdptGrpName().equals(adapterGrpName)) {
* @return return adptUri;
*/ }
private HttpDynamicInAdapterUri findAdptUri(String apiUri, HttpDynamicInAdapterManager manager, String adapterGrpName) throws Exception { }
if (StringUtils.isBlank(apiUri)) {
return null;
}
//* manager 출력 // /api/v1/public
logger.warn("===== adptUriMap 상세 내용 ====="); apiUri = StringUtils.substringBeforeLast(apiUri, "/");
for (Map.Entry<String, HttpDynamicInAdapterUri> entry : manager.adptUriMap.entrySet()) { if (apiUri.length() < 4) { // /api
HttpDynamicInAdapterUri uriObj = entry.getValue(); return null;
logger.warn("GroupName=" + uriObj.getAdptGrpName() }
+ ", AdapterName=" + uriObj.getAdptName() }
+ ", URI=" + uriObj.getUri());
}
logger.warn("================================");
return null;
}
// private void logError(HttpServletRequest request) {
for (int i = 0; i < 10; i++) { InboundErrorInfoVO errorInfoVO = new InboundErrorInfoVO();
HttpDynamicInAdapterUri adptUri = manager.getAdptUri(apiUri);
if (adptUri != null) {
if (adptUri.getAdptGrpName().equals(adapterGrpName)) {
return adptUri;
}
}
// /api/v1/public EAIServerManager eaiServerManager = EAIServerManager.getInstance();
apiUri = StringUtils.substringBeforeLast(apiUri, "/"); String serverName = eaiServerManager.getLocalServerName();
if (apiUri.length() < 4) { // /api String uuid = null;
return null; StringBuffer sb = new StringBuffer();
}
}
return null; String instanceid1 = serverName.substring(0, 2);
} String instanceid2 = serverName.substring(serverName.length() - 2, serverName.length());
String instid = instanceid1 + instanceid2;
uuid = instid + UUIDGenerator.getUUID();
private void logError(HttpServletRequest request) { String[] msgArgs = new String[1];
InboundErrorInfoVO errorInfoVO = new InboundErrorInfoVO(); msgArgs[0] = request.getRequestURI();
EAIServerManager eaiServerManager = EAIServerManager.getInstance(); String errorCode = "RECEAIIRP010";
String serverName = eaiServerManager.getLocalServerName(); String errorMsg = ExceptionUtil.make(new Exception("cat not find uri"), errorCode, msgArgs);
String uuid = null;
StringBuffer sb = new StringBuffer();
String instanceid1 = serverName.substring(0, 2); errorInfoVO.setEaiSvcSno(uuid); // EAI서비스일련번호
String instanceid2 = serverName.substring(serverName.length() - 2, serverName.length()); errorInfoVO.setAdptBwkGrpNm("HTTP_IN_NO_URI"); // 어댑터업무그룹명
String instid = instanceid1 + instanceid2; errorInfoVO.setErrCd(errorCode); // 에러코드
uuid = instid + UUIDGenerator.getUUID(); errorInfoVO.setErrTxt(errorMsg); // 에러내용
errorInfoVO.setErrTm(DatetimeUtil.getCurrentTime(new Date().getTime())); // 에러발생시각
errorInfoVO.setErrDstcd(" ");
sb.append("Remote Addr : ").append(request.getRemoteAddr()).append("\n").append("Request URI : ")
.append(request.getRequestURI());
errorInfoVO.setBwkDataTxt(sb.toString()); // 업무데이터내용
errorInfoVO.setEaiSvrInstNm(serverName); // EAI서버인스턴스명
String[] msgArgs = new String[1]; InboundErrorLogger.error(errorInfoVO);
msgArgs[0] = request.getRequestURI(); }
String errorCode = "RECEAIIRP010"; private String makeResponseBodyMsg() {
String errorMsg = ExceptionUtil.make(new Exception("cat not find uri"), errorCode, msgArgs);
errorInfoVO.setEaiSvcSno(uuid); // EAI서비스일련번호 Map<String, Object> dataMap = new HashMap<>();
errorInfoVO.setAdptBwkGrpNm("HTTP_IN_NO_URI"); // 어댑터업무그룹명 dataMap.put("result", 1);
errorInfoVO.setErrCd(errorCode); // 에러코드
errorInfoVO.setErrTxt(errorMsg); // 에러내용
errorInfoVO.setErrTm(DatetimeUtil.getCurrentTime(new Date().getTime())); // 에러발생시각
errorInfoVO.setErrDstcd(" ");
sb.append("Remote Addr : ").append(request.getRemoteAddr()).append("\n").append("Request URI : ")
.append(request.getRequestURI());
errorInfoVO.setBwkDataTxt(sb.toString()); // 업무데이터내용
errorInfoVO.setEaiSvrInstNm(serverName); // EAI서버인스턴스명
InboundErrorLogger.error(errorInfoVO);
}
private String makeResponseBodyMsg() {
Map<String, Object> dataMap = new HashMap<>();
dataMap.put("result", 1);
Map<String, Object> map = new HashMap<>(); Map<String, Object> map = new HashMap<>();
map.put("code", "200"); map.put("code", "200");
map.put("data", dataMap); map.put("data", dataMap);
map.put("message", "정상 처리 되었습니다."); map.put("message", "정상 처리 되었습니다.");
JSONObject json = new JSONObject(); JSONObject json = new JSONObject();
json.putAll(map); json.putAll(map);
return json.toJSONString(); return json.toJSONString();
} }
/* /*
private String makeResponseBodyMsg(String asyncMsgStyle) { * private String makeResponseBodyMsg(String asyncMsgStyle) {
*
Map<String, Object> dataMap = new HashMap<>(); * Map<String, Object> dataMap = new HashMap<>(); dataMap.put("result", 1);
dataMap.put("result", 1); * Map<String, Object> map = new HashMap<>();
Map<String, Object> map = new HashMap<>(); *
* switch (asyncMsgStyle) { case "TB_SUC": map.put("rspCode", "TB_SUC_000");
switch (asyncMsgStyle) { * map.put("rspMsg", "정상"); map.put("data", dataMap); break; case "ONLYDATA":
case "TB_SUC": * map.put("data", dataMap); map.put("success", "true"); break; default:
map.put("rspCode", "TB_SUC_000"); * map.put("code", "200"); map.put("data", dataMap); map.put("message",
map.put("rspMsg", "정상"); * "정상 처리 되었습니다."); break; }
map.put("data", dataMap); *
break; * JSONObject json = new JSONObject(); json.putAll(map);
case "ONLYDATA": *
map.put("data", dataMap); * return json.toJSONString(); }
map.put("success", "true"); */
break;
default:
map.put("code", "200");
map.put("data", dataMap);
map.put("message", "정상 처리 되었습니다.");
break;
}
JSONObject json = new JSONObject();
json.putAll(map);
return json.toJSONString();
}
*/
} }