soapdecoder.java

彩信发送源代码,实现mm7接口

/**
 * File Name:SOAPDecoder.java Company: 中国移动集团公司 Date : 2004-2-12
 */

package com.cmcc.mm7.vasp.common;

/**
 * modified by liuhuafeng on 2006/7/26 
 * 1：日志由Log4j产生
 * 2:隐藏掉222，251，261行
 */

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.OutputStream;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;

import org.apache.log4j.Logger;
import org.jdom.Document;
import org.jdom.Element;
import org.jdom.JDOMException;
import org.jdom.input.SAXBuilder;

import sun.misc.BASE64Decoder;

import com.cmcc.mm7.vasp.message.MM7DeliverReq;
import com.cmcc.mm7.vasp.message.MM7DeliveryReportReq;
import com.cmcc.mm7.vasp.message.MM7RSReq;
import com.cmcc.mm7.vasp.message.MM7ReadReplyReq;

public class SOAPDecoder {
	private static final Logger log = Logger.getLogger(SOAPDecoder.class);

	private MM7RSReq mm7rsReq;

	private boolean bDecoder;

	private boolean bMessageExist;

	private OutputStream OutputMessage;

	private String MessageName;

	private String strEnvelope;

	private ByteArrayOutputStream SoapStream;

	/** 默认构造方法 */
	public SOAPDecoder() {
		reset();
	}

	public void reset() {
		bDecoder = false;
		bMessageExist = false;
		OutputMessage = null;
		MessageName = "";
		mm7rsReq = new MM7RSReq();
		strEnvelope = "";
		SoapStream = new ByteArrayOutputStream();
	}

	private void setEnvelope(String env) {
		strEnvelope = env;
	}

	public String getEnvelope() {
		return strEnvelope;
	}

	private void setSoapStream(ByteArrayOutputStream soapstream) {
		SoapStream = soapstream;
	}

	public ByteArrayOutputStream getSoapStream() {
		return SoapStream;
	}

	/** 传入的是OutputStream */
	public void setMessage(OutputStream output) {
		OutputMessage = output;
		bMessageExist = true;
	}

	/** 得到封装好的MM7RSReq消息 */
	public MM7RSReq getMessage() {
		if (bDecoder)
			return mm7rsReq;
		else
			return null;
	}

	public String getMessageName() {
		return MessageName;
	}

	/** 进行消息的解码 */
	public void decodeMessage() throws SOAPDecodeException {
		if (!bMessageExist)
			throw new SOAPDecodeException("No Multimedia Messages get in the decoder!");
		try {
			if (OutputMessage == null) {
				bDecoder = false;
			}
			else {
				ByteArrayOutputStream baos = (ByteArrayOutputStream) OutputMessage;
		
				
				ByteArrayOutputStream attachbaos = new ByteArrayOutputStream();
				// 得到整个输出流
				String message = baos.toString();
		
				if (message.indexOf("encoding=\"UTF-8\"") > 0) {
					byte byteXml[] = baos.toByteArray();
					message = new String(byteXml, "UTF-8");
				}
				else if (message.indexOf("encoding=\"GB2312\"") > 0) {
					byte byteXml[] = baos.toByteArray();
					message = new String(byteXml, "GB2312");
				}
				int xmlbeg = message.indexOf(MMConstants.BEGINXMLFLAG);
				// 得到SOAP消息的Envelope部分
				// add by hudm 2004-03-21
				int index1 = message.indexOf(MMConstants.BOUNDARY);
				String strboundary = "";
				String xmlContent = "";
				int index2 = 0, index3 = 0, xmlend = 0;
				if (index1 > 0) {
					index2 = message.indexOf("\"", index1 + 1);
					index3 = message.indexOf("\"", index2 + 1);
					strboundary = message.substring(index2 + 1, index3);
					xmlend = message.indexOf("--" + strboundary, xmlbeg + 1);
					if (xmlend > 0)
						xmlContent = message.substring(xmlbeg, xmlend);
				}
				else
					xmlContent = message.substring(xmlbeg);
				setEnvelope(xmlContent);
				ByteArrayOutputStream bb = new ByteArrayOutputStream();
				bb.write(baos.toByteArray(), xmlbeg, (baos.size() - xmlbeg));
				setSoapStream(bb);
				// 解析SOAPEnvelope部分，并返回MM7RSReq消息
				MM7RSReq req = new MM7RSReq();
				req = parseXML(xmlContent);
				if (req != null) {
					attachbaos.write(baos.toByteArray(), xmlend, (baos.size() - xmlend));
					
				
					
					/**
					 * 若返回的消息类型为MM7DeliverReq，则进行附件的解析， 返回MM7DeliverReq类型的消息
					 */
					if (req instanceof MM7DeliverReq) {
						MM7DeliverReq deliverReq = (MM7DeliverReq) req;
						req = parseAttachment(attachbaos, deliverReq);
					}
					bDecoder = true;
				}
				else {
					bDecoder = false;
				}
			}
		}
		catch (Exception e) {
			// System.err.println(e);
			log.error("SOAPDecoder.decodeMessage():" + e);
		}
	}

	private MM7DeliverReq parseAttachment(ByteArrayOutputStream content, MM7DeliverReq deliverReq) {

		MMContent deliverContent = new MMContent();
		// add by hudm 2004-03-21
		String boundary = "";
		int bound_index1 = content.toString().indexOf(MMConstants.BOUNDARY);
		if (bound_index1 > 0) {
			int bound_index2 = bound_index1 + MMConstants.BOUNDARY.length();
			char c = content.toString().charAt(bound_index2 + 1);
			if (c == '"')
				bound_index2++;
			int bound_index3 = bound_index2;
			while (1 == 1) {
				c = content.toString().charAt(bound_index3);
				if (c == ';' || c == '\r' || c == '\n')
					break;
				bound_index3++;
			}
			c = content.toString().charAt(bound_index3 - 1);
			if (c == '"')
				bound_index3--;
			boundary = content.toString().substring(bound_index2 + 1, bound_index3);
		}
		// end add by hudm 2004-03-21
		int length = boundary.length() + 2;
		List bound = new ArrayList();
		// 得到所有边界部分的index
		byte[] bContent = content.toByteArray();
		int index = 0;
		byte[] bBoundary = ("--" + boundary).getBytes();
		int m = 0;
		for (int i = 0; i < bContent.length; i++) {
			if (bContent[i] == bBoundary[m] && m < bBoundary.length) {
				if (m == bBoundary.length - 1) {
					index = i - bBoundary.length + 1;
					bound.add(Integer.toString(index));
					m = 0;
					continue;
				}
				index = i;
				m++;
				continue;
			}
			else {
				m = 0;
				continue;
			}
		}
		for (int j = 1; j < bound.size(); j++) {
			MMContent subContent = new MMContent();
			int bound1 = Integer.parseInt((String) bound.get(j - 1));
			int bound2 = Integer.parseInt((String) bound.get(j));
			ByteArrayOutputStream attachment = new ByteArrayOutputStream();

			attachment.write(content.toByteArray(), bound1 + length, (bound2 - (bound1 + length)));
			int type_index = attachment.toString().toLowerCase().indexOf(MMConstants.CONTENT_TYPE);
//			int attach_index = 0;
			// 若存在ContentType，则取得值并进行赋值
			if (type_index > 0) {
				// 得到附件的具体内容，并进行赋值
				int attindex = attachment.toString().indexOf("\r\n\r\n");
				if (attindex > 0) {
					ByteArrayOutputStream att = new ByteArrayOutputStream();
					// add by hudm 2004-04-01
					// 修改目的：判断内容是否进行了base64编码，若是则先进行base64解码
					String strEncoding = "Content-Transfer-Encoding";
					int encodingindex = attachment.toString().indexOf(strEncoding);
					if (encodingindex >= 0) {
						int endEncoding = attachment.toString().indexOf("\r\n", encodingindex + 1);
						String EncodingType = attachment.toString().substring(encodingindex + strEncoding.length() + 1,
								endEncoding).trim();
						if (EncodingType.equalsIgnoreCase("base64")) {
							att = getFromBASE64(attachment.toString().substring(endEncoding, attachment.size()).trim());
						}
						else {
							att.write(attachment.toByteArray(), attindex + 4, attachment.size() - attindex - 4);
						}
					}
					else {
						att.write(attachment.toByteArray(), attindex + 4, attachment.size() - attindex - 4);
					}
					// end add by hudm 2004-04-01
					subContent = MMContent.createFromBytes(att.toByteArray());
				}
				int lineend = attachment.toString().indexOf("\r\n", type_index + 1);
//				attach_index = lineend;
				int linebeg = type_index + MMConstants.CONTENT_TYPE.length() + 1;
				String contentType = attachment.toString().substring(linebeg, lineend).trim();
				if (contentType == null || contentType.equals(""))
					continue;
				subContent.setContentType(new MMContentType(contentType));
				int id_index = attachment.toString().toLowerCase().indexOf(MMConstants.CONTENT_ID);
				// 若存在ContentID，则取得值并进行赋值
				if (id_index > 0) {
					lineend = attachment.toString().indexOf("\r", id_index + 1);
//					attach_index = lineend;
					linebeg = id_index + MMConstants.CONTENT_ID.length() + 1;
					String contentID = attachment.toString().substring(linebeg, lineend).trim();
					subContent.setContentID(contentID);
				}

				int char_index1 = attachment.toString().indexOf(MMConstants.CHARSET);
				if (char_index1 > 0) {
					int char_index2 = char_index1 + MMConstants.CHARSET.length();
					char c = attachment.toString().charAt(char_index2 + 1);
					if (c == '"')
						char_index2++;
					int char_index3 = char_index2;
					while (1 == 1) {
						c = attachment.toString().charAt(char_index3);
						if (c == ';' || c == '\r' || c == '\n')
							break;
						char_index3++;
					}
					c = attachment.toString().charAt(char_index3 - 1);
					if (c == '"')
						char_index3--;
					String charset = attachment.toString().substring(char_index2 + 1, char_index3).trim();
					subContent.setCharset(charset);
				}

				int loc_index1 = attachment.toString().indexOf("Content-Location");
				if (loc_index1 > 0) {
					int loc_index2 = loc_index1 + "Content-Location".length();
					char c = attachment.toString().charAt(loc_index2 + 1);
					if (c == '"')
						loc_index2++;
					int loc_index3 = loc_index2;
					while (1 == 1) {
						c = attachment.toString().charAt(loc_index3);
						if (c == ';' || c == '\r' || c == '\n')