notesender.java

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

package com.sf.note;

import java.io.UnsupportedEncodingException;
import java.util.Date;

import com.huawei.insa2.comm.cmpp.message.CMPPMessage;
import com.huawei.insa2.comm.cmpp.message.CMPPSubmitMessage;
import com.huawei.insa2.comm.cmpp30.message.CMPP30SubmitMessage;

public class NoteSender {
	
	
	//int pk_Total,   //

   // int pk_Number,   // pk_Number 相同msg_Id的消息序号

  // int registered_Delivery,   // registered_Delivery 是否要求返回状态报告

  // int msg_Level,   // msg_Level  信息级别

 //  String service_Id,   // service_Id 业务类型

 // int fee_UserType,   // fee_UserType 计费用户类型字段

 // String fee_Terminal_Id,   // fee_Terminal_Id 被计费用户的号码

 // int tp_Pid,   // tp_Pid GSM协议类型

  //   int tp_Udhi,   // tp_Udhi GSM协议类型

  // int msg_Fmt,   // msg_Fmt 消息格式

  // String msg_Src,   // msg_Src 消息内容来源

  // String fee_Type,   // fee_Type 资费类别

  // String fee_Code,   // fee_Code 资费代码(以分为单位)

  // Date valid_Time,   // valid_Time 存活有效期

  // Date at_Time,   // at_Time 定时发送时间

  // String src_Terminal_Id,   // src_Terminal_Id 源号码

  // String[] dest_Terminal_Id,   // dest_Terminal_Id 接收短信的MSISDN号码

 //  byte[] msg_Content,   // msg_Content 消息内容

  // String reserve   // LinkID    点播业务使用的LinkID

	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	public void sendNote(String srcMobileNumber,String destMobileNumber,String content) throws InterruptedException,UnsupportedEncodingException {
		
		if (Constant.ISMG_VERSION != 2 && Constant.ISMG_VERSION != 3) {
			throw new InterruptedException();
		}
		//信息标识，由SP侧短信网关本身产生，本处填空

		int pk_Total=1;
		int pk_Number = 1;
		int registered_Delivery = 0;
		int msg_Level = 0;
        String service_Id = "09555";
        int fee_UserType = 1;
        String fee_Terminal_Id = srcMobileNumber;
        int tp_Pid = 0;
        int tp_Udhi = 0;
        int msg_Fmt = 15;
        String msg_Src = Constant.SPID;
        String fee_Type = "02";
        String fee_Code = "";
        Date valid_Time = null;
		Date at_Time = null;
		String srcTerminalId =srcMobileNumber;
		String destTerminalId[];
		destTerminalId = new String[1];
		destTerminalId[0] = destMobileNumber;
		String reserve = "";
		
		
		
		int fee_Terminal_Type = 0;
		int dest_Terminal_Type = 0;
		String LinkID = "";
		
		
		
		byte[] msgContent = content.getBytes("UTF-8");
		if (Constant.ISMG_VERSION == 2) {	
		   CMPPSubmitMessage submitMsg = new CMPPSubmitMessage( pk_Total, pk_Number, registered_Delivery, msg_Level,service_Id, fee_UserType, fee_Terminal_Id, tp_Pid, tp_Udhi, msg_Fmt, msg_Src, fee_Type, fee_Code, valid_Time, at_Time, srcTerminalId, destTerminalId, msgContent, reserve);
		   send(submitMsg);
		}
		if (Constant.ISMG_VERSION == 3) {	
			CMPP30SubmitMessage submitMsg = new CMPP30SubmitMessage(pk_Total, pk_Number, registered_Delivery, msg_Level, service_Id, fee_UserType, fee_Terminal_Id, fee_Terminal_Type, tp_Pid, tp_Udhi, msg_Fmt, msg_Src,  fee_Type,  fee_Code, valid_Time,  at_Time,  srcTerminalId,  destTerminalId,  dest_Terminal_Type,  msgContent,  LinkID);
			send(submitMsg);
		}
	}
	
	
	private void send(CMPPMessage message) throws InterruptedException {
		if (QueueInstance.sendQueue == null)
        {
			QueueInstance.sendQueue = new Queue();
        }
		QueueInstance.sendQueue.put(message);
	}

}