Envio de mensagem para celular

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package modems;

import banco.centralsms.objetos.ModemsTbl;

import gnu.io.SerialPort;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.ArrayList;
import log.Log;
import xml.Mensagem;

/**
 *
 * @author ricoldi
 */
public class ModemSerial {

    private static final String ENTER = "\r\n";
    private SerialPort porta;
    private ModemsTbl dados;

    public ModemSerial(SerialPort porta) throws Exception {
        this.porta = porta;
        setEco("0");
    }

    public ModemsTbl getDados() {
        return dados;
    }

    public void setDados(ModemsTbl dados) {
        this.dados = dados;
    }

    private void comandoEnviar(String _comando) throws IOException {
        OutputStream saida = porta.getOutputStream();
        saida.write(_comando.getBytes());
        try {
            Thread.sleep(1000);
        } catch (Exception e) {
        }
    }

    private String comandoReceber() throws IOException {
        int timeout = 10;

        InputStream entrada = porta.getInputStream();
        StringBuilder resposta = new StringBuilder();

        byte[] buffer;
        int tamanho = 0;
        while (timeout > 0 || ((tamanho = entrada.available()) > 0)) {

            if (tamanho > 0) {
                buffer = new byte[tamanho];
                entrada.read(buffer);
                resposta.append(new String(buffer).trim());
            } else {
                if (timeout > 0) {
                    timeout--;
                    try {
                        Thread.sleep(10);
                    } catch (Exception e) {
                    }
                } else {
                    throw new IOException("TIMEOUT AO RECEBER COMANDO");
                }
            }
        }

        try {
            Thread.sleep(1000);
        } catch (Exception e) {
        }

        return resposta.toString();
    }

    public boolean setEco(String tipo) throws Exception {
        synchronized (this) {
            comandoEnviar("ATE" + tipo + ENTER);
            return comandoReceber().contains("OK");
            
        }
    }

    public String getImei() throws Exception {
        synchronized (this) {
            comandoEnviar("AT+CGSN" + ENTER);
            String imei = comandoReceber();
            imei = imei.substring(imei.indexOf("\"") + 1, imei.lastIndexOf("\""));
            return imei;
        }
    }

    public String getSinal() {
        synchronized (this) {
            try {
                comandoEnviar("AT+CSQ" + ENTER);
                String resposta = comandoReceber();
                resposta = resposta.substring(resposta.indexOf(": ") + 1, resposta.indexOf("OK")).trim();
                return resposta;
            } catch (Exception e) {
                Log.escreveLog(e);
            }
            return "<Erro>";
        }
    }

    public boolean deletarTodas() {
        synchronized (this) {
            try {

                comandoEnviar("AT+CMGD=1,4" + ENTER);
                return comandoReceber().toUpperCase().contains("OK");
            } catch (Exception e) {
                Log.escreveLog(e);
            }
            return false;
        }
    }

    public boolean modoTexto() {
        synchronized (this) {
            try {
                comandoEnviar("AT+CMGF=1" + ENTER);
                return comandoReceber().toUpperCase().contains("OK");
            } catch (Exception e) {
                e.printStackTrace();
            }
            return false;
        }
    }

    public boolean enviaSMS(String numero, String mensagem) {
        if (numero == null || numero.length() == 0) {
            return false;
        }

        if (mensagem == null || mensagem.length() == 0) {
            return false;
        }

        synchronized (this) {
            try {

                mensagem = retiraAcentos(mensagem);
                mensagem = mensagem.replaceAll("\n", " ");
                mensagem = mensagem.replaceAll("\r", " ");

                ArrayList<String> msgs = split(mensagem, 140);
                String msgShort;
                String contador;
                for (int cont = 0; cont < msgs.size(); cont++) {
                    if (msgs.size() > 1) {
                        contador = " - [" + (cont + 1) + "/" + msgs.size() + "]";
                    } else {
                        contador = "";
                    }
                    msgShort = msgs.get(cont) + contador;

                    comandoEnviar("AT+CMGS=\"" + numero + "\"\r");
                    comandoEnviar(msgShort + "\032\r");
                    Log.escreveLog("Modem: envio para modem: " + numero + "<" + msgShort + ">");

                    try {
                        Thread.sleep(10000);
                    } catch (Exception e) {
                    }
                    msgShort = comandoReceber();
                    Log.escreveLog("Modem: envio do modem: <" + msgShort + ">");

                    if (!msgShort.toUpperCase().contains("OK")) {
                        return false;
                    }
                }

                return true;

            } catch (Exception e) {
                Log.escreveLog(e);
            }
            return false;
        }
    }

    private String retiraAcentos(String _texto) {
        String retirar = "ÀÁÂÃÄÅÇÈÉÊËÌÍÎÏÒÓÔÕÖÙÚÛÜàáâãäåçèéêëìíîïòóôõöùúûüñÑ";
        String substituir = "AAAAAACEEEEIIIIOOOOOUUUUaaaaaaceeeeiiiiooooouuuunN";

        int cont = 0;
        while (cont < retirar.length()) {
            _texto = _texto.replace(retirar.charAt(cont), substituir.charAt(cont));
            cont++;
        }
        return _texto;
    }

    private ArrayList<String> split(String mensagem, int max) {
        ArrayList<String> mensagens = new ArrayList<String>();

        String[] palavras = mensagem.split(" ");
        String subMensagem = "";
        int cont = 0;
        while (cont < palavras.length) {
            if ((subMensagem.length() + palavras[cont].length()) < max) {
                subMensagem += palavras[cont] + " ";
                cont++;
            } else {
                if (subMensagem.length() > 0) {
                    mensagens.add(subMensagem.trim());
                    subMensagem = "";
                }
                if (palavras[cont].length() >= max) {
                    mensagens.add(palavras[cont].substring(0, max));
                    subMensagem = "";
                    palavras[cont] = palavras[cont].substring(max);
                }
            }
        }

        if (subMensagem.length() > 0) {
            mensagens.add(subMensagem.trim());
        }

        return mensagens;
    }

    public ArrayList<Mensagem> recebeSMS() {
        synchronized (this) {
            try {

                ArrayList<Mensagem> mensagens = new ArrayList<Mensagem>();

                comandoEnviar("AT+CMGL=\"REC UNREAD\"" + ENTER);
                try {
                    Thread.sleep(10000);
                } catch (Exception e) {
                }
                String recebido = comandoReceber();

                recebido = recebido.trim();

                if (recebido.length() > 0) {

                    Log.escreveLog("Modem: recebido: <" + recebido + ">");

                    Mensagem mensagem;
                    String[] cmgl = recebido.split("CMGL");
                    String[] virgula;
                    String[] msgarray;
                    String msgtxt;
                    int negativo;
                    for (int cont = 0; cont < cmgl.length; cont++) {
                        cmgl[cont] = cmgl[cont].trim();
                        if (!cmgl[cont].equalsIgnoreCase("ok")) {
                            try {
                                if (cmgl[cont].contains(",")) {
                                    virgula = cmgl[cont].split(",");
                                    if ((virgula[1].equalsIgnoreCase("\"REC UNREAD\"")) && (virgula[2].length() > 5)) {
                                        mensagem = new Mensagem();
                                        mensagem.setDestinatario(String.valueOf(dados.getNumero()));

                                        if (virgula[2].startsWith("55") && virgula[2].length() == 12) {
                                            virgula[2] = virgula[2].substring(2);

                                        }

                                        mensagem.setRemetente(virgula[2].replaceAll("\"", "").substring(1));
                                        mensagem.setData(virgula[4].replaceAll("\"", ""));
                                        msgarray = virgula[5].split("\"");

                                        msgarray[0] = msgarray[0].replaceAll("\"", "");
                                        negativo = msgarray[0].indexOf("-");
                                        if (negativo > 0) {
                                            msgarray[0] = msgarray[0].substring(0, negativo);
                                        }
                                        mensagem.setHora(msgarray[0]);

                                        msgtxt = "";
                                        if (msgarray.length > 1) {
                                            for (int cont3 = 1; cont3 < msgarray.length; cont3++) {
                                                msgtxt += msgarray[cont3].replaceFirst("\r", "");
                                            }
                                        }
                                        if (virgula.length > 6) {
                                            for (int cont4 = 6; cont < virgula.length; cont++) {
                                                msgtxt += msgarray[cont4];
                                            }
                                        }
                                        if (cont + 1 == cmgl.length) {
                                            if (msgtxt.endsWith("OK")) {
                                                msgtxt = msgtxt.substring(0, msgtxt.length() - 2);
                                            }
                                        } else {
                                            if (msgtxt.endsWith("+")) {
                                                msgtxt = msgtxt.substring(0, msgtxt.length() - 1);
                                            }

                                        }
                                        mensagem.setMensagem(msgtxt.trim());
                                        mensagens.add(mensagem);

                                    }
                                }
                            } catch (Exception e) {
                                Log.escreveLog(e);
                            }

                        }
                    }

                }
                return mensagens;
            } catch (Exception e) {
                Log.escreveLog(e);
            }
            return null;
        }

    }
}