mbirth/php-owntracks-recorder
Archived
1
0
Fork 0
Code Issues 1 Pull Requests Activity

Update record.php

Browse Source
This commit is contained in:
tomyvi
2018-03-15 16:17:14 +01:00
committed by GitHub
parent 2a9a1410e9
commit c705bb4a0c
1 changed files with 100 additions and 47 deletions
Download Patch File Download Diff File Expand all files Collapse all files

147
record.php
View File

@ -1,59 +1,112 @@
<?php <?php
$fp = fopen('./log/record_log.txt', 'a+');
function _log($msg){
global $fp;
if(!$fp) { $fp = fopen('./log/record_log.txt', 'a+'); }
return fprintf($fp, date('Y-m-d H:i:s') . " - ".$_SERVER['REMOTE_ADDR']." - %s\n", $msg);
}
//http://owntracks.org/booklet/tech/http/ //http://owntracks.org/booklet/tech/http/
# Obtain the JSON payload from an OwnTracks app POSTed via HTTP # Obtain the JSON payload from an OwnTracks app POSTed via HTTP
# and insert into database table. # and insert into database table.
header("Content-type: application/json"); header("Content-type: application/json");
require_once('config.inc.php'); require_once('./config.inc.php');
$payload = file_get_contents("php://input"); $payload = file_get_contents("php://input");
$data = @json_decode($payload, true); _log("Payload = ".$payload);
$data = @json_decode($payload, true);
if ($data['_type'] == 'location') { if ($data['_type'] == 'location') {
# CREATE TABLE locations (dt TIMESTAMP, tid CHAR(2), lat DECIMAL(9,6), lon DECIMAL(9,6)); # CREATE TABLE locations (dt TIMESTAMP, tid CHAR(2), lat DECIMAL(9,6), lon DECIMAL(9,6));
$mysqli = new mysqli($_config['sql_host'], $_config['sql_user'], $_config['sql_pass'], $_config['sql_db']); $mysqli = new mysqli($_config['sql_host'], $_config['sql_user'], $_config['sql_pass'], $_config['sql_db']);
//http://owntracks.org/booklet/tech/json/ //http://owntracks.org/booklet/tech/json/
if (array_key_exists('acc', $data)) $accuracy = $data['acc']; //iiiissddissiiidsiis
if (array_key_exists('alt', $data)) $altitude = $data['alt']; if (array_key_exists('acc', $data)) $accuracy = intval($data['acc']);
if (array_key_exists('batt', $data)) $battery_level = $data['batt']; if (array_key_exists('alt', $data)) $altitude = intval($data['alt']);
if (array_key_exists('cog', $data)) $heading = $data['cog']; if (array_key_exists('batt', $data)) $battery_level = intval($data['batt']);
if (array_key_exists('desc', $data)) $description = $data['desc']; if (array_key_exists('cog', $data)) $heading = intval($data['cog']);
if (array_key_exists('event', $data)) $event = $data['event']; if (array_key_exists('desc', $data)) $description = strval($data['desc']);
if (array_key_exists('lat', $data)) $latitude = $data['lat']; if (array_key_exists('event', $data)) $event = strval($data['event']);
if (array_key_exists('lon', $data)) $longitude = $data['lon']; if (array_key_exists('lat', $data)) $latitude = floatval($data['lat']);
if (array_key_exists('rad', $data)) $radius = $data['rad']; if (array_key_exists('lon', $data)) $longitude = floatval($data['lon']);
if (array_key_exists('t', $data)) $trig = $data['t']; if (array_key_exists('rad', $data)) $radius = intval($data['rad']);
if (array_key_exists('tid', $data)) $tracker_id = $data['tid']; if (array_key_exists('t', $data)) $trig = strval($data['t']);
if (array_key_exists('tst', $data)) $epoch = $data['tst']; if (array_key_exists('tid', $data)) $tracker_id = strval($data['tid']);
if (array_key_exists('vac', $data)) $vertical_accuracy = $data['vac']; if (array_key_exists('tst', $data)) $epoch = intval($data['tst']);
if (array_key_exists('vel', $data)) $velocity = $data['vel']; if (array_key_exists('vac', $data)) $vertical_accuracy = intval($data['vac']);
if (array_key_exists('p', $data)) $pressure = $data['p']; if (array_key_exists('vel', $data)) $velocity = intval($data['vel']);
if (array_key_exists('conn', $data)) $connection = $data['conn']; if (array_key_exists('p', $data)) $pressure = floatval($data['p']);
if (array_key_exists('conn', $data)) $connection = strval($data['conn']);
$sql = "SELECT epoch FROM ".$_config['sql_prefix']."locations WHERE tracker_id = '$tracker_id' AND epoch = $epoch";
_log("Duplicate SQL = ".$sql);
if ($stmt = $mysqli->prepare($sql)){
$stmt->execute();
$stmt->store_result();
if ($epoch) _log("Duplicate SQL : Rows found = ".$stmt->num_rows);
{
$dt = new DateTime("@$epoch"); // convert UNIX timestamp to PHP DateTime //record only if same data found at same epoch / tracker_id
$timestamp = $dt->format('Y-m-d H:i:s'); // output = 2017-01-01 00:00:00 if($stmt->num_rows == 0) {
}
$sql = "INSERT INTO ".$_config['sql_prefix']."locations (accuracy, altitude, battery_level, heading, description, event, latitude, longitude, radius, trig, tracker_id, epoch, vertical_accuracy, velocity, pressure, connection, place_id, osm_id) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
$stmt = $mysqli->prepare($sql);
$stmt->bind_param('iiiissddissiiidsii', $accuracy, $altitude, $battery_level, $heading, $description, $event, $latitude, $longitude, $radius, $trig, $tracker_id, $epoch, $vertical_accuracy, $velocity, $pressure, $connection, $place_id, $osm_id);
if ($stmt->execute()){
# bind parameters (s = string, i = integer, d = double, b = blob)
http_response_code(200);
$response['msg'] = "OK record saved";
_log("Insert OK");
}else{
http_response_code(500);
die("Can't write to database : ".$stmt->error);
$response['msg'] = "Can't write to database";
_log("Insert KO - Can't write to database : ".$stmt->error);
}
}else{
_log("Duplicate location found for epoc $epoch / tid '$tracker_id' - no insert");
}
$stmt->close();
}else{
http_response_code(500);
die("Can't read from database");
$response['msg'] = "Can't read from database";
_log("Can't read from database");
}
$sql = "INSERT INTO ".$_config['sql_prefix']."locations (dt, accuracy, altitude, battery_level, heading, description, event, latitude, longitude, radius, trig, tracker_id, epoch, vertical_accuracy, velocity, pressure, connection) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
if ($stmt = $mysqli->prepare($sql))
{
# bind parameters (s = string, i = integer, d = double, b = blob)
$stmt->bind_param('siiiissddisssiids', $timestamp, $accuracy, $altitude, $battery_level, $heading, $description, $event, $latitude, $longitude, $radius, $trig, $tracker_id, $epoch, $vertical_accuracy, $velocity, $pressure, $connection);
$stmt->execute();
$stmt->close();
}else{
die("Can't write to database");
}
}
$response = array(); }else{
# optionally add objects to return to the app (e.g. http_response_code(204);
# friends or cards) $response['msg'] = "OK type is not location";
print json_encode($response); _log("OK type is not location : " . $data['_type']);
}
$response = array();
print json_encode($response);
fclose($fp);
?> ?>