cservice.java

Sending and receiving of SMS using Java

											{
												duplicate = false;
												for (l = 0; l < tmpList.size(); l++)
												{
													listMsg = (CIncomingMessage) tmpList.get(l);
													if (listMsg.getMpSeqNo() == msg.getMpSeqNo())
													{
														duplicate = true;
														break;
													}
												}
												if (!duplicate) tmpList.add(msg);
												found = true;
												break;
											}
										}
										if (!found)
										{
											tmpList = new LinkedList();
											tmpList.add(msg);
											mpMsgList.add(tmpList);
										}
									}
								}
								else if (isStatusReportMessage(pdu))
								{
									messageList.add(new CStatusReportMessage(pdu, memIndex, atHandler.storageLocations.substring((ml * 2), (ml * 2) + 2)));
									deviceInfo.getStatistics().incTotalIn();
								}
							}
							catch (Exception e)
							{
								if (log != null)
								{
									log.error("*****");
									log.error("Unhandled SMS in inbox, skipping!");
									log.error("Err: " + e.getMessage());
									log.error("*****");
								}
							}
							line = reader.readLine().trim();
							while (line.length() == 0)
								line = reader.readLine().trim();
							if ((limit > 0) && (messageList.size() == limit)) break;
						}
						reader.close();
					}
				}
			}
			else throw new NotConnectedException();
		}
		checkMpMsgList(messageList);
	}

	//@SuppressWarnings("unchecked")
	private void readMessages_TEXT(LinkedList messageList, int messageClass, int limit) throws Exception
	{
		int i, j, memIndex;
		byte[] bytes;
		String response, line, msgText, originator, dateStr, refNo;
		BufferedReader reader;
		StringTokenizer tokens;
		CIncomingMessage msg;
		Calendar cal1 = Calendar.getInstance();
		Calendar cal2 = Calendar.getInstance();

		if (limit < 0) limit = 0;
		synchronized (_SYNC_)
		{
			if (getConnected())
			{
				atHandler.switchToCmdMode();
				for (int ml = 0; ml < (atHandler.storageLocations.length() / 2); ml++)
				{
					if (atHandler.setMemoryLocation(atHandler.storageLocations.substring((ml * 2), (ml * 2) + 2)))
					{
						response = atHandler.listMessages(messageClass);
						response = response.replaceAll("\\s+OK\\s+", "\nOK");
						reader = new BufferedReader(new StringReader(response));
						for (;;)
						{
							line = reader.readLine().trim();
							if (line == null) break;
							line = line.trim();
							if (line.length() > 0) break;
						}
						while (true)
						{
							if (line == null) break;
							line = line.trim();
							if (line.length() <= 0 || line.equalsIgnoreCase("OK")) break;
							i = line.indexOf(':');
							j = line.indexOf(',');
							memIndex = Integer.parseInt(line.substring(i + 1, j).trim());
							tokens = new StringTokenizer(line, ",");
							tokens.nextToken();
							tokens.nextToken();
							if (Character.isDigit(tokens.nextToken().trim().charAt(0)))
							{
								line = line.replaceAll(",,", ", ,");
								tokens = new StringTokenizer(line, ",");
								tokens.nextToken();
								tokens.nextToken();
								tokens.nextToken();
								refNo = tokens.nextToken();
								tokens.nextToken();
								dateStr = tokens.nextToken().replaceAll("\"", "");
								cal1.set(Calendar.YEAR, 2000 + Integer.parseInt(dateStr.substring(0, 2)));
								cal1.set(Calendar.MONTH, Integer.parseInt(dateStr.substring(3, 5)) - 1);
								cal1.set(Calendar.DAY_OF_MONTH, Integer.parseInt(dateStr.substring(6, 8)));
								dateStr = tokens.nextToken().replaceAll("\"", "");
								cal1.set(Calendar.HOUR_OF_DAY, Integer.parseInt(dateStr.substring(0, 2)));
								cal1.set(Calendar.MINUTE, Integer.parseInt(dateStr.substring(3, 5)));
								cal1.set(Calendar.SECOND, Integer.parseInt(dateStr.substring(6, 8)));
								dateStr = tokens.nextToken().replaceAll("\"", "");
								cal2.set(Calendar.YEAR, 2000 + Integer.parseInt(dateStr.substring(0, 2)));
								cal2.set(Calendar.MONTH, Integer.parseInt(dateStr.substring(3, 5)) - 1);
								cal2.set(Calendar.DAY_OF_MONTH, Integer.parseInt(dateStr.substring(6, 8)));
								dateStr = tokens.nextToken().replaceAll("\"", "");
								cal2.set(Calendar.HOUR_OF_DAY, Integer.parseInt(dateStr.substring(0, 2)));
								cal2.set(Calendar.MINUTE, Integer.parseInt(dateStr.substring(3, 5)));
								cal2.set(Calendar.SECOND, Integer.parseInt(dateStr.substring(6, 8)));

								msg = new CStatusReportMessage(Integer.parseInt(refNo), memIndex, atHandler.storageLocations.substring((ml * 2), (ml * 2) + 2), cal1.getTime(), cal2.getTime());
								if (log != null) log.debug("IN-DTLS: MI:" + msg.getMemIndex());
								messageList.add(msg);
								deviceInfo.getStatistics().incTotalIn();
							}
							else
							{
								line = line.replaceAll(",,", ", ,");
								tokens = new StringTokenizer(line, ",");
								tokens.nextToken();
								tokens.nextToken();
								originator = tokens.nextToken().replaceAll("\"", "");
								tokens.nextToken();
								dateStr = tokens.nextToken().replaceAll("\"", "");
								cal1.set(Calendar.YEAR, 2000 + Integer.parseInt(dateStr.substring(0, 2)));
								cal1.set(Calendar.MONTH, Integer.parseInt(dateStr.substring(3, 5)) - 1);
								cal1.set(Calendar.DAY_OF_MONTH, Integer.parseInt(dateStr.substring(6, 8)));
								dateStr = tokens.nextToken().replaceAll("\"", "");
								cal1.set(Calendar.HOUR_OF_DAY, Integer.parseInt(dateStr.substring(0, 2)));
								cal1.set(Calendar.MINUTE, Integer.parseInt(dateStr.substring(3, 5)));
								cal1.set(Calendar.SECOND, Integer.parseInt(dateStr.substring(6, 8)));
								msgText = reader.readLine().trim();
								bytes = new byte[msgText.length() / 2];
								j = 0;
								for (i = 0; i < msgText.length(); i += 2)
								{
									bytes[j] = Byte.parseByte(msgText.substring(i, i + 2), 16);
									j++;
								}
								msgText = CGSMAlphabet.bytesToString(bytes);
								msg = new CIncomingMessage(cal1.getTime(), originator, msgText, memIndex, atHandler.storageLocations.substring((ml * 2), (ml * 2) + 2));
								if (log != null) log.debug("IN-DTLS: MI:" + msg.getMemIndex());
								messageList.add(msg);
								deviceInfo.getStatistics().incTotalIn();
							}
							line = reader.readLine().trim();
							while (line.length() == 0)
								line = reader.readLine().trim();
						}
						reader.close();
					}
				}
			}
			else throw new NotConnectedException();
		}
	}

	//@SuppressWarnings("unchecked")
	private void checkMpMsgList(LinkedList messageList)
	{
		int k, l, m;
		LinkedList tmpList;
		CIncomingMessage listMsg, mpMsg;
		boolean found;

		mpMsg = null;
		if (log != null) log.debug("CheckMpMsgList(): MAINLIST: " + mpMsgList.size());
		for (k = 0; k < mpMsgList.size(); k++)
		{
			tmpList = (LinkedList) mpMsgList.get(k);
			if (log != null) log.debug("CheckMpMsgList(): SUBLIST[" + k + "]: " + tmpList.size());
			listMsg = (CIncomingMessage) tmpList.get(0);
			found = false;
			if (listMsg.getMpMaxNo() == tmpList.size())
			{
				found = true;
				for (l = 0; l < tmpList.size(); l++)
					for (m = 0; m < tmpList.size(); m++)
					{
						listMsg = (CIncomingMessage) tmpList.get(m);
						if (listMsg.getMpSeqNo() == (l + 1))
						{
							if (listMsg.getMpSeqNo() == 1)
							{
								mpMsg = listMsg;
								mpMsg.setMpMemIndex(mpMsg.getMemIndex());
							}
							else
							{
								if (mpMsg != null)
								{
									mpMsg.addText(listMsg.getText());
									mpMsg.setMpSeqNo(listMsg.getMpSeqNo());
									mpMsg.setMpMemIndex(listMsg.getMemIndex());
									if (listMsg.getMpSeqNo() == listMsg.getMpMaxNo())
									{
										mpMsg.setMemIndex(-1);
										messageList.add(mpMsg);
										mpMsg = null;
									}
								}
							}
							break;
						}
					}
				tmpList.clear();
				tmpList = null;
			}
			if (found)
			{
				mpMsgList.remove(k);
				k--;
			}
		}
	}

	/**
	 * Sends an SMS message from the GSM modem.
	 * <p>
	 * This method actually wraps the message in a list and calls #sendMessage(List) that does the job.
	 * 
	 * @param message
	 *            The message to be sent.
	 * @throws NotConnectedException
	 *             Either connect() is not called or modem has been disconnected.
	 * @see CService#sendMessage(LinkedList)
	 * @see CService#readMessages(LinkedList, int)
	 */
	//@SuppressWarnings("unchecked")
	public void sendMessage(COutgoingMessage message) throws Exception
	{
		LinkedList messageList;

		messageList = new LinkedList();
		messageList.add(message);
		sendMessage(messageList);
	}

	/**
	 * Sends a list of messages from the GSM modem.
	 * <p>
	 * The function iterates through the supplied list of COutgoingMessage objects and tries to send them.
	 * <p>
	 * Upon succesful sending, each COutgoingMessage object should have its RefNo and DispatchDate fields set to specific values. Upon failure, the RefNo will be set to 0 and DispatchDate set to null.
	 * 
	 * @param messageList
	 *            A list of COutgoingMessage objects presenting messages that will be sent out.
	 * @throws NotConnectedException
	 *             Either connect() is not called or modem has been disconnected.
	 * @see CService#sendMessage(COutgoingMessage)
	 * @see COutgoingMessage
	 * @see CWapSIMessage
	 * @see CService#readMessages(LinkedList, int)
	 */
	public void sendMessage(LinkedList messageList) throws Exception
	{
		switch (protocol)
		{
			case Protocol.PDU:
				sendMessage_PDU(messageList);
				break;
			case Protocol.TEXT:
				sendMessage_TEXT(messageList);
				break;
		}
	}

	private void sendMessage_PDU(LinkedList messageList) throws Exception
	{
		COutgoingMessage message;
		int i, j, refNo;
		String pdu;

		if (getConnected())
		{
			synchronized (_SYNC_)
			{
				atHandler.keepGsmLinkOpen();
			}
			for (i = 0; i < messageList.size(); i++)
			{
				message = (COutgoingMessage) messageList.get(i);
				if (!message.isBig())
				{
					pdu = message.getPDU(smscNumber, 0, 0);
					j = pdu.length();
					j /= 2;
					if (smscNumber == null) ; // Do nothing on purpose!
					else if (smscNumber.length() == 0) j--;
					else
					{
						int smscNumberLen = smscNumber.length();
						if (smscNumber.charAt(0) == '+') smscNumberLen--;
						if (smscNumberLen % 2 != 0) smscNumberLen++;
						int smscLen = (2 + smscNumberLen) / 2;
						j = j - smscLen - 1;
					}
					synchronized (_SYNC_)
					{
						refNo = atHandler.sendMessage(j, pdu, null, null);
					}
					if (refNo >= 0)
					{
						message.setRefNo(refNo);
						message.dispatchDate = new Date();
						deviceInfo.getStatistics().incTotalOut();
					}
					else if (refNo == -2)
					{
						disconnect();
						break;
					}
					else message.dispatchDate = null;
				}
				else
				{
					for (int partNo = 1; partNo <= message.getNoOfParts(); partNo++)
					{
						pdu = message.getPDU(smscNumber, outMpRefNo, partNo);
						j = pdu.length();
						j /= 2;
						if (smscNumber == null) ; // Do nothing on purpose!
						else if (smscNumber.length() == 0) j--;
						else
						{
							int smscNumberLen = smscNumber.length();
							if (smscNumber.charAt(0) == '+') smscNumberLen--;
							if (smscNumberLen % 2 != 0) smscNumberLen++;
							int smscLen = (2 + smscNumberLen) / 2;
							j = j - smscLen - 1;
						}
						synchronized (_SYNC_)
						{
							refNo = atHandler.sendMessage(j, pdu, null, null);
						}
						if (refNo >= 0)
						{
							message.setRefNo(refNo);
							message.dispatchDate = new Date();
							deviceInfo.getStatistics().incTotalOut();
						}
						else if (refNo == -2)
						{
							disconnect();
							break;
						}
						else message.dispatchDate = null;
					}
					outMpRefNo = (outMpRefNo + 1) % 65536;
				}
			}
		}
		else throw new NotConnectedException();
	}

	private void sendMessage_TEXT(LinkedList messageList) throws Exception
	{
		COutgoingMessage message;
		byte[] bytes;
		StringBuffer hexText = new StringBuffer();
		int i, j, n, refNo;

		if (getConnected())
		{
			for (i = 0; i < messageList.size(); i++)
			{
				hexText.delete(0, hexText.length());
				message = (COutgoingMessage) messageList.get(i);
				bytes = new byte[400];
				n = CGSMAlphabet.stringToBytes(message.getText(), bytes);
				for (j = 0; j < n; j++)
					hexText.append(Integer.toHexString(bytes[j]).toUpperCase());
				synchronized (_SYNC_)
				{
					refNo = atHandler.sendMessage(0, null, message.getRecipient(), hexText.toString());
				}
				if (refNo >= 0)
				{
					message.setRefNo(refNo);
					message.dispatchDate = new Date();
					deviceInfo.getStatistics().incTotalOut();
				}
				else message.dispatchDate = null;
			}
		}
		else throw new NotConnectedException();
	}

	protected void deleteMessage(int memIndex, String memLocation) throws Exception
	{
		synchronized (_SYNC_)
		{
			if (getConnected()) atHandler.deleteMessage(memIndex, memLocation);
			else throw new NotConnectedException();
		}
	}

	/**
	 * Deletes a message from the modem's memory.
	 * <p>
	 * <strong>Warning</strong>: Do not pass invalid CIncomingMessage objects to this call - You may corrupt your modem's storage!
	 * <p>
	 * Delete operations are irreversible.
	 * 
	 * @param message
	 *            The CIncomingMessage object previously read with readMessages() call.
	 * @throws NotConnectedException
	 *             Either connect() is not called or modem has been disconnected.
	 * @see CIncomingMessage
	 * @see CService#readMessages(LinkedList, int)
	 */