最近需要对接 东方国际 edi 报文
下面，就简单描述一下过程。
首先，放上参考资料：都很有帮助
参考链接：
1 有嵌套对象的例子，而且很有帮助
https://blog.csdn.net/yzjdt/article/details/28589493
2 smooks example ：
https://github.com/smooks/smooks-examples
一，项目结构
1 MainDongFang是测试类
2 model.modelEDI.dongfang 是 java bean
3 resources.testDongFang 存放
① input-message.edi 测试edi数据
② smooks-config.xml 配置文件
③ edi-to-java-order-mapping.xml 映射文件
二，引入smooks
<dependency>
<groupId>org.milyn</groupId>
<artifactId>milyn-smooks-all</artifactId>
<version>1.7.0</version>
</dependency>
三，
1 数据 input-message.edi
这里为了简洁，我只映射 00,03,47 的字段
00:IFTMBF:BOOKING:9:QYHD::201912261722' 02:FLEX923423:DMDFR191217001:CY-CY::::::::::::OIT1234' 03:EXP::::1' 11::::ONE:OCEAN NETWORK EXPRESS:::20200109' 12:CNSHA:SHANGHAI:CNSHA:SHANGHAI:CAVAN:VANCOUVER,BC:::CAMTR:MONTREAL,QC:CAMTR:MONTREAL,QC' 14::FREIGHT PREPAID' 15:::P' 17:it@oitco.com' 20::SHANGHAI OIT:HONGKOU CHANG YANG ROAD NO 8:TEL 6100000:MAIL IT@OITCO.COM' 21::USA OIT:ADDRESS?:NEW YORK:LOCAL NO.4:BILL BUILDING:TEL ?: 00121-1234567' 22::USA OIT:ADDRESS?:NEW YORK:LOCAL NO.4:BILL BUILDING:TEL ?: 00121-1234567' 41:1:::30:PACKAGE(S):PACKAGE(S):6000.0:21.73::::::6000.0' 44:N/M::' 47:VEHICLE DOOR FORGING' 47:ACCEPT LONG-TERM LEASED & ' 47:CARRIER OWNED CNTR ONLY' 48:20GP:1:F:::::N' 48:40HC:1:F:::::N' 99:18'
2 配置smooks-config.xml
jb:wiring ：代表引用类型
jb:value ：代表基本类型
<?xml version="1.0"?> <smooks-resource-list xmlns="http://www.milyn.org/xsd/smooks-1.1.xsd" xmlns:edi="http://www.milyn.org/xsd/smooks/edi-1.4.xsd" xmlns:jb="http://www.milyn.org/xsd/smooks/javabean-1.4.xsd"> <!-- Configure the EDI Reader to parse the message stream into a stream of SAX events. --> <edi:reader mappingModel="edi-to-java-order-mapping.xml" /> <!-- beanId 类的实例名 class 类的全路径+类名 createOnElement 这个有点复杂，单个和集合类，设置不一样。看例子。 --> <jb:bean beanId="order" class="com.kintech.webEDI.model.modelEDI.dongfang.DongFangOrder" createOnElement="DongFangOrder"> <jb:wiring property="head_00" beanIdRef="head_00" /> <jb:wiring property="bl_03" beanIdRef="bl_03" /> <jb:wiring property="cargo_description_47s" beanIdRef="cargo_description_47s" /> </jb:bean> <!-- Header --> <jb:bean beanId="head_00" class="com.kintech.webEDI.model.modelEDI.dongfang.HEAD_00" createOnElement="${order}/HEAD_00"> <jb:value property="messageType" decoder="String" data="#/messageType" /> <jb:value property="fileDescription" decoder="String" data="#/fileDescription" /> <jb:value property="fileFunction" decoder="String" data="#/fileFunction" /> <jb:value property="sendCode" decoder="String" data="#/sendCode" /> <jb:value property="receiverCode" decoder="String" data="#/receiverCode" /> <jb:value property="fileCreateTime" decoder="Date" data="#/fileCreateTime"> <jb:decodeParam name="format">yyyyMMddHHmm</jb:decodeParam> </jb:value> </jb:bean> <!-- BL --> <jb:bean beanId="bl_03" class="com.kintech.webEDI.model.modelEDI.dongfang.BL_03" createOnElement="${order}/BL_03"> <jb:value property="typeOfBLFrom" decoder="String" data="#/typeOfBLFrom" /> <jb:value property="placeOfBLIssueCode" decoder="String" data="#/placeOfBLIssueCode" /> <jb:value property="placeOfBLIssue" decoder="String" data="#/placeOfBLIssue" /> <jb:value property="dateOfIssue" decoder="String" data="#/dateOfIssue" /> <jb:value property="numberOfOriginalBL" decoder="Integer" data="#/numberOfOriginalBL" /> <!-- <jb:value property="prepaidAt" decoder="String" data="#/prepaidAt" />--> <!-- <jb:value property="payableAt" decoder="String" data="#/payableAt" />--> </jb:bean> <!-- CARGO DESCRIPTION (List) --> <jb:bean beanId="cargo_description_47s" class="java.util.ArrayList" createOnElement="DongFangOrder"> <jb:wiring beanIdRef="cargo_description_47" /> </jb:bean> <jb:bean beanId="cargo_description_47" class="com.kintech.webEDI.model.modelEDI.dongfang.CARGO_DESCRIPTION_47" createOnElement="CARGO_DESCRIPTION_47"> <jb:value property="cargoDescription" decoder="String" data="#/cargoDescription" /> </jb:bean> </smooks-resource-list>
3 edi-to-java-order-mapping.xml
---- medi:description
segment：换行符
field：字段分隔符
component：根据某一列的分隔符再次分割。
escape：转义符
----medi:segment
segcode：行指令
xmltag：我看下来，是smooks-config.xml 中的createOnElement
truncatable ： 可空（注意segment和field都要加！）
----medi:segmentGroup 代表循环
maxOccurs ： 最大循环次数，-1代表多个。
minOccurs：最小循环次数，0代表可能没有。
----medi:segment segcode=99
这个是海关要求，需要一个总行数。可以没有对应实体。
<?xml version="1.0" encoding="UTF-8"?> <medi:edimap xmlns:medi="http://www.milyn.org/schema/edi-message-mapping-1.4.xsd"> <medi:description name="Order" version="1.0" /> <medi:delimiters segment="'" field=":" component="^" sub-component="~" escape="?" /> <medi:segments xmltag="DongFangOrder"> <medi:segment segcode="00" xmltag="HEAD_00" truncatable="true"> <medi:field xmltag="messageType" /> <medi:field xmltag="fileDescription" /> <medi:field xmltag="fileFunction" /> <medi:field xmltag="sendCode" /> <medi:field xmltag="receiverCode" truncatable="true" /> <medi:field xmltag="fileCreateTime" truncatable="true" /> </medi:segment> <medi:segment segcode="03" xmltag="BL_03" truncatable="true"> <medi:field xmltag="typeOfBLFrom" /> <medi:field xmltag="placeOfBLIssueCode" truncatable="true" /> <medi:field xmltag="placeOfBLIssue" truncatable="true" /> <medi:field xmltag="dateOfIssue" truncatable="true" /> <medi:field xmltag="numberOfOriginalBL" /> <medi:field xmltag="prepaidAt" truncatable="true" /> <medi:field xmltag="payableAt" truncatable="true" /> </medi:segment> <medi:segment segcode="47" xmltag="CARGO_DESCRIPTION_47" maxOccurs="-1" minOccurs="0" > <medi:field xmltag="cargoDescription" /> </medi:segment> <medi:segment segcode="99" xmltag="End" minOccurs="0"> <medi:field xmltag="endNumLine" /> </medi:segment> </medi:segments> </medi:edimap>
四，实体类
1，DongFangOrder
@Data public class DongFangOrder { private HEAD_00 head_00; private BL_03 bl_03; private List<CARGO_DESCRIPTION_47> cargo_description_47s; }
2，Head_00
@Data public class HEAD_00 { private String messageType; //报文类型 private String fileDescription; //文件说明 private String fileFunction; //文件功能 private String sendCode; //发送方代码 private String receiverCode; //接收方代码 private Date fileCreateTime; //文件建立时间 }
3，BL_03
@Data public class BL_03 { private String typeOfBLFrom; //提单类型 private String placeOfBLIssueCode; //提单签发地代码 private String placeOfBLIssue; //提单签发地 private String dateOfIssue; //签发日期 private Integer numberOfOriginalBL; //正本提单份数 private String prepaidAt; //预付地点 private String payableAt; //到付地点 }
4，Cargo_Description_47
@Data public class CARGO_DESCRIPTION_47 { private String cargoDescription; //货物描述 }
五，测试
直接调用 smooks的example中例子就可以了。
package com.kintech.webEDI; import org.milyn.Smooks; import org.milyn.SmooksException; import org.milyn.container.ExecutionContext; import org.milyn.event.report.HtmlReportGenerator; import org.milyn.io.StreamUtils; import org.milyn.payload.JavaResult; import org.xml.sax.SAXException; import javax.xml.transform.stream.StreamSource; import java.io.*; /** * Simple example main class. * * @author <a href="mailto:tom.fennelly@gmail.com">tom.fennelly@gmail.com</a> */ public class MainDongFang { private static byte[] messageIn = readInputMessage(); private final Smooks smooks; protected MainDongFang() throws IOException, SAXException { // Instantiate Smooks with the config... smooks = new Smooks("testDongFang/smooks-config.xml"); } protected JavaResult runSmooksTransform(ExecutionContext executionContext) throws IOException, SAXException, SmooksException { try { //java bean JavaResult javaResult = new JavaResult(); smooks.filterSource(new StreamSource(new ByteArrayInputStream(messageIn)), javaResult); //xml // StringResult result=new StringResult(); // smooks.filterSource(new StreamSource(new ByteArrayInputStream(messageIn)), result); // System.out.println(result.getResult()); return javaResult; } finally { smooks.close(); } } public static void main(String[] args) throws IOException, SAXException, SmooksException { System.out.println(" ==============Message In=============="); System.out.println(new String(messageIn)); System.out.println("====================================== "); pause("The EDI input stream can be seen above. Press 'enter' to see how this stream is transformed into an Order Object graph..."); MainDongFang smooksMain = new MainDongFang(); ExecutionContext executionContext = smooksMain.smooks.createExecutionContext(); JavaResult result = smooksMain.runSmooksTransform(executionContext); System.out.println(" ==============EDI as Java Object Graph============="); System.out.println(result.getBean("order")); System.out.println("====================================== "); pause("And that's it! Press 'enter' to finish..."); } private static byte[] readInputMessage() { try { return StreamUtils.readStream(Main.class.getResourceAsStream("../../../testDongFang/input-message.edi")); } catch (IOException e) { e.printStackTrace(); return "<no-message/>".getBytes(); } } private static void pause(String message) { try { BufferedReader in = new BufferedReader(new InputStreamReader(System.in)); System.out.print("> " + message); in.readLine(); } catch (IOException e) { } System.out.println(" "); } public JavaResult runSmooksTransform() throws IOException, SAXException { ExecutionContext executionContext = smooks.createExecutionContext(); return runSmooksTransform(executionContext); } }
需要注意的是：runSmooksTransform 方法中，使用了工厂模式，
底层会通过 TransformFactory工厂接收你传入的 JavaResult / StringResult等等，来产生不同的结果。
JavaResult返回java bean
StringResult 返回 xml String
其他类型，暂时我没有研究。
六，结果
