subscribeservicereqbean.java

对于cmpp3.0 开发有一定的帮助,请大家下载下来进行研究.

package com.zhanghao.provision;

import javax.xml.soap.*;
import java.util.Iterator;

import java.io.ByteArrayOutputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;

import com.zhanghao.common.util.Base64;

public class SubscribeServiceReqBean {

  public String TransactionID;

  public String Version;

  public SchemaOfAddress Send_Address = new SchemaOfAddress();

  public SchemaOfAddress Dest_Address = new SchemaOfAddress();

  public SchemaOfUserID FeeUser_ID  = new SchemaOfUserID();

  public SchemaOfUserID DestUser_ID = new SchemaOfUserID();

  public String LinkID;

  public int ActionID;

  public int ActionReasonID;

  public String SPID;

  public String SPServiceID;

  public int AccessMode;

  public String FeatureStr; //=Base64(SPNumber + MsgContent)

  public String SPNumber;
  public String MsgContent;

  public SOAPMessage soapMessage;

  public SubscribeServiceReqBean() {
  }


  public SubscribeServiceReqBean(java.io.InputStream inputStream ) throws Exception{
    try{
      javax.xml.soap.MessageFactory messageFactory =
          MessageFactory.newInstance();

      soapMessage = messageFactory.createMessage();

      javax.xml.soap.SOAPPart soapPart = soapMessage.getSOAPPart();
      javax.xml.soap.SOAPEnvelope soapEnvelop = soapPart.getEnvelope();
      javax.xml.soap.SOAPBody soapBody = soapEnvelop.getBody();

      javax.xml.transform.stream.StreamSource
          streamSource = new javax.xml.transform.stream.StreamSource(inputStream);
      soapPart.setContent(streamSource);

      soapMessage.saveChanges();



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


  private static int transactionID = 10;
  public String getTransactionId(){
    if (transactionID + 10 >= 9999999999l) transactionID = 10;
    transactionID = transactionID + 10;
    return String.valueOf(transactionID);
  }


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

      this.soapMessage.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.soapMessage.writeTo(dataOutStream);
      return byteArrayOutStream.toByteArray();
    }
    catch(Exception ex){
      return null;
    }
  }

}