From 6b6842c72b28c1346ef501bc656ec3016d00e1c7 Mon Sep 17 00:00:00 2001 From: Jacek Kowalski <Jacek@jacekk.info> Date: Mon, 10 Jun 2019 20:49:08 +0000 Subject: [PATCH] Add procedure to match TTSS to GTFS via bus positions --- lib/mapper.php | 50 ++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 50 insertions(+), 0 deletions(-) diff --git a/lib/mapper.php b/lib/mapper.php index 453db3f..933305f 100644 --- a/lib/mapper.php +++ b/lib/mapper.php @@ -9,6 +9,8 @@ private $ttssTrips = []; private $gtfsrtDate = NULL; private $gtfsrtTrips = []; + private $gtfsTrips = []; + private $gtfsRoutes = []; private $logger = NULL; private $specialNames = [ @@ -42,8 +44,11 @@ continue; } } + $name = explode(' ', $vehicle->name, 2); $this->ttssTrips[(int)$vehicle->tripId] = [ 'id' => $vehicle->id, + 'line' => $name[0], + 'direction' => $name[1], 'latitude' => (float)$vehicle->latitude / 3600000.0, 'longitude' => (float)$vehicle->longitude / 3600000.0, ]; @@ -53,6 +58,29 @@ public function getTTSSDate() { return $this->ttssDate / 1000.0; + } + + public function loadGTFS($file) { + $buffer_size = 512; + + $routes = fopen('phar://'.$file.'/routes.txt', 'r'); + $route_header = fgetcsv($routes, $buffer_size); + while(($route = fgetcsv($routes, $buffer_size)) !== FALSE) { + $this->gtfsRoutes[$route[0]] = $route[2]; + } + fclose($routes); + + $trips = fopen('phar://'.$file.'/trips.txt', 'r'); + $trip_header = fgetcsv($trips, $buffer_size); + var_dump($trip_header); + while(($trip = fgetcsv($trips, $buffer_size)) !== FALSE) { + $this->gtfsTrips[$trip[0]] = [ + 'line' => $this->gtfsRoutes[$trip[1]] ?? NULL, + 'route' => $trip[1], + 'direction' => $trip[3], + ]; + } + fclose($trips); } public function loadGTFSRT($file) { @@ -81,6 +109,28 @@ return $this->gtfsrtDate; } + public function mapUsingCoords() { + $level = 0.002; + foreach($this->gtfsrtTrips as $gkey => $gtrip) { + $trip = $this->gtfsTrips[$gtrip['tripId']] ?? NULL; + + if($trip === NULL) continue; + + foreach($this->ttssTrips as $jkey => $jtrip) { + echo $gtrip['latitude'].' '.$jtrip['latitude']."\n"; + echo $gtrip['longitude'].' '.$jtrip['longitude']."\n"; + echo $jtrip['line'].' '.$trip['line']."\n"; + echo "\n"; + + if($jtrip['line'] != $trip['line']) continue; + if(abs($gtrip['latitude'] - $jtrip['latitude']) > $level) continue; + if(abs($gtrip['longitude'] - $jtrip['longitude']) < $level) continue; + + echo 'MATCH '.$gtrip['num'].' '.$gkey.' '.$jkey.' ('.($jkey-$gkey).')'."\n"; + } + } + } + public function findOffset() { if(count($this->ttssTrips) == 0 || count($this->gtfsrtTrips) == 0) { return NULL; -- Gitblit v1.9.1