Java-解析 SOAP 格式数据总结，内部类使用

2020年02月12日 18:19 · 阅读(2819) ·

目标

解析 SOAP 数据格式

开发环境

名称 版本
操作系统 Windows 10 X64
JDK JDK1.8（jdk-8u151-windows-x64）
IntelliJ IDEA IntelliJ IDEA 2018.3
Maven Maven 3.6.0

SOAP 解析参考

Java解析Soap XML

说明

用 Java 程序实现下面的接口调用

Headers 参数

名称 值
SOAPAction
Content-Type text/xml; charset=utf-8

Body 参数

  1. <?xml version="1.0" encoding="utf-16"?>
  2. <soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema">
  3.   <soap:Body>
  4.     <PGetPo xmlns="http://tempuri.org/">
  5.       <startDate></startDate>
  6.       <endDate></endDate>
  7.       <appKey>luoma</appKey>
  8.     </PGetPo>
  9.   </soap:Body>
  10. </soap:Envelope>

返回值

  1. <?xml version="1.0" encoding="utf-8"?>
  2. <soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema">
  3.     <soap:Body>
  4.         <PGetPoResponse xmlns="http://tempuri.org/">
  5.             <PGetPoResult>{"code":0,"data":[{"PO_NUMBER":"POGO201702170002","ORG_ID":115.0,"VENDOR_AREA":"境外","VENDOR_NAME":"xx1有限公司","VENDOR_ID":16684.0,"CONTRACT_CODE":"T-044-PUR-201510723-03","APPLY_NO":"PA-PL-201703220001","CREATION_DATE":"\/Date(1487294589000+0800)\/"},{"PO_NUMBER":"POGO201702200016","ORG_ID":115.0,"VENDOR_AREA":"境外","VENDOR_NAME":"xx2有限公司","VENDOR_ID":3331207.0,"CONTRACT_CODE":"T-044-PUR-20150602-01","APPLY_NO":"PA-PL-201703230001","CREATION_DATE":"\/Date(1487575960000+0800)\/"}]}</PGetPoResult>
  6.         </PGetPoResponse>
  7.     </soap:Body>
  8. </soap:Envelope>

公共类-WebClientUtils

公共类-WebClientUtils

公共类-SoapUtil

  1. package com.foreign.payment.common.util;
  3. import com.alibaba.fastjson.JSON;
  4. import com.foreign.payment.common.data.PGetPoResult;
  5. import com.foreign.payment.common.data.WebserviceResultBean;
  7. import java.io.ByteArrayInputStream;
  8. import java.util.Iterator;
  11. import javax.xml.soap.MessageFactory;
  12. import javax.xml.soap.MimeHeaders;
  13. import javax.xml.soap.SOAPBody;
  14. import javax.xml.soap.SOAPElement;
  15. import javax.xml.soap.SOAPMessage;
  17. /**
  18.  * XML  Soap 解析
  19.  * https://blog.csdn.net/chenmintong/article/details/79970624
  20.  */
  21. public class SoapUtil {
  22.     /**
  23.      * 解析soapXML
  24.      * @param soapXML
  25.      * @return
  26.      */
  27.     public static WebserviceResultBean parseSoapMessage(String soapXML) {
  28.         WebserviceResultBean resultBean = new WebserviceResultBean();
  29.         try {
  30.             SOAPMessage msg = formatSoapString(soapXML);
  31.             SOAPBody body = msg.getSOAPBody();
  32.             Iterator<SOAPElement> iterator = body.getChildElements();
  33.             parse(iterator, resultBean);
  34.         } catch (Exception e) {
  35.             e.printStackTrace();
  36.         }
  37.         return resultBean;
  38.     }
  41.     public static void main(String[] args) {
  42.         String deptXML = "<SOAP-ENV:Envelope xmlns:SOAP-ENV=\"http://schemas.xmlsoap.org/soap/envelope/\">";
  43.         deptXML += "<SOAP-ENV:Body>";
  44.         deptXML += "<ns0:GetServiceTest xmlns:ns0=\"http://www.xxx.com/wsdl/test/v003\">";
  45.         deptXML += "<ns1:aa xmlns:ns1=\"http://www.xxx.com/wsdl/test/v003\">";
  46.         deptXML += "<ns1:bb/>";
  47.         deptXML += "<ns1:cc>123456</ns1:cc>";
  48.         deptXML += "<ns1:dd>999</ns1:dd>";
  49.         deptXML += " <ns1:ee>123</ns1:ee>";
  50.         deptXML += "  <ns1:ff>888</ns1:ff>";
  51.         deptXML += "   <ns1:gg>666</ns1:gg>";
  52.         deptXML += "  <ns1:hh>0108A</ns1:hh>";
  53.         deptXML += " </ns1:aa>";
  54.         deptXML += "</ns0:GetServiceTest>";
  55.         deptXML += "</SOAP-ENV:Body>";
  56.         deptXML += "</SOAP-ENV:Envelope>";
  58.         deptXML = "<?xml version=\"1.0\" encoding=\"utf-8\"?>";
  59.         deptXML += "<soap:Envelope xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\">";
  60.         deptXML += "<soap:Body>";
  61.         deptXML += "<PGetPoResponse xmlns=\"http://tempuri.org/\">";
  62.         deptXML += "<PGetPoResult>{\"code\":0,\"data\":[{\"PO_NUMBER\":\"POGO201702200016\",\"ORG_ID\":115.0,\"VENDOR_AREA\":\"境外\",\"VENDOR_NAME\":\"xx1有限公司\",\"CONTRACT_CODE\":\"T-044-PUR-20150602-01\",\"APPLY_NO\":\"PA-PL-201703230001\",\"CREATION_DATE\":\"\\/Date(1487575960000+0800)\\/\"},{\"PO_NUMBER\":\"POGO201702170002\",\"ORG_ID\":115.0,\"VENDOR_AREA\":\"境外\",\"VENDOR_NAME\":\"xx2有限公司\",\"CONTRACT_CODE\":\"T-044-PUR-20150723-03\",\"APPLY_NO\":\"PA-PL-201703220001\",\"CREATION_DATE\":\"\\/Date(1487294589000+0800)\\/\"}]}</PGetPoResult>\n";
  63.         deptXML += "</PGetPoResponse>";
  64.         deptXML += "</soap:Body>";
  65.         deptXML += "</soap:Envelope>";
  67.         //WebserviceResultBean ret = parseSoapMessage(deptXML);
  68.         try {
  69.             SOAPMessage msg = formatSoapString(deptXML);
  70.             SOAPBody body = msg.getSOAPBody();
  71.             Iterator<SOAPElement> iterator = body.getChildElements();
  72.             PrintBody(iterator, null);
  73.         } catch (Exception e) {
  74.             e.printStackTrace();
  75.         }
  76.     }
  79.     /**
  80.      * 把soap字符串格式化为SOAPMessage
  81.      *
  82.      * @param soapString
  83.      * @return
  84.      * @see [类、类#方法、类#成员]
  85.      */
  86.     public static SOAPMessage formatSoapString(String soapString) {
  87.         MessageFactory msgFactory;
  88.         try {
  89.             msgFactory = MessageFactory.newInstance();
  90.             SOAPMessage reqMsg = msgFactory.createMessage(new MimeHeaders(),
  91.                     new ByteArrayInputStream(soapString.getBytes("UTF-8")));
  92.             reqMsg.saveChanges();
  93.             return reqMsg;
  94.         } catch (Exception e) {
  95.             e.printStackTrace();
  96.             return null;
  97.         }
  98.     }
  101.     /**
  102.      * 解析soap xml
  103.      * @param iterator
  104.      * @param resultBean
  105.      */
  106.     private static void parse(Iterator<SOAPElement> iterator, WebserviceResultBean resultBean) {
  107.         while (iterator.hasNext()) {
  108.             SOAPElement element = iterator.next();
  109.             //ns
  110.             if ("PGetPo:BASEINFO".equals(element.getNodeName())) {
  111.                 continue;
  113.             } else if ("PGetPo:MESSAGE".equals(element.getNodeName())) {//ns
  114.                 Iterator<SOAPElement> it = element.getChildElements();
  115.                 SOAPElement el = null;
  116.                 while (it.hasNext()) {
  117.                     el = it.next();
  118.                     if ("RESULT".equals(el.getLocalName())) {
  119.                         resultBean.setResult(el.getValue());
  120.                         System.out.println("#### " + el.getLocalName() + "  ====  " + el.getValue());
  121.                     } else if ("REMARK".equals(el.getLocalName())) {
  122.                         resultBean.setRemark(null != el.getValue() ? el.getValue() : "");
  123.                         System.out.println("#### " + el.getLocalName() + "  ====  " + el.getValue());
  124.                     } else if ("XMLDATA".equals(el.getLocalName())) {
  125.                         resultBean.setXmlData(el.getValue());
  126.                         System.out.println("#### " + el.getLocalName() + "  ====  " + el.getValue());
  127.                     }
  128.                 }
  129.             } else if (null == element.getValue()
  130.                     && element.getChildElements().hasNext()) {
  131.                 parse(element.getChildElements(), resultBean);
  132.             }
  133.         }
  134.     }
  137.     public static void PrintBody(Iterator<SOAPElement> iterator, String side) {
  138.         PGetPoResult result =new PGetPoResult();
  139.         while (iterator.hasNext()) {
  140.             Object o=iterator.next();
  141.             if(o!=null)  {
  142.                 SOAPElement element=null;
  143.                 try{
  144.                     element = (SOAPElement) o;
  145.                     System.out.println("Node Name:" + element.getNodeName());
  146.                     System.out.println("Value:" + element.getValue());
  148.                     if(element.getNodeName().equals("PGetPoResult")){
  149.                        String nodeValue = element.getValue();
  150.                         result =  JSON.parseObject(nodeValue, PGetPoResult.class);
  151.                         System.out.println(result.getCode());
  152.                         System.out.println(result.getData().get(0).getAPPLY_NO());
  153.                         //return result;
  154.                     }
  155.                 }catch(Exception e){}
  156.                 if ( element !=null ) {
  157.                     PrintBody(element.getChildElements(), side + "-----");
  158.                 }
  159.             }
  160.         }
  162.        //return result;
  163.     }
  164. }

解析类-PGetPoResult

  1. package com.foreign.payment.common.data;
  3. import lombok.Data;
  5. import java.util.Date;
  6. import java.util.List;
  8. /**
  9.  * 实物进口供应商解析类
  10.  *
  11.  * @author: v_hwhao
  12.  * @date: 2020-02-11 12:21
  13.  */
  14. @Data
  15. public class PGetPoResult {
  16.     String code;
  18.     List<PGetPoItem> data;
  20.     @Data
  21.     public class PGetPoItem{
  22.         /**
  23.          * EPO 订单号
  24.          */
  25.         String PO_NUMBER;
  27.         /**
  28.          * 我方主体ID
  29.          */
  30.         String ORG_ID;
  32.         /**
  33.          * 供应商区域
  34.          */
  35.         String VENDOR_AREA;
  37.         /**
  38.          * 供应商名称
  39.          */
  40.         String VENDOR_NAME;
  42.         /**
  43.          * 合同号
  44.          */
  45.         String CONTRACT_CODE;
  47.         /**
  48.          * 付款单号
  49.          */
  50.         String APPLY_NO;
  52.         /**
  53.          * EPO 订单创建时间
  54.          */
  55.         Date CREATION_DATE;
  56.     }
  57. }

解析类-WebserviceResultBean

  1. package com.foreign.payment.common.data;
  3. public class WebserviceResultBean{
  5.     private String result;
  6.     private String xmlData;
  7.     private String remark;
  9.     public String getResult() {
  10.         return result;
  11.     }
  13.     public void setResult(String result) {
  14.         this.result = result;
  15.     }
  17.     public String getXmlData() {
  18.         return xmlData;
  19.     }
  21.     public void setXmlData(String xmlData) {
  22.         this.xmlData = xmlData;
  23.     }
  25.     public String getRemark() {
  26.         return remark;
  27.     }
  29.     public void setRemark(String remark) {
  30.         this.remark = remark;
  31.     }
  33. }

调用解析逻辑

  1. /**
  2.  * 调用接口获取实物进口供应商数据
  3.  * @return 实物进口供应商数据
  4.  */
  5. public PGetPoResult getSupplierPhysical(){
  6.     PGetPoResult result = new PGetPoResult();
  8.     //soap 请求参数
  9.     StringBuffer sb = new StringBuffer("");
  10.     sb.append("<?xml version=\"1.0\" encoding=\"utf-16\"?>");
  11.     sb.append("<soap:Envelope xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\">");
  12.     sb.append("<soap:Body>");
  13.     sb.append("<PGetPo xmlns=\"http://tempuri.org/\">");
  14.     sb.append("<startDate></startDate>");
  15.     sb.append("<endDate></endDate>");
  16.     sb.append("<appKey>"+config.getSupplierPhysicalAppId()+"</appKey>");
  17.     sb.append("</PGetPo>");
  18.     sb.append("</soap:Body>");
  19.     sb.append("</soap:Envelope>");
  21.     //header
  22.     Map<String,String> headers = new HashMap<>();
  23.     headers.put("SOAPAction","");
  24.     //headers.put("Content-Type","text/xml; charset=utf-8");
  26.     //调用接口获取 SOAP 数据
  27.     String resultStr = WebClientUtils.post(config.getSupplierPhysicalUrl(), headers,sb.toString(),"text/xml; charset=utf-8");
  28.     //result.setCode(resultStr);
  30.     try {
  31.         SOAPMessage msg = SoapUtil.formatSoapString(resultStr);
  32.         SOAPBody body = msg.getSOAPBody();
  33.         Iterator<SOAPElement> iterator = body.getChildElements();
  34.         result = getPGetPoResult(iterator,null);
  36.     } catch (Exception e) {
  37.         e.printStackTrace();
  38.     }
  40.     return result;
  41. }
  43. /**
  44.  * 解析 SOAP 数据为 PGetPoResult
  45.  * @param iterator Iterator<SOAPElement>
  46.  * @param side
  47.  * @return PGetPoResult
  48.  */
  49. public static PGetPoResult getPGetPoResult(Iterator<SOAPElement> iterator, String side) {
  50.     PGetPoResult result =new PGetPoResult();
  51.     while (iterator.hasNext()) {
  52.         Object o=iterator.next();
  53.         if(o!=null)  {
  54.             SOAPElement element=null;
  55.             try{
  56.                 element = (SOAPElement) o;
  57.                 System.out.println("Node Name:" + element.getNodeName());
  58.                 System.out.println("Value:" + element.getValue());
  60.                 if(element.getNodeName().equals("PGetPoResult")){
  61.                     String nodeValue = element.getValue();
  62.                     result =  JSON.parseObject(nodeValue, PGetPoResult.class);
  63.                     System.out.println(result.getCode());
  64.                     System.out.println(result.getData().get(0).getAPPLY_NO());
  65.                     break;
  66.                     //return result;
  67.                 }
  68.             }catch(Exception e){}
  69.             if ( element !=null ) {
  70.                 result = getPGetPoResult(element.getChildElements(), side + "-----");
  71.             }
  72.         }
  73.     }
  75.     return result;
  76. }

测试结果

调用方法 getSupplierPhysical()，返回结果为

  1. {
  2.     "code": "0",
  3.     "data": [
  4.         {
  5.             "apply_NO": "PA-PL-201703220001",
  6.             "po_NUMBER": "POGO201702170002",
  7.             "vendor_NAME": "xx1有限公司",
  8.             "creation_DATE": "2017-02-17T01:23:09.000+0000",
  9.             "contract_CODE": "T-044-PUR-20150723-03",
  10.             "org_ID": "115.0",
  11.             "vendor_AREA": "境外"
  12.         },
  13.         {
  14.             "apply_NO": "PA-PL-201703230001",
  15.             "po_NUMBER": "POGO201702200016",
  16.             "vendor_NAME": "xx2有限公司",
  17.             "creation_DATE": "2017-02-20T07:32:40.000+0000",
  18.             "contract_CODE": "T-044-PUR-20150602-01",
  19.             "org_ID": "115.0",
  20.             "vendor_AREA": "境外"
  21.         }
  22.     ]
  23. }