import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileWriter;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.StringReader;

import java.io.StringWriter;

import org.dom4j.Document;

import org.dom4j.DocumentException;

import org.dom4j.DocumentHelper;

import org.dom4j.Element;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;public classXmlUtil {private final static Logger logger = LoggerFactory.getLogger(MsBusUtil.class);public final static String msBus_xmlns = "http://MSBUSPlatform/v2.0";/**

* Add RequestHead to Request, Invoke, and remove ResponseHead from Response

*

* @param strRequestParam String

* @param strSvcName String

* @param strSvcMethod String

* @return String

* @throws GeneralException*/

public staticString invokeParam(String strRequestParam, String strSvcID, String keyword) throws DocumentException {

Document doc=DocumentHelper.createDocument();

Element elmRoot= doc.addElement("ServiceInvoke", MsBusUtil.msBus_xmlns);

Element elmHead= elmRoot.addElement("RequestHead");

elmHead.addElement("Requestid").addText(getRequestID(strSvcID));

elmHead.addElement("Requesttime").addText(DateUtil.getNowStr());

elmHead.addElement("Sourcesystemid").addText("");elmRoot.addElement("Serviceid").addText(strSvcID);elmParam.addCDATA(strRequestParam);

elmRoot.addElement("Keyword").addText(keyword);

String strRequest= StringTranslator.toString(doc, "UTF-8");

logger.info("invoke Request:" +strRequest);returnstrRequest;

}public staticString getRequestID(String strSvcID) throws DocumentException {

RandomGUID randomGUID= newRandomGUID();return strSvcID + "-" +randomGUID.toString();

}public static voidmain(String[] args) throws Throwable {

UnifiedContentDefineType ucd= newUnifiedContentDefineType();

ucd.setHead(newHeadType());

String param= JaxbUtil.convertToXml(ucd, "utf-8");

String req = invokeParam(param, "PLATFORM-UnifiedImport", "测试一下");

string2File(req,"F:\\归档.xml");

};/**

* 文本文件转换为指定编码的字符串

*

* @param file 文本文件

* @param encoding 编码类型

* @return 转换后的字符串

* @throws IOException*/

public staticString file2String(File file, String encoding) {

InputStreamReader reader= null;

StringWriter writer= newStringWriter();try{if (encoding == null || "".equals(encoding.trim())) {

reader= new InputStreamReader(newFileInputStream(file), encoding);

}else{

reader= new InputStreamReader(newFileInputStream(file));

}//将输入流写入输出流

char[] buffer = new char[1024];int n = 0;while (-1 != (n =reader.read(buffer))) {

writer.write(buffer,0, n);

}

}catch(Exception e) {

e.printStackTrace();return null;

}finally{if (reader != null)try{

reader.close();

}catch(IOException e) {

e.printStackTrace();

}

}returnwriter.toString();

}/**

* 将字符串写入指定文件(当指定的父路径中文件夹不存在时，会最大限度去创建，以保证保存成功！)

*

* @param res 原字符串

* @param filePath 文件路径

* @return 成功标记*/

public staticboolean string2File(String res, String filePath) {

boolean flag= true;

BufferedReader bufferedReader= null;

BufferedWriter bufferedWriter= null;try{

File distFile= newFile(filePath);if (!distFile.getParentFile().exists()) distFile.getParentFile().mkdirs();

bufferedReader= new BufferedReader(newStringReader(res));

bufferedWriter= new BufferedWriter(newFileWriter(distFile));char buf[] = new char[1024]; //字符缓冲区

intlen;while ((len = bufferedReader.read(buf)) != -1) {

bufferedWriter.write(buf,0, len);

}

bufferedWriter.flush();

bufferedReader.close();

bufferedWriter.close();

}catch(IOException e) {

e.printStackTrace();

flag= false;returnflag;

}finally{if (bufferedReader != null) {try{

bufferedReader.close();

}catch(IOException e) {

e.printStackTrace();

}

}

}returnflag;

}

}