socket php

[bruno nozé 0]

alguem pode me judar com este socket, preciso pegar as informações que vem na string 12 deste equipamento, como faço isso?

 

 

#!/usr/bin/php -q

<?php

//waiting for system startup

//crontab: @reboot php -q /var/www/server/tracker.php

//sleep (180);

/**

* Listens for requests and forks on each connection

*/

$tipoLog = "arquivo"; // tela //debug log, escreve na tela ou no arquivo de log.

$fh = null;

$remip = null;

$remport = null;

$imei = '';

/*if ($tipoLog == "arquivo") {

//Criando arquivo de log

$fn = $_SERVER['DOCUMENT_ROOT']."/sites/1/logs/" . "Log_". date("dmyhis") .".log";

$fh = fopen($fn, 'w') or die ("Can not create file");

$tempstr = "Log Inicio".chr(13).chr(10);

fwrite($fh, $tempstr);

}*/

function abrirArquivoLog($imeiLog) {

GLOBAL $fh;

//$fn = ".".dirname(__FILE__)."/sites/1/logs/Log_". trim($imeiLog) .".log";

$fn = "./var/www/sites/1/logs/Log_". trim($imeiLog) .".log";

$fn = trim($fn);

$fh = fopen($fn, 'a') or die ("Can not create file");

$tempstr = "Log Inicio".chr(13).chr(10);

fwrite($fh, $tempstr);

}

function fecharArquivoLog() {

GLOBAL $fh;

if ($fh != null)

fclose($fh);

}

function printLog( $fh, $mensagem ) {

GLOBAL $tipoLog;

GLOBAL $fh;

if ($tipoLog == "arquivo") {

//escreve no arquivo

if ($fh != null)

fwrite($fh, $mensagem.chr(13).chr(10));

} else {

//escreve na tela

echo $mensagem."<br />";

}

}

//$cnx = mysql_connect("localhost", "user1", "pass1")

// or die("Could not connect: " . mysql_error());

//mysql_select_db('tracker', $cnx);

//$res = mysql_query("select valor from preferencias where nome = 'host_apn'", $cnx);

//$dataIp = mysql_fetch_assoc($res);

//$res = mysql_query("select valor from preferencias where nome = 'port_apn'", $cnx);

//$dataPorta = mysql_fetch_assoc($res);

//$res = mysql_query("select valor from preferencias where nome = 'email_alertas'", $cnx);

//$dataEmail = mysql_fetch_assoc($res);

// IP Local

//$ip = $dataIp['valor'];

$ip = '23.89.198.254';

// Port

//$port = $dataPorta['valor'];

$port = '7095';

// Path to look for files with commands to send

$command_path = "./var/www/sites/1/";

//$from_email = $dataEmail['valor'];

$from_email = 'josenilsontrindade@gmail.com';

//mysql_close($cnx);

$__server_listening = true;

error_reporting(E_ALL);

set_time_limit(0);

ob_implicit_flush();

declare(ticks = 1);

ini_set('sendmail_from', $from_email);

//printLog($fh, "become_daemon() in");

become_daemon();

//printLog($fh, "become_daemon() out");

/* nobody/nogroup, change to your host's uid/gid of the non-priv user

** Comment by Andrew - I could not get this to work, i commented it out

the code still works fine but mine does not run as a priv user anyway....

uncommented for completeness

*/

//change_identity(65534, 65534);

/* handle signals */

pcntl_signal(SIGTERM, 'sig_handler');

pcntl_signal(SIGINT, 'sig_handler');

pcntl_signal(SIGCHLD, 'sig_handler');

//printLog($fh, "pcntl_signal ok");

/* change this to your own host / port */

//printLog($fh, "server_loop in");

server_loop($ip, $port);

//Finalizando arquivo

//fclose($fh);

/**

* Change the identity to a non-priv user

*/

function change_identity( $uid, $gid ) {

if( !posix_setgid( $gid ) ) {

print "Unable to setgid to " . $gid . "!\n";

exit;

}

if( !posix_setuid( $uid ) ) {

print "Unable to setuid to " . $uid . "!\n";

exit;

}

}

/**

* Creates a server socket and listens for incoming client connections

* @param string $address The address to listen on

* @param int $port The port to listen on

*/

function server_loop($address, $port) {

GLOBAL $fh;

GLOBAL $__server_listening;

printLog($fh, "server_looping...");

if(($sock = socket_create(AF_INET, SOCK_STREAM, 0)) < 0) {

printLog($fh, "failed to create socket: ".socket_strerror($sock));

exit();

}

if(($ret = socket_bind($sock, $address, $port)) < 0) {

printLog($fh, "failed to bind socket: ".socket_strerror($ret));

exit();

}

if( ( $ret = socket_listen( $sock, 0 ) ) < 0 ) {

printLog($fh, "failed to listen to socket: ".socket_strerror($ret));

exit();

}

socket_set_nonblock($sock);

printLog($fh, "waiting for clients to connect...");

while ($__server_listening) {

$connection = @socket_accept($sock);

if ($connection === false) {

usleep(100);

} elseif ($connection > 0) {

handle_client($sock, $connection);

} else {

printLog($fh, "error: ".socket_strerror($connection));

die;

}

}

}

/**

* Signal handler

*/

function sig_handler($sig) {

switch($sig) {

case SIGTERM:

case SIGINT:

//exit();

break;

case SIGCHLD:

pcntl_waitpid(-1, $status);

break;

}

}

$firstInteraction = false;

/**

* Handle a new client connection

*/

function handle_client($ssock, $csock) {

GLOBAL $__server_listening;

GLOBAL $fh;

GLOBAL $firstInteraction;

GLOBAL $remip;

GLOBAL $remport;

$pid = pcntl_fork();

if ($pid == -1) {

/* fork failed */

//printLog($fh, "fork failure!");

die;

} elseif ($pid == 0) {

/* child process */

$__server_listening = false;

socket_getpeername($csock, $remip, $remport);

//printLog($fh, date("d-m-y h:i:sa") . " Connection from $remip:$remport");

$firstInteraction = true;

socket_close($ssock);

interact($csock);

socket_close($csock);

printLog($fh, date("d-m-y h:i:sa") . " Connection to $remip:$remport closed");

fecharArquivoLog();

} else {

socket_close($csock);

}

}

function interact($socket) {

GLOBAL $fh;

GLOBAL $command_path;

GLOBAL $firstInteraction;

GLOBAL $remip;

GLOBAL $remport;

$loopcount = 0;

$conn_imei = "";

/* TALK TO YOUR CLIENT */

$rec = "";

// Variavel que indica se comando est� em banco ou arquivo.

$tipoComando = "arquivo"; //"arquivo";

//Checando o protocolo

$isGIMEI = false;

$isGPRMC = false;

$send_cmd = "";

# Read the socket but don't wait for data..

while (@socket_recv($socket, $rec, 2048, 0x40) !== 0) {

# If we know the imei of the phone and there is a pending command send it.

if ($conn_imei != "") {

if ($tipoComando == "arquivo" and file_exists("$command_path/$conn_imei")) {

$send_cmd = file_get_contents("$command_path/$conn_imei");

socket_send($socket, $send_cmd, strlen($send_cmd), 0);

unlink("$command_path/$conn_imei");

printLog($fh, "Arquivo de comandos apagado: " . $send_cmd . " imei: " . $conn_imei);

} else {

if ($tipoComando == "banco" and file_exists("$command_path/$conn_imei")) {

//Conecta e pega o comando pendente

$cnx = mysql_connect("localhost", "user1", "pass1")

or die("Could not connect: " . mysql_error());

mysql_select_db('tracker', $cnx);

$res = mysql_query("SELECT c.command FROM command c WHERE c.imei = '$conn_imei' ORDER BY date DESC LIMIT 1", $cnx);

while($data = mysql_fetch_assoc($res)) {

$send_cmd = $data['command'];

echo 'acessou o comando';

}

// Deletando comando

//mysql_query("DELETE FROM command WHERE imei = $conn_imei");

mysql_close($cnx);

socket_send($socket, $send_cmd, strlen($send_cmd), 0);

unlink("$command_path/$conn_imei");

printLog($fh, "Comandos do arquivo apagado: " . $send_cmd . " imei: " . $conn_imei);

}

else

{

//Se nao tiver comando na fila e for a primeira iteracao, obtem o ultimo comando v�lido enviado

if ($firstInteraction == true) {

sleep (1);

$send_cmd = "**,imei:". $conn_imei .",C,02m";

//Obtendo o ultimo comando

$cnx = mysql_connect("localhost", "user1", "pass1")

or die("Could not connect: " . mysql_error());

mysql_select_db('tracker', $cnx);

$res = mysql_query("SELECT c.command FROM command c WHERE c.command like '**,imei:". $conn_imei .",C,%' and c.imei = $conn_imei ORDER BY date DESC LIMIT 1", $cnx);

while($data = mysql_fetch_assoc($res)) {

$send_cmd = $data['command'];

}

mysql_close($cnx);

socket_send($socket, $send_cmd, strlen($send_cmd), 0);

printLog($fh, "Comando de start: " . $send_cmd . " imei: " . $conn_imei);

$firstInteraction = false;

}

}

}

// Comando enviado

printLog($fh, date("d-m-y h:i:sa") . " Sent: $send_cmd");

}

# Some pacing to ensure we don't split any incoming data.

sleep (1);

# Timeout the socket if it's not talking...

# Prevents duplicate connections, confusing the send commands

$loopcount++;

if ($loopcount > 120) return;

#remove any whitespace from ends of string.

$cnx = mysql_connect("localhost", "user1", "pass1");

mysql_select_db('tracker', $cnx);

if ($rec != "") {

$rec = trim($rec);

if (strpos($rec, "GPRMC") === false) {

/* M�DULO IMEI GEN�RICO */

$isGIMEI = true;

$loopcount = 0;

if ($fh != null)

printLog($fh, date("d-m-y h:i:sa") . " Got : $rec");

$parts = explode(',',$rec);

if (strpos($parts[0], "#") === FALSE) {

/* Andrew's tracker is different....

Array

(

[0] => imei:354779030525274

[1] => tracker

[2] => 0909221022

[3] => +61417801658

[4] => F

[5] => 022234.000

[6] => A

[7] => 3506.5232

[8] => S

[9] => 13829.5988

[10] => E

[11] => 0.00

[12] =>

)

*/

# $imei = substr($parts[0],0, -1);

# Only worry about the rest if there is data to get

if (count($parts) > 1) {

$imei = substr($parts[0],5);

$infotext = mysql_real_escape_string($parts[1]);

$trackerdate = mysql_real_escape_string($parts[2]);

$gpsSignalIndicator = mysql_real_escape_string($parts[4]);

$speed = 0;

//Se gpsSignalIndicator <> L, pega o outros dados

if ($gpsSignalIndicator != 'L') {

$phone = mysql_real_escape_string($parts[3]);

$satelliteFixStatus = mysql_real_escape_string($parts[6]);

$latitudeDecimalDegrees = mysql_real_escape_string($parts[7]);

$latitudeHemisphere = mysql_real_escape_string($parts[8]);

$longitudeDecimalDegrees = mysql_real_escape_string($parts[9]);

$longitudeHemisphere = mysql_real_escape_string($parts[10]);

$speed = mysql_real_escape_string($parts[11]);

}

//inicio verifica geofence

mysql_select_db('tracker', $cnx);

$texto_sms_localiza = "";

$texto_sms_alerta_hodometro = "";

$texto_sms_alerta = "";

$result = mysql_query("select * from preferencias", $cnx);

while ($dataPref = mysql_fetch_assoc($result)){

if($dataPref['nome'] == 'texto_sms_localiza')

$texto_sms_localiza = $dataPref['valor'];

if($dataPref['nome'] == 'texto_sms_alerta_hodometro')

$texto_sms_alerta_hodometro = $dataPref['valor'];

if($dataPref['nome'] == 'texto_sms_alerta')

$texto_sms_alerta = $dataPref['valor'];

}

if ( $imei != "" ) {

$consulta = mysql_query("SELECT * FROM geo_fence WHERE imei = '$imei'", $cnx);

while($data = mysql_fetch_assoc($consulta)) {

$idCerca = $data['id'];

$imeiCerca = $data['imei'];

$nomeCerca = $data['nome'];

$coordenadasCerca = $data['coordenadas'];

$resultCerca = $data['tipo'];

$tipoEnvio = $data['tipoEnvio'];

strlen($latitudeDecimalDegrees) == 9 && $latitudeDecimalDegrees = '0'.$latitudeDecimalDegrees;

$g = substr($latitudeDecimalDegrees,0,3);

$d = substr($latitudeDecimalDegrees,3);

$strLatitudeDecimalDegrees = $g + ($d/60);

$latitudeHemisphere == "S" && $strLatitudeDecimalDegrees = $strLatitudeDecimalDegrees * -1;

strlen($longitudeDecimalDegrees) == 9 && $longitudeDecimalDegrees = '0'.$longitudeDecimalDegrees;

$g = substr($longitudeDecimalDegrees,0,3);

$d = substr($longitudeDecimalDegrees,3);

$strLongitudeDecimalDegrees = $g + ($d/60);

$longitudeHemisphere == "S" && $strLongitudeDecimalDegrees = $strLongitudeDecimalDegrees * -1;

$strLongitudeDecimalDegrees = $strLongitudeDecimalDegrees * -1;

$lat_point = $strLatitudeDecimalDegrees;

$lng_point = $strLongitudeDecimalDegrees;

$exp = explode("|", $coordenadasCerca);

if( ( count($exp) ) < 5 ) {

$strExp = explode(",", $exp[0]);

$strExp1 = explode(",", $exp[2]);

} else {

$int = (count($exp)) / 2;

$strExp = explode(",", $exp[0]);

$strExp1 = explode(",", $exp[$int]);

}

$lat_vertice_1 = $strExp[0];

$lng_vertice_1 = $strExp[1];

$lat_vertice_2 = $strExp1[0];

$lng_vertice_2 = $strExp1[1];

if ( $lat_vertice_1 < $lat_point Or $lat_point < $lat_vertice_2 And $lng_point < $lng_vertice_1 Or $lng_vertice_2 < $lng_point ) {

$result = '0';

$situacao = 'fora';

} else {

$result = '1';

$situacao = 'dentro';

}

if ( $result <> $resultCerca And round($speed * 1.852,0) > 0 ) {

mysql_query("INSERT INTO message (imei, message) VALUES ('$imei', 'Cerca ". $nomeCerca ." Violada!')", $cnx);

if ( $tipoEnvio == 0 ) {

# Convert the GPS coordinates to a human readable address

$tempstr = "http://www.systemtracker.com.br\">www.systemtracker.com.br</a></p>";

$msg .= "</body>";

$msg .= "</html>";

$mail = new PHPMailer();

$mail->Mailer = "smtp";

$mail->IsHTML(true);

$mail->CharSet = "utf-8";

$mail->SMTPSecure = "tls";

$mail->Host = "smtp.gmail.com";

$mail->Port = "587";

$mail->SMTPAuth = "true";

$mail->Username = "josenilsontrindade@gmail.com";

$mail->Password = "jnt99971387";

$mail->From = "josenilsontrindade@gmail.com";

$mail->FromName = "System Tracker";

$mail->AddAddress($emailDestino);

$mail->AddReplyTo($mail->From, $mail->FromName);

$mail->Subject = "System Tracker - Alerta de Violacao de Perimetro";

$mail->Body = $msg;

if (!$mail->Send()) {

echo "Erro de envio: ". $mail->ErrorInfo;

} else {

echo "Mensagem enviada com sucesso!";

}

}

}

}

}

} // if imei

//final verifica geofence

$dataBem = null;

$dataCliente = null;

$resBem = mysql_query("select id, cliente, envia_sms, name, alerta_hodometro, alerta_hodometro_saldo from bem where imei = '$imei'", $cnx);

$dataBem = mysql_fetch_assoc($resBem);

$resCliente = mysql_query("select id, celular, dt_ultm_sms, envia_sms, sms_acada, hour(timediff(now(), dt_ultm_sms)) horas, minute(timediff(now(), dt_ultm_sms)) minutos, nome from cliente where id = $dataBem[cliente]", $cnx);

$dataCliente = mysql_fetch_assoc($resCliente);

# Write it to the database...

if ($gpsSignalIndicator != 'L') {

$movimento = '';

if($speed > 0)

$movimento = 'S';

else

$movimento = 'N';

$gpsLat = gprsToGps($latitudeDecimalDegrees, $latitudeHemisphere);

$gpsLon = gprsToGps($longitudeDecimalDegrees, $longitudeHemisphere);

$gpsLatAnt = 0;

$gpsLatHemAnt = '';

$gpsLonAnt = 0;

$gpsLonHemAnt = '';

$alertaACadaSaldo = 0;

$resLocAtual = mysql_query("select id, latitudeDecimalDegrees, latitudeHemisphere, longitudeDecimalDegrees, longitudeHemisphere from loc_atual where imei = '$imei' limit 1", $cnx);

$numRows = mysql_num_rows($resLocAtual);

if($numRows == 0){

//mysql_query("insert into logs evento values ('ok') ");

mysql_query("INSERT INTO loc_atual (date, imei, phone, satelliteFixStatus, latitudeDecimalDegrees, latitudeHemisphere, longitudeDecimalDegrees, longitudeHemisphere, speed, infotext, gpsSignalIndicator, converte) VALUES (now(), '$imei', '$phone', '$satelliteFixStatus', '$latitudeDecimalDegrees', '$latitudeHemisphere', '$longitudeDecimalDegrees', '$longitudeHemisphere', '$speed', '$infotext', '$gpsSignalIndicator', 1)", $cnx);

} else {

mysql_query("UPDATE loc_atual set date = now(), phone = '$phone', satelliteFixStatus = '$satelliteFixStatus', latitudeDecimalDegrees = '$latitudeDecimalDegrees', latitudeHemisphere = '$latitudeHemisphere', longitudeDecimalDegrees = '$longitudeDecimalDegrees', longitudeHemisphere = '$longitudeHemisphere', speed = '$speed', infotext = '$infotext', gpsSignalIndicator = '$gpsSignalIndicator' where imei = '$imei'", $cnx);

}

$distance = 0;

try{

$bemId = $dataBem[id];

$countGeoDistance = mysql_query("select bem from geo_distance where bem = $bemId", $cnx);

if($countGeoDistance === false || mysql_num_rows($countGeoDistance) == 0) {

mysql_query("insert into geo_distance (bem, tipo) values($bemId, 'I')", $cnx);

mysql_query("insert into geo_distance (bem, tipo) values($bemId, 'F')", $cnx);

}

/*envio de sms*/

if($dataCliente['envia_sms'] == 'S' && $dataBem['envia_sms'] == 'S' && !empty($dataCliente['celular']) && !empty($dataCliente['sms_acada'])){

if(empty($dataCliente['dt_ultm_sms'])){

mysql_query("update cliente set dt_ultm_sms = now() where id = $dataCliente[id]",$cnx);

} else {

$horas = $dataCliente['horas'];

$minutos = $dataCliente['minutos'];

if(!empty($horas))

$horas = $horas * 60;

$tempoTotal = $horas+$minutos;

if($tempoTotal > $dataCliente['sms_acada']){

$json = json_decode(file_get_contents("http://www.systemtracker.com.br\">www.systemtracker.com.br</a></p>";

$msg .= "</body>";

$msg .= "</html>";

$mail = new PHPMailer();

$mail->Mailer = "smtp";

$mail->IsHTML(true);

$mail->CharSet = "utf-8";

$mail->SMTPSecure = "tls";

$mail->Host = "smtp.gmail.com";

$mail->Port = "587";

$mail->SMTPAuth = "true";

$mail->Username = "josenilsontrindade@gmail.com";

$mail->Password = "jnt99971387";

$mail->From = "josenilsontrindade@gmail.com";

$mail->FromName = "System Tracker";

$mail->AddAddress($emailDestino);

$mail->AddReplyTo($mail->From, $mail->FromName);

$mail->Subject = "System Tracker - Alerta de Violacao de Perimetro";

$mail->Body = $msg;

if (!$mail->Send()) {

echo "Erro de envio: ". $mail->ErrorInfo;

} else {

echo "Mensagem enviada com sucesso!";

}

}

}

}

}

} // if imei

//final verifica geofence

if($gpsSignalIndicator != 'L') {

$movimento = '';

if($speed > 0)

$movimento = 'S';

else

$movimento = 'N';

$gpsLat = gprsToGps($latitudeDecimalDegrees, $latitudeHemisphere);

$gpsLon = gprsToGps($longitudeDecimalDegrees, $longitudeHemisphere);

$gpsLatAnt = 0;

$gpsLatHemAnt = '';

$gpsLonAnt = 0;

$gpsLonHemAnt = '';

$resLocAtual = mysql_query("select id from loc_atual where imei = '$imei' limit 1", $cnx);

$numRows = mysql_num_rows($resLocAtual);

if($numRows == 0){

mysql_query("INSERT INTO loc_atual (date, imei, phone, satelliteFixStatus, latitudeDecimalDegrees, latitudeHemisphere, longitudeDecimalDegrees, longitudeHemisphere, speed, infotext, gpsSignalIndicator, converte) VALUES (now(), '$imei', '$phone', '$satelliteFixStatus', '$latitudeDecimalDegrees', '$latitudeHemisphere', '$longitudeDecimalDegrees', '$longitudeHemisphere', '$speed', '$infotext', '$gpsSignalIndicator', 1)", $cnx);

} else {

$dataLocAtual = mysql_fetch_assoc($resLocAtual);

$gpsLatAnt = $dataLocAtual[latitudeDecimalDegrees];

$gpsLatHemAnt = $dataLocAtual[latitudeHemisphere];

$gpsLonAnt = $dataLocAtual[longitudeDecimalDegrees];

$gpsLonHemAnt = $dataLocAtual[longitudeHemisphere];

mysql_query("UPDATE loc_atual set date = now(), phone = '$phone', satelliteFixStatus = '$satelliteFixStatus', latitudeDecimalDegrees = '$latitudeDecimalDegrees', latitudeHemisphere = '$latitudeHemisphere', longitudeDecimalDegrees = '$longitudeDecimalDegrees', longitudeHemisphere = '$longitudeHemisphere', speed = '$speed', infotext = '$infotext', gpsSignalIndicator = '$gpsSignalIndicator' where imei = '$imei'", $cnx);

}

$distance = 0;

try{

$bemId = $dataBem[id];

$countGeoDistance = mysql_query("select bem from geo_distance where bem = $bemId", $cnx);

if($countGeoDistance === false || mysql_num_rows($countGeoDistance) == 0) {

mysql_query("insert into geo_distance (bem, tipo) values($bemId, 'I')", $cnx);

mysql_query("insert into geo_distance (bem, tipo) values($bemId, 'F')", $cnx);

}

/*envio de sms*/

if($dataCliente['envia_sms'] == 'S' && $dataBem['envia_sms'] == 'S' && !empty($dataCliente['celular']) && !empty($dataCliente['sms_acada'])){

if(empty($dataCliente['dt_ultm_sms'])){

mysql_query("update cliente set dt_ultm_sms = now() where id = $dataCliente[id]",$cnx);

} else {

$horas = $dataCliente['horas'];

$minutos = $dataCliente['minutos'];

if(!empty($horas))

$horas = $horas * 60;

$tempoTotal = $horas+$minutos;

if($tempoTotal > $dataCliente['sms_acada']){

$json = json_decode(file_get_contents("http://maps.google.com/maps/api/geocode/json?sensor=false&latlng=$gpsLat,$gpsLon&language=es-ES"));

if ( isset( $json->status ) && $json->status == 'OK' && isset($json->results[0]->formatted_address)) {

$address = $json->results[0]->formatted_address;

$address = utf8_decode($address);

$aDataCliente = split(' ', $dataCliente['nome']);

$msg = $texto_sms_localiza;

$msg = str_replace("#CLIENTE", $aDataCliente[0], $msg);

$msg = str_replace("#VEICULO", $dataBem['name'], $msg);

$msg = str_replace("#LOCALIZACAO", $address, $msg);

$msg = str_replace(' ', '+', $msg);

sendSMS($dataCliente['celular'], $msg, '');

if($retorno < 0)

mysql_query("insert into controle(texto) values('envio de sms retorno: $retorno')",$cnx);

else

mysql_query("update cliente set dt_ultm_sms = now() where id = $dataCliente[id]",$cnx);

}

}

}

}

if($movimento == 'S'){

$resGeoDistance = mysql_query("select parou from geo_distance where bem = $bemId and tipo = 'I'", $cnx);

$dataGeoDistance = mysql_fetch_assoc($resGeoDistance);

if($dataGeoDistance[parou] == 'S' || empty($dataGeoDistance[parou])){

mysql_query("update geo_distance set latitudeDecimalDegrees = '$latitudeDecimalDegrees', latitudeHemisphere = '$latitudeHemisphere', longitudeDecimalDegrees = '$longitudeDecimalDegrees', longitudeHemisphere = '$longitudeHemisphere', parou = 'N' where bem = $bemId and tipo = 'I'", $cnx);

}

} else {

$resGeoDistance = mysql_query("select latitudeDecimalDegrees, latitudeHemisphere, longitudeDecimalDegrees, longitudeHemisphere from geo_distance where bem = $bemId and tipo = 'I'", $cnx);

if(mysql_num_rows($resGeoDistance) > 0){

$update = mysql_query("update geo_distance set latitudeDecimalDegrees = '$latitudeDecimalDegrees', latitudeHemisphere = '$latitudeHemisphere', longitudeDecimalDegrees = '$longitudeDecimalDegrees', longitudeHemisphere = '$longitudeHemisphere', parou = 'S' where bem = $bemId and tipo = 'I'", $cnx);

$dataGeoDistance = mysql_fetch_assoc($resGeoDistance);

$gpsLatAnt = gprsToGps($dataGeoDistance[latitudeDecimalDegrees], $dataGeoDistance[latitudeHemisphere]);

$gpsLonAnt = gprsToGps($dataGeoDistance[longitudeDecimalDegrees], $dataGeoDistance[longitudeHemisphere]);

if($gpsLatAnt != $gpsLat) {

if($gpsLatAnt != 0 && $gpsLonAnt != 0){

/*

$json = json_decode(file_get_contents('http://dev.virtualearth.net/REST/V1/Routes/Driving?o=xml&wp.0=$gpsLatAnt,$gpsLonAnt&wp.1=$gpsLat,$gpsLon&avoid=minimizeTolls&key=AqMJv19uaRKDbu-wSgUt3paCfXETZjBafVBMDXX9Rc4XyqmM6l4R_A8TgEXuWT6G'));

if(isset($json->rows[0]->elements[0]->distance)){

}

*/

/*

$json = json_decode(file_get_contents("http://maps.googleapis.com/maps/api/distancematrix/json?sensor=false&origins=$gpsLatAnt,$gpsLonAnt&destinations=$gpsLat,$gpsLon"));

if(isset($json->rows[0]->elements[0]->distance)){

$strDistance = $json->rows[0]->elements[0]->distance->value;

$distance = $strDistance+0;

$alertaACada = $dataBem['alerta_hodometro'];

$alertaACadaSaldo = $dataBem['alerta_hodometro_saldo'];

$alertaACadaSaldo = ($alertaACadaSaldo*1000) - $distance;

if($alertaACadaSaldo <= 0 && $alertaACada > 0){

$msg = $texto_sms_alerta_hodometro;

$msg = str_replace("#CLIENTE", $aDataCliente[0], $msg);

$msg = str_replace("#VEICULO", $dataBem['name'], $msg);

$msg = str_replace("#HODOMETRO", $alertaACada, $msg);

$msg = str_replace(' ', '+', $msg);

sendSMS($dataCliente['celular'], $msg, '');

$alertaACadaSaldo = $alertaACada;

}

$alertaACadaSaldo = (int)$alertaACadaSaldo/1000;

}

*/

$geoDistance = distance($gpsLatAnt, $gpsLonAnt, $gpsLat, $gpsLon,'K');

//$strDistance = $json->rows[0]->elements[0]->distance->value;

$distance = (int)($geoDistance*1000);

$alertaACada = $dataBem['alerta_hodometro'];

$alertaACadaSaldo = $dataBem['alerta_hodometro_saldo'];

$alertaACadaSaldo = ($alertaACadaSaldo*1000) - $distance;

if($alertaACadaSaldo <= 0 && $alertaACada > 0){

$msg = $texto_sms_alerta_hodometro;

$msg = str_replace("#CLIENTE", $aDataCliente[0], $msg);

$msg = str_replace("#VEICULO", $dataBem['name'], $msg);

$msg = str_replace("#HODOMETRO", $alertaACada, $msg);

$msg = str_replace(' ', '+', $msg);

//sendSMS($dataCliente['celular'], $msg, '');

$alertaACadaSaldo = $alertaACada;

}

$alertaACadaSaldo = (int)$alertaACadaSaldo/1000;

}

}

}

}

}catch(Exception $e){

mysql_query("INSERT INTO controle (texto) VALUES ($e->getMessage())", $cnx);

}

mysql_query("UPDATE bem set date = date, status_sinal = 'R', movimento = '$movimento', hodometro=hodometro+$distance WHERE imei = '$imei'", $cnx);

mysql_query("INSERT INTO gprmc (date, imei, phone, satelliteFixStatus, latitudeDecimalDegrees, latitudeHemisphere, longitudeDecimalDegrees, longitudeHemisphere, speed, infotext, gpsSignalIndicator, km_rodado, converte) VALUES (now(), '$imei', '$phone', '$satelliteFixStatus', '$latitudeDecimalDegrees', '$latitudeHemisphere', '$longitudeDecimalDegrees', '$longitudeHemisphere', '$speed', '$infotext', '$gpsSignalIndicator', $distance, 1)", $cnx);

} else {

mysql_query("UPDATE bem set date = date, status_sinal = 'S' WHERE imei = '$imei'", $cnx);

}

# Now check to see if we need to send any alerts.

if (trim($infotext) != "gprmc") {

$res = mysql_query("SELECT responsible FROM bem WHERE imei='$imei'", $cnx);

while($data = mysql_fetch_assoc($res)) {

switch ($infotext) {

case "dt":

$body = "Disable Track OK";

break;

case "et":

$body = "Stop Alarm OK";

break;

case "gt";

$body = "Move Alarm set OK";

break;

case "help me":

$body = "Help!";

mysql_query("INSERT INTO message (imei, message) VALUES ('$imei', 'SOS!')", $cnx);

break;

case "ht":

$body = "Speed alarm set OK";

break;

case "it":

$body = "Timezone set OK";

break;

case "low battery":

$body = "Low battery!\nYou have about 2 minutes...";

mysql_query("INSERT INTO message (imei, message) VALUES ('$imei', 'Bat. Fraca')", $cnx);

break;

case " bat:":

$body = "Low battery!\nYou have about 2 minutes...";

mysql_query("INSERT INTO message (imei, message) VALUES ('$imei', 'Bat. Fraca')", $cnx);

break;

case "Low batt":

$body = "Low battery!\nYou have about 2 minutes...";

mysql_query("INSERT INTO message (imei, message) VALUES ('$imei', 'Bat. Fraca')", $cnx);

break;

case "move":

$body = "Move Alarm!";

mysql_query("INSERT INTO message (imei, message) VALUES ('$imei', 'Movimento')", $cnx);

break;

case "nt":

$body = "Returned to SMS mode OK";

break;

case "speed":

$body = "Speed alarm!";

mysql_query("INSERT INTO message (imei, message) VALUES ('$imei', 'Velocidade')", $cnx);

break;

case "stockade":

$body = "Geofence Violation!";

mysql_query("INSERT INTO message (imei, message) VALUES ('$imei', 'Cerca')", $cnx);

break;

} //switch

//Enviando e-mail de alerta

$headers = "From: $email_from" . "\r\n" . "Reply-To: $email_from" . "\r\n";

$responsible = $data['responsible'];

$rv = mail($responsible, "Tracker - $imei", $body, $headers);

} //while

}

} else {

//GRPMC nao precisa reter a sessao

}

//No protocolo GPRMC cada nova conex�o � um IP. Enviando comando no fim da conexao, ap�s obter os dados.

if (file_exists("$command_path/$conn_imei")) {

$send_cmd = file_get_contents("$command_path/$conn_imei");

socket_send($socket, $send_cmd, strlen($send_cmd), 0);

mysql_query("DELETE FROM command WHERE imei = $conn_imei");

unlink("$command_path/$conn_imei");

printLog($fh, "Comandos do Banco e Arquivo apagados: " . $send_cmd . " imei: " . $conn_imei);

}

mysql_close($cnx);

break;

}

}

//Checando se utilizou os dois protocolos para uma escuta

if ($isGIMEI == true and $isGPRMC == true) {

//printLog($fh, "ATENCAO: falha na obtencao do protocolo. Kill pid.");

}

$rec = "";

} //while

} //fim interact

/**

* Become a daemon by forking and closing the parent

*/

function become_daemon() {

GLOBAL $fh;

//printLog($fh, "pcntl_fork() in");

$pid = pcntl_fork();

//printLog($fh, "pcntl_fork() out");

if ($pid == -1) {

/* fork failed */

//printLog($fh, "fork failure!");

exit();

} elseif ($pid) {

//printLog($fh, "pid: " . $pid);

/* close the parent */

exit();

} else {

/* child becomes our daemon */

posix_setsid();

chdir('/');

umask(0);

return posix_getpid();

}

//printLog($fh, "become_daemon() fim");

}

function gprsToGps($cord, $hemisphere){

$novaCord = 0;

strlen($cord) == 9 && $cord = '0'.$cord;

$g = substr($cord,0,3);

$d = substr($cord,3);

$novaCord = $g + ($d/60);

if($hemisphere == "S")

$hemisphere == "S" && $novaCord = $novaCord * -1;

if($hemisphere == "W")

$hemisphere == "W" && $novaCord = $novaCord * -1;

return $novaCord;

}

function sendSMS($contato, $mensagem, $remetente){

$cnx = mysql_connect("localhost", "user1", "pass1")

or die("Could not connect: " . mysql_error());

mysql_select_db('tracker', $cnx);

$res = mysql_query("select valor from preferencias where nome = 'url_sms'", $cnx);

$data = mysql_fetch_assoc($res);

$url = $data['valor'];

$res = mysql_query("select valor from preferencias where nome = 'usuario_sms'", $cnx);

$data = mysql_fetch_assoc($res);

$usuario = $data['valor'];

$res = mysql_query("select valor from preferencias where nome = 'senha_sms'", $cnx);

$data = mysql_fetch_assoc($res);

$senha = $data['valor'];

$res = mysql_query("select valor from preferencias where nome = 'de_sms'", $cnx);

$data = mysql_fetch_assoc($res);

$de = $data['valor'];

file_get_contents($url."usr=".$usuario."&pwd=".$senha."&number=55".$contato."&sender=".$de."&msg=$mensagem");

}

function distance($lat1, $lon1, $lat2, $lon2) {

$center_lat = $lat1;

$center_lng = $lon1;

$lat = $lat2;

$lng = $lon2;

$distance =( 6371 * acos((cos(deg2rad($center_lat)) ) * (cos(deg2rad($lat))) * (cos(deg2rad($lng) - deg2rad($center_lng)) )+ ((sin(deg2rad($center_lat))) * (sin(deg2rad($lat))))) );

return $distance;

/*

$theta = $lon1 - $lon2;

$dist = sin(deg2rad($lat1)) * sin(deg2rad($lat2)) + cos(deg2rad($lat1)) * cos(deg2rad($lat2)) * cos(deg2rad($theta));

$dist = acos($dist);

$dist = rad2deg($dist);

$miles = $dist * 60 * 1.1515;

$unit = strtoupper($unit);

if ($unit == "K")

{

return ($miles * 1.609344);

}

else if ($unit == "N")

{

return ($miles * 0.8684);

}

else

{

return $miles;

}

*/

}

?>

[lucaswxp 22]

Não dá pra entender nada da sua pergunta nem do código que você postou. Qual a parte relevante do código? Ninguém vai se dar ao trabalho de ler isso tudo...