Merge branch 'feature/standard-message-djb' into master

This commit is contained in:
curry772
2026-04-21 16:00:25 +09:00
5 changed files with 24 additions and 21 deletions
@@ -427,15 +427,15 @@ public class BaseFCProcess extends Process {
public void setGUID() throws Exception { public void setGUID() throws Exception {
InterfaceMapper mapper = this.resEaiMsg.getMapper(); InterfaceMapper mapper = this.resEaiMsg.getMapper();
StandardMessage standardMessage = this.resEaiMsg.getStandardMessage(); StandardMessage standardMessage = this.resEaiMsg.getStandardMessage();
String guid = mapper.getGuid(standardMessage); // String guid = mapper.getGuid(standardMessage);
String guidseq = mapper.getGuidSeq(standardMessage); // String guidseq = mapper.getGuidSeq(standardMessage);
//
if (logger.isDebug()) // if (logger.isDebug())
logger.debug(guidLogPrefix + " REQ Current GUID [" + guid + "][" + guidseq + "]"); // logger.debug(guidLogPrefix + " REQ Current GUID [" + guid + "][" + guidseq + "]");
mapper.nextGuidSeq(standardMessage); // mapper.nextGuidSeq(standardMessage);
guidseq = mapper.getGuidSeq(standardMessage); // guidseq = mapper.getGuidSeq(standardMessage);
if (logger.isDebug()) // if (logger.isDebug())
logger.debug(guidLogPrefix + " REQ ADD PATHSEQ GUID [" + guid + "][" + guidseq + "]"); // logger.debug(guidLogPrefix + " REQ ADD PATHSEQ GUID [" + guid + "][" + guidseq + "]");
String svcTsmtUsgTp = this.reqEaiMsg.getSvcTsmtUsgTp(); // 기동 호출방식 String svcTsmtUsgTp = this.reqEaiMsg.getSvcTsmtUsgTp(); // 기동 호출방식
String psvItfTp = this.reqEaiMsg.getCurrentSvcMsg().getPsvItfTp(); // 수동 호출방식 String psvItfTp = this.reqEaiMsg.getCurrentSvcMsg().getPsvItfTp(); // 수동 호출방식
@@ -1292,17 +1292,17 @@ public class RequestProcessor extends RequestProcessorSupport {
STDMessageKeys.SEND_RECV_CD_SEND.equals(returnType) ) { STDMessageKeys.SEND_RECV_CD_SEND.equals(returnType) ) {
try { try {
retEaiMsg.setLogPssSno(400); retEaiMsg.setLogPssSno(400);
String retGuid = mapper.getGuid(retEaiMsg.getStandardMessage()); //String retGuid = mapper.getGuid(retEaiMsg.getStandardMessage());
String retGuidSeq = mapper.getGuidSeq(retEaiMsg.getStandardMessage()); //String retGuidSeq = mapper.getGuidSeq(retEaiMsg.getStandardMessage());
String newGuid = retGuid + StringUtils.defaultString(StringUtils.leftPad(retGuidSeq, UUIDGenerator.GUID_SEQ_LENGTH, '0')); //String newGuid = retGuid + StringUtils.defaultString(StringUtils.leftPad(retGuidSeq, UUIDGenerator.GUID_SEQ_LENGTH, '0'));
mapper.setGuid(retEaiMsg.getStandardMessage(), newGuid); //mapper.setGuid(retEaiMsg.getStandardMessage(), newGuid);
mapper.setSendTime(retEaiMsg.getStandardMessage(), DatetimeUtil.getCurrentTimeMillis()); //mapper.setSendTime(retEaiMsg.getStandardMessage(), DatetimeUtil.getCurrentTimeMillis());
EAILogSender.send(retEaiMsg, null); EAILogSender.send(retEaiMsg, null);
} catch(Exception e) { } catch(Exception e) {
vo.setRspErrorCode("RECEAIIRP100"); vo.setRspErrorCode("RECEAIIRP100");
vo.setRspErrorMsg(ExceptionUtil.make(e, vo.getRspErrorCode(), new String[]{vo.getEaiSvcCd()} )); vo.setRspErrorMsg(ExceptionUtil.make(e, vo.getRspErrorCode(), new String[]{vo.getEaiSvcCd()} ));
if (logger.isError()) logger.error(guidLogPrefix + " : " + vo.getRspErrorMsg()); if (logger.isError()) logger.error(guidLogPrefix + " : " + vo.getRspErrorMsg(), e);
} }
if (logger.isInfo()) logger.info(guidLogPrefix + " : LOG(" + eaiMsg.getLogPssSno() + ") EAIMessage : "+eaiMsg.getEAISvcCd()); if (logger.isInfo()) logger.info(guidLogPrefix + " : LOG(" + eaiMsg.getLogPssSno() + ") EAIMessage : "+eaiMsg.getEAISvcCd());
} }
@@ -783,12 +783,15 @@ public class StandardItem implements Serializable, Cloneable {
if(p>0) sb.append(","); if(p>0) sb.append(",");
sb.append("{"); sb.append("{");
while(keyIter.hasNext()) { while(keyIter.hasNext()) {
if(ai>0) sb.append(",");
String key = keyIter.next(); String key = keyIter.next();
StandardItem item = group.get(key); StandardItem item = group.get(key);
if(showPretty) sb.append("\n"); String itemPart = item.toJson(showPretty, withBizData);
sb.append(item.toJson(showPretty, withBizData)); if(StringUtils.isNotEmpty(itemPart)) {
ai++; if(ai>0) sb.append(",");
if(showPretty) sb.append("\n");
sb.append(itemPart);
ai++;
}
} }
if(showPretty) { if(showPretty) {
@@ -47,7 +47,7 @@ reader.XML=com.eactive.eai.message.parser.XmlReader
reader.FLAT=com.eactive.eai.message.parser.FlatReader reader.FLAT=com.eactive.eai.message.parser.FlatReader
*/ */
public static String STANDARD_MESSAGE_CONFIG = "standard.message.config"; public static String STANDARD_MESSAGE_CONFIG = "standard.message.config";
private String DEFAULT_CONFIG_PATH = "./resources/standard-message-config.properties"; private String DEFAULT_CONFIG_PATH = "./standard-message-config.properties";
private String DEFAULT_CONFIG_FILE = "standard-message-config.properties"; private String DEFAULT_CONFIG_FILE = "standard-message-config.properties";
private String LAYOUT_FILE_TYPE = "layout.file.type"; private String LAYOUT_FILE_TYPE = "layout.file.type";
@@ -776,7 +776,7 @@ public abstract class DefaultProcess extends Process {
} }
standardMessage.setBizData(this.resObject, this.inboundCharset); standardMessage.setBizData(this.resObject, this.inboundCharset);
try { try {
mapper.nextGuidSeq(standardMessage); //mapper.nextGuidSeq(standardMessage);
mapper.setSendRecvDivision(standardMessage, STDMessageKeys.SEND_RECV_CD_RECV); mapper.setSendRecvDivision(standardMessage, STDMessageKeys.SEND_RECV_CD_RECV);
StandardMessageManager standardManager = StandardMessageManager.getInstance(); StandardMessageManager standardManager = StandardMessageManager.getInstance();
standardManager.getMessageCoordinator().coordinateSetStandardMessageError(standardMessage, mapper, standardManager.getMessageCoordinator().coordinateSetStandardMessageError(standardMessage, mapper,