deliver.java

联通短信网关SGIP通用java源代码

package com.zzxy.shortmessage.SGIP;

import java.nio.ByteBuffer;
import java.nio.ByteOrder;
import java.nio.channels.SocketChannel;

import com.zzxy.common.Logger;


  public class Deliver  extends SGIPAbstractStruct{
	
	public String Mobile_no;   //21B 发送短消息的用户手机号，手机号码前加"86"国别标志
	public String SPNumber;  //21B SP的接入号码
	
	public byte TP_pid;   //1B GSM协议类型。详细解释请参考GSM03.40中的9.2.3.9
	public byte TP_udhi;   //1B GSM协议类型。详细解释请参考GSM03.40中的9.2.3.23,仅使用1位，右对齐
	public byte MessageCoding;   //1B 短消息的编码格式。0：纯ASCII字符串3：写卡操作4：二进制编码8：UCS2编码15: GBK编码其它参见GSM3.38第4节：SMS Data Coding Scheme
	public int MessageLength;//4B Integer 短消息的长度
	public String msg;//Message Length  短消息的内容
	public String Reserve;//8B 保留，扩展用
	
	public static final int STRUCT_SIZE=49;//不含短消息内容的长度
	
	@Override
	public ByteBuffer getBuffer() {
		ByteBuffer buffer = ByteBuffer.allocate(STRUCT_SIZE+MessageLength);
		buffer.order(byteOrder);
		
		buffer.put(Mobile_no.getBytes());
		for (int i = Mobile_no.getBytes().length; i < 21; i++) {
			buffer.put((byte)0);
		}
		
		buffer.put(SPNumber.getBytes());
		for (int i = SPNumber.getBytes().length; i < 21; i++) {
			buffer.put((byte)0);
		}
		
		buffer.put(TP_pid);
		buffer.put(TP_udhi);
		buffer.put(MessageCoding);
		buffer.putInt(MessageLength);
		buffer.put(msg.getBytes());
		
		for (int i = 0; i < 8; i++) {
			buffer.put((byte)0);
		}
		buffer.flip();
		return buffer;
	}

	@Override
	public void setBuffer(ByteBuffer buffer) throws Exception {
		buffer.order(byteOrder);
		
		byte temp[] = new byte[21];
		buffer.get(temp, 0, 21);
		Mobile_no = new String(temp, "GB2312");
		Mobile_no = Mobile_no.trim();
		buffer.get(temp, 0, 21);
		SPNumber = new String(temp, "GB2312");
		SPNumber = SPNumber.trim();
		
		TP_pid = buffer.get();
		TP_udhi = buffer.get();
		MessageCoding = buffer.get();
		MessageLength=buffer.getInt();
	}
	
	  private String UCS2String(byte[] msg) {

		    int zhong, zhong1;
		    String snr = "";
		    for (int j = 0; j < this.MessageLength; j += 2) {
		      zhong = msg[j];
		      if (zhong < 0)
		        zhong += 256;
		      zhong1 = msg[j + 1];
		      if (zhong1 < 0)
		        zhong1 += 256;

		      zhong = zhong * 256 + zhong1;
		      if (zhong == 0)
		        break;

		      snr = snr + (char) zhong;
		    }

		    return snr;
		  }
	
	public void setBuffermsg(ByteBuffer buffer) throws Exception {
		buffer.order(byteOrder);
		
		byte temp[] = new byte[this.MessageLength];
		buffer.get(temp, 0, this.MessageLength);
		
	    // 判断接收信息格式
	    switch ( MessageCoding ) {
	      case 0 :// ASCII串
	    	msg = new String(temp).trim();
	        break;
	      case 3 :// 短信写卡操作
	        break;
	      case 4 :// 二进制信息
	        break;
	      case 8 :// UCS2编码
	    	msg = UCS2String(temp);
	        break;
	      case 15 :// 含GB汉字
	        break;
	      default :
	        break;

	    }
		
	}
	
	public void read(SocketChannel channel) throws Exception {
		ByteBuffer buffer = ByteBuffer.allocate(STRUCT_SIZE);
		buffer.order(byteOrder);
		channel.read(buffer);
		buffer.flip();
		this.setBuffer(buffer);
		buffer = ByteBuffer.allocate(this.MessageLength);
		buffer.order(ByteOrder.nativeOrder());
		channel.read(buffer);
		buffer.flip();
		msg = new String(buffer.array(), charset);
	}
  }