cincomingmessage.java

java编写的短信收发程序

// SMSLib for Java
// An open-source API Library for sending and receiving SMS via a GSM modem.
// Copyright (C) 2002-2006, Thanasis Delenikas, Athens/GREECE
// Web Site: http://www.smslib.org
//
// SMSLib is distributed under the LGPL license.
//
// This library is free software; you can redistribute it and/or
// modify it under the terms of the GNU Lesser General Public
// License as published by the Free Software Foundation; either
// version 2.1 of the License, or (at your option) any later version.
// 
// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
// Lesser General Public License for more details.
// 
// You should have received a copy of the GNU Lesser General Public
// License along with this library; if not, write to the Free Software
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA

package org.smslib;

import java.util.*;

public class CIncomingMessage extends CMessage implements java.io.Serializable
{
	private static final long serialVersionUID = -2267318578768120211L;

	public static enum MessageClass { All, RecvUnread, RecvRead }

	private int memIndex;
	private String memLocation;
	private int mpRefNo;
	private int mpMaxNo;
	private int mpSeqNo;
	private String mpMemIndex;

	protected CIncomingMessage(Date date, String originator, String text, int memIndex, String memLocation)
	{
		super(MessageType.Incoming, date, originator, null, text);

		this.memIndex = memIndex;
		this.memLocation = memLocation;

		mpRefNo = 0;
		mpMaxNo = 0;
		mpSeqNo = 0;
		mpMemIndex = "";
	}

	protected CIncomingMessage(MessageType messageType, int memIndex, String memLocation)
	{
		super(messageType, null, null, null, null);

		this.memIndex = memIndex;
		this.memLocation = memLocation;

		mpRefNo = 0;
		mpMaxNo = 0;
		mpSeqNo = 0;
		mpMemIndex = "";
	}

	protected CIncomingMessage(String pdu, int memIndex, String memLocation)
	{
		super(MessageType.Incoming, null, null, null, null);

		Date date;
		String originator;
		String str1, str2;
		int index, i, j, k, protocol, addr, year, month, day, hour, min, sec, skipBytes;
		boolean hasUDH;
		int UDHLength;
		String UDHData;
		byte[] bytes;

		this.memIndex = memIndex;
		this.memLocation = memLocation;

		mpRefNo = 0;
		mpMaxNo = 0;
		mpSeqNo = 0;
		mpMemIndex = "";

		skipBytes = 0;

		i = Integer.parseInt(pdu.substring(0, 2), 16);
		index = (i + 1) * 2;

		hasUDH = ((Integer.parseInt(pdu.substring(index, index + 2), 16) & 0x40) != 0) ? true : false;

		index += 2;
		i = Integer.parseInt(pdu.substring(index, index + 2), 16);
		j = index + 4;
		originator = "";
		for (k = 0; k < i; k += 2)
			originator = originator + pdu.charAt(j + k + 1) + pdu.charAt(j + k);
		originator = "+" + originator;
		if (originator.charAt(originator.length() - 1) == 'F') originator = originator.substring(0, originator.length() - 1);

		addr = Integer.parseInt(pdu.substring(j - 2, j), 16);
		if ((addr & (1 << 6)) != 0 && (addr & (1 << 5)) == 0 && (addr & (1 << 4)) != 0)
		{
			str1 = pduToText(pdu.substring(j, j + k));
			bytes = new byte[str1.length()];
			for (i = 0; i < str1.length(); i++)
				bytes[i] = (byte) str1.charAt(i);
			originator = CGSMAlphabet.bytesToString(bytes);
		}
		// else if ( (addr & (1 << 6)) == 0 && (addr & (1 << 5)) == 0 && (addr &
		// (1 << 4)) != 0) originator = "+" + originator;

		index = j + k + 2;
		str1 = "" + pdu.charAt(index) + pdu.charAt(index + 1);
		protocol = Integer.parseInt(str1, 16);
		index += 2; year = Integer.parseInt("" + pdu.charAt(index + 1) + pdu.charAt(index));
		index += 2; month = Integer.parseInt("" + pdu.charAt(index + 1) + pdu.charAt(index));
		index += 2; day = Integer.parseInt("" + pdu.charAt(index + 1) + pdu.charAt(index));
		index += 2; hour = Integer.parseInt("" + pdu.charAt(index + 1) + pdu.charAt(index));
		index += 2; min = Integer.parseInt("" + pdu.charAt(index + 1) + pdu.charAt(index));
		index += 2; sec = Integer.parseInt("" + pdu.charAt(index + 1) + pdu.charAt(index));
		index += 4;
		Calendar cal = Calendar.getInstance();
		cal.set(Calendar.YEAR, year + 2000);
		cal.set(Calendar.MONTH, month - 1);
		cal.set(Calendar.DAY_OF_MONTH, day);
		cal.set(Calendar.HOUR_OF_DAY, hour);
		cal.set(Calendar.MINUTE, min);
		cal.set(Calendar.SECOND, sec);
		date = cal.getTime();

		if (hasUDH)
		{
			UDHLength = Integer.parseInt(pdu.substring(index + 2, index + 2 + 2), 16);
			UDHData = pdu.substring(index + 2 + 2, index + 2 + 2 + (UDHLength * 2));

			if (UDHData.substring(0, 2).equalsIgnoreCase("00"))
			{
				mpRefNo = Integer.parseInt(UDHData.substring(4, 6), 16);
				mpMaxNo = Integer.parseInt(UDHData.substring(6, 8), 16);
				mpSeqNo = Integer.parseInt(UDHData.substring(8, 10), 16);
				skipBytes = 7;
			}
			else if (UDHData.substring(0, 2).equalsIgnoreCase("08"))
			{
				mpRefNo = Integer.parseInt(UDHData.substring(4, 8), 16);
				mpMaxNo = Integer.parseInt(UDHData.substring(8, 10), 16);
				mpSeqNo = Integer.parseInt(UDHData.substring(10, 12), 16);
				skipBytes = 8;
			}
		}
		else
		{
			UDHLength = 0;
			UDHData = "";
		}

		switch (protocol & 0x0C)
		{
			case 0:
				setMessageEncoding(MessageEncoding.Enc7Bit);
				str1 = pduToText(pdu.substring(index + 2));
				bytes = new byte[str1.length()];
				for (i = 0; i < str1.length(); i++)
					bytes[i] = (byte) str1.charAt(i);
				str2 = CGSMAlphabet.bytesToString(bytes);
				if (hasUDH) str1 = str2.substring(UDHLength + 2);
				else str1 = str2;
				break;
			case 4:
				setMessageEncoding(MessageEncoding.Enc8Bit);
				index += 2;
				if (hasUDH) index += UDHLength + skipBytes;
				str1 = "";
				while (index < pdu.length())
				{
					i = Integer.parseInt("" + pdu.charAt(index) + pdu.charAt(index + 1), 16);
					str1 = str1 + (char) i;
					index += 2;
				}
				break;
			case 8:
				setMessageEncoding(MessageEncoding.EncUcs2);
				index += 2;
				if (hasUDH) index += UDHLength + skipBytes;
				str1 = "";
				while (index < pdu.length())
				{
					i = Integer.parseInt("" + pdu.charAt(index) + pdu.charAt(index + 1), 16);
					j = Integer.parseInt("" + pdu.charAt(index + 2) + pdu.charAt(index + 3), 16);
					str1 = str1 + (char) ((i * 256) + j);
					index += 4;
				}
				break;
		}

		this.originator = originator;
		this.date = date;
		this.text = str1;
	}

	private String pduToText(String pdu)
	{
		String text;
		byte oldBytes[], newBytes[];
		BitSet bitSet;
		int i, j, value1, value2;

		oldBytes = new byte[pdu.length() / 2];
		for (i = 0; i < pdu.length() / 2; i++)
		{
			oldBytes[i] = (byte) (Integer.parseInt(pdu.substring(i * 2, (i * 2) + 1), 16) * 16);
			oldBytes[i] += (byte) Integer.parseInt(pdu.substring((i * 2) + 1, (i * 2) + 2), 16);
		}

		bitSet = new BitSet(pdu.length() / 2 * 8);
		value1 = 0;
		for (i = 0; i < pdu.length() / 2; i++)
			for (j = 0; j < 8; j++)
			{
				value1 = (i * 8) + j;
				if ((oldBytes[i] & (1 << j)) != 0) bitSet.set(value1);
			}
		value1++;

		value2 = value1 / 7;
		if (value2 == 0) value2++;

		newBytes = new byte[value2];
		for (i = 0; i < value2; i++)
			for (j = 0; j < 7; j++)
				if ((value1 + 1) > (i * 7 + j)) if (bitSet.get(i * 7 + j)) newBytes[i] |= (byte) (1 << j);

		if (newBytes[value2 - 1] == 0) text = new String(newBytes, 0, value2 - 1);
		else text = new String(newBytes);
		return text;
	}

	protected void setMpRefNo(int mpRefNo) { this.mpRefNo = mpRefNo; }
	public void setMpSeqNo(int mpSeqNo) { this.mpSeqNo = mpSeqNo; }
	public void setMemIndex(int memIndex) { this.memIndex = memIndex; }
	public void setMpMemIndex(int memIndex) { this.mpMemIndex += (mpMemIndex.length() == 0 ? "" : ",") + memIndex; }

	/**
	*	Returns the Originator's number. Number is in international format or in text format.
	*
	*	@return	The Originator's number.
	*/
	public String getOriginator() { return originator; }
	public int getMemIndex() { return memIndex; }
	public String getMemLocation() { return memLocation; }
	public int getMpRefNo() { return mpRefNo; }
	public int getMpMaxNo() { return mpMaxNo; }
	public int getMpSeqNo() { return mpSeqNo; }
	public String getMpMemIndex() { return mpMemIndex; }
}