数据传输格式报文格式：xmlpublic CisReportRoot queryCisReport(PyQueryBean pyQueryBean) throwsException {

CisReportRoot cisReportRoot=invokePy(pyQueryBean){

CisReportRoot cisReportRoot=queryCisReportFromPyServer(pyQueryBean); 　　} }

pyQueryBean--CisReportRoot

注意：接口数据传输通过xml，无论发送请求，还是获取响应都需要经过经过xml格式转化。1,CisReportRoot cisReportRoot = getCisReportRoot(doc); pyQueryBean--Map--doc--xmL

//实体转化为Map

2,Map map = CommonUtils.beanToMap(pyQueryBean);

//Map转化为指定标签的xml字符串 Map-doc-xml

3,String queryInfo = XmlUtil.createQueryCondition(map);

//从鹏元获取Xml,转化为doc xml-doc-

4,Document doc =pyClient.connectToPyClient(queryInfo);

//解析doc中数据，赋值到实体

5,CisReportRoot cisReportRoot = getCisReportRoot(doc);

具体实现如下：2,public static MapbeanToMap(Object obj) {if (obj == null) {return null;

}

Map map = new HashMap<>();try{

BeanInfo beanInfo=Introspector.getBeanInfo(obj.getClass());

PropertyDescriptor[] propertyDescriptors=beanInfo.getPropertyDescriptors();for(PropertyDescriptor property : propertyDescriptors) {

String key=property.getName();//过滤class属性

if (!"class".equals(key)) {//得到property对应的getter方法

Method getter =property.getReadMethod();

Object value=getter.invoke(obj);

map.put(key, String.valueOf(value));

}

}

}catch(Exception e) {

System.out.println("transBean2Map@CommonUtils_Exception" +e);

}returnmap;

}3, 构建请求xmlpublic static String createQueryCondition(Map map) throwsException {

Document document=DocumentHelper.createDocument();

document.setXMLEncoding(ENCODING);

Element root= document.addElement("conditions");

Element conditionElement= root.addElement("condition");

conditionElement.addAttribute("queryType", map.get("queryType"));

Element itemName= conditionElement.addElement("item");

itemName.addElement("name").addText("name");

itemName.addElement("value").addText(map.get("name") == null ? "" : map.get("name"));

Element itemDocumentNo= conditionElement.addElement("item");

itemDocumentNo.addElement("name").addText("documentNo");

itemDocumentNo.addElement("value").addText(map.get("documentNo") == null ? "" : map.get("documentNo"));

Element itemPhone= conditionElement.addElement("item");

itemPhone.addElement("name").addText("phone");

itemPhone.addElement("value").addText(map.get("phone") == null ? "" : map.get("phone"));

Element itemQueryReasonID= conditionElement.addElement("item");

itemQueryReasonID.addElement("name").addText("queryReasonID");

itemQueryReasonID.addElement("value").addText(map.get("queryReasonID") == null ? "" : map.get("queryReasonID"));

Element itemSubreportIDs= conditionElement.addElement("item");

itemSubreportIDs.addElement("name").addText("subreportIDs");

itemSubreportIDs.addElement("value").addText(map.get("subreportIDs") == null ? "" : map.get("subreportIDs"));

Element itemRefID= conditionElement.addElement("item");

itemRefID.addElement("name").addText("refID");

itemRefID.addElement("value").addText(map.get("refID") == null ? "" : map.get("refID"));returndocument.asXML();

}4,获取鹏飞响应Xml/*** 连接到鹏飞服务端

*

*@paramqueryInfo 查询信息--Xml格式

*@return返回查询结果*/

public Document connectToPyClient(String queryInfo) throwsException {try{

Client client= new Client(newURL(configInfo.getPy_ssl_ip()));

Object[] results= client.invoke(QUERY_REPORT, new Object[]{configInfo.getPy_username(), configInfo.getPy_password(), queryInfo, "xml"});

Document dom4j;if (results[FIRST_NODE] instanceoforg.w3c.dom.Document) {//FIRST_NODE = 0

org.w3c.dom.Document doc =(org.w3c.dom.Document) results[FIRST_NODE];

org.w3c.dom.Element element=doc.getDocumentElement();//获取所有子节点

NodeList children =element.getChildNodes();//获取第一个子节点//xml to dom

dom4j =XmlUtil.getDoc(children.item(FIRST_NODE).getNodeValue());//获取根节点

Element root =dom4j.getRootElement();

Element statusElement=root.element(STATUS);

String ba64;if(statusElement.getData().equals(SUCCESS)) {/*客户端获取该returnValue值后需要依次做以下工作：

1、 把returnValue值用Base64解码，把字符串(string)转成字节流(byte[])；

2、 把字节流解压缩后，获取到相应的多个输出文件，其中html和pdf是压缩文件；

3、 解析reports.xml获取xml报告的详细内容；*/

//1、 把returnValue值用Base64解码，把字符串(string)转成字节流(byte[])；

ba64 =root.element(RETURN_VALUE).getData().toString();byte[] re =Base64Utils.decode(ba64);//2、 把字节流解压缩后，获取到相应的多个输出文件，其中html和pdf是压缩文件；

String xml =CompressStringUtil.decompress(re);

logger.info(xml);//3、 解析reports.xml获取xml报告的详细内容；

returnXmlUtil.getDoc(xml);

}else{

StringBuilder sb= newStringBuilder(PyCreditServiceErrorEnum.PY_SYS_ERROR.getMsg());

String xml=XmlUtil.getString(dom4j);

logger.error(xml);if (null != root.element("errorMessage")) {

sb.append(", ").append(root.element("errorMessage").getData().toString());

logger.error("py server has problem, errorMessage: " +sb.toString());

}throw newCreditException(PyCreditServiceErrorEnum.PY_SYS_ERROR.getCode(), sb.toString());

}

}return null;

}catch(SocketTimeoutException e) {

logger.error("level0_loadClient@PyClientService_Exception", e);throw newCreditException(PyCreditServiceErrorEnum.PY_SYS_TIMEOUT.getCode(), PyCreditServiceErrorEnum.PY_SYS_TIMEOUT.getMsg());

}catch(Exception e) {

logger.error("level0_connectToPyClient@ConnectToPyClient_Exception", e);throwe;

}

}5，解析xml报告中数据

CisReportRoot cisReportRoot = getCisReportRoot(doc);

总括：解析doc每一层节点,获取属性，当前子节点数据，以此类推分层解析。思路：属性，子节点List-map-通过反射给实体赋值