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