athandler.java

华为编程开发规范与案例, 华为编程开发规范与案例,华为编程开发规范与案例

// SMSLib for Java v3
// A Java API library for sending and receiving SMS via a GSM modem
// or other supported gateways.
// Web Site: http://www.smslib.org
//
// SMSLib is distributed under the terms of the Apache License version 2.0
//
// Copyright (C) 2002-2007, Thanasis Delenikas, Athens/GREECE
// Portions Copyright:
// Davide Bettoni, Clusone/ITALY, [e-mail]
// Tomek Cejner, Polland, [e-mail]
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package org.smslib.athandlers;

import java.util.*;
import java.util.regex.*;
import org.smslib.gateway.*;

public class ATHandler extends AbstractATHandler
{
	protected ModemDriver modemDriver;

	public ATHandler(ModemGateway gateway)
	{
		super(gateway);
		modemDriver = gateway.getModemDriver();
		terminators = new String[12];
		terminators[0] = "OK\\s";
		terminators[1] = "\\s*[\\p{ASCII}]*\\s+OK\\s";
		terminators[2] = "ERROR\\s";
		terminators[3] = "ERROR: \\d+\\s";
		terminators[4] = "\\+CMS ERROR: \\d+\\s";
		terminators[5] = "\\+CPIN: READY\\s";
		terminators[6] = "\\+CPIN: SIM BUSY\\s";
		terminators[7] = "\\+CPIN: SIM PIN\\s";
		terminators[8] = "\\+CMTI: \\p{Punct}[\\p{ASCII}]+\\p{Punct}\\p{Punct}\\d+\\s";
		terminators[9] = "\\+CDSI: \\p{Punct}[\\p{ASCII}]+\\p{Punct}\\p{Punct}\\d+\\s";
		terminators[10] = "RING\\s";
		terminators[11] = "\\+CLIP: \\p{Punct}[\\p{ASCII}]+\\p{Punct}\\p{Punct}\\d+\\s";
	}

	public void setStorageLocations(String loc)
	{
		storageLocations = loc;
	}

	public void sync() throws Exception
	{
		modemDriver.write("ATZ\r");
		Thread.sleep(DELAY_AT);
	}

	public void reset() throws Exception
	{
	}

	public void echoOff() throws Exception
	{
		modemDriver.write("ATE0\r");
		modemDriver.clearBuffer();
	}

	public void init() throws Exception
	{
		modemDriver.write("AT+CLIP=1\r");
	}

	public boolean isAlive() throws Exception
	{
		modemDriver.write("AT\r");
		return (modemDriver.getResponse().matches("[\\p{ASCII}]*OK\\s"));
	}

	public String getSimStatus() throws Exception
	{
		modemDriver.write("AT+CPIN?\r");
		return (modemDriver.getResponse());
	}

	public boolean enterPin(String pin) throws Exception
	{
		modemDriver.write("AT+CPIN=\"_1_\"\r".replaceAll("_1_", pin));
		if (modemDriver.getResponse().indexOf("OK") > 0) return true;
		else return false;
	}

	public boolean setVerboseErrors() throws Exception
	{
		modemDriver.write("AT+CMEE=1\r");
		return (modemDriver.getResponse().matches("OK\\s"));
	}

	public boolean setPduProtocol() throws Exception
	{
		modemDriver.write("AT+CMGF=0\r");
		return (modemDriver.getResponse().matches("OK\\s"));
	}

	public boolean setTextProtocol() throws Exception
	{
		modemDriver.write("AT+CMGF=1\r");
		if (modemDriver.getResponse().matches("OK\\s"))
		{
			modemDriver.write("AT+CSCS=\"HEX\"\r");
			return (modemDriver.getResponse().matches("OK\\s"));
		}
		else return false;
	}

	public boolean setIndications() throws Exception
	{
		modemDriver.write("AT+CNMI=2,1,0,2\r");
		return (modemDriver.getResponse().matches("OK\\s"));
	}

	public String getManufacturer() throws Exception
	{
		modemDriver.write("AT+CGMI\r");
		return modemDriver.getResponse();
	}

	public String getModel() throws Exception
	{
		modemDriver.write("AT+CGMM\r");
		return modemDriver.getResponse();
	}

	public String getSerialNo() throws Exception
	{
		modemDriver.write("AT+CGSN\r");
		return modemDriver.getResponse();
	}

	public String getImsi() throws Exception
	{
		modemDriver.write("AT+CIMI\r");
		return modemDriver.getResponse();
	}

	public String getSwVersion() throws Exception
	{
		modemDriver.write("AT+CGMR\r");
		return modemDriver.getResponse();
	}

	public String getBatteryLevel() throws Exception
	{
		modemDriver.write("AT+CBC\r");
		return modemDriver.getResponse();
	}

	public String getSignalLevel() throws Exception
	{
		modemDriver.write("AT+CSQ\r");
		return modemDriver.getResponse();
	}

	public boolean setMemoryLocation(String mem) throws Exception
	{
		modemDriver.write("AT+CPMS=\"" + mem + "\"\r");
		return (modemDriver.getResponse().matches("[\\p{ASCII}]*\\sOK\\s"));
	}

	public void switchToCmdMode() throws Exception
	{
		modemDriver.write("+++");
		Thread.sleep(DELAY_CMD_MODE);
	}

	public boolean keepGsmLinkOpen() throws Exception
	{
		modemDriver.write("AT+CMMS=1\r");
		return (modemDriver.getResponse().matches("OK\\s+"));
	}

	public int sendMessage(int size, String pdu, String phone, String text) throws Exception
	{
		int responseRetries, errorRetries;
		String response;
		int refNo;

		switch (gateway.getProtocol())
		{
			case PDU:
				errorRetries = 0;
				while (true)
				{
					responseRetries = 0;
					modemDriver.write("AT+CMGS=\"_1_\"\r".replaceAll("\"_1_\"", "" + size));
					Thread.sleep(DELAY_CMGS);
					while (!modemDriver.dataAvailable())
					{
						responseRetries++;
						if (responseRetries == gateway.getRetriesNoResponse()) throw new org.smslib.NoResponseException();
						gateway.getLogger().warn("ATHandler().SendMessage(): Still waiting for response (I) (" + responseRetries + ")...");
						Thread.sleep(gateway.getDelayNoResponse());
					}
					responseRetries = 0;
					modemDriver.clearBuffer();
					modemDriver.write(pdu);
					modemDriver.write((char) 26);
					response = modemDriver.getResponse();
					while (response.length() == 0)
					{
						responseRetries++;
						if (responseRetries == gateway.getRetriesNoResponse()) throw new org.smslib.NoResponseException();
						gateway.getLogger().warn("ATHandler().SendMessage(): Still waiting for response (II) (" + responseRetries + ")...");
						Thread.sleep(gateway.getDelayNoResponse());
						response = modemDriver.getResponse();
					}

					if (modemDriver.getLastError() == 0)
					{
						Matcher m = Pattern.compile("\\s*\\+CMGS: (\\d+)").matcher(response);
						if (m.find())
						{
							refNo = Integer.parseInt(m.group(1));
						}
						else
						{
							// Message-Reference ID not returned
							refNo = -1;
						}
						break;
					}
					else if (modemDriver.getLastError() > 0)
					{
						// CMS or CME error could happen here
						errorRetries++;
						if (errorRetries == gateway.getRetriesCmsErrors())
						{
							gateway.getLogger().error(modemDriver.getLastErrorText() + ": Quit retrying, message lost...");
							refNo = -1;
							break;
						}
						else
						{
							gateway.getLogger().warn(modemDriver.getLastErrorText() + ": Retrying...");
							Thread.sleep(gateway.getDelayCmsErrors());
						}
					}
					else refNo = -1;
				}
				break;
			case TEXT:
				modemDriver.write("AT+CMGS=\"_1_\"\r".replaceAll("_1_", phone));
				modemDriver.clearBuffer();
				modemDriver.write(text);
				Thread.sleep(DELAY_CMGS);
				modemDriver.write((char) 26);
				response = modemDriver.getResponse();
				if (response.indexOf("OK\r") >= 0)
				{
					int i;
					String tmp = "";

					i = response.indexOf(":");
					while (!Character.isDigit(response.charAt(i)))
						i++;
					while (Character.isDigit(response.charAt(i)))
					{
						tmp += response.charAt(i);
						i++;
					}
					refNo = Integer.parseInt(tmp);
				}
				else refNo = -1;
				break;
			default:
				refNo = -1;
				break;
		}
		return refNo;
	}

	public String listMessages(org.smslib.InboundMessage.MessageClass messageClass) throws Exception
	{
		switch (gateway.getProtocol())
		{
			case PDU:
				switch (messageClass)
				{
					case All:
						modemDriver.write("AT+CMGL=4\r");
						break;
					case Unread:
						modemDriver.write("AT+CMGL=0\r");
						break;
					case Read:
						modemDriver.write("AT+CMGL=1\r");
						break;
				}
				break;
			case TEXT:
				switch (messageClass)
				{
					case All:
						modemDriver.write("AT+CMGL=\"ALL\"\r");
						break;
					case Unread:
						modemDriver.write("AT+CMGL=\"REC UNREAD\"\r");
						break;
					case Read:
						modemDriver.write("AT+CMGL=\"REC READ\"\r");
						break;
				}
				break;
		}
		return modemDriver.getResponse();
	}

	public boolean deleteMessage(int memIndex, String memLocation) throws Exception
	{
		if (!setMemoryLocation(memLocation)) throw new org.smslib.OopsException("CATHandler.deleteMessage() : Memory Location not found!!!");
		modemDriver.write("AT+CMGD=_1_\r".replaceAll("_1_", "" + memIndex));
		return (modemDriver.getResponse().matches("OK\\s"));
	}

	public String getGprsStatus() throws Exception
	{
		modemDriver.write("AT+CGATT?\r");
		return modemDriver.getResponse();
	}

	public String send(String s) throws Exception
	{
		modemDriver.write(s);
		return modemDriver.getResponse();
	}

	public String getNetworkRegistration() throws Exception
	{
		modemDriver.write("AT+CREG?\r");
		return modemDriver.getResponse();
	}

	public void readStorageLocations() throws Exception
	{
		String response, loc;
		StringTokenizer tokens;

		modemDriver.write("AT+CPMS?\r");
		response = modemDriver.getResponse();
		if (response.indexOf("+CPMS:") >= 0)
		{
			response = response.replaceAll("\\s*\\+CPMS:\\s*", "");
			tokens = new StringTokenizer(response, ",");
			while (tokens.hasMoreTokens())
			{
				loc = tokens.nextToken().replaceAll("\"", "");
				if (storageLocations.indexOf(loc) < 0) storageLocations += loc;
				tokens.nextToken();
				tokens.nextToken();
			}
		}
	}

	public org.smslib.gateway.ModemDriver.AsyncEvents processUnsolicitedEvents(String response) throws Exception
	{
		org.smslib.gateway.ModemDriver.AsyncEvents event = org.smslib.gateway.ModemDriver.AsyncEvents.Nothing;

		if (response.indexOf("+CMTI") == 0) event = org.smslib.gateway.ModemDriver.AsyncEvents.InboundMessage;
		else if (response.indexOf("+CDSI") == 0) event = org.smslib.gateway.ModemDriver.AsyncEvents.InboundStatusReportMessage;
		else if (response.indexOf("RING") == 0) event = org.smslib.gateway.ModemDriver.AsyncEvents.Nothing;
		else if (response.indexOf("+CLIP") == 0)
		{
			gateway.getModemDriver().write("ATH\r");
			event = org.smslib.gateway.ModemDriver.AsyncEvents.InboundCall;
		}
		if (event != org.smslib.gateway.ModemDriver.AsyncEvents.Nothing) asyncEventResponse = response;
		return event;
	}

	public String getAsyncEventResponse(org.smslib.gateway.ModemDriver.AsyncEvents event) throws Exception
	{
		String response = "";

		switch (event)
		{
			case Nothing:
				break;
			case InboundMessage:
				response = asyncEventResponse;
				break;
			case InboundStatusReportMessage:
				response = asyncEventResponse;
				break;
			case InboundCall:
				response = asyncEventResponse;
				gateway.getModemDriver().getResponse();
				break;
			default:
				throw new org.smslib.OopsException();
		}
		return response;
	}
}