/*獲取通過WebService傳過來的xml，資料校驗通過解析後儲存到資料庫返回一個xml，資料校驗不通過也返回一個XML*/

import java.sql.Date;
import java.text.ParseException;
import java.text.SimpleDateFormat;

import javax.jws.WebMethod;
import javax.jws.WebResult;
import javax.jws.WebService;

import org.apache.commons.lang.StringUtils;
import org.dom4j.Document;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import com.*.user;
import com.*.util.api.DtoUtil;
import com.neusoft.agileggfw.webservice.internal.cc22.Cc22Service;
import com.neusoft.agileggfw.webservice.internal.xml.XMLBandingData;

/*
 * 這裡是通過SpringMVC 整合CXF方式釋出的介面； 
 * serviceName 為介面名；
 * uploadUserInfo 為實現方法
 * 
 * */

@Component
@WebService(serviceName = "/testJws", targetNamespace = "www.testJws.gov.cn")
public class JwsServiceImpl implements JwsService{
	
	
	@Autowired
	private user userdao;

	@Autowired
	private XMLBandingData xmlbandingdata;
	

	@WebMethod
	@WebResult(targetNamespace = "www.testJws.gov.cn")
	@Transactional
	@Override
	public String uploadUserInfo(String xmlInput) {
		//1.解析xmlInput
		UserDto dto =resolveXml(xmlInput);
		//2.校驗
		String errorMsg=checkIsNotNull(dto);
		User user=new User();
		//插入資料庫中的User表中，此處省略
		if(StringUtils.isBlank(errorMsg)){
			
			//DtoUtil是一個複製dto的工具類，此處省略，這一段程式碼主要是儲存解析及校驗後的XML到資料庫中
			DtoUtil.copyProperties(dto, user);
			userdao.save(user);
		}
		//4.返回XML
		return xmlbandingdata.bandingUser(errorMsg);
	}
		private String checkIsNotNull(UserDto dto) {
		String errorMsg="";
		
		if(StringUtils.isBlank(dto.getUsername())){
			errorMsg+="使用者名稱不能為空,";
		}
		if(StringUtils.isBlank(dto.getId())){
			errorMsg+="編號不能為空,";
		}
		
		
		return errorMsg;
	}

	private UserDto resolveXml(String xmlInput) {
		UserDto dto = new UserDto();
		try {
			Document document = DocumentHelper.parseText(xmlInput);
			Element root = document.getRootElement();
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy/MM/dd");
			Element USERNAME = root.element("username");//姓名
			if(USERNAME!=null){
				dto.setUsername(USERNAME.getText());
			}
			Element ID = root.element("id");//個人編號
			if(ID!=null){
				dto.setId(ID.getText());//
			}
			
			
			
		} catch (Exception e) {
			 e.printStackTrace();
		}
		return dto;
	}

}




/*介面類*/




import java.text.ParseException;

import javax.jws.WebMethod;
import javax.jws.WebResult;
import javax.jws.WebService;
import javax.xml.ws.BindingType;
import javax.xml.ws.soap.SOAPBinding;

/*@WebMethod(operationName = "uploadUserInfo") 為介面向外提供的呼叫方法*/

@WebService(targetNamespace = "www.testJws.gov.cn", name = "testJWS")
@BindingType(value = SOAPBinding.SOAP11HTTP_BINDING)
public interface JwsService {
	@WebResult(targetNamespace = "www.testJws.gov.cn", name = "testjavaWbs")
	@WebMethod(operationName = "uploadUserInfo")
	String uploadUserInfo(String xmlInput) throws ParseException; 
}





import org.springframework.stereotype.Repository;

import com.*.User;
import com.*.PlatformDao;

import java.io.IOException;
import java.io.InputStream;
import java.io.Serializable;
import java.lang.reflect.Field;
import java.lang.reflect.Modifier;
import java.sql.Blob;
import java.sql.Clob;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;

import javax.annotation.Resource;
import javax.sql.DataSource;

import org.hibernate.Criteria;
import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.SQLQuery;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.criterion.CriteriaSpecification;
import org.hibernate.criterion.Projection;
import org.hibernate.criterion.Projections;
import org.hibernate.criterion.Restrictions;
import org.hibernate.internal.CriteriaImpl;
import org.hibernate.internal.SessionImpl;
import org.hibernate.transform.ResultTransformer;
import org.hibernate.transform.Transformers;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.ConnectionCallback;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.util.Assert;
import org.springframework.web.multipart.MultipartFile;

public abstract class PlatformDao<T>{

	@Resource(name = "sessionFactory")
	private SessionFactory sessionFactory;

	@Resource(name = "dataSource")
	private DataSource dataSource;

	protected abstract Class<T> getEntityClass();
	
}




public class Cc22Dto{
	
	
	private String username;
	private String id;
	
	public String getUsername() {
		return username;
	}
	public void setUsername(String username) {
		this.username = username;
	}
	
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
}


/*
 * 對應的實體和hebinate對映此處省略
 * User.java
user.hbm.xml
等*/

/*以上通過SpringMVC與cxf整合後釋出，此處略，這裡是在本地tomcat中釋出的*/



/*客戶端呼叫以上介面
 * 這裡也是用SpringMVC的方式呼叫，其他方式略
 * */





import java.text.ParseException;

import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;

import com.*。JwsService;



public class TestClient {
	
	public static void main(String[] args) {
		JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
		factory.setServiceClass(JwsService.class);
		factory.setAddress("http://localhost:8080/services/testJWS?wsdl");
		JwsService client = (JwsService) factory.create();
		String inputXml="<?xml version='1.0' encoding='UTF-8'?>"+
		   "<row>"+
		     "<getType>testJWS</getType>"+
             "<username>username</username>"+
             "<id>8888</id>"+                
		   "</row>";	
	
		try {
			client.uploadUserInfo(inputXml);
		} catch (ParseException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}
	
}




 

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.StringWriter;
import java.lang.reflect.Field;
import java.lang.reflect.InvocationTargetException;
import java.sql.Blob;
import java.sql.Date;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.List;

import org.apache.commons.beanutils.PropertyUtils;
import org.apache.commons.lang.StringUtils;
import org.dom4j.Document;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
import org.dom4j.io.OutputFormat;
import org.dom4j.io.XMLWriter;
import org.springframework.stereotype.Service;


@Service
public class XMLBandingData {

	public String bandingUser(String errorMsg) {
		Document document = DocumentHelper.createDocument();
		Element results = document.addElement("results");
		Element WEBNAME = results.addElement("WEBNAME");  //介面名稱
		WEBNAME.addText("testJWS");       
		Element lastTime = results.addElement("lastTime");  //返回時間
		lastTime.addText(DateUtil.getDate().toString());
		Element state = results.addElement("state");    //狀態:1--成功    0--失敗
		if(StringUtils.isBlank(errorMsg)){
			state.addText("1");
		}else{
			state.addText("0");
		}
		Element errorMsg1 = results.addElement("errorMsg");   //錯誤資訊
		errorMsg1.addText(errorMsg);
		StringWriter sw = new StringWriter();
		OutputFormat format = OutputFormat.createPrettyPrint();
		XMLWriter writer = new XMLWriter(sw, format);
		try {
			writer.write(document);
		} catch (IOException e) {
			e.printStackTrace();
		}
		return sw.toString();
	}
}
 

<!--  入參 -->
<?xml version="1.0" encoding="UTF-8"?>
<row>	         
<getType>testJWS</getType>						//介面名稱
		<username>username</username> 					
	    	<id>8888</id>     	//
		  	
		……
		……       
	</row>

<!--出參 -->

<?xml version="1.0" encoding="UTF-8"?>
<results>
  <webName> testJWS</webName >								//介面名稱
  <lastUpdate>2015-04-09 17:23:59</lastUpdate>		//返回時間
  <state>1</state>  //狀態
  <errorMsg></errorMsg>									//錯誤資訊
</results>
 

以上主要描述釋出介面對接收到的XML處理方法及返回xml.