JSONMessage 불필요한 로직 제거

This commit is contained in:
curry772
2026-08-05 13:04:02 +09:00
parent 027ec4fcea
commit 375f0e0f15
2 changed files with 73 additions and 112 deletions
@@ -1,7 +1,6 @@
package com.eactive.eai.transformer.message; package com.eactive.eai.transformer.message;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.text.DecimalFormat;
import java.util.HashMap; import java.util.HashMap;
import java.util.Iterator; import java.util.Iterator;
import java.util.Stack; import java.util.Stack;
@@ -338,14 +337,15 @@ public class JSONMessage extends Message {
if( parent instanceof ObjectNode ) { if( parent instanceof ObjectNode ) {
obj = (ObjectNode)parent; obj = (ObjectNode)parent;
String val = getStringValue(item.getValue(),item); // 출력 시점 자릿수 검증 (변환으로 생성된 값은 setData 입력검증을 거치지 않음)
validateDecimal(item.getValue(), item);
// String인 경우에만 Masking 이 가능 - 숫자는 불가능
int itemType = item.getDataTypeId(); int itemType = item.getDataTypeId();
if (isMask && "Y".equals(item.getMask()) && (Types.TYPE_STRING == itemType )){ if (isMask && "Y".equals(item.getMask()) && (Types.TYPE_STRING == itemType )){
val = maskString2(val, item.getMaskLength(), item.getMaskOffset()); String val = maskString2(getStringValue(item.getValue(),item), item.getMaskLength(), item.getMaskOffset());
item.setValue(val); item.setValue(val);
} }
// Object value = toJsonObjectType(item.getDataTypeId(), val);
String value = val;
if( item.getOccMax() > 1 || item.getOccMax() == -1 ) { // FIELD ARRAY FORMAT "name":["value1", "value2"] if( item.getOccMax() > 1 || item.getOccMax() == -1 ) { // FIELD ARRAY FORMAT "name":["value1", "value2"]
arr = (ArrayNode)obj.get(item.getName()); arr = (ArrayNode)obj.get(item.getName());
if (arr == null){ if (arr == null){
@@ -480,41 +480,22 @@ public class JSONMessage extends Message {
} }
} }
/**
* item 값을 문자열로 변환한다. 마스킹 대상(TYPE_STRING) 필드에서만 사용된다.
*/
protected String getStringValue(Object value, Item item) throws Exception{ protected String getStringValue(Object value, Item item) throws Exception{
if (value == null) return null; if (value == null) return null;
String val=""; String val="";
if (value instanceof String){ if (value instanceof String){
String data = (String)value; val = (String)value;
if (item.getDataTypeId() == Types.TYPE_BIGDECIMAL){
val = getFormat(data,item.getLength(),item.getDecimalPointLength());
}else{
val = data;
}
} else if (value instanceof byte[]){ } else if (value instanceof byte[]){
String data = new String((byte[])value); val = new String((byte[])value);
if (item.getDataTypeId() == Types.TYPE_BIGDECIMAL){
val = getFormat(data,item.getLength(),item.getDecimalPointLength());
}else{
val = data;
}
} else if ( value instanceof BigDecimal) { } else if ( value instanceof BigDecimal) {
String data = ((BigDecimal) value).toPlainString(); val = ((BigDecimal) value).toPlainString();
if (item.getDataTypeId() == Types.TYPE_BIGDECIMAL){
val = getFormat(data,item.getLength(),item.getDecimalPointLength());
}else{
val = data;
}
} else if ( value instanceof Integer) { } else if ( value instanceof Integer) {
String data = String.valueOf(value); val = String.valueOf(value);
if (item.getDataTypeId() == Types.TYPE_BIGDECIMAL){
val = getFormat(data,item.getLength(),item.getDecimalPointLength());
}else{
val = data;
}
} else if ( value instanceof Boolean) { } else if ( value instanceof Boolean) {
String data = String.valueOf(value); val = String.valueOf(value);
val = data;
} }
return val; return val;
} }
@@ -591,81 +572,44 @@ public class JSONMessage extends Message {
} }
} }
private String getFormat(String value,int length,int pointLength) throws Exception { /**
boolean validation = SystemKeys.isValidationEnabled(); * BIGDECIMAL 필드의 출력값 검증.
return getFormat(value, length, pointLength, validation) ; *
* 변환으로 생성된 target 메시지의 값은 setData() 입력검증을 거치지 않으므로
* (Message.setBigDecimal() 에 검증 없음) 출력 시점에 레이아웃 자릿수를 확인한다.
*
* 이전에는 DecimalFormat 으로 자릿수를 맞춘 문자열을 반환하는 getFormat() 이었으나,
* 출력이 setJsonNodeValue() 에서 item.getValue() 를 직접 쓰는 방식으로 바뀌면서
* 반환값이 사용되지 않아 포맷 로직을 제거하고 검증만 남김.
*/
private void validateDecimal(Object value, Item item) throws Exception {
if (value == null || item.getDataTypeId() != Types.TYPE_BIGDECIMAL) {
return;
} }
private String getFormat(String value, int length, int pointLength, boolean isValidation) throws Exception{ String data;
if(isValidation) { if (value instanceof String) {
if (!Converter.isValid(value,length,pointLength)){ data = (String) value;
} else if (value instanceof byte[]) {
data = new String((byte[]) value);
} else if (value instanceof BigDecimal) {
data = ((BigDecimal) value).toPlainString();
} else if (value instanceof Integer) {
data = String.valueOf(value);
} else {
// 그 외 타입은 검증 대상 아님
return;
}
int length = item.getLength();
int pointLength = item.getDecimalPointLength();
if (SystemKeys.isValidationEnabled() && !Converter.isValid(data, length, pointLength)) {
throw new Exception(String.format("Invalid decimal point format Error value=%s,length=%d,pointLength=%d" throw new Exception(String.format("Invalid decimal point format Error value=%s,length=%d,pointLength=%d"
, value,length,pointLength) , data,length,pointLength)
); );
} }
// 숫자형 여부 확인 - 파싱 불가 시 NumberFormatException
boolean isMinus=false; new BigDecimal(data.replaceAll(" ", ""));
String pattern = "";
//음수/양수 check
if (value.indexOf("-")>=0){
isMinus = true;
}
String data = value.replaceAll(" ", "").replaceAll("-", "");
if (pointLength> 0 ){//소수부가 있을 경우
for(int i=isMinus?1:0;i<length-pointLength-1;i++){
pattern = pattern + "#";
}
pattern =pattern+".";
for(int i=0;i<pointLength;i++){
pattern = pattern + "0";
}
}else{//소수부가 없을경우
for(int i=isMinus?1:0;i<length-pointLength;i++){
pattern = pattern + "#";
}
}
if (isMinus) {
pattern="-"+pattern;
}
DecimalFormat format = new DecimalFormat(pattern);
// double num = Double.parseDouble(data);
BigDecimal num = new BigDecimal(data);
return format.format(num);
}
else {
BigDecimal num = new BigDecimal(value);
return num.toPlainString();
}
}
private boolean isValid(String value,int length,int pointLength){
String[] data = value.replaceAll(" ", "").split("[.]");
if (pointLength > 0 ){
if (data.length ==1){
if (data[0].length() > length - pointLength - 1 ){ //정수부 오류
return false;
}
}else if (data.length ==2){
if (data[0].length() > length - pointLength - 1 ){ //정수부 오류
return false;
}
if (data[1].length() > pointLength ){ //실수부 오류
return false;
}
}else{
//오류
return false;
}
}else{
if (data.length != 1){ //소수점이 들어와서 오류
return false;
}
if (data[0].length() > length - pointLength - 1){ //정수부 오류
return false;
}
}
return true;
} }
// private Object toJsonObjectType(int itemType, String value) { // private Object toJsonObjectType(int itemType, String value) {
@@ -26,7 +26,8 @@ import com.eactive.eai.transformer.message.MessageSetDataException;
* 테스트 대상 레이아웃: EAI_UJSONTYPE_REQ1 * 테스트 대상 레이아웃: EAI_UJSONTYPE_REQ1
* - INT_VALUE : INT, length=5, decimal=0 * - INT_VALUE : INT, length=5, decimal=0
* - LONG_VALUE : LONG, length=10, decimal=0 * - LONG_VALUE : LONG, length=10, decimal=0
* - BIG_VALUE : BIGDECIMAL, length=10, decimal=5 → 정수부 최대 4자리 * - BIG_VALUE : BIGDECIMAL, length=10, decimal=5 → 정수부 최대 5자리
* (length 는 소수점(.) 문자를 제외한 전체 자릿수 규약)
* - BIG15_VALUE : BIGDECIMAL, length=15, decimal=0 → 정수부 최대 15자리 * - BIG15_VALUE : BIGDECIMAL, length=15, decimal=0 → 정수부 최대 15자리
* - STR_VALUE : STRING, length=20 * - STR_VALUE : STRING, length=20
* *
@@ -195,12 +196,12 @@ class JSONMessageValidationTest {
// ───────────────────────────────────────────────────────────────── // ─────────────────────────────────────────────────────────────────
@Test @Test
@DisplayName("BIG_VALUE 정수부 초과(5자리 > 4자리 제한) → MessageSetDataException") @DisplayName("BIG_VALUE 정수부 초과(6자리 > 5자리 제한) → MessageSetDataException")
void testBigDecimalIntegerPartOverflow() { void testBigDecimalIntegerPartOverflow() {
enableValidation(); enableValidation();
// 정수부 5자리(12345) → 제한(4자리) 초과 // 정수부 6자리(123456) → 제한(5자리) 초과
String data = "{\"EAI_UJSONTYPE_REQ1\":{\"BIG_VALUE\":12345.12345}}"; String data = "{\"EAI_UJSONTYPE_REQ1\":{\"BIG_VALUE\":123456.12345}}";
Message msg = MessageFactory.getFactory().getMessage("EAI_UJSONTYPE_REQ1"); Message msg = MessageFactory.getFactory().getMessage("EAI_UJSONTYPE_REQ1");
MessageSetDataException ex = assertThrows( MessageSetDataException ex = assertThrows(
@@ -260,17 +261,33 @@ class JSONMessageValidationTest {
assertTrue(result.contains("BIG_VALUE"), "BIG_VALUE가 결과에 포함되어야 합니다"); assertTrue(result.contains("BIG_VALUE"), "BIG_VALUE가 결과에 포함되어야 합니다");
} }
@Test
@DisplayName("BIG_VALUE 정수부 경계값(정수부 5자리 + 소수부 5자리) → 정상 처리")
void testBigDecimalIntegerPartBoundary() throws Exception {
enableValidation();
// length=10, decimal=5 이고 length 에 소수점(.)은 포함되지 않으므로
// 정수부 5자리(10-5)까지 허용된다.
String data = "{\"EAI_UJSONTYPE_REQ1\":{\"BIG_VALUE\":12345.12345}}";
Message msg = MessageFactory.getFactory().getMessage("EAI_UJSONTYPE_REQ1");
msg.setData(data);
String result = (String) msg.getData();
assertNotNull(result, "결과값이 null이 아니어야 합니다");
assertTrue(result.contains("BIG_VALUE"), "BIG_VALUE가 결과에 포함되어야 합니다");
}
// ───────────────────────────────────────────────────────────────── // ─────────────────────────────────────────────────────────────────
// 2-c. BigDecimal 자릿수 초과 (JSON 문자열 형태) — transformer.validation=true 필요 // 2-c. BigDecimal 자릿수 초과 (JSON 문자열 형태) — transformer.validation=true 필요
// ───────────────────────────────────────────────────────────────── // ─────────────────────────────────────────────────────────────────
@Test @Test
@DisplayName("BIG_VALUE 정수부 초과 문자열 입력(5자리 > 4자리 제한) → MessageSetDataException") @DisplayName("BIG_VALUE 정수부 초과 문자열 입력(6자리 > 5자리 제한) → MessageSetDataException")
void testBigDecimalIntegerPartOverflowFromString() { void testBigDecimalIntegerPartOverflowFromString() {
enableValidation(); enableValidation();
// JSON 문자열 "12345.12345" → 정수부 5자리 초과 // JSON 문자열 "123456.12345" → 정수부 6자리 초과
String data = "{\"EAI_UJSONTYPE_REQ1\":{\"BIG_VALUE\":\"12345.12345\"}}"; String data = "{\"EAI_UJSONTYPE_REQ1\":{\"BIG_VALUE\":\"123456.12345\"}}";
Message msg = MessageFactory.getFactory().getMessage("EAI_UJSONTYPE_REQ1"); Message msg = MessageFactory.getFactory().getMessage("EAI_UJSONTYPE_REQ1");
MessageSetDataException ex = assertThrows( MessageSetDataException ex = assertThrows(