diff --git a/pom.xml b/pom.xml index a2baf4e..c7c8aeb 100644 --- a/pom.xml +++ b/pom.xml @@ -6,7 +6,7 @@ <packaging>jar</packaging> <groupId>com.tianbo.messagebus</groupId> <artifactId>cdhz-parse</artifactId> - <version>1.2-parse</version> + <version>1.3-parse</version> <description>消息转发服务</description> <parent> diff --git a/src/main/java/com/tianbo/messagebus/service/Custom_Response_Processor.java b/src/main/java/com/tianbo/messagebus/service/Custom_Response_Processor.java index fcf55bd..1b9d6a9 100644 --- a/src/main/java/com/tianbo/messagebus/service/Custom_Response_Processor.java +++ b/src/main/java/com/tianbo/messagebus/service/Custom_Response_Processor.java @@ -101,12 +101,15 @@ public class Custom_Response_Processor { log.info("4-循环处理消息[{}]--->{}<---",i,msg); JSONObject rootJson = JSON.parseObject(msg); JSONObject msgJson = rootJson.getJSONObject("MSG"); + //报头 + HEADER msgHeader = msgJson.getObject("HEADER",HEADER.class); + + log.info("4.1-消息序号[SEQN]:{},[DDTM]:{}",msgHeader.getSEQNO(),msgHeader.getDDTM()); //回执实体 JSONObject body = msgJson.getJSONObject("BODY"); - //报头 - HEADER msgHeader = msgJson.getObject("HEADER",HEADER.class); + //判断类型 if ("CDHZ".equals(msgHeader.getSTYPE())){