syncorderrelationrespbean.java

cmpp的开发的短信端口实例

package com.zhanghao.provision;


import javax.xml.soap.*;
import java.util.Iterator;
import java.io.ByteArrayOutputStream;
import java.io.DataOutputStream;

public class SyncOrderRelationRespBean {

  public String TransactionID = "00000000000";

  public String Version = "1.5.0";

  private String MsgType = "SyncOrderRelationResp";

  public int hRet = 0;

  public SOAPMessage respXML;

  public SyncOrderRelationRespBean() {
  }

  public SyncOrderRelationRespBean(SyncOrderRelationReqBean syncReqBean) throws Exception {
    try{

      SOAPElement soapElement;
      MessageFactory messageFactory = MessageFactory.newInstance();
      SOAPMessage soapMessage = messageFactory.createMessage();
      SOAPPart soapPart = soapMessage.getSOAPPart();
      SOAPEnvelope soapEnv = soapPart.getEnvelope();
      SOAPBody soapBody = soapEnv.getBody();


      if(syncReqBean!=null){

        soapElement = soapEnv.getHeader().addHeaderElement(
            soapEnv.createName("TransactionID","","http://www.monternet.com/dsmp/schemas/"));
        System.out.println("syncReqBean.TransactionID = " + syncReqBean.TransactionID);
        soapElement.addTextNode(syncReqBean.TransactionID==null?"":syncReqBean.TransactionID);

        SOAPBodyElement bodyElement = soapBody.addBodyElement(
            soapEnv.createName("SyncOrderRelationResp","","http://www.monternet.com/dsmp/schemas/"));

        bodyElement.addChildElement("Version").addTextNode(syncReqBean.Version);
        bodyElement.addChildElement("MsgType").addTextNode(MsgType);
        bodyElement.addChildElement("hRet").addTextNode(String.valueOf(hRet));

      }
      else{

        soapElement = soapEnv.getHeader().addHeaderElement(
            soapEnv.createName("TransactionID","","http://www.monternet.com/dsmp/schemas/"));
        System.out.println("syncReqBean.TransactionID = " + this.TransactionID);
        soapElement.addTextNode(this.TransactionID);

        SOAPBodyElement bodyElement = soapBody.addBodyElement(
            soapEnv.createName("SyncOrderRelationResp","","http://www.monternet.com/dsmp/schemas/"));

        bodyElement.addChildElement("Version").addTextNode(this.Version);
        bodyElement.addChildElement("MsgType").addTextNode(this.MsgType);
        bodyElement.addChildElement("hRet").addTextNode(String.valueOf(4000));


      }

      soapMessage.saveChanges();
      this.respXML = soapMessage;


    }
    catch(Exception ex){
      throw ex;
    }
  }


  public int getMsgLength(){
    try{
      ByteArrayOutputStream byteArrayOutStream = new ByteArrayOutputStream();
      DataOutputStream dataOutStream = new DataOutputStream(byteArrayOutStream);

      this.respXML.writeTo(dataOutStream);
      return byteArrayOutStream.toByteArray().length;
    }
    catch(Exception ex){
      return 0;
    }
  }

  public byte[] getBytes(){
    try{
      ByteArrayOutputStream byteArrayOutStream = new ByteArrayOutputStream();
      DataOutputStream dataOutStream = new DataOutputStream(byteArrayOutStream);

      this.respXML.writeTo(dataOutStream);
      return byteArrayOutStream.toByteArray();
    }
    catch(Exception ex){
      return null;
    }
  }


}