cmpp20proxy.java

java 编写的短信平台。支持所有协议

package com.sf.note;

import java.io.IOException;
import java.util.Date;

import com.huawei.insa2.comm.cmpp.message.CMPPDeliverMessage;
import com.huawei.insa2.comm.cmpp.message.CMPPMessage;
import com.huawei.insa2.comm.cmpp.message.CMPPSubmitMessage;
import com.huawei.insa2.comm.cmpp.message.CMPPSubmitRepMessage;
import com.huawei.insa2.util.Args;
import com.huawei.smproxy.SMProxy;

public class Cmpp20Proxy extends SMProxy {
	
	private String spid = null;
	
	private int mmsid = 0;
	
	public Cmpp20Proxy(Args args) {
		super(args);
		spid = args.get("source-addr", "999999");
		Constant.SPID = spid;
	}
	
	public void ProcessRecvDeliverMsg(CMPPMessage msg) {
		CMPPDeliverMessage deliverMsg = (CMPPDeliverMessage) msg;




		/*if (deliverMsg.getRegisteredDeliver() == 0) {
			try {
				String msgcont = new String(deliverMsg.getMsgContent(),
						"UTF-8");
		
				System.out.println(deliverMsg.getSrcterminalId());

				CMPPMessage m = getreq("", "", "8613906631212", "", msgcont
						.getBytes());
				System.out.println(msgcont);
				CMPPMessage res = super.send(m);
				System.out.println(res+"**");
			} catch (IOException e) {
				e.printStackTrace();
			}

		}*/


	}

	/*public CMPPSubmitMessage getreq(String Msg_src, String Dest_Id,
			String addTo, String service_id, byte msgContent[]) {

		String feeTerminalId = "0";
		Date valid_Time = null;
		Date at_Time = null;
		String srcTerminalId;
		String destTerminalId[];
		srcTerminalId = Dest_Id;
		destTerminalId = new String[1];
		destTerminalId[0] = addTo;
		CMPPSubmitMessage submitMsg = null;
		try {
			//CMPP30SubmitMessage y = new CMPP30SubmitMessage(mmsid, mmsid, mmsid, mmsid, srcTerminalId, mmsid, srcTerminalId, mmsid, mmsid, mmsid, mmsid, srcTerminalId, srcTerminalId, srcTerminalId, at_Time, at_Time, srcTerminalId, destTerminalId, mmsid, msgContent, srcTerminalId);
			//CMPPSubmitMessage x = new CMPPSubmitMessage(mmsid, mmsid, mmsid, mmsid, srcTerminalId, mmsid, srcTerminalId, mmsid, mmsid, mmsid, srcTerminalId, srcTerminalId, srcTerminalId, at_Time, at_Time, srcTerminalId, destTerminalId, msgContent, srcTerminalId);
			submitMsg = new CMPPSubmitMessage( 1, 1, 0, 0, srcTerminalId, mmsid, srcTerminalId, mmsid, mmsid, mmsid, srcTerminalId, srcTerminalId, srcTerminalId, at_Time, at_Time, srcTerminalId, destTerminalId, msgContent, srcTerminalId);
			
		} catch (IllegalArgumentException e) {

			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();

		} finally {
			return submitMsg;
		}
	}*/

	/**
	 *
	 * 对ISMG主动下发的消息的处理
	 * 重载实现SMProxy30的onDeliver方法用以处理接收到的Deliver消息
	 * @param msg CMPP30DeliverMessage
	 * @return CMPPMessage
	 */
	public CMPPMessage onDeliver(CMPPDeliverMessage msg) {
		this.ProcessRecvDeliverMsg(msg);
		//返回响应消息
		return super.onDeliver(msg);
	}
	
	

	/**
	 *
	 * 重载实现SMProxy30的OnTerminate方法，用以处理与ISMG连接断开
	 */
	public void OnTerminate() {

		//demo.Terminate();
	}

}