chore: elink-online-common 서브모듈 업데이트 (JSON 파싱 횟수 최적화)

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

src/main/java/com/eactive/eai/adapter/controller/DJErpApiAdapterController.java

@@ -29,7 +29,7 @@ import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceKey;
 import com.eactive.eai.adapter.http.dynamic.HttpDynamicInAdapterManager;
 import com.eactive.eai.adapter.http.dynamic.HttpDynamicInAdapterUri;
 import com.eactive.eai.adapter.http.dynamic.filter.HttpAdapterFilter;
-import com.eactive.eai.adapter.http.dynamic.filter.HttpAdapterFilterFactoryKjb;
+import com.eactive.eai.adapter.http.dynamic.filter.HttpAdapterFilterFactory;
 import com.eactive.eai.adapter.http.dynamic.filter.JwtAuthException;
 import com.eactive.eai.adapter.service.DJErpApiAdapterService;
 import com.eactive.eai.common.TransactionContextKeys;
@@ -220,7 +220,7 @@ public class DJErpApiAdapterController implements HttpAdapterServiceKey {
 			String postFilterNames = httpProp.getProperty("POST_FILTERS","");
 			
 			if( postFilterNames.contains("HMAC_SHA256") ) {
-				HttpAdapterFilter filter = HttpAdapterFilterFactoryKjb.createFilter("HMAC_SHA256");
+				HttpAdapterFilter filter = HttpAdapterFilterFactory.createFilter("HMAC_SHA256");
 				filter.doPostFilter(adapterGroupName, postFilterNames, errorMsg, transactionProp, servletRequest, servletResponse);
 			}
 			

src/main/java/com/eactive/eai/adapter/service/DJErpApiAdapterService.java

@@ -7,6 +7,7 @@ import com.eactive.eai.adapter.Keys;
 import com.eactive.eai.adapter.http.HttpMemoryLogger;
 import com.eactive.eai.adapter.http.HttpMethodType;
 import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceSupport;
+import com.eactive.eai.adapter.http.filter.AbstractCryptoFilter;
 import com.eactive.eai.adapter.http.dynamic.filter.JwtAuthFilter;
 import com.eactive.eai.common.exception.ExceptionUtil;
 import com.eactive.eai.common.message.MessageType;
@@ -142,7 +143,8 @@ public class DJErpApiAdapterService extends HttpAdapterServiceSupport {
         transactionProp.put(INBOUND_TOKEN, inboundToken);
         transactionProp.put(ENCRYPT_AES256_IV, httpProp.getProperty(ENCRYPT_AES256_IV, ""));  //jwhong
         transactionProp.put(ENCRYPT_AES256_KEY, httpProp.getProperty(ENCRYPT_AES256_KEY, ""));  //jwhong
-      
+        
+        transactionProp.put(AbstractCryptoFilter.PROP_MODULE_NAME, httpProp.getProperty(AbstractCryptoFilter.PROP_MODULE_NAME, ""));
         
         // SEED 컬럼암호하 시  Key로 사용함
         String seedkey = getHeaders(request).getOrDefault("x-obp-partnercode", "").toString();

src/main/java/com/eactive/eai/custom/adapter/http/dynamic/filter/DJBErpCryptoFilter.java

@@ -8,7 +8,7 @@ import javax.servlet.http.HttpServletRequest;
 
 import org.apache.commons.lang3.StringUtils;
 
-import com.eactive.eai.adapter.http.dynamic.filter.CryptoFilter;
+import com.eactive.eai.adapter.http.dynamic.filter.InCryptoFilter;
 import com.eactive.eai.util.JsonPathUtil;
 
 /**
@@ -38,7 +38,7 @@ import com.eactive.eai.util.JsonPathUtil;
  * 필터 타입 등록 (FQCN):
  *   com.eactive.eai.custom.adapter.http.dynamic.filter.DJBErpCryptoFilter
  */
-public class DJBErpCryptoFilter extends CryptoFilter {
+public class DJBErpCryptoFilter extends InCryptoFilter {
 
     public static final String PROP_CONTEXT_KEY          = "crypto.context.key";
     public static final String PROP_CONTEXT_HEADER       = "crypto.context.header";

src/main/java/com/eactive/eai/custom/adapter/http/dynamic/filter/EncFieldCryptoFilter.java

@@ -0,0 +1,40 @@
+package com.eactive.eai.custom.adapter.http.dynamic.filter;
+
+import java.util.Properties;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+import com.eactive.eai.adapter.http.dynamic.filter.InCryptoFilter;
+import com.eactive.eai.adapter.http.dynamic.filter.HttpAdapterFilter;
+
+/**
+ * CryptoFilter 프로퍼티를 멤버변수로 관리하는 HttpAdapterFilter 구현체.
+ *
+ * 멤버변수에 세팅된 값을 Properties로 변환하여 {@link InCryptoFilter}에 위임한다.
+ * 값이 blank인 멤버변수는 Properties에 포함하지 않으며, CryptoFilter의 기본값이 적용된다.
+ */
+public class EncFieldCryptoFilter implements HttpAdapterFilter {
+
+    private final InCryptoFilter filter = new InCryptoFilter();
+
+    @Override
+    public Object doPreFilter(String adptGrpName, String adptName, Object message, Properties prop,
+            HttpServletRequest request, HttpServletResponse response) throws Exception {
+        return filter.doPreFilter(adptGrpName, adptName, message, setProp(prop), request, response);
+    }
+
+    @Override
+    public Object doPostFilter(String adptGrpName, String adptName, Object resultMessage, Properties prop,
+            HttpServletRequest request, HttpServletResponse response) throws Exception {
+        return filter.doPostFilter(adptGrpName, adptName, resultMessage, setProp(prop), request, response);
+    }
+
+    private Properties setProp(Properties p) {
+    	p.setProperty(InCryptoFilter.PROP_DEC_FROM_PATH, "/encryptedData");
+    	p.setProperty(InCryptoFilter.PROP_ENC_TO_PATH, "/encryptedData");
+        return p;
+    }
+
+    
+}

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/AllHeaderFilter.java

@@ -1,123 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.util.Arrays;
-import java.util.Map;
-import java.util.Properties;
-import java.util.TreeMap;
-import java.util.stream.Stream;
-
-import org.apache.commons.lang3.StringUtils;
-
-import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceKey;
-import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceSupport;
-import com.eactive.eai.common.TransactionContextKeys;
-import com.eactive.eai.common.property.PropManager;
-import com.eactive.eai.common.util.Logger;
-
-public class AllHeaderFilter implements HttpClientAdapterFilter, HttpAdapterServiceKey {
-	protected static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER);
-	
-	public static final String PROPERTIES_GROUP_NAME = "HttpHeaderFilter";
-	public static final String HEADER_KEY_NAMES = "AllHeaderFilter.blackList";
-
-
-	String[] HttpHeaderRelayBlackList = {
-			"Content-Length",
-			"Transfer-Encoding",
-			"Host",
-			"Authorization",
-			"Accept",
-			"Host",
-			"Cookie",
-			"Connection",
-			"Keep-Alive",
-			"Proxy-Authenticate",
-			"Proxy-Authorization",
-			"TE",
-			"Trailer",
-			"Transfer-Encoding",
-			"Upgrade",
-			"Content-Type",
-			"Content-Encoding",
-			"Content-Language",
-			"Content-Location",
-			"Content-MD5",
-			"Expect",
-	};
-	
-	@Override
-	public Object doPreFilter(String adptGrpName, String adptName, Properties prop, Object message, Properties tempProp)
-			throws Exception {
-
-		logger.debug("doPreFilter Processing Start.");
-
-		Properties filterHeaders = (Properties) tempProp.get("FILTERHEADER");
-		if (filterHeaders == null) {
-			filterHeaders = new Properties();
-			tempProp.put("FILTERHEADER", filterHeaders);
-		}
-		
-		Map<String, String> inboundHeaderMap = getInboundHeaderProp(tempProp);
-		
-		String propValue = PropManager.getInstance().getProperty(PROPERTIES_GROUP_NAME, HEADER_KEY_NAMES, "").trim();
-		
-		String[] userSettingBlackList = propValue.split(",");
-		
-		if( userSettingBlackList.length > 0 ) {
-			HttpHeaderRelayBlackList = Stream
-			        .concat(Arrays.stream(HttpHeaderRelayBlackList), Arrays.stream(userSettingBlackList))
-			        .toArray(String[]::new);
-		}
-		
-		
-		for(String keyName : inboundHeaderMap.keySet() ) {
-			
-			if( StringUtils.equalsAnyIgnoreCase( keyName, HttpHeaderRelayBlackList ) ) {
-				logger.debug("Skip Processing Key ["+keyName+"], value ["+inboundHeaderMap.get(keyName)+"] in HttpHeaderRelayBlackList");
-				continue;
-			}
-			
-			filterHeaders.put(keyName, inboundHeaderMap.get(keyName));
-			logger.debug("Processing Key ["+keyName+"], value ["+inboundHeaderMap.get(keyName)+"]");
-		}
-		
-		logger.debug("doPreFilter Processing End.");
-		
-		return message;
-	}
-	
-	public Map<String, String> getInboundHeaderProp(Properties prop) {
-		Properties header = new Properties();
-		Map<String, String> inboundHeaderMap = new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
-		try {
-			Object headerObj = prop.get(HttpAdapterServiceKey.INBOUND_HEADER);
-			if (headerObj instanceof Properties) {    //tomcat
-				header = (Properties) headerObj;
-				for (String name : header.stringPropertyNames()) {
-					inboundHeaderMap.put(name, header.getProperty(name));
-				}
-			} else if (headerObj instanceof String) {  //weblogic
-				String str = (String) headerObj;
-				str = str.substring(1, str.length() - 1);
-				// key=value 쌍 분리
-				String[] entries = str.split(",");
-				for (String entry : entries) {
-				    String[] kv = entry.split("=", 2);
-				    if (kv.length == 2) {
-				    	inboundHeaderMap.put(kv[0].trim(), kv[1].trim());
-				    }
-				}
-			}	
-		} catch (Exception  e) {
-		    e.printStackTrace();
-		}
-		return inboundHeaderMap;
-	}
-
-	@Override
-	public Object doPostFilter(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp) throws Exception {
-		return message;
-	}
-
-}

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/AsyncReponseFilter.java

@@ -1,118 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.util.Arrays;
-import java.util.Map;
-import java.util.Properties;
-import java.util.TreeMap;
-
-import org.apache.commons.lang3.StringUtils;
-
-import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceKey;
-import com.eactive.eai.common.TransactionContextKeys;
-import com.eactive.eai.common.property.PropManager;
-import com.eactive.eai.common.util.Logger;
-
-
-public class AsyncReponseFilter implements HttpClientAdapterFilter, HttpAdapterServiceKey {
-	protected static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER);
-
-	public static final String X_TRACE_ID = "partnerTraceId";
-	public static final String TRACE_ID = "traceId";
-	
-	public static final String PROPERTIES_GROUP_NAME = "HttpHeaderFilter";
-	public static final String HEADER_KEY_NAMES = "AsyncReponseFilter";
-	
-
-	@Override
-	public Object doPreFilter(String adptGrpName, String adptName, Properties prop, Object message, Properties tempProp)
-			throws Exception {
-
-		logger.debug("AsyncReponseFilter] PreFilter Processing Start!!");
-		String traceId = tempProp.getProperty(TransactionContextKeys.TRANSACTION_UUID, "");
-
-		Properties filterHeaders = (Properties) tempProp.get("FILTERHEADER");
-		if (filterHeaders == null) {
-			filterHeaders = new Properties();
-			tempProp.put("FILTERHEADER", filterHeaders);
-		}
-		
-		String propValue = PropManager.getInstance().getProperty(PROPERTIES_GROUP_NAME, HEADER_KEY_NAMES, "").trim();
-
-		String[] headerKeyNames = propValue.split(",");
-		
-		
-		headerKeyNames = Arrays.stream(headerKeyNames)
-		        .map(String::trim)
-		        .toArray(String[]::new);
-		
-		try {
-			Map<String, String> inboundHeaderMap = getInboundHeaderProp(tempProp);
-
-			if (!inboundHeaderMap.isEmpty()) {
-				if (inboundHeaderMap.containsKey(X_TRACE_ID)) {
-					filterHeaders.put(X_TRACE_ID, inboundHeaderMap.get(X_TRACE_ID));
-					logger.debug("AsyncReponseFilter] Processing Key ["+X_TRACE_ID+"], value ["+inboundHeaderMap.get(X_TRACE_ID)+"]");
-				}
-				
-				if (inboundHeaderMap.containsKey(TransactionContextKeys.X_LOAN_TOKEN)) {
-					filterHeaders.put(TransactionContextKeys.X_LOAN_TOKEN, inboundHeaderMap.get(TransactionContextKeys.X_LOAN_TOKEN));
-					logger.debug("AsyncReponseFilter] Processing Key ["+TransactionContextKeys.X_LOAN_TOKEN+"], value ["+inboundHeaderMap.get(TransactionContextKeys.X_LOAN_TOKEN)+"]");
-				}
-			}
-			
-			filterHeaders.setProperty(TRACE_ID, traceId);
-			logger.debug("AsyncReponseFilter] Processing Key ["+TRACE_ID+"], value ["+traceId+"]");
-			
-			for (String keyName : inboundHeaderMap.keySet()) {
-
-				if (StringUtils.equalsAnyIgnoreCase(keyName, headerKeyNames)) {
-					String value = inboundHeaderMap.get(keyName);
-					filterHeaders.put(keyName, value);
-					logger.debug("AsyncReponseFilter] Processing Key [" + keyName + "], value [" + value + "]");
-				}
-
-			}
-
-		} catch (Exception e) {
-			logger.error(e.getMessage());
-		}
-		
-		return message;
-	}
-	
-	public Map<String, String> getInboundHeaderProp(Properties prop) {
-		Properties header = new Properties();
-		Map<String, String> inboundHeaderMap = new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
-		try {
-			Object headerObj = prop.get(HttpAdapterServiceKey.INBOUND_HEADER);
-			if (headerObj instanceof Properties) {    //tomcat
-				header = (Properties) headerObj;
-				for (String name : header.stringPropertyNames()) {
-					inboundHeaderMap.put(name, header.getProperty(name));
-				}
-			} else if (headerObj instanceof String) {  //weblogic
-				String str = (String) headerObj;
-				str = str.substring(1, str.length() - 1);
-				// key=value 쌍 분리
-				String[] entries = str.split(",");
-				for (String entry : entries) {
-				    String[] kv = entry.split("=", 2);
-				    if (kv.length == 2) {
-				    	inboundHeaderMap.put(kv[0].trim(), kv[1].trim());
-				    }
-				}
-			}	
-		} catch (Exception  e) {
-		    e.printStackTrace();
-		}
-		return inboundHeaderMap;
-	}
-
-	@Override
-	public Object doPostFilter(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp) throws Exception {
-		return message;
-	}
-
-}
-

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/HttpClient5AdapterFilterFactory.java

@@ -1,115 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.util.concurrent.ConcurrentHashMap;
-
-import com.eactive.eai.common.util.Logger;
-
-public class HttpClient5AdapterFilterFactory {
-	static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER);
-	static String basePackage = "com.eactive.eai.custom.kjb.adapter.http.client.filter";
-	private static ConcurrentHashMap<String, HttpClientAdapterFilter> h = new ConcurrentHashMap<>();
-	private static ConcurrentHashMap<String, HttpClientAdapterExceptionFilter> eh = new ConcurrentHashMap<>();
-
-	private HttpClient5AdapterFilterFactory() {
-		throw new IllegalStateException("Utility class");
-	}
-
-	public static HttpClientAdapterFilter createFilter(String type) {
-		if (h.containsKey(type)) {
-			return h.get(type);
-		}
-
-		HttpClientAdapterFilter filter = null;
-		switch (HttpClient5AdapterFilterType.getValue(type)) {
-		case SIMPLEFRAMEWORK:
-			filter = new SimpleFrameworkFilter();
-			break;
-		case SIMPLEFRAMEWORKBODY:
-			filter = new SimpleframeworkBodyFilter();
-			break;
-		case JBOBP:
-			filter = new JBOBPFilter();
-			break;
-		case KFTCFACE:
-			filter = new KFTCFaceFilter();
-			break;
-		case KFTCP2P:
-			filter = new KFTCP2PFilter();
-			break;
-		case KAKAOBANK:
-			filter = new KAKAOBankFilter();
-			break;
-		case NAVERFIN:
-			filter = new NAVERFinFilter();
-			break;
-		case NICECREDIT:
-			filter = new NICECreditFilter();
-			break;
-		case TRACEBODY:
-			filter = new TraceBodyFilter();
-			break;
-		case TOSSBANK:
-			filter = new TOSSBankFilter();
-			break;
-		case ASYNCRESPONSE:
-			filter = new AsyncReponseFilter();
-			break;
-		case ALLHEADER:
-			filter = new AllHeaderFilter();
-			break;
-		default:
-			filter = classForName(type);
-			if (filter == null) {
-				filter = classForName(basePackage + "." + type);
-			}
-			break;
-		}
-
-		if (filter != null) {
-			h.put(type, filter);
-			return filter;
-		} else {
-			return null;
-		}
-	}
-	
-	private static HttpClientAdapterFilter classForName(String type) {
-		try {
-			Class<?> cl = Class.forName(type);
-			return (HttpClientAdapterFilter) cl.newInstance();
-		} catch (ClassNotFoundException | IllegalAccessException | InstantiationException e) {
-			logger.error("Cannot create a HttpClientAdapterFilter. - {}", type);
-			return null;
-		}
-	}
-	
-	public static HttpClientAdapterExceptionFilter createExceptionFilter(String type) {
-		if (eh.containsKey(type)) {
-			return eh.get(type);
-		}
-
-		HttpClientAdapterExceptionFilter filter = classForExceptionFilterName(type);
-		if (filter == null) {
-			filter = classForExceptionFilterName(basePackage + "." + type);
-		}
-
-		if (filter != null) {
-			eh.put(type, filter);
-			return filter;
-		} else {
-			return null;
-		}
-	}
-
-	private static HttpClientAdapterExceptionFilter classForExceptionFilterName(String type) {
-		try {
-			Class<?> cl = Class.forName(type);
-			return (HttpClientAdapterExceptionFilter) cl.newInstance();
-		} catch (ClassNotFoundException | IllegalAccessException | InstantiationException e) {
-			logger.error("Cannot create a HttpClientAdapterExceptionFilter. - {}", type);
-			return null;
-		}
-	}
-
-	
-}

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/HttpClient5AdapterFilterType.java

@@ -1,27 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-public enum HttpClient5AdapterFilterType {
-	SIMPLEFRAMEWORK,
-	SIMPLEFRAMEWORKBODY,
-	JBOBP,
-	KFTCFACE,
-	KFTCP2P,
-	KAKAOBANK,
-	NAVERFIN,
-	NICECREDIT,
-	TOSSBANK,
-	TRACEBODY,
-	ASYNCRESPONSE,
-	ALLHEADER,
-	UNKNOWN;
-
-	public static HttpClient5AdapterFilterType getValue(String type) {
-		try {
-			return valueOf(type.toUpperCase());
-		} catch (NullPointerException e) {
-			return UNKNOWN;
-		} catch (Exception e) {
-			return UNKNOWN;
-		}
-	}
-}

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/HttpClientAdapterBaseFilter.java

@@ -1,62 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Properties;
-
-import com.eactive.eai.common.util.Logger;
-
-public abstract class HttpClientAdapterBaseFilter implements HttpClientAdapterFilter {
-	protected static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER);
-	protected String filterName = "";
-	protected List<HttpClientAdapterFilter> filters;
-	
-	protected HttpClientAdapterBaseFilter(String filterName) {
-		this.filterName = filterName;
-		filters = new ArrayList<>();
-		logger.info("{}] filter created.", filterName);
-	}
-	
-	protected void addFilter(HttpClientAdapterFilter filter) {
-		filters.add(filter);
-		logger.info("{}] sub filter({}) added. filters= {}", filterName, filter, filters);
-	}
-
-	@Override
-	public Object doPreFilter(String adptGrpName, String adptName, Properties prop, Object message, Properties tempProp)
-			throws Exception {
-		try {
-			Object filteredMessage = message;
-			for(HttpClientAdapterFilter subFilter : filters) {
-				logger.debug("{}] sub filter({}) doPreFilter start.", filterName, subFilter);
-				filteredMessage = subFilter.doPreFilter(adptGrpName, adptName, prop, filteredMessage, tempProp);
-				logger.debug("{}] sub filter({}) doPreFilter end.", filterName, subFilter);
-			}
-			
-			return filteredMessage;
-		} catch (Exception e) {
-			logger.error(this.filterName + "] doPreFilter error.", e);
-			throw e;
-		}
-	}
-
-	@Override
-	public Object doPostFilter(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp) throws Exception {
-		try {
-			Object filteredMessage = message;
-			for(HttpClientAdapterFilter subFilter : filters) {
-				logger.debug("{}] sub filter({}) doPostFilter start.", filterName, subFilter);
-				filteredMessage = subFilter.doPostFilter(adptGrpName, adptName, prop, filteredMessage, tempProp);
-				logger.debug("{}] sub filter({}) doPostFilter end.", filterName, subFilter);
-			}
-			return filteredMessage; 
-		} catch (Exception e) {
-			logger.error(this.filterName + "] doPostFilter error.", e);
-			throw e;
-		}
-	}
-	
-	
-
-}

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/HttpClientAdapterExceptionFilter.java

@@ -1,10 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.util.Properties;
-
-public interface HttpClientAdapterExceptionFilter {
-
-	public Object doExceptionFilter(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp, Exception e) throws Exception;
-
-}

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/HttpClientAdapterFilter.java

@@ -1,12 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.util.Properties;
-
-public interface HttpClientAdapterFilter {
-
-	public Object doPreFilter(String adptGrpName, String adptName, Properties prop, Object message, Properties tempProp)
-			throws Exception;
-
-	public Object doPostFilter(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp) throws Exception;
-}

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/HttpClientAdapterFilterException.java

@@ -1,35 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.util.Properties;
-
-import lombok.Getter;
-
-public class HttpClientAdapterFilterException extends RuntimeException {
-	private static final long serialVersionUID = -1208983360831093751L;
-	@Getter
-	private final String code;
-	@Getter
-	private final Properties prop;
-	@Getter
-	private final Properties tempProp;
-	
-	public HttpClientAdapterFilterException(String code, String msg, Properties prop, Properties tmepProp) {
-		super(msg);
-		this.code = code;
-		this.prop = prop;
-		this.tempProp = tmepProp;
-	}
-
-	public HttpClientAdapterFilterException(String code, String msg, Properties prop, Properties tempProp, Throwable cause) {
-		super(msg, cause);
-		this.code = code;
-		this.prop = prop;
-		this.tempProp = tempProp;
-	}
-
-	@Override
-	public String toString() {
-		return "HttpClientAdapterFilterException [code=" + code + ", prop=" + prop + ", tempProp=" + tempProp + ", parent=" + super.toString() + "]";
-	}
-
-}

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/JBOBPFilter.java

@@ -1,106 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.util.Map;
-import java.util.Properties;
-import java.util.TreeMap;
-
-import org.apache.commons.lang3.StringUtils;
-
-import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceKey;
-import com.eactive.eai.common.TransactionContextKeys;
-import com.eactive.eai.common.property.PropGroupVO;
-import com.eactive.eai.common.property.PropManager;
-import com.eactive.eai.common.util.Logger;
-
-
-public class JBOBPFilter implements HttpClientAdapterFilter, HttpAdapterServiceKey {
-	protected static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER);
-
-	public static final String KJB_HEADER = "KJB_Header";
-	public static final String X_OBP_PARTNERCODE = "x-obp-partnercode";
-	public static final String X_OBP_TXID = "x-obp-txid";
-	public static final String X_OBP_TRUST_SYSTEM = "x-obp-trust-system";
-	String systemTrustKey = "APIMGW-0001-QVBJTUdXLTAwMDE=";
-
-	@Override
-	public Object doPreFilter(String adptGrpName, String adptName, Properties prop, Object message, Properties tempProp)
-			throws Exception {
-
-		logger.debug("JBOBPFilter] PreFilter Processing Start!!");
-		PropGroupVO propGroupVo = PropManager.getInstance().getPropGroupVO(KJB_HEADER);
-		if (propGroupVo != null) systemTrustKey = propGroupVo.getProperty(X_OBP_TRUST_SYSTEM, systemTrustKey);
-
-		Properties filterHeaders = (Properties) tempProp.get("FILTERHEADER");
-		if (filterHeaders == null) {
-			filterHeaders = new Properties();
-			tempProp.put("FILTERHEADER", filterHeaders);
-		}
-		try {
-			String obpPartnerCode = "000000-00";
-			Map<String, String> inboundHeaderMap = getInboundHeaderProp(tempProp);
-
-			if (!inboundHeaderMap.isEmpty()) {
-				if (inboundHeaderMap.containsKey(X_OBP_PARTNERCODE)) {
-					filterHeaders.put(X_OBP_PARTNERCODE, inboundHeaderMap.get(X_OBP_PARTNERCODE));
-					logger.debug("JBOBPFilter] Processing Key ["+X_OBP_PARTNERCODE+"], value ["+inboundHeaderMap.get(X_OBP_PARTNERCODE)+"]");
-				} else {
-					filterHeaders.put(X_OBP_PARTNERCODE, obpPartnerCode);
-					logger.debug("JBOBPFilter] Processing Key ["+X_OBP_PARTNERCODE+"], value ["+obpPartnerCode+"]");
-				}
-			} else {
-				filterHeaders.put(X_OBP_PARTNERCODE, obpPartnerCode);
-				logger.debug("JBOBPFilter] Processing Key ["+X_OBP_PARTNERCODE+"], value ["+obpPartnerCode+"]");
-			}
-
-			String uuid = tempProp.getProperty(TransactionContextKeys.TRANSACTION_UUID, "");
-			if (StringUtils.isNotBlank(uuid)) {
-				filterHeaders.setProperty(X_OBP_TXID, uuid); // JB OBP Framework용
-				logger.debug("JBOBPFilter] Processing Key ["+X_OBP_TXID+"], value ["+uuid+"]");
-			}
-			if (StringUtils.isNotBlank(systemTrustKey)) {
-				filterHeaders.setProperty(X_OBP_TRUST_SYSTEM, systemTrustKey); // JB OBP Framework용
-				logger.debug("JBOBPFilter] Processing Key ["+X_OBP_TRUST_SYSTEM+"], value ["+systemTrustKey+"]");
-			}
-		} catch (Exception e) {
-			logger.error(e.getMessage());
-		}
-		
-		return message;
-	}
-
-	public Map<String, String> getInboundHeaderProp(Properties prop) {
-		Properties header = new Properties();
-		Map<String, String> inboundHeaderMap = new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
-		try {
-			Object headerObj = prop.get(HttpAdapterServiceKey.INBOUND_HEADER);
-			if (headerObj instanceof Properties) {    //tomcat
-				header = (Properties) headerObj;
-				for (String name : header.stringPropertyNames()) {
-					inboundHeaderMap.put(name, header.getProperty(name));
-				}
-			} else if (headerObj instanceof String) {  //weblogic
-				String str = (String) headerObj;
-				str = str.substring(1, str.length() - 1);
-				// key=value 쌍 분리
-				String[] entries = str.split(",");
-				for (String entry : entries) {
-				    String[] kv = entry.split("=", 2);
-				    if (kv.length == 2) {
-				    	inboundHeaderMap.put(kv[0].trim(), kv[1].trim());
-				    }
-				}
-			}	
-		} catch (Exception  e) {
-		    e.printStackTrace();
-		}
-		return inboundHeaderMap;
-	}
-
-	@Override
-	public Object doPostFilter(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp) throws Exception {
-		return message;
-	}
-
-}
-

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/KAKAOBankFilter.java

@@ -1,135 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.Map;
-import java.util.Properties;
-import java.util.TreeMap;
-
-import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceKey;
-import com.eactive.eai.common.property.PropGroupVO;
-import com.eactive.eai.common.property.PropManager;
-import com.eactive.eai.common.util.Logger;
-
-
-public class KAKAOBankFilter implements HttpClientAdapterFilter, HttpAdapterServiceKey {
-	protected static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER);
-
-	public static final String KJB_HEADER = "KJB_Header";
-	public static final String PROP_PREFIX = "kakaobank";
-	public static final String X_KKB_PARTNER_CODE = "X-KKB-PARTNER-CODE";
-	public static final String X_KKB_API_NAME = "X-KKB-API-NAME";
-	public static final String X_KKB_API_TX_ID = "X-KKB-API-TX-ID";
-	public static final String X_KKB_TX_TIME = "X-KKB-TX-TIME";
-	public static final String X_KKB_CMPR_MGMT_NO = "X-KKB-CMPR-MGMT-NO";
-
-	@Override
-	public Object doPreFilter(String adptGrpName, String adptName, Properties prop, Object message, Properties tempProp)
-			throws Exception {
-
-		logger.debug("KAKAOBankFilter] PreFilter Processing Start!!");
-		Object returnMessage = message;
-		String partnerCode = "KJB";
-		String apiName = "status_change";
-		String apiTxId = "0";
-		String txTime = new SimpleDateFormat("yyyyMMddHHmmss").format(new Date());
-		String cmprMgmtNo = "0";
-
-		PropGroupVO propGroupVo = PropManager.getInstance().getPropGroupVO(KJB_HEADER);
-		if (propGroupVo != null) {
-			partnerCode = propGroupVo.getProperty(PROP_PREFIX + "." + X_KKB_PARTNER_CODE);
-			apiName = propGroupVo.getProperty(PROP_PREFIX + "." + X_KKB_API_NAME);
-			apiTxId = propGroupVo.getProperty(PROP_PREFIX + "." + X_KKB_API_TX_ID);
-			cmprMgmtNo = propGroupVo.getProperty(PROP_PREFIX + "." + X_KKB_CMPR_MGMT_NO);
-		}
-
-		Properties filterHeaders = (Properties) tempProp.get("FILTERHEADER");
-		if (filterHeaders == null) {
-			filterHeaders = new Properties();
-			tempProp.put("FILTERHEADER", filterHeaders);
-		}
-		try {
-			Map<String, String> inboundHeaderMap = getInboundHeaderProp(tempProp);
-
-			if (!inboundHeaderMap.isEmpty()) {
-				if (inboundHeaderMap.containsKey(X_KKB_PARTNER_CODE)) {
-					filterHeaders.put(X_KKB_PARTNER_CODE, inboundHeaderMap.get(X_KKB_PARTNER_CODE));
-				} else {
-					filterHeaders.put(X_KKB_PARTNER_CODE, partnerCode);
-				}
-				if (inboundHeaderMap.containsKey(X_KKB_API_NAME)) {
-					filterHeaders.put(X_KKB_API_NAME, inboundHeaderMap.get(X_KKB_API_NAME));
-				} else {
-					filterHeaders.put(X_KKB_API_NAME, apiName);
-				}
-				if (inboundHeaderMap.containsKey(X_KKB_API_TX_ID)) {
-					filterHeaders.put(X_KKB_API_TX_ID, inboundHeaderMap.get(X_KKB_API_TX_ID));
-				} else {
-					filterHeaders.put(X_KKB_API_TX_ID, apiTxId);
-				}
-				if (inboundHeaderMap.containsKey(X_KKB_TX_TIME)) {
-					filterHeaders.put(X_KKB_TX_TIME, inboundHeaderMap.get(X_KKB_TX_TIME));
-				} else {
-					filterHeaders.put(X_KKB_TX_TIME, txTime);
-				}
-				if (inboundHeaderMap.containsKey(X_KKB_CMPR_MGMT_NO)) {
-					filterHeaders.put(X_KKB_CMPR_MGMT_NO, inboundHeaderMap.get(X_KKB_CMPR_MGMT_NO));
-				} else {
-					filterHeaders.put(X_KKB_CMPR_MGMT_NO, cmprMgmtNo);
-				}
-			} else {
-				filterHeaders.put(X_KKB_PARTNER_CODE, partnerCode);
-				filterHeaders.put(X_KKB_API_NAME, apiName);
-				filterHeaders.put(X_KKB_API_TX_ID, apiTxId);
-				filterHeaders.put(X_KKB_TX_TIME, txTime);
-				filterHeaders.put(X_KKB_CMPR_MGMT_NO, cmprMgmtNo);
-			}
-			logger.debug("KAKAOBankFilter] Processing Key ["+X_KKB_PARTNER_CODE+"], value ["+filterHeaders.getProperty(X_KKB_PARTNER_CODE)+"]");
-			logger.debug("KAKAOBankFilter] Processing Key ["+X_KKB_API_NAME+"], value ["+filterHeaders.getProperty(X_KKB_API_NAME)+"]");
-			logger.debug("KAKAOBankFilter] Processing Key ["+X_KKB_API_TX_ID+"], value ["+filterHeaders.getProperty(X_KKB_API_TX_ID)+"]");
-			logger.debug("KAKAOBankFilter] Processing Key ["+X_KKB_TX_TIME+"], value ["+filterHeaders.getProperty(X_KKB_TX_TIME)+"]");
-			logger.debug("KAKAOBankFilter] Processing Key ["+X_KKB_CMPR_MGMT_NO+"], value ["+filterHeaders.getProperty(X_KKB_CMPR_MGMT_NO)+"]");
-
-		} catch (Exception e) {
-			logger.error(e.getMessage());
-		}
-		
-		return returnMessage;
-	}
-
-	public Map<String, String> getInboundHeaderProp(Properties prop) {
-		Properties header = new Properties();
-		Map<String, String> inboundHeaderMap = new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
-		try {
-			Object headerObj = prop.get(HttpAdapterServiceKey.INBOUND_HEADER);
-			if (headerObj instanceof Properties) {    //tomcat
-				header = (Properties) headerObj;
-				for (String name : header.stringPropertyNames()) {
-					inboundHeaderMap.put(name, header.getProperty(name));
-				}
-			} else if (headerObj instanceof String) {  //weblogic
-				String str = (String) headerObj;
-				str = str.substring(1, str.length() - 1);
-				// key=value 쌍 분리
-				String[] entries = str.split(",");
-				for (String entry : entries) {
-				    String[] kv = entry.split("=", 2);
-				    if (kv.length == 2) {
-				    	inboundHeaderMap.put(kv[0].trim(), kv[1].trim());
-				    }
-				}
-			}	
-		} catch (Exception  e) {
-		    e.printStackTrace();
-		}
-		return inboundHeaderMap;
-	}
-
-	@Override
-	public Object doPostFilter(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp) throws Exception {
-		return message;
-	}
-
-}
-

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/KFTCFaceFilter.java

@@ -1,154 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.Map;
-import java.util.Properties;
-import java.util.TreeMap;
-
-import org.apache.commons.lang3.RandomStringUtils;
-import org.apache.commons.lang3.StringUtils;
-import org.json.simple.JSONObject;
-import org.json.simple.JSONValue;
-
-import com.eactive.eai.adapter.AdapterGroupVO;
-import com.eactive.eai.adapter.AdapterManager;
-import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceKey;
-import com.eactive.eai.common.property.PropGroupVO;
-import com.eactive.eai.common.property.PropManager;
-import com.eactive.eai.common.server.EAIServerManager;
-import com.eactive.eai.common.util.Logger;
-
-
-public class KFTCFaceFilter implements HttpClientAdapterFilter, HttpAdapterServiceKey {
-	protected static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER);
-
-	public static final String KJB_HEADER = "KJB_Header";
-	public static final String PROP_PREFIX = "kftcface";
-	public static final String H_CLIENT_ID = "Client-Id";
-	public static final String B_ORG_CODE = "org_code";
-	public static final String B_TRANSACTION_ID = "transaction_id";
-	public static final String B_REQUEST_DATETIME = "request_datetime";
-	public static String instId = null;
-
-	static {
-		EAIServerManager eaiServerManager = EAIServerManager.getInstance();
-		instId = eaiServerManager.getInstId();
-	}
-
-	@SuppressWarnings({ "unchecked" })
-	@Override
-	public Object doPreFilter(String adptGrpName, String adptName, Properties prop, Object message, Properties tempProp)
-			throws Exception {
-
-		logger.debug("KFTCFaceFilter] PreFilter Processing Start!!");
-		JSONObject returnMessage = null;
-		String clientId = "";
-		String orgCode = "034"; // 광주은행 행코드
-
-		PropGroupVO propGroupVo = PropManager.getInstance().getPropGroupVO(KJB_HEADER);
-		if (propGroupVo != null) {
-			if (StringUtils.isEmpty(clientId))
-				clientId = propGroupVo.getProperty(PROP_PREFIX + "." + H_CLIENT_ID);
-			orgCode = propGroupVo.getProperty(PROP_PREFIX + "." + B_ORG_CODE);
-		}
-
-		String request_datetime = new SimpleDateFormat("yyyyMMddHHmmss").format(new Date());
-		String reqDate = new SimpleDateFormat("yyMMdd").format(new Date());
-		String reqTime = new SimpleDateFormat("HHmmss").format(new Date());
-		// 기관코드(3) + 요청일자(6) -- 금결원 표준화 항목, 고정 9자리.
-		// 요청시간(6) + 인스턴스ID(2) + RandomString(3) -- 기관별 생성 거래고유번호(11자리)
-		// 기관코드(3) + 요청일자(6) + 요청시간(6) + 인스턴스ID(2) + RandomString(3) -- 20자리.
-		String transaction_id = orgCode + reqDate + reqTime + instId + RandomStringUtils.random(3, true, true).toUpperCase();
-		
-		Properties filterHeaders = (Properties) tempProp.get("FILTERHEADER");
-		if (filterHeaders == null) {
-			filterHeaders = new Properties();
-			tempProp.put("FILTERHEADER", filterHeaders);
-		}
-		try {
-			Map<String, String> inboundHeaderMap = getInboundHeaderProp(tempProp);
-
-			if (!inboundHeaderMap.isEmpty()) {
-				if (inboundHeaderMap.containsKey(H_CLIENT_ID)) {
-					filterHeaders.put(H_CLIENT_ID, inboundHeaderMap.get(H_CLIENT_ID));
-					logger.debug("KFTCFaceFilter] Processing Key ["+H_CLIENT_ID+"], value ["+inboundHeaderMap.get(H_CLIENT_ID)+"]");
-				} else {
-					filterHeaders.put(H_CLIENT_ID, clientId);
-					logger.debug("KFTCFaceFilter] Processing Key ["+H_CLIENT_ID+"], value ["+clientId+"]");
-				}
-			} else {
-				filterHeaders.setProperty(H_CLIENT_ID, clientId);
-				logger.debug("KFTCFaceFilter] Processing Key ["+H_CLIENT_ID+"], value ["+clientId+"]");
-			}
-
-		} catch (Exception e) {
-			logger.error(e.getMessage());
-		}
-		
-		AdapterManager adapterManager = AdapterManager.getInstance();
-		AdapterGroupVO adptGrpVO = adapterManager.getAdapterGroupVO(adptGrpName);
-		String encode = adptGrpVO.getMessageEncode();
-		if (message == null) {
-			returnMessage = new JSONObject();
-		} else {
-			if (message instanceof JSONObject) {
-				returnMessage = (JSONObject) message;
-			} else if (message instanceof String) {
-				returnMessage = parseJson((String) message);
-			} else if (message instanceof byte[]) {
-				returnMessage = parseJson(new String((byte[]) message, encode));
-			}
-		}
-		
-		returnMessage.put(B_ORG_CODE, orgCode);
-		returnMessage.put(B_TRANSACTION_ID, transaction_id);
-		returnMessage.put(B_REQUEST_DATETIME, request_datetime);
-
-		return returnMessage.toJSONString();
-	}
-
-	private JSONObject parseJson(String message) throws Exception {
-		if (message == null) {
-			return null;
-		}
-
-		return (JSONObject) JSONValue.parse(message);
-	}
-
-	public Map<String, String> getInboundHeaderProp(Properties prop) {
-		Properties header = new Properties();
-		Map<String, String> inboundHeaderMap = new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
-		try {
-			Object headerObj = prop.get(HttpAdapterServiceKey.INBOUND_HEADER);
-			if (headerObj instanceof Properties) {    //tomcat
-				header = (Properties) headerObj;
-				for (String name : header.stringPropertyNames()) {
-					inboundHeaderMap.put(name, header.getProperty(name));
-				}
-			} else if (headerObj instanceof String) {  //weblogic
-				String str = (String) headerObj;
-				str = str.substring(1, str.length() - 1);
-				// key=value 쌍 분리
-				String[] entries = str.split(",");
-				for (String entry : entries) {
-				    String[] kv = entry.split("=", 2);
-				    if (kv.length == 2) {
-				    	inboundHeaderMap.put(kv[0].trim(), kv[1].trim());
-				    }
-				}
-			}	
-		} catch (Exception  e) {
-		    e.printStackTrace();
-		}
-		return inboundHeaderMap;
-	}
-
-	@Override
-	public Object doPostFilter(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp) throws Exception {
-		return message;
-	}
-
-}
-

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/KFTCP2PFilter.java

@@ -1,122 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.Map;
-import java.util.Properties;
-import java.util.TreeMap;
-
-import org.apache.commons.lang3.RandomStringUtils;
-
-import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceKey;
-import com.eactive.eai.common.property.PropGroupVO;
-import com.eactive.eai.common.property.PropManager;
-import com.eactive.eai.common.server.EAIServerManager;
-import com.eactive.eai.common.util.Logger;
-
-
-public class KFTCP2PFilter implements HttpClientAdapterFilter, HttpAdapterServiceKey {
-	protected static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER);
-
-	public static final String KJB_HEADER = "KJB_Header";
-	public static final String PROP_PREFIX = "kftcp2p";
-	public static final String H_ORG_CODE = "org_code";
-	public static final String H_TRX_NO = "api_trx_no";
-	public static final String H_TRX_DTM = "api_trx_dtm";
-	public static String instId = null;
-
-	static {
-		EAIServerManager eaiServerManager = EAIServerManager.getInstance();
-		instId = eaiServerManager.getInstId();
-	}
-
-	@Override
-	public Object doPreFilter(String adptGrpName, String adptName, Properties prop, Object message, Properties tempProp)
-			throws Exception {
-
-		logger.debug("KFTCP2PFilter] PreFilter Processing Start!!");
-		String orgCode = "D210400012"; // 광주은행 개발 기관코드(운영: K210800020)
-
-		PropGroupVO propGroupVo = PropManager.getInstance().getPropGroupVO(KJB_HEADER);
-		if (propGroupVo != null) {
-			orgCode = propGroupVo.getProperty(PROP_PREFIX + "." + H_ORG_CODE);
-		}
-	
-		String apiTrxDtm = new SimpleDateFormat("yyyyMMddHHmmssSSS").format(new Date());
-		String apiTrxTm = new SimpleDateFormat("HHmmss").format(new Date());
-		// 기관코드(10) + 인스턴스ID(2) + 일시(6) + RandomString(2) -- 총 20자리 
-		String apiTrxNo = orgCode + instId + apiTrxTm + RandomStringUtils.random(2, true, true).toUpperCase(); 
-
-		Properties filterHeaders = (Properties) tempProp.get("FILTERHEADER");
-		if (filterHeaders == null) {
-			filterHeaders = new Properties();
-			tempProp.put("FILTERHEADER", filterHeaders);
-		}
-		try {
-			Map<String, String> inboundHeaderMap = getInboundHeaderProp(tempProp);
-
-			if (!inboundHeaderMap.isEmpty()) {
-				if (inboundHeaderMap.containsKey(H_TRX_NO)) {
-					filterHeaders.put(H_TRX_NO, inboundHeaderMap.get(H_TRX_NO));
-					logger.debug("KFTCP2PFilter] Processing Key ["+H_TRX_NO+"], value ["+inboundHeaderMap.get(H_TRX_NO)+"]");
-				} else {
-					filterHeaders.put(H_TRX_NO, apiTrxNo);
-					logger.debug("KFTCP2PFilter] Processing Key ["+H_TRX_NO+"], value ["+apiTrxNo+"]");
-				}
-				if (inboundHeaderMap.containsKey(H_TRX_DTM)) {
-					filterHeaders.put(H_TRX_DTM, inboundHeaderMap.get(H_TRX_DTM));
-					logger.debug("KFTCP2PFilter] Processing Key ["+H_TRX_DTM+"], value ["+inboundHeaderMap.get(H_TRX_DTM)+"]");
-				} else {
-					filterHeaders.put(H_TRX_DTM, apiTrxDtm);
-					logger.debug("KFTCP2PFilter] Processing Key ["+H_TRX_DTM+"], value ["+apiTrxDtm+"]");
-				}
-			} else {
-				filterHeaders.put(H_TRX_NO, apiTrxNo);
-				filterHeaders.put(H_TRX_DTM, apiTrxDtm);
-			}
-			logger.debug("KFTCP2PFilter] Processing Key ["+H_TRX_NO+"], value ["+filterHeaders.getProperty(H_TRX_NO)+"]");
-			logger.debug("KFTCP2PFilter] Processing Key ["+H_TRX_DTM+"], value ["+filterHeaders.getProperty(H_TRX_DTM)+"]");
-
-		} catch (Exception e) {
-			logger.error(e.getMessage());
-		}
-		
-		return message;
-	}
-
-	public Map<String, String> getInboundHeaderProp(Properties prop) {
-		Properties header = new Properties();
-		Map<String, String> inboundHeaderMap = new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
-		try {
-			Object headerObj = prop.get(HttpAdapterServiceKey.INBOUND_HEADER);
-			if (headerObj instanceof Properties) {    //tomcat
-				header = (Properties) headerObj;
-				for (String name : header.stringPropertyNames()) {
-					inboundHeaderMap.put(name, header.getProperty(name));
-				}
-			} else if (headerObj instanceof String) {  //weblogic
-				String str = (String) headerObj;
-				str = str.substring(1, str.length() - 1);
-				// key=value 쌍 분리
-				String[] entries = str.split(",");
-				for (String entry : entries) {
-				    String[] kv = entry.split("=", 2);
-				    if (kv.length == 2) {
-				    	inboundHeaderMap.put(kv[0].trim(), kv[1].trim());
-				    }
-				}
-			}	
-		} catch (Exception  e) {
-		    e.printStackTrace();
-		}
-		return inboundHeaderMap;
-	}
-
-	@Override
-	public Object doPostFilter(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp) throws Exception {
-		return message;
-	}
-
-}
-

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/NAVERFinFilter.java

@@ -1,107 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.util.Map;
-import java.util.Properties;
-import java.util.TreeMap;
-
-import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceKey;
-import com.eactive.eai.common.property.PropGroupVO;
-import com.eactive.eai.common.property.PropManager;
-import com.eactive.eai.common.util.Logger;
-
-
-public class NAVERFinFilter implements HttpClientAdapterFilter, HttpAdapterServiceKey {
-	protected static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER);
-
-	public static final String KJB_HEADER = "KJB_Header";
-	public static final String PROP_PREFIX = "naverfin";
-	public static final String X_PARTNER_ID = "X-Partner-Id";
-	public static final String X_FINTECH_ID = "X-Fintech-Id";
-
-	@Override
-	public Object doPreFilter(String adptGrpName, String adptName, Properties prop, Object message, Properties tempProp)
-			throws Exception {
-
-		logger.debug("NAVERFinFilter] PreFilter Processing Start!!");
-		String partnerID = "r0jtqwC9gAW5";
-		String fintechId = "NF";
-
-		PropGroupVO propGroupVo = PropManager.getInstance().getPropGroupVO(KJB_HEADER);
-		if (propGroupVo != null) {
-			partnerID = propGroupVo.getProperty(PROP_PREFIX + "." + X_PARTNER_ID);
-			fintechId = propGroupVo.getProperty(PROP_PREFIX + "." + X_FINTECH_ID);
-		}
-
-		Properties filterHeaders = (Properties) tempProp.get("FILTERHEADER");
-		if (filterHeaders == null) {
-			filterHeaders = new Properties();
-			tempProp.put("FILTERHEADER", filterHeaders);
-		}
-		try {
-			Map<String, String> inboundHeaderMap = getInboundHeaderProp(tempProp);
-
-			if (!inboundHeaderMap.isEmpty()) {
-				if (inboundHeaderMap.containsKey(X_PARTNER_ID)) {
-					filterHeaders.put(X_PARTNER_ID, inboundHeaderMap.get(X_PARTNER_ID));
-					logger.debug("NAVERFinFilter] Processing Key ["+X_PARTNER_ID+"], value ["+inboundHeaderMap.get(X_PARTNER_ID)+"]");
-				} else {
-					filterHeaders.put(X_PARTNER_ID, partnerID);
-					logger.debug("NAVERFinFilter] Processing Key ["+X_PARTNER_ID+"], value ["+partnerID+"]");
-				}
-				if (inboundHeaderMap.containsKey(X_FINTECH_ID)) {
-					filterHeaders.put(X_FINTECH_ID, inboundHeaderMap.get(X_FINTECH_ID));
-					logger.debug("NAVERFinFilter] Processing Key ["+X_FINTECH_ID+"], value ["+inboundHeaderMap.get(X_FINTECH_ID)+"]");
-				} else {
-					filterHeaders.put(X_FINTECH_ID, fintechId);
-					logger.debug("NAVERFinFilter] Processing Key ["+X_FINTECH_ID+"], value ["+fintechId+"]");
-				}
-			} else {
-				filterHeaders.put(X_PARTNER_ID, partnerID);
-				filterHeaders.put(X_FINTECH_ID, fintechId);
-			}
-			logger.debug("NAVERFinFilter] Processing Key ["+X_PARTNER_ID+"], value ["+filterHeaders.getProperty(X_PARTNER_ID)+"]");
-			logger.debug("NAVERFinFilter] Processing Key ["+X_FINTECH_ID+"], value ["+filterHeaders.getProperty(X_FINTECH_ID)+"]");
-
-		} catch (Exception e) {
-			logger.error(e.getMessage());
-		}
-		
-		return message;
-	}
-
-	public Map<String, String> getInboundHeaderProp(Properties prop) {
-		Properties header = new Properties();
-		Map<String, String> inboundHeaderMap = new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
-		try {
-			Object headerObj = prop.get(HttpAdapterServiceKey.INBOUND_HEADER);
-			if (headerObj instanceof Properties) {    //tomcat
-				header = (Properties) headerObj;
-				for (String name : header.stringPropertyNames()) {
-					inboundHeaderMap.put(name, header.getProperty(name));
-				}
-			} else if (headerObj instanceof String) {  //weblogic
-				String str = (String) headerObj;
-				str = str.substring(1, str.length() - 1);
-				// key=value 쌍 분리
-				String[] entries = str.split(",");
-				for (String entry : entries) {
-				    String[] kv = entry.split("=", 2);
-				    if (kv.length == 2) {
-				    	inboundHeaderMap.put(kv[0].trim(), kv[1].trim());
-				    }
-				}
-			}	
-		} catch (Exception  e) {
-		    e.printStackTrace();
-		}
-		return inboundHeaderMap;
-	}
-
-	@Override
-	public Object doPostFilter(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp) throws Exception {
-		return message;
-	}
-
-}
-

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/NICECreditFilter.java

@@ -1,138 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.util.Map.Entry;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.Map;
-import java.util.Properties;
-import java.util.TreeMap;
-
-import org.apache.commons.lang3.StringUtils;
-import org.json.simple.JSONObject;
-import org.json.simple.JSONValue;
-
-import com.eactive.eai.adapter.AdapterGroupVO;
-import com.eactive.eai.adapter.AdapterManager;
-import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceKey;
-import com.eactive.eai.common.property.PropGroupVO;
-import com.eactive.eai.common.property.PropManager;
-import com.eactive.eai.common.util.Logger;
-
-
-public class NICECreditFilter implements HttpClientAdapterFilter, HttpAdapterServiceKey {
-	protected static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER);
-
-	public static final String KJB_HEADER = "KJB_Header";
-	public static final String PROP_PREFIX = "nicecredit";
-	public static final String H_PRODUCTID = "ProductID";
-	public static final String B_REQ_DTM = "req_dtm";
-	public static final String B_GOODS_CLS = "goods_cls";
-
-	@SuppressWarnings({ "unchecked" })
-	@Override
-	public Object doPreFilter(String adptGrpName, String adptName, Properties prop, Object message, Properties tempProp)
-			throws Exception {
-
-		JSONObject returnMessage = null;
-		String productId = "2303102120";
-		String reqDtm = new SimpleDateFormat("yyyyMMddHHmmss").format(new Date());
-		String goodsCls = "KJBAPI0001";
-
-		PropGroupVO propGroupVo = PropManager.getInstance().getPropGroupVO(KJB_HEADER);
-		if (propGroupVo != null) {
-			productId = propGroupVo.getProperty(PROP_PREFIX + "." + H_PRODUCTID);
-			goodsCls = propGroupVo.getProperty(PROP_PREFIX + "." + B_GOODS_CLS);
-		}
-
-		Properties filterHeaders = (Properties) tempProp.get("FILTERHEADER");
-		if (filterHeaders == null) {
-			filterHeaders = new Properties();
-			tempProp.put("FILTERHEADER", filterHeaders);
-		}
-		try {
-			Map<String, String> inboundHeaderMap = getInboundHeaderProp(tempProp);
-			if (inboundHeaderMap != null && inboundHeaderMap.containsKey(H_PRODUCTID)) {
-				for (Entry<String, String> e : inboundHeaderMap.entrySet()) {
-					String key = (String) e.getKey();
-					String value = (String) e.getValue();
-	
-					if (StringUtils.equalsIgnoreCase(key, H_PRODUCTID)) {
-						filterHeaders.setProperty(key, value);
-					}
-					if (logger.isDebugEnabled()) {
-						logger.debug("Request Header :" + key + "=[" + value + "]");
-					}
-				}
-			} else {
-				filterHeaders.setProperty(H_PRODUCTID, productId);
-			}
-
-		} catch (Exception e) {
-			logger.error(e.getMessage());
-		}
-		
-		AdapterManager adapterManager = AdapterManager.getInstance();
-		AdapterGroupVO adptGrpVO = adapterManager.getAdapterGroupVO(adptGrpName);
-		String encode = adptGrpVO.getMessageEncode();
-		if (message == null) {
-			returnMessage = new JSONObject();
-		} else {
-			if (message instanceof JSONObject) {
-				returnMessage = (JSONObject) message;
-			} else if (message instanceof String) {
-				returnMessage = parseJson((String) message);
-			} else if (message instanceof byte[]) {
-				returnMessage = parseJson(new String((byte[]) message, encode));
-			}
-		}
-		
-		returnMessage.put(B_REQ_DTM, reqDtm);
-		returnMessage.put(B_GOODS_CLS, goodsCls);
-
-		return returnMessage.toJSONString();
-	}
-
-	private JSONObject parseJson(String message) throws Exception {
-		if (message == null) {
-			return null;
-		}
-
-		return (JSONObject) JSONValue.parse(message);
-	}
-
-	public Map<String, String> getInboundHeaderProp(Properties prop) {
-		Properties header = new Properties();
-		Map<String, String> inboundHeaderMap = new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
-		try {
-			Object headerObj = prop.get(HttpAdapterServiceKey.INBOUND_HEADER);
-			if (headerObj instanceof Properties) {    //tomcat
-				header = (Properties) headerObj;
-				for (String name : header.stringPropertyNames()) {
-					inboundHeaderMap.put(name, header.getProperty(name));
-				}
-			} else if (headerObj instanceof String) {  //weblogic
-				String str = (String) headerObj;
-				str = str.substring(1, str.length() - 1);
-				// key=value 쌍 분리
-				String[] entries = str.split(",");
-				for (String entry : entries) {
-				    String[] kv = entry.split("=", 2);
-				    if (kv.length == 2) {
-				    	inboundHeaderMap.put(kv[0].trim(), kv[1].trim());
-				    }
-				}
-			}	
-		} catch (Exception  e) {
-		    e.printStackTrace();
-		}
-		return inboundHeaderMap;
-	}
-
-	@Override
-	public Object doPostFilter(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp) throws Exception {
-		return message;
-	}
-
-}
-

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/SimpleFrameworkFilter.java

@@ -1,109 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.util.Map;
-import java.util.Properties;
-import java.util.TreeMap;
-
-import org.apache.commons.lang3.StringUtils;
-
-import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceKey;
-import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceSupport;
-import com.eactive.eai.common.TransactionContextKeys;
-import com.eactive.eai.common.util.Logger;
-
-public class SimpleFrameworkFilter implements HttpClientAdapterFilter, HttpAdapterServiceKey {
-	protected static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER);
-
-	public static final String CLIENTID = "clientId";
-	public static final String TRACEID = "traceId";
-	public static final String GUID = "guid";
-	public static final String RECEIVEDTIMESTAMP = "receivedTimestamp";
-	public static final String PARTNER_TRACE_ID = "partnerTraceId";
-
-	@Override
-	public Object doPreFilter(String adptGrpName, String adptName, Properties prop, Object message, Properties tempProp)
-			throws Exception {
-
-		logger.debug("SimpleFrameworkFilter] PreFilter Processing Start!!");
-
-		Properties filterHeaders = (Properties) tempProp.get("FILTERHEADER");
-		if (filterHeaders == null) {
-			filterHeaders = new Properties();
-			tempProp.put("FILTERHEADER", filterHeaders);
-		}
-		
-		Map<String, String> inboundHeaderMap = getInboundHeaderProp(tempProp);	
-		
-		try {
-    		/* 업체정보 */
-			String clientId = tempProp.getProperty(HttpAdapterServiceSupport.PROPERTIES_NAME_CLIENT_ID);
-			if (StringUtils.isEmpty(clientId)) clientId = "";
-			filterHeaders.put(CLIENTID, clientId);
-			logger.debug("SimpleFrameworkFilter] Processing Key ["+CLIENTID+"], value ["+clientId+"]");
-            
-            /* APIM 거래추적자 */
-            String uuid = tempProp.getProperty(TransactionContextKeys.TRANSACTION_UUID, "");
-			filterHeaders.put(TRACEID, uuid);
-			logger.debug("SimpleFrameworkFilter] Processing Key ["+TRACEID+"], value ["+uuid+"]");
-            
-            /* GUID */
-            String guid = tempProp.getProperty(TransactionContextKeys.GUID, "");
-            filterHeaders.put(GUID, guid);
-			logger.debug("SimpleFrameworkFilter] Processing Key ["+GUID+"], value ["+guid+"]");
-               
-            /* 최초요청시간  */
-            String receivedTimestamp = tempProp.getProperty(HttpAdapterServiceKey.INBOUND_REQUESTED_TIME, "");
-            filterHeaders.put(RECEIVEDTIMESTAMP, receivedTimestamp);
-			logger.debug("SimpleFrameworkFilter] Processing Key ["+RECEIVEDTIMESTAMP+"], value ["+receivedTimestamp+"]");
-			
-			String partnerTraceId = inboundHeaderMap.getOrDefault(PARTNER_TRACE_ID, "");
-			filterHeaders.put(PARTNER_TRACE_ID, partnerTraceId);
-			logger.debug("SimpleFrameworkFilter] Processing Key ["+PARTNER_TRACE_ID+"], value ["+partnerTraceId+"]");
-			
-			String x_loan_token = inboundHeaderMap.getOrDefault(TransactionContextKeys.X_LOAN_TOKEN, "");
-			filterHeaders.put(TransactionContextKeys.X_LOAN_TOKEN, x_loan_token);
-			logger.debug("SimpleFrameworkFilter] Processing Key ["+TransactionContextKeys.X_LOAN_TOKEN+"], value ["+x_loan_token+"]");
-
-			
-		} catch (Exception e) {
-			logger.error(e.getMessage());
-		}
-		
-		return message;
-	}
-	
-	public Map<String, String> getInboundHeaderProp(Properties prop) {
-		Properties header = new Properties();
-		Map<String, String> inboundHeaderMap = new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
-		try {
-			Object headerObj = prop.get(HttpAdapterServiceKey.INBOUND_HEADER);
-			if (headerObj instanceof Properties) {    //tomcat
-				header = (Properties) headerObj;
-				for (String name : header.stringPropertyNames()) {
-					inboundHeaderMap.put(name, header.getProperty(name));
-				}
-			} else if (headerObj instanceof String) {  //weblogic
-				String str = (String) headerObj;
-				str = str.substring(1, str.length() - 1);
-				// key=value 쌍 분리
-				String[] entries = str.split(",");
-				for (String entry : entries) {
-				    String[] kv = entry.split("=", 2);
-				    if (kv.length == 2) {
-				    	inboundHeaderMap.put(kv[0].trim(), kv[1].trim());
-				    }
-				}
-			}	
-		} catch (Exception  e) {
-		    e.printStackTrace();
-		}
-		return inboundHeaderMap;
-	}
-
-	@Override
-	public Object doPostFilter(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp) throws Exception {
-		return message;
-	}
-
-}

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/SimpleframeworkBodyFilter.java

@@ -1,28 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.util.Properties;
-
-import org.json.simple.JSONObject;
-import org.json.simple.JSONValue;
-
-import com.eactive.eai.common.TransactionContextKeys;
-
-public class SimpleframeworkBodyFilter extends SimpleFrameworkFilter {
-	@Override
-	public Object doPreFilter(String adptGrpName, String adptName, Properties prop, Object message, Properties tempProp)
-			throws Exception {
-		
-		Object returnMessage = super.doPreFilter(adptGrpName, adptName, prop, message, tempProp);
-		
-		JSONObject bizJsonStr = null;
-		
-		if ( returnMessage instanceof String ) {
-			bizJsonStr = (JSONObject) JSONValue.parse( (String)returnMessage);
-			if( bizJsonStr != null ) {
-			    bizJsonStr.put("GUID", tempProp.getOrDefault(TransactionContextKeys.GUID, "") );
-			}
-		}
-		
-		return bizJsonStr != null ? bizJsonStr.toJSONString() : returnMessage;
-	}
-}

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/TOSSBankFilter.java

@@ -1,97 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.util.Map;
-import java.util.Properties;
-import java.util.TreeMap;
-
-import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceKey;
-import com.eactive.eai.common.TransactionContextKeys;
-import com.eactive.eai.common.property.PropGroupVO;
-import com.eactive.eai.common.property.PropManager;
-import com.eactive.eai.common.util.Logger;
-
-
-public class TOSSBankFilter implements HttpClientAdapterFilter, HttpAdapterServiceKey {
-	protected static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER);
-
-	public static final String KJB_HEADER = "KJB_Header";
-	public static final String PROP_PREFIX = "tossbank";
-	public static final String X_TOSSBANK_LOAN_TRACE_ID = "X-TOSSBANK-LOAN-TRACE-ID";
-
-	@Override
-	public Object doPreFilter(String adptGrpName, String adptName, Properties prop, Object message, Properties tempProp)
-			throws Exception {
-
-		logger.debug("TOSSBankFilter] PreFilter Processing Start!!");
-		String traceId = tempProp.getProperty(TransactionContextKeys.TRANSACTION_UUID, "");
-
-		PropGroupVO propGroupVo = PropManager.getInstance().getPropGroupVO(KJB_HEADER);
-		if (propGroupVo != null) {
-		}
-
-		Properties filterHeaders = (Properties) tempProp.get("FILTERHEADER");
-		if (filterHeaders == null) {
-			filterHeaders = new Properties();
-			tempProp.put("FILTERHEADER", filterHeaders);
-		}
-		try {
-			Map<String, String> inboundHeaderMap = getInboundHeaderProp(tempProp);
-
-			if (!inboundHeaderMap.isEmpty()) {
-				if (inboundHeaderMap.containsKey(X_TOSSBANK_LOAN_TRACE_ID)) {
-					filterHeaders.put(X_TOSSBANK_LOAN_TRACE_ID, inboundHeaderMap.get(X_TOSSBANK_LOAN_TRACE_ID));
-					logger.debug("TOSSBankFilter] Processing Key ["+X_TOSSBANK_LOAN_TRACE_ID+"], value ["+inboundHeaderMap.get(X_TOSSBANK_LOAN_TRACE_ID)+"]");
-				} else {
-					filterHeaders.put(X_TOSSBANK_LOAN_TRACE_ID, traceId);
-					logger.debug("TOSSBankFilter] Processing Key ["+X_TOSSBANK_LOAN_TRACE_ID+"], value ["+traceId+"]");
-				}
-			} else {
-	            /* APIM 거래추적자 */
-				filterHeaders.setProperty(X_TOSSBANK_LOAN_TRACE_ID, traceId);
-				logger.debug("TOSSBankFilter] Processing Key ["+X_TOSSBANK_LOAN_TRACE_ID+"], value ["+traceId+"]");
-			}
-			logger.debug("TOSSBankFilter] Processing Key ["+X_TOSSBANK_LOAN_TRACE_ID+"], value ["+filterHeaders.getProperty(X_TOSSBANK_LOAN_TRACE_ID)+"]");
-
-		} catch (Exception e) {
-			logger.error(e.getMessage());
-		}
-		
-		return message;
-	}
-
-	public Map<String, String> getInboundHeaderProp(Properties prop) {
-		Properties header = new Properties();
-		Map<String, String> inboundHeaderMap = new TreeMap<>(String.CASE_INSENSITIVE_ORDER);
-		try {
-			Object headerObj = prop.get(HttpAdapterServiceKey.INBOUND_HEADER);
-			if (headerObj instanceof Properties) {    //tomcat
-				header = (Properties) headerObj;
-				for (String name : header.stringPropertyNames()) {
-					inboundHeaderMap.put(name, header.getProperty(name));
-				}
-			} else if (headerObj instanceof String) {  //weblogic
-				String str = (String) headerObj;
-				str = str.substring(1, str.length() - 1);
-				// key=value 쌍 분리
-				String[] entries = str.split(",");
-				for (String entry : entries) {
-				    String[] kv = entry.split("=", 2);
-				    if (kv.length == 2) {
-				    	inboundHeaderMap.put(kv[0].trim(), kv[1].trim());
-				    }
-				}
-			}	
-		} catch (Exception  e) {
-		    e.printStackTrace();
-		}
-		return inboundHeaderMap;
-	}
-
-	@Override
-	public Object doPostFilter(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp) throws Exception {
-		return message;
-	}
-
-}
-

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/filter/TraceBodyFilter.java

@@ -1,71 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.filter;
-
-import java.util.Properties;
-
-import org.json.simple.JSONObject;
-import org.json.simple.JSONValue;
-
-import com.eactive.eai.adapter.http.dynamic.HttpAdapterServiceKey;
-import com.eactive.eai.common.TransactionContextKeys;
-import com.eactive.eai.common.util.Logger;
-import com.nimbusds.jose.shaded.gson.JsonObject;
-
-public class TraceBodyFilter implements HttpClientAdapterFilter, HttpAdapterServiceKey {
-
-	protected static Logger logger = Logger.getLogger(Logger.LOGGER_ADAPTER);
-	
-	public static final String BIZ_HEADER = "header";
-	public static final String GUID = "guid";
-	public static final String TRACEID = "traceId";
-
-	@Override
-	public Object doPreFilter(String adptGrpName, String adptName, Properties prop, Object message, Properties tempProp)
-			throws Exception {
-
-		JSONObject bizJsonStr = null;
-
-		if (message instanceof String) {
-
-			bizJsonStr = (JSONObject) JSONValue.parse((String) message);
-			
-			if ( bizJsonStr == null ) return message; //json string이 아님.
-
-			if (bizJsonStr.containsKey(BIZ_HEADER)) {
-				JSONObject bizHeader = (JSONObject) bizJsonStr.get(BIZ_HEADER);
-
-				putBizHeaderData(bizHeader, tempProp);
-
-			}else {
-				
-				JSONObject bizHeader = new JSONObject();
-				bizJsonStr.put(BIZ_HEADER, bizHeader);
-				putBizHeaderData(bizHeader, tempProp);
-				
-			}
-
-		}
-
-		return bizJsonStr != null ? bizJsonStr.toJSONString() : message;
-	}
-	
-	static private void putBizHeaderData(JSONObject bizHeader, Properties tempProp) {
-
-		String traceId = tempProp.getProperty(TransactionContextKeys.TRANSACTION_UUID, "");
-
-		String guid = tempProp.getProperty(TransactionContextKeys.GUID, "");
-
-		bizHeader.put(GUID, guid);
-		logger.debug("Processing Key [" + GUID + "], value [" + guid + "]");
-
-		bizHeader.put(TRACEID, traceId);
-		logger.debug("Processing Key [" + TRACEID + "], value [" + traceId + "]");
-	}
-
-	@Override
-	public Object doPostFilter(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp) throws Exception {
-		// TODO Auto-generated method stub
-		return message;
-	}
-
-}

src/main/java/com/eactive/eai/custom/kjb/adapter/http/client/impl/HttpClient5AdapterServiceRestAddFilter.java

@@ -1,222 +0,0 @@
-package com.eactive.eai.custom.kjb.adapter.http.client.impl;
-
-import java.util.Properties;
-//import java.util.concurrent.Callable;
-
-import org.apache.commons.lang3.StringUtils;
-import org.dom4j.Node;
-import org.json.simple.JSONObject;
-
-import com.eactive.eai.adapter.http.client.HttpClientAdapterServiceKey;
-import com.eactive.eai.adapter.http.client.impl.HttpClient5AdapterServiceRest;
-import com.eactive.eai.custom.kjb.adapter.http.client.filter.HttpClient5AdapterFilterFactory;
-//import com.eactive.eai.custom.kjb.adapter.http.client.filter.HttpClientAdapterExceptionFilter;
-import com.eactive.eai.custom.kjb.adapter.http.client.filter.HttpClientAdapterFilter;
-//import com.eactive.eai.custom.kjb.adapter.http.client.filter.IBKOutCommonFilter;
-//import com.eactive.eai.custom.kjb.adapter.http.client.filter.IBKOutExceptionFilter;
-//import com.fasterxml.jackson.databind.ObjectMapper;
-//import com.fasterxml.jackson.databind.node.ObjectNode;
-//import com.ibk.eai.common.circuitbreaker.url.UrlCircuitBreakerManager;
-
-//import io.github.resilience4j.circuitbreaker.CircuitBreaker;
-
-/**
- * 1. 기능 : HttpClient5AdapterServiceRest 호출 전후 Filter 적용할 수 있는 기능을 제공한다.<br>
- * 2. 처리 개요 : <br>
- * 3. 주의사항 <br>
- *
- * @author :
- * @version : v 1.0.0
- * @see : HttpClientAdapterServiceFactory.java,
- *      HttpClientAdapterServiceSupport.java, HttpClient5AdapterServiceRest.java
- * @since :
- * 
- */
-public class HttpClient5AdapterServiceRestAddFilter extends HttpClient5AdapterServiceRest
-		implements HttpClientAdapterServiceKey {
-
-	// 요청전 수행할 필터(쉼표(,)로 구분)
-	static final String PRE_FILTERS = "PRE_FILTERS";
-
-	// 요청후 수행할 필터(쉼표(,)로 구분)
-	static final String POST_FILTERS = "POST_FILTERS";
-
-//	// Adapter에서 Exception이 발생한 경우, 처리할 필터
-//	static final String EXCEPTION_FILTER = "EXCEPTION_FILTER";
-
-	/**
-	 * 1. 기능 : HttpClient 호출 전후 Filter 적용용 2. 처리 개요 : <br>
-	 * 3. 주의사항 <br>
-	 *
-	 * @param prop Http Adapter 속성 정보
-	 * @return 반환 된 Object
-	 * @exception Exception 수동 시스템 간 통신 중 발생
-	 */
-	public Object execute(Properties prop, Object data, Properties tempProp) throws Exception {
-
-		String adptGrpName = tempProp.getProperty(ADAPTER_GROUP_NAME);
-		String adptName = tempProp.getProperty(ADAPTER_NAME);
-
-		data = doPreFilters(adptGrpName, adptName, prop, data, tempProp);
-
-		Object adapterResponse = super.execute(prop, data, tempProp);
-		
-//		//원본 url를 찾아서 있으면, 그것을 사용한다.
-//		String url = tempProp.getProperty("URL_ORG");
-//		if(StringUtils.isEmpty(url))
-//			url = tempProp.getProperty(HttpClientAdapterServiceKey.URL);
-//		
-//		UrlCircuitBreakerManager cManager = UrlCircuitBreakerManager.getInstance();
-//		CircuitBreaker circuitBreaker = cManager.getCircuitBreaker(url);
-//		try {
-//			if (circuitBreaker != null) {
-//				if (logger.isDebugEnabled()) {
-//					// ObjectMapper 인스턴스 생성
-//					ObjectMapper objectMapper = new ObjectMapper();
-//					// 서킷 브레이커의 메트릭 정보와 상태 정보를 직접 Node로 변환
-//					ObjectNode combinedNode = objectMapper.createObjectNode();
-//					combinedNode.put("state", circuitBreaker.getState().toString());
-//					combinedNode.set("metrics", objectMapper.valueToTree(circuitBreaker.getMetrics()));
-//					logger.debug("CircuitBreaker state [" + circuitBreaker.getName() + "] - " + combinedNode.toString());
-//				}
-//				adapterResponse = circuitBreaker.executeCallable(new HttpClientAdapterCallable(prop, data, tempProp, this));
-//			} else {
-//				adapterResponse = super.execute(prop, data, tempProp);
-//			}
-//		} catch (Exception e) {
-//			adapterResponse = doExceptionFilters(adptGrpName, adptName, prop, adapterResponse, tempProp, e);
-//			
-//			if (adapterResponse instanceof JSONObject)
-//				adapterResponse = ((JSONObject) adapterResponse).toJSONString();
-//
-//			if (adapterResponse instanceof Node)
-//				adapterResponse = ((Node) adapterResponse).asXML();
-//
-//			return adapterResponse;
-//		}
-
-		adapterResponse = doPostFilters(adptGrpName, adptName, prop, adapterResponse, tempProp);
-		if (adapterResponse instanceof JSONObject)
-			adapterResponse = ((JSONObject) adapterResponse).toJSONString();
-
-		if (adapterResponse instanceof Node)
-			adapterResponse = ((Node) adapterResponse).asXML();
-
-		return adapterResponse;
-	}
-
-//	protected Object callSuper(Properties prop, Object data, Properties tempProp) throws Exception {
-//		return super.execute(prop, data, tempProp);
-//	}
-
-//	private class HttpClientAdapterCallable implements Callable<Object> {
-//		Properties prop;
-//		Object data;
-//		Properties tempProp;
-//		HttpClient5AdapterServiceRestAddFilter clientService;
-//
-//		public HttpClientAdapterCallable(Properties prop, Object data, Properties tempProp,
-//				HttpClient5AdapterServiceRestAddFilter clientService) {
-//			this.prop = prop;
-//			this.data = data;
-//			this.tempProp = tempProp;
-//			this.clientService = clientService;
-//		}
-//
-//		@Override
-//		public Object call() throws Exception {
-//			return clientService.callSuper(prop, data, tempProp);
-//		}
-//
-//	}
-
-	protected Object doPreFilters(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp) throws Exception {
-
-//		boolean isSetCommonFilterInAdapterProp = false;
-		// 1. adapter에 설정된 필터 수행
-		String preFiltersStr = prop.getProperty(PRE_FILTERS);
-		if (StringUtils.isNotEmpty(preFiltersStr)) {
-			String[] preFilters = StringUtils.split(preFiltersStr, ",");
-			for (String filterName : preFilters) {
-				if (StringUtils.isBlank(filterName)) {
-					continue;
-				}
-
-				logger.debug("HttpClient5AdapterServiceRestAddFilter] Processing Start [" + filterName + "]");
-				HttpClientAdapterFilter adapterFilter = HttpClient5AdapterFilterFactory.createFilter(filterName.trim());
-
-				if (adapterFilter != null) {
-//					if (adapterFilter instanceof IBKOutCommonFilter)
-//						isSetCommonFilterInAdapterProp = true;
-
-					message = adapterFilter.doPreFilter(adptGrpName, adptName, prop, message, tempProp);
-				} else {
-					throw new Exception("Failed get Filter Class: " + filterName);
-				}
-			}
-		}
-
-//		// 2. IBKOutCommonFilter 필터 수행(adapter 필터에서 수행하지 않을 때만)
-//		if (!isSetCommonFilterInAdapterProp) {
-//			HttpClientAdapterFilter ibkFilter = HttpClient5AdapterFilterFactory
-//					.createFilter(IBKOutCommonFilter.class.getName());
-//			if (ibkFilter != null) {
-//				message = ibkFilter.doPreFilter(adptGrpName, adptName, prop, message, tempProp);
-//			}
-//		} else {
-//			logger.debug("IBKOutCommonFilter isSetCommonFilterInAdapterProp 'POST_FILTERS'. already in adapter filters");
-//		}
-
-		return message;
-	}
-
-	protected Object doPostFilters(String adptGrpName, String adptName, Properties prop, Object message,
-			Properties tempProp) throws Exception {
-
-//		boolean isSetCommonFilterInAdapterProp = false;
-		// 1. adapter에 설정된 필터 수행
-		String postFiltersStr = prop.getProperty(POST_FILTERS);
-		if (StringUtils.isNotEmpty(postFiltersStr)) {
-			String[] postFilters = StringUtils.split(postFiltersStr, ",");
-			for (String filterName : postFilters) {
-				if (StringUtils.isBlank(filterName)) {
-					continue;
-				}
-
-				HttpClientAdapterFilter adapterFilter = HttpClient5AdapterFilterFactory.createFilter(filterName.trim());
-				if (adapterFilter != null) {
-//					if (adapterFilter instanceof IBKOutCommonFilter)
-//						isSetCommonFilterInAdapterProp = true;
-					message = adapterFilter.doPostFilter(adptGrpName, adptName, prop, message, tempProp);
-				} else {
-					throw new Exception("Failed get Filter Class: " + filterName);
-				}
-			}
-		}
-
-//		// 2. IBKOutCommonFilter 필터 수행
-//		if (!isSetCommonFilterInAdapterProp) {
-//			HttpClientAdapterFilter ibkFilter = HttpClient5AdapterFilterFactory
-//					.createFilter(IBKOutCommonFilter.class.getName());
-//			if (ibkFilter != null) {
-//				message = ibkFilter.doPostFilter(adptGrpName, adptName, prop, message, tempProp);
-//			}
-//		} else {
-//			logger.debug("IBKOutCommonFilter isSetCommonFilterInAdapterProp 'PRE_FILTERS'. already in adapter filters");
-//		}
-		return message;
-	}
-	
-//	protected Object doExceptionFilters(String adptGrpName, String adptName, Properties prop, Object message,
-//			Properties tempProp, Exception e) throws Exception {
-//		String exceptionFilterName = prop.getProperty(EXCEPTION_FILTER);
-//		if (StringUtils.isEmpty(exceptionFilterName))
-//			exceptionFilterName = IBKOutExceptionFilter.class.getSimpleName();
-//			
-//		HttpClientAdapterExceptionFilter exceptionFilter = HttpClient5AdapterFilterFactory.createExceptionFilter(exceptionFilterName.trim());
-//		return exceptionFilter.doExceptionFilter(adptGrpName, adptName, prop, message, tempProp, e);
-//		
-//	}
-
-}

src/main/java/com/eactive/eai/custom/security/keyderiv/strategy/HsmContextSha256KeyDerivationStrategy.java

@@ -1,68 +0,0 @@
-package com.eactive.eai.custom.security.keyderiv.strategy;
-
-import java.nio.charset.StandardCharsets;
-import java.security.MessageDigest;
-import java.util.Map;
-
-import javax.crypto.SecretKey;
-
-import com.eactive.eai.common.hsm.HsmCryptoService;
-import com.eactive.eai.common.security.keyderiv.DerivedKey;
-import com.eactive.eai.common.security.keyderiv.KeyDerivationStrategy;
-import com.eactive.eai.common.util.ApplicationContextProvider;
-
-/**
- * HSM 마스터키 + 런타임 컨텍스트값을 연결(concatenate)한 뒤 SHA-256 해싱으로 키를 도출하는 전략.
- * SHA-256 출력은 항상 32바이트(AES-256)이므로 별도 keyLength 파라미터가 불필요하다.
- *
- * key_deriv_params (JSON) 예시:
- * {
- *   "hsmKeyAlias" : "MASTER_KEY_AES",
- *   "contextKey"  : "X-Api-Group-Seq"  -- runtimeContext에서 꺼낼 키 이름
- * }
- */
-public class HsmContextSha256KeyDerivationStrategy implements KeyDerivationStrategy {
-
-	/** DB key_deriv_strategy 컬럼에 사용하는 FQCN 참조용 상수. */
-	public static final String STRATEGY_CLASS = HsmContextSha256KeyDerivationStrategy.class.getName();
-
-	private static final String PARAM_HSM_KEY_ALIAS = "hsmKeyAlias";
-	private static final String PARAM_CONTEXT_KEY   = "contextKey";
-
-	@Override
-	public DerivedKey deriveKey(Map<String, String> params, Map<String, String> runtimeContext) throws Exception {
-		String hsmKeyAlias = required(params, PARAM_HSM_KEY_ALIAS);
-		String contextKey  = required(params, PARAM_CONTEXT_KEY);
-
-		SecretKey masterKey   = hsmCryptoService().getSecretKey(hsmKeyAlias);
-		byte[] masterKeyBytes = masterKey.getEncoded();
-		byte[] contextBytes   = runtimeContext.getOrDefault(contextKey, "")
-				.getBytes(StandardCharsets.UTF_8);
-
-		byte[] combined = new byte[masterKeyBytes.length + contextBytes.length];
-		System.arraycopy(masterKeyBytes, 0, combined, 0, masterKeyBytes.length);
-		System.arraycopy(contextBytes,  0, combined, masterKeyBytes.length, contextBytes.length);
-
-		byte[] derived = MessageDigest.getInstance("SHA-256").digest(combined);
-		return new DerivedKey(derived, derived);
-	}
-
-	@Override
-	public String buildCacheKey(String cryptoName, Map<String, String> params, Map<String, String> runtimeContext) {
-		String contextKey   = params.getOrDefault(PARAM_CONTEXT_KEY, "");
-		String contextValue = runtimeContext.getOrDefault(contextKey, "");
-		return cryptoName + ":" + contextValue;
-	}
-
-	private String required(Map<String, String> params, String key) {
-		String value = params.get(key);
-		if (value == null || value.trim().isEmpty()) {
-			throw new IllegalArgumentException("key_deriv_params 필수값 누락: " + key);
-		}
-		return value;
-	}
-
-	private HsmCryptoService hsmCryptoService() {
-		return ApplicationContextProvider.getContext().getBean(HsmCryptoService.class);
-	}
-}

src/test/java/com/eactive/eai/custom/security/keyderiv/HsmContextSha256KeyDerivationStrategyTest.java

@@ -1,179 +0,0 @@
-package com.eactive.eai.custom.security.keyderiv;
-
-import static org.junit.jupiter.api.Assertions.*;
-import static org.mockito.Mockito.*;
-
-import java.nio.charset.StandardCharsets;
-import java.security.MessageDigest;
-import java.util.HashMap;
-import java.util.Map;
-
-import javax.crypto.SecretKey;
-import javax.crypto.spec.SecretKeySpec;
-
-import org.junit.jupiter.api.BeforeAll;
-import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.DisplayName;
-import org.junit.jupiter.api.MethodOrderer;
-import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.TestMethodOrder;
-import org.springframework.beans.factory.support.BeanDefinitionBuilder;
-import org.springframework.context.support.GenericApplicationContext;
-
-import com.eactive.eai.common.hsm.HsmCryptoService;
-import com.eactive.eai.common.security.keyderiv.DerivedKey;
-import com.eactive.eai.common.util.ApplicationContextProvider;
-import com.eactive.eai.custom.security.keyderiv.strategy.HsmContextSha256KeyDerivationStrategy;
-
-/**
- * HsmContextSha256KeyDerivationStrategy 단위 테스트
- */
-@TestMethodOrder(MethodOrderer.DisplayName.class)
-class HsmContextSha256KeyDerivationStrategyTest {
-
-    private static final String HSM_KEY_ALIAS = "MASTER_KEY_AES";
-    private static final byte[] MASTER_KEY    = "0123456789abcdef".getBytes(StandardCharsets.UTF_8);
-
-    private static GenericApplicationContext              ctx;
-    private static HsmCryptoService                      mockHsmCryptoService;
-    private static HsmContextSha256KeyDerivationStrategy strategy;
-
-    private Map<String, String> params;
-    private Map<String, String> runtimeContext;
-
-    @BeforeAll
-    static void setUpClass() throws Exception {
-        mockHsmCryptoService = mock(HsmCryptoService.class);
-        SecretKey mockSecretKey = new SecretKeySpec(MASTER_KEY, "AES");
-        when(mockHsmCryptoService.getSecretKey(HSM_KEY_ALIAS)).thenReturn(mockSecretKey);
-
-        ctx = new GenericApplicationContext();
-        ctx.getBeanFactory().registerSingleton("hsmCryptoService", mockHsmCryptoService);
-        ctx.registerBeanDefinition("applicationContextProvider",
-                BeanDefinitionBuilder.genericBeanDefinition(ApplicationContextProvider.class)
-                        .getBeanDefinition());
-        ctx.refresh();
-
-        strategy = new HsmContextSha256KeyDerivationStrategy();
-    }
-
-    @BeforeEach
-    void setUpParams() {
-        params = new HashMap<>();
-        params.put("hsmKeyAlias", HSM_KEY_ALIAS);
-        params.put("contextKey",  "X-Api-Group-Seq");
-
-        runtimeContext = new HashMap<>();
-        runtimeContext.put("X-Api-Group-Seq", "GROUP_001");
-    }
-
-    // =========================================================================
-    // 1. deriveKey
-    // =========================================================================
-
-    @Test
-    @DisplayName("1-1. 정상 파라미터 — DerivedKey 반환, 길이 32바이트(SHA-256 고정 출력)")
-    void testDeriveKey_validParams_returns32ByteKey() throws Exception {
-        DerivedKey dk = strategy.deriveKey(params, runtimeContext);
-
-        assertNotNull(dk);
-        assertNotNull(dk.getEncKey());
-        assertNotNull(dk.getDecKey());
-        assertEquals(32, dk.getEncKey().length, "SHA-256 출력은 항상 32바이트여야 한다");
-    }
-
-    @Test
-    @DisplayName("1-2. SHA-256(masterKey || contextValue) 계산 결과 검증")
-    void testDeriveKey_sha256ResultIsCorrect() throws Exception {
-        DerivedKey dk = strategy.deriveKey(params, runtimeContext);
-
-        byte[] contextBytes = "GROUP_001".getBytes(StandardCharsets.UTF_8);
-        byte[] combined = new byte[MASTER_KEY.length + contextBytes.length];
-        System.arraycopy(MASTER_KEY,    0, combined, 0,               MASTER_KEY.length);
-        System.arraycopy(contextBytes,  0, combined, MASTER_KEY.length, contextBytes.length);
-        byte[] expected = MessageDigest.getInstance("SHA-256").digest(combined);
-
-        assertArrayEquals(expected, dk.getEncKey(), "SHA-256 해싱 결과가 일치해야 한다");
-    }
-
-    @Test
-    @DisplayName("1-3. 대칭 알고리즘 — encKey == decKey")
-    void testDeriveKey_encKeyEqualsDecKey() throws Exception {
-        DerivedKey dk = strategy.deriveKey(params, runtimeContext);
-
-        assertArrayEquals(dk.getEncKey(), dk.getDecKey(), "대칭 방식이므로 encKey와 decKey가 동일해야 한다");
-    }
-
-    @Test
-    @DisplayName("1-4. runtimeContext 값 없음 — 빈 문자열로 처리")
-    void testDeriveKey_missingContextValue_emptyStringUsed() throws Exception {
-        runtimeContext.remove("X-Api-Group-Seq");
-        DerivedKey dk = strategy.deriveKey(params, runtimeContext);
-
-        byte[] expected = MessageDigest.getInstance("SHA-256").digest(MASTER_KEY);
-
-        assertArrayEquals(expected, dk.getEncKey(), "컨텍스트 값 없으면 masterKey만 해싱해야 한다");
-    }
-
-    @Test
-    @DisplayName("1-5. 다른 runtimeContext 값 — 다른 DerivedKey 생성")
-    void testDeriveKey_differentContextValue_differentKey() throws Exception {
-        DerivedKey dk1 = strategy.deriveKey(params, runtimeContext);
-
-        runtimeContext.put("X-Api-Group-Seq", "GROUP_002");
-        DerivedKey dk2 = strategy.deriveKey(params, runtimeContext);
-
-        assertFalse(java.util.Arrays.equals(dk1.getEncKey(), dk2.getEncKey()),
-                "컨텍스트 값이 다르면 도출된 키도 달라야 한다");
-    }
-
-    @Test
-    @DisplayName("1-6. 필수 파라미터 누락(hsmKeyAlias) — IllegalArgumentException")
-    void testDeriveKey_missingHsmKeyAlias_throwsException() {
-        params.remove("hsmKeyAlias");
-
-        assertThrows(IllegalArgumentException.class,
-                () -> strategy.deriveKey(params, runtimeContext),
-                "hsmKeyAlias 누락 시 IllegalArgumentException이 발생해야 한다");
-    }
-
-    @Test
-    @DisplayName("1-7. 필수 파라미터 누락(contextKey) — IllegalArgumentException")
-    void testDeriveKey_missingContextKey_throwsException() {
-        params.remove("contextKey");
-
-        assertThrows(IllegalArgumentException.class,
-                () -> strategy.deriveKey(params, runtimeContext),
-                "contextKey 누락 시 IllegalArgumentException이 발생해야 한다");
-    }
-
-    // =========================================================================
-    // 2. buildCacheKey
-    // =========================================================================
-
-    @Test
-    @DisplayName("2-1. buildCacheKey — cryptoName:contextValue 형식")
-    void testBuildCacheKey_format() {
-        String cacheKey = strategy.buildCacheKey("CRYPTO_A", params, runtimeContext);
-
-        assertEquals("CRYPTO_A:GROUP_001", cacheKey);
-    }
-
-    @Test
-    @DisplayName("2-2. buildCacheKey — contextKey 값 없으면 빈 문자열")
-    void testBuildCacheKey_missingContextValue_emptyString() {
-        runtimeContext.remove("X-Api-Group-Seq");
-        String cacheKey = strategy.buildCacheKey("CRYPTO_A", params, runtimeContext);
-
-        assertEquals("CRYPTO_A:", cacheKey);
-    }
-
-    @Test
-    @DisplayName("2-3. buildCacheKey — 다른 cryptoName은 다른 캐시 키")
-    void testBuildCacheKey_differentCryptoName_differentKey() {
-        String key1 = strategy.buildCacheKey("CRYPTO_A", params, runtimeContext);
-        String key2 = strategy.buildCacheKey("CRYPTO_B", params, runtimeContext);
-
-        assertNotEquals(key1, key2);
-    }
-}