emailqueuehelper.java

短信发送

/**
 * Created at Dec 4, 2008
 */
package com.jdev.app.db;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;

import com.jdev.app.db.queue.EmailAddWorker;
import com.jdev.app.db.queue.EmailBodyQueue;
import com.jdev.app.db.queue.EmailQueue;
import com.jdev.app.db.queue.EmailQueueFactory;
import com.jdev.app.db.queue.EmailTakeWorker;
import com.jdev.net.connector.ConnectionFactory;
import com.jdev.net.data.QueueWorker;
import com.jdev.net.data.datatype.StringType;
import com.jdev.util.Debug;

/**
 * <p>Title: EmailQueueHelper</p>
 * <p>Description: </p>
 * @author Lawrence
 * @version 
 */
public class EmailQueueHelper {
	private final static String module = SmsQueueHelper.class.getName();
	private final static EmailQueueFactory queueFactory = EmailQueueFactory
			.getInstance();
	
	protected int CSType;

	/**
	 * @param type
	 */
	public EmailQueueHelper(int type) {
		CSType = type;
	}

	public byte[] getSend() throws Exception {
		byte[] response = null;
		try {
			EmailQueue queue = queueFactory.getQueue();
			if (queue.getSendRecord() <= 0)
				return null;
			
			ByteArrayOutputStream bout = (ByteArrayOutputStream) queue
			.removeSendFirst();
			response = bout.toByteArray();
		} catch (Exception e) {
			Debug.logError("getSend() error:" + e, module);
			throw new Exception(e);
		}
		return response;
	}

	public byte[] getRecv() throws Exception {
		byte[] response = null;
		try {
			EmailQueue queue = queueFactory.getQueue();
			if (queue.getRecvRecord() <= 0)
				return null;
			ByteArrayOutputStream bout = (ByteArrayOutputStream) queue
					.removeRecvFirst();
			response = bout.toByteArray();
		} catch (Exception e) {
			Debug.logError("getRecv() error:" + e, module);
			throw new Exception(e);
		}
		return response;
	}

	public InputStream putSend(byte[] array) throws Exception {
		try {
			EmailQueue queue = queueFactory.getQueue();
			InputStream bin = new ByteArrayInputStream(array);
			queue.pushSend(bin);
			return bin;
		} catch (Exception e) {
			Debug.logError("putSend error:" + e, module);
			throw new Exception(e);
		}

	}

	public InputStream putRecv(byte[] array) throws Exception {
		try {
			EmailQueue queue = queueFactory.getQueue();
			InputStream bin = new ByteArrayInputStream(array);
			queue.pushRecv(bin);
			return bin;
		} catch (Exception e) {
			Debug.logError("putRecv error:" + e, module);
			throw new Exception(e);
		}

	}

	/**
	 * 根据是服务器应用还是客户端应用，设置写入Queue中的信息类型
	 * 是request 还是response
	 * @return
	 */
	public int getWriteMsgType() {
		if (CSType == ConnectionFactory.CLIENT)
			return QueueWorker.REQUEST;
		else
			return QueueWorker.RESPONSE;
	}

	/**
	 * 根据是服务器应用还是客户端应用，设置从Queue中读取的信息类型
	 * 是request 还是response
	 * @return
	 */
	public int getReadMsgType() {
		if (CSType == ConnectionFactory.CLIENT)
			return QueueWorker.REQUEST;
		else
			return QueueWorker.RESPONSE;
	}
	
	/**
	 * 读取字符串
	 * @return String
	 * @throws java.lang.Exception
	 */
	public String readSend() throws Exception {
		try {
			EmailQueue queue = queueFactory.getQueue();
			QueueWorker worker = new EmailTakeWorker(queue);
			StringType st = new StringType(QueueWorker.RESPONSE);
			st.accpet(worker);
			return st.getContent();
		} catch (Exception ex) {
			Debug.logError("readString error:" + ex, module);
			throw new Exception(ex);
		}
	}

	/**
	 * 写入字符串
	 * @param msg
	 * @throws java.lang.Exception
	 */
	public void writeSend(String msg) throws Exception {
		try {
			EmailQueue queue = queueFactory.getQueue();
			QueueWorker worker = new EmailAddWorker(queue);
			StringType st = new StringType(QueueWorker.RESPONSE);
			st.setContent(msg);
			st.accpet(worker);
		} catch (Exception ex) {
			Debug.logError("writeString error:" + ex, module);
			throw new Exception(ex);

		}
	}

	/**
	 * 读取字符串
	 * @return String
	 * @throws java.lang.Exception
	 */
	public String readRecv() throws Exception {
		try {
			EmailQueue queue = queueFactory.getQueue();
			QueueWorker worker = new EmailTakeWorker(queue);
			StringType st = new StringType(QueueWorker.REQUEST);
			st.accpet(worker);
			return st.getContent();
		} catch (Exception ex) {
			Debug.logError("readString error:" + ex, module);
			throw new Exception(ex);
		}
	}

	/**
	 * 写入字符串
	 * @param msg
	 * @throws java.lang.Exception
	 */
	public void writeRecv(String msg) throws Exception {
		try {
			EmailQueue queue = queueFactory.getQueue();
			QueueWorker worker = new EmailAddWorker(queue);
			StringType st = new StringType(QueueWorker.REQUEST);
			st.setContent(msg);
			st.accpet(worker);
		} catch (Exception ex) {
			Debug.logError("writeString error:" + ex, module);
			throw new Exception(ex);

		}
	}

	public void writeBody(String msg) throws Exception {
		try {
			EmailBodyQueue queue = queueFactory.getBodyQueue();
			queue.push(msg);
		} catch (Exception ex) {
			Debug.logError("writeBody error:" + ex, module);
			throw new Exception(ex);

		}
	}
	
	public int getBodyRecord() throws Exception {
		try {
			EmailBodyQueue queue = queueFactory.getBodyQueue();
			return queue.getRecord();
		} catch (Exception e) {
			Debug.logError("readBody error:" + e, module);
			throw new Exception(e);
			
		}
	}
	public String[] readBodyAll() throws Exception {
		try {
			EmailBodyQueue queue = queueFactory.getBodyQueue();
			int index = queue.getRecord();
			String[] s = new String[index];
			for(int i=0;i< index;i++){
				s[i] = queue.get(i).toString();
			}
			return s;
			
		} catch (Exception e) {
			Debug.logError("readBody error:" + e, module);
			throw new Exception(e);
			
		}
	}
	
	public String readBody(int index) throws Exception {
		try {
			EmailBodyQueue queue = queueFactory.getBodyQueue();
			
			return queue.get(index).toString();
		} catch (Exception ex) {
			Debug.logError("readBody error:" + ex, module);
			throw new Exception(ex);
		}
	}
	
	public boolean findBody(String key) throws Exception {
		try {
			EmailBodyQueue queue = queueFactory.getBodyQueue();
			for (int j=0; j< queue.getRecord(); j++) {
				String str = queue.get(j).toString();
				String[] s = str.split(",");
				if(s.length == 4) {
					if(s[0].equalsIgnoreCase(key))
						return true;
				}
				
			}
			return false;
		} catch (Exception e) {
			Debug.logError("findBody error:" + e, module);
			throw new Exception(e);
			
		}
	}
}