cathandler_wavecom_m1306b.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.handler;

import org.smslib.*;
import org.apache.log4j.*;

public class CATHandler_Wavecom_M1306B extends CATHandler_Wavecom
{
	public CATHandler_Wavecom_M1306B(CSerialDriver serialDriver, Logger log, CService srv)
	{
		super(serialDriver, log, srv);
		log.warn("****************************************************");
		log.warn("* You are using Wavecom M1306B experimental driver *");
		log.warn("");
		log.warn("Its better to use the standard Wavecom Handler");
		log.warn(" unless you know and understand the differences.");
		log.warn("****************************************************");
	}

	protected void reset() throws Exception
	{
		serialDriver.send("AT+CFUN=1\r");
		Thread.sleep(20000);
		serialDriver.clearBuffer();
	}

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

		errorRetries = 0;
		while (true)
		{
			responseRetries = 0;
			serialDriver.send("AT+CMGS=\"{1}\"\r".replace("\"{1}\"", "" + size));
			Thread.sleep(300);
			while (!serialDriver.dataAvailable())
			{
				responseRetries++;
				if (responseRetries == srv.getRetriesNoResponse()) throw new NoResponseException();
				log.warn("ATHandler().SendMessage(): Still waiting for response (I) (" + responseRetries + ")...");
				Thread.sleep(srv.getDelayNoResponse());
			}
			responseRetries = 0;
			serialDriver.clearBuffer();
			serialDriver.send(pdu);
			serialDriver.send((char) 26);
			response = serialDriver.getResponse();
			while (response.length() == 0)
			{
				responseRetries++;
				if (responseRetries == srv.getRetriesNoResponse()) throw new NoResponseException();
				log.warn("ATHandler().SendMessage(): Still waiting for response (II) (" + responseRetries + ")...");
				Thread.sleep(srv.getDelayNoResponse());
				response = serialDriver.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);
				break;
			}
			else if (response.indexOf("ERROR") >= 0)
			{
				String err = response.replaceAll("\\s+", "");
				errorRetries++;
				if (errorRetries == srv.getRetriesCmsErrors())
				{
					log.error("CMS Errors [ " + err + " ]: Quit retrying, message lost...");
					refNo = -2;
					break;
				}
				else
				{
					log.error("CMS Errors [ " + err + " ]: Retrying...");
					Thread.sleep(srv.getDelayCmsErrors());
				}
			}
			else refNo = -1;
		}
		return refNo;
	}
}