From a01ee024c0ff9f91c822d81f89befdef5cfaff4a Mon Sep 17 00:00:00 2001 From: curry772 Date: Mon, 15 Jun 2026 14:47:01 +0900 Subject: [PATCH] =?UTF-8?q?djbank=EC=97=90=20=EC=BB=A4=EC=8A=A4=ED=85=80?= =?UTF-8?q?=20=EB=90=A0=20AdapterErrorMsgHandler=20=EC=B6=94=EA=B0=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../handler/ErpAdapterErrorMsgHandler.java | 48 +++++++++++++++++ .../adapter/handler/LonErrorMsgHandler.java | 52 ------------------- 2 files changed, 48 insertions(+), 52 deletions(-) create mode 100644 src/main/java/com/eactive/eai/custom/adapter/handler/ErpAdapterErrorMsgHandler.java delete mode 100644 src/main/java/com/eactive/eai/custom/adapter/handler/LonErrorMsgHandler.java diff --git a/src/main/java/com/eactive/eai/custom/adapter/handler/ErpAdapterErrorMsgHandler.java b/src/main/java/com/eactive/eai/custom/adapter/handler/ErpAdapterErrorMsgHandler.java new file mode 100644 index 0000000..ec53d92 --- /dev/null +++ b/src/main/java/com/eactive/eai/custom/adapter/handler/ErpAdapterErrorMsgHandler.java @@ -0,0 +1,48 @@ +package com.eactive.eai.custom.adapter.handler; + +import java.util.Properties; + +import org.apache.commons.lang3.StringUtils; + +import com.eactive.eai.adapter.handler.TemplateCodeConvertAdapterErrorMsgHandler; +import com.eactive.eai.common.message.EAIMessage; +import com.eactive.eai.common.util.Logger; +import com.fasterxml.jackson.databind.JsonNode; +import com.fasterxml.jackson.databind.ObjectMapper; + +public class ErpAdapterErrorMsgHandler extends TemplateCodeConvertAdapterErrorMsgHandler { + + private static final Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER); + + private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper(); + + @Override + public Object generateNonStandardErrorResponseMessage(String inboundAdapterGroupName, String inboundAdapterName, + Properties callProp, Object outboundRequestData, EAIMessage resEaiMsg) throws Exception { + + Object responseMsessage = super.generateNonStandardErrorResponseMessage(inboundAdapterGroupName, + inboundAdapterName, callProp, outboundRequestData, resEaiMsg); + + logger.debug("generateNonStandardErrorResponseMessage - {}", responseMsessage); + + if (!(responseMsessage instanceof String)) { + return responseMsessage; + } + + String jsonStr = (String) responseMsessage; + if (StringUtils.isBlank(jsonStr)) { + return responseMsessage; + } + + JsonNode rootNode = OBJECT_MAPPER.readTree(jsonStr); + + boolean modified = false; + + if (modified) { + responseMsessage = OBJECT_MAPPER.writeValueAsString(rootNode); + } + + return responseMsessage; + } + +} diff --git a/src/main/java/com/eactive/eai/custom/adapter/handler/LonErrorMsgHandler.java b/src/main/java/com/eactive/eai/custom/adapter/handler/LonErrorMsgHandler.java deleted file mode 100644 index 2fee9d6..0000000 --- a/src/main/java/com/eactive/eai/custom/adapter/handler/LonErrorMsgHandler.java +++ /dev/null @@ -1,52 +0,0 @@ -//package com.eactive.eai.custom.adapter.handler; -// -//import java.util.Properties; -// -//import com.eactive.eai.adapter.AdapterGroupVO; -//import com.eactive.eai.adapter.AdapterManager; -//import com.eactive.eai.adapter.handler.AdapterErrorMessageHandler; -//import com.eactive.eai.common.message.MessageType; -//import com.eactive.eai.message.StandardMessage; -//import com.eactive.eai.message.manager.StandardMessageManager; -//import com.eactive.eai.message.service.InterfaceMapper; -//import com.ext.eai.common.stdmessage.STDMessageKeys; -//import com.fasterxml.jackson.databind.JsonNode; -//import com.fasterxml.jackson.databind.ObjectMapper; -//import com.fasterxml.jackson.databind.node.ObjectNode; -// -//public class LonErrorMsgHandler implements AdapterErrorMessageHandler { -// -// @Override -// public Object generateNonStandardErrorResponseMessage(String inboudnAdapterGroupName, String inboudnAdapterName, -// Properties callProp, Object outboundRequestData, StandardMessage resStandardMessage) throws Exception{ -// -// if(resStandardMessage != null && isErrorMessage(resStandardMessage)) { -// AdapterGroupVO adapterGroupVO = AdapterManager.getInstance().getAdapterGroupVO(inboudnAdapterGroupName); -// if(MessageType.JSON.equals(adapterGroupVO.getMessageType())) { -// ObjectMapper objectMapper = new ObjectMapper(); -// String requestMessage = (String) outboundRequestData; -// JsonNode requestJson = objectMapper.readTree(requestMessage); -// String alncInstCd = requestJson.get("dataCmn").get("alncInstCd").asText(); -// -// ObjectNode responseJson = objectMapper.createObjectNode(); -// ObjectNode dataCmnNode = objectMapper.createObjectNode(); -// responseJson.set("dataCmn", dataCmnNode); -// dataCmnNode.put("fnclInstCd", "KBK"); -// dataCmnNode.put("alncInstCd", alncInstCd); -// dataCmnNode.put("tlgrRspnsCd", "0210"); -// -// return responseJson.toString(); -// } -// } -// -// -// return ""; -// } -// -// private boolean isErrorMessage(StandardMessage standardMessage) { -// InterfaceMapper mapper = StandardMessageManager.getInstance().getMapper(); -// String responseType = mapper.getResponseType(standardMessage); -// return STDMessageKeys.RESPONSE_TYPE_CODE_E.equals(responseType); -// } -// -//}