From a3143a2d45264911b75618b75b09fe493effee9a Mon Sep 17 00:00:00 2001 From: cho Date: Fri, 16 Jan 2026 12:57:19 +0900 Subject: [PATCH] =?UTF-8?q?=ED=91=9C=EC=A4=80=EB=A9=94=EC=84=B8=EC=A7=80?= =?UTF-8?q?=20=EC=A0=81=EC=9A=A9.(=EC=9C=A4=EC=A4=80=EC=98=81=EC=B0=A8?= =?UTF-8?q?=EC=9E=A5=20=EB=B0=98=EC=98=81=EB=B3=B8)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../eactive/eai/outbound/SocketProcess.java | 25 +++++++++++++++++++ 1 file changed, 25 insertions(+) diff --git a/src/main/java/com/eactive/eai/outbound/SocketProcess.java b/src/main/java/com/eactive/eai/outbound/SocketProcess.java index cb08133..8b360e0 100644 --- a/src/main/java/com/eactive/eai/outbound/SocketProcess.java +++ b/src/main/java/com/eactive/eai/outbound/SocketProcess.java @@ -36,6 +36,10 @@ import com.eactive.eai.message.StandardMessage; import com.eactive.eai.message.manager.StandardMessageManager; import com.eactive.eai.message.parser.StandardReader; import com.ext.eai.common.stdmessage.STDMessageKeys; +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.databind.JsonNode; +import com.fasterxml.jackson.databind.ObjectMapper; +import org.apache.commons.lang3.StringUtils; public class SocketProcess extends DefaultProcess { static final long serialVersionUID = 1L; @@ -426,6 +430,8 @@ public class SocketProcess extends DefaultProcess { } if (com.eactive.eai.adapter.Keys.IF_STANDARD.equals(this.adptrMsgPtrnCd)) { + String restOption = this.reqEaiMsg.getCurrentSvcMsg().getRestOption(); + setStandardRouteInfo(restOption); AdapterManager adapterManager = AdapterManager.getInstance(); AdapterGroupVO adptGrpVO = adapterManager.getAdapterGroupVO(adapterGroupName); AdapterVO adptVO = null; @@ -680,6 +686,25 @@ public class SocketProcess extends DefaultProcess { } } + + protected void setStandardRouteInfo(String routeOption) throws JsonProcessingException { + if(StringUtils.isBlank(routeOption)) { + return ; + } + JsonNode rootNode = new ObjectMapper().readTree(routeOption); + JsonNode standardCommonFields = rootNode.get("standardCommonFields"); + + if (standardCommonFields != null && standardCommonFields.isObject()) { + standardCommonFields.fields().forEachRemaining(field -> { + String key = field.getKey(); + String value = field.getValue().asText(); + + StandardMessage standardMessage = this.reqEaiMsg.getStandardMessage(); + standardMessage.setData(key, value); + }); + } + } + @Override public void transControlHeaderTrnsformSinglesRes() throws Exception {