websmsender.java.svn-base

华为短信网关实现的功能,包括服务器端和客户端代码

package com.fetion.cmpp.server.sender;

import java.io.IOException;
import java.sql.PreparedStatement;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import com.huawei.smproxy.CMPPSMProxy;
import com.huawei.smproxy.comm.cmpp.message.CMPPDeliverMessage;
import com.huawei.smproxy.comm.cmpp.message.CMPPDeliverRepMessage;
import com.huawei.smproxy.comm.cmpp.message.CMPPMessage;
import com.huawei.smproxy.comm.cmpp.message.CMPPSubmitMessage;
import com.huawei.smproxy.util.Args;
import com.huawei.smproxy.util.TypeConvert;

public class WebSMSender extends CMPPSMProxy
{
	private  Log logger = LogFactory.getLog(getClass());

	private static Args arg = Env.getConfig().getArgs("CMPPConnect");

	private static WebSMSender instance;
	

	public static final String service_Id = Env.getConfig().get(
			"CMPPSubmitMessage/service_Id", "WebSM");

	public static final String msg_Src = Env.getConfig().get(
			"CMPPSubmitMessage/msg_Src", "WebSMS");

	public static final String connectCode = Env.getConfig().get(
			"CMPPSubmitMessage/src_Terminal_Id", "");

	public static WebSMSender getInstance()
	{

		if (instance == null)
			instance = new WebSMSender();
		return instance;
	}

	protected WebSMSender() {
		super(arg);
	}

	public void OnTerminate()
	{
		logger.info("Connection have been breaked! ");
		super.onTerminate();
	}

	public CMPPMessage onDeliver(CMPPDeliverMessage msg)
	{

		byte msgId[] = msg.getMsgId();
		if (msg.getRegisteredDeliver() == 1)
		{
			if (String.valueOf(msg.getStat()).equalsIgnoreCase("DELIVRD"))
			{
				logger.info(String.valueOf(String.valueOf((new StringBuffer("\t\treceived DELIVRD message msgid=[")).append(msg.getMsgId()).append("]"))));
				long submitMsgId = TypeConvert.byte2long(msg.getStatusMsgId());
				PreparedStatement stat = null;
				try
				{
					CMPPDeliverRepMessage cmppdeliverrepmessage = new CMPPDeliverRepMessage(
							msgId, 0);
					return cmppdeliverrepmessage;
				} catch (Exception ex)
				{
					ex.printStackTrace();
					CMPPDeliverRepMessage cmppdeliverrepmessage1 = new CMPPDeliverRepMessage(
							msgId, 9);
					return cmppdeliverrepmessage1;
				}
			} else
			{
				return new CMPPDeliverRepMessage(msgId, 9);
			}
		} else
		{
			logger.info(String.valueOf(String.valueOf((new StringBuffer("\t\treceived non DELIVRD message msgid=[")).append(msg.getMsgId()).append("]"))));
			return new CMPPDeliverRepMessage(msgId, 9);
		}
	}

	public boolean send(CMPPSubmitMessage msg)
	{
		if (msg == null)
			return false;	
		
		boolean flag = false;		
		
		try
		{
			super.send(msg);
			flag = true;
		} catch (IOException ex)
		{
			ex.printStackTrace();
		}
		return flag;
	}
}