dev-chiefworks
113 lines
3.9 KiB
PHP
113 lines
3.9 KiB
PHP
<?php
|
|
|
|
function save_tracked($in) {
|
|
global $tracklocation_dir, $pgconn;
|
|
if ($in["batch"]) {
|
|
$response = [
|
|
"retval" => PHP_API_OK,
|
|
"status" => 0,
|
|
"error" => NULL,
|
|
"details" => []
|
|
];
|
|
try {
|
|
$sessionId = null;
|
|
$deviceToken = null;
|
|
$requestHeaders = getallheaders();
|
|
if (array_key_exists("x-session-id",$requestHeaders)) {
|
|
$sessionId = $requestHeaders["x-session-id"];
|
|
}
|
|
if (array_key_exists("x-devicetoken",$requestHeaders)) {
|
|
$deviceToken = $requestHeaders["x-devicetoken"];
|
|
$q = "SELECT * FROM members_devices WHERE access_token='".pg_escape_string($deviceToken)."'";
|
|
$r = pg_query($pgconn, $q);
|
|
if ($r && pg_num_rows($r) && $f=pg_fetch_assoc($r)) {
|
|
$q = "UPDATE members_devices SET updated=now(), status=1 WHERE id=".((int)$f['id'])." RETURNING *";
|
|
$r = pg_query($pgconn, $q);
|
|
if ($r && pg_num_rows($r) && $f=pg_fetch_assoc($r)) {
|
|
error_log('Status updated at: '.$f['updated']);
|
|
}
|
|
}
|
|
}
|
|
$data = [
|
|
"batch" => $in["batch"],
|
|
"loc" => $in["loc"],
|
|
"sessionId" => $sessionId,
|
|
"deviceToken" => $deviceToken
|
|
];
|
|
$session = $in["session"];
|
|
file_put_contents( $tracklocation_dir.'tl_'.getmygid().'_'.$sessionId.'_'.microtime(true).'.json', json_encode($data));
|
|
} catch(Exception $e) {
|
|
$response["retval"] = -1;
|
|
$response["error"] = $e->getMessage();
|
|
}
|
|
return $response;
|
|
} else {
|
|
return save_tracked_vintage($in);
|
|
}
|
|
}
|
|
|
|
function save_tracked_vintage($in) {
|
|
global $pgconn_gps;
|
|
$message = "";
|
|
list ($pass, $device, $session) = checkRequestHeaders(
|
|
'tracklocation',
|
|
$in,
|
|
[],
|
|
['tracklocation' => 1]
|
|
);
|
|
|
|
if ($in["member_id"]>0 && $in["lng"]!="" && $in["lat"]!="") {
|
|
$device_id = (isset($device) && array_key_exists("id",$device) && $device["id"]>0) ? $device["id"] : "NULL";
|
|
$mysql = "INSERT INTO members_tracking (member_id,traked_group,speed,lat,lng,gps,ttime,loc,device_id) ";
|
|
$mysql.= " VALUES(" . $in["member_id"] . ",'" . $in["traked_group"] . "','" . $in["speed"] . "', " . $in["lat"] . "," . $in["lng"] . ",ST_SetSRID(ST_MakePoint(" . $in["lng"] . "," . $in["lat"] . "),4326)::geography,now(),'" . $in["loc"] . "',";
|
|
$mysql.= "${device_id}) RETURNING *";
|
|
LogString("Query->", $mysql);
|
|
$r = pg_query($pgconn_gps, $mysql);
|
|
if ($r && pg_num_rows($r) && $f=pg_fetch_assoc($r)) {
|
|
$nid = $f["id"];
|
|
$gps = $f["gps"];
|
|
$ttime = $f["ttime"];
|
|
// TODO: merge two next queries into one???
|
|
$q = "SELECT id AS pid, ST_Distance(gps,'${gps}'::geometry) AS distance,";
|
|
$q.= "EXTRACT(epoch FROM '${ttime}'::timestamp-ttime) AS duration ";
|
|
$q.= "FROM members_tracking ";
|
|
$q.= "WHERE member_id=".$in["member_id"]." AND ttime<'${ttime}'::timestamp AND ";
|
|
$q.= ($device_id=="NULL" ? "device_id IS NULL" : "device_id=${device_id}");
|
|
$q.= " ORDER BY ttime DESC LIMIT 1";
|
|
LogString("Query->", $q);
|
|
$r = pg_query($pgconn_gps, $q);
|
|
if ($r && pg_num_rows($r) && $f=pg_fetch_assoc($r)) {
|
|
$pid = $f["pid"];
|
|
/*
|
|
$q = "SELECT a.id AS nid, b.id AS pid, ";
|
|
$q.= "ST_Distance(a.gps,b.gps) AS distance, EXTRACT(epoch FROM a.ttime-b.ttime) AS duration ";
|
|
$q.= "FROM members_tracking a LEFT JOIN members_tracking b ON (b.id=${pid}) WHERE a.id=${nid}";
|
|
$r = pg_query($pgconn_gps, $q);
|
|
$f = pg_fetch_assoc($r);
|
|
*/
|
|
// Update! previous_id | distance | duration
|
|
$q = "UPDATE members_tracking SET previous_id=".$f["pid"].",distance=".((int)$f["distance"]).",duration=".((int)(1000*$f["duration"]));
|
|
$q.= " WHERE id=${nid}";
|
|
LogString("Query->", $q);
|
|
$r = pg_query($pgconn_gps, $q);
|
|
}
|
|
}
|
|
$message = pg_last_error($pgconn_gps);
|
|
} else {
|
|
$message = "Invalid input";
|
|
}
|
|
return array(
|
|
"retval" => pg_affected_rows($r) ? PHP_API_OK : -1,
|
|
"status" => pg_affected_rows($r),
|
|
"error" => $message
|
|
);
|
|
}
|
|
|
|
function decompress($str) {
|
|
return gzinflate(base64_decode($str));
|
|
}
|
|
|
|
function compress($str) {
|
|
return base64_encode(gzdeflate($str, 9));
|
|
}
|