responsehandler.java

采用JAVA开发

package com.gctech.misc.provision.handler;

import java.sql.Connection;

import javax.xml.soap.MessageFactory;
import javax.xml.soap.Name;
import javax.xml.soap.SOAPBody;
import javax.xml.soap.SOAPBodyElement;
import javax.xml.soap.SOAPElement;
import javax.xml.soap.SOAPEnvelope;
import javax.xml.soap.SOAPHeader;
import javax.xml.soap.SOAPHeaderElement;
import javax.xml.soap.SOAPMessage;

import com.gctech.misc.provision.dao.CyncresprecordDAO;
import com.gctech.misc.util.Base64Util;

/**
 * <p>Title:</p>
 * <p>Description:</p>
 * <p>Copyright: Copyright (c) Gctech 2004-7-30</p>
 * <p>Company: 吉芙德资讯有限公司</p>
 *
 * @version 1.0
 * @author liyi
 *
 */

public class ResponseHandler {
	public SOAPMessage handle(Connection conn, String TransactionID,ExchangeData exchangeData) throws Exception {
		try {

			CyncresprecordDAO dao = new CyncresprecordDAO();
			dao.setConnection(conn);
			Base64Util base64util = new Base64Util();
			
			MessageFactory mesFactory = MessageFactory.newInstance();
			SOAPMessage resMessage = mesFactory.createMessage();
			SOAPEnvelope resEnv = resMessage.getSOAPPart().getEnvelope();

			SOAPHeader resHeader = resEnv.getHeader();
			Name headerName = resEnv.createName("TransactionID", "dsmp", "http://www.monternet.com/dsmp/schemas/");
			SOAPHeaderElement headerElement = resHeader.addHeaderElement(headerName);
			headerElement.addTextNode(TransactionID);
			dao.setTransactionid(TransactionID);

			SOAPBody resBody = resEnv.getBody();
			Name SyncOrderRelationResp = resEnv.createName("SyncOrderRelationResp", "", "http://www.monternet.com/dsmp/schemas/");
			SOAPBodyElement pbodyElement = resBody.addBodyElement(SyncOrderRelationResp);

			Name pVersion = resEnv.createName("Version");
			SOAPElement VersionElement = pbodyElement.addChildElement(pVersion);
			VersionElement.addTextNode("1.5.0");
			dao.setVersion("1.5.0");

			Name pMsgType = resEnv.createName("MsgType");
			SOAPElement MsgTypeElement = pbodyElement.addChildElement(pMsgType);
			MsgTypeElement.addTextNode("SyncOrderRelationResp");
			dao.setMsgtype("SyncOrderRelationResp");

			Name phRet = resEnv.createName("hRet");
			SOAPElement hRetElement = pbodyElement.addChildElement(phRet);
			hRetElement.addTextNode("0");
			dao.setHret("0");

			Name pFeeCode = resEnv.createName("FeeCode");
			SOAPElement FeeCodeElement = pbodyElement.addChildElement(pFeeCode);
			FeeCodeElement.addTextNode("0");
			dao.setFeeCode("0");

			Name pFeeMSISDN = resEnv.createName("FeeMSISDN");
			SOAPElement FeeMSISDNElement = pbodyElement.addChildElement(pFeeMSISDN);
			FeeMSISDNElement.addTextNode(exchangeData.getFeeMSISDN());
			dao.setFeeMsisdn(exchangeData.getFeeMSISDN());

			Name pFeePseudoCode = resEnv.createName("FeePseudoCode");
			SOAPElement FeePseudoCodeElement = pbodyElement.addChildElement(pFeePseudoCode);
			FeePseudoCodeElement.addTextNode(exchangeData.getFeePseudoCode());
			dao.setFeePseudocode(exchangeData.getFeePseudoCode());

			Name pDestMSISDN = resEnv.createName("DestMSISDN");
			SOAPElement DestMSISDNElement = pbodyElement.addChildElement(pDestMSISDN);
			DestMSISDNElement.addTextNode(exchangeData.getDestMSISDN());
			dao.setDestMsisdn(exchangeData.getDestMSISDN());

			Name pDestPseudoCode = resEnv.createName("DestPseudoCode");
			SOAPElement DestPseudoCodeElement = pbodyElement.addChildElement(pDestPseudoCode);
			DestPseudoCodeElement.addTextNode(exchangeData.getDestPseudoCode());
			dao.setDestPseudocode(exchangeData.getDestPseudoCode());

			Name pSendSPUserIDType = resEnv.createName("SendSPUserIDType");
			SOAPElement SendSPUserIDTypeElement = pbodyElement.addChildElement(pSendSPUserIDType);
			SendSPUserIDTypeElement.addTextNode("integer");
			dao.setSendspuserType("integer");

			Name pOperType = resEnv.createName("OperType");
			SOAPElement OperTypeElement = pbodyElement.addChildElement(pOperType);
			OperTypeElement.addTextNode(exchangeData.getActionID());
			dao.setOperType(exchangeData.getActionID());

			Name pLinkID = resEnv.createName("LinkID");
			SOAPElement LinkIDElement = pbodyElement.addChildElement(pLinkID);
			LinkIDElement.addTextNode(exchangeData.getLinkID());
			dao.setLinkid(exchangeData.getLinkID());

			Name pUserType = resEnv.createName("UserType");
			SOAPElement UserTypeElement = pbodyElement.addChildElement(pUserType);
			UserTypeElement.addTextNode("string");
			dao.setUserType("string");

			Name pSPID = resEnv.createName("SPID");
			SOAPElement SPIDElement = pbodyElement.addChildElement(pSPID);
			SPIDElement.addTextNode("900209");
			dao.setSpid("900209");

			Name pSPServiceID = resEnv.createName("SPServiceID");
			SOAPElement SPServiceIDElement = pbodyElement.addChildElement(pSPServiceID);
			SPServiceIDElement.addTextNode(exchangeData.getSPServiceID());
			dao.setSpserviceId(exchangeData.getSPServiceID());

			Name pConnectDeviceID = resEnv.createName("ConnectDeviceID");
			SOAPElement ConnectDeviceIDElement = pbodyElement.addChildElement(pConnectDeviceID);
			ConnectDeviceIDElement.addTextNode("string");
			dao.setConnectDeviceid("string");
			dao.setGenerateTime(new Long(System.currentTimeMillis()));
			dao.create();
			return resMessage;
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		}
	}
}