lib/mapper.php

@@ -5,8 +5,12 @@
use transit_realtime\FeedMessage;

class Mapper {
   private $ttssDate = NULL;
   private $ttssTrips = [];
   private $gtfsrtDate = NULL;
   private $gtfsrtTrips = [];
   private $gtfsTrips = [];
   private $gtfsRoutes = [];
   private $logger = NULL;
   
   private $specialNames = [
@@ -28,6 +32,7 @@
   
   public function loadTTSS($file) {
      $ttss = json_decode(file_get_contents($file));
      $this->ttssDate = $ttss->lastUpdate;
      foreach($ttss->vehicles as $vehicle) {
         if(isset($vehicle->isDeleted) && $vehicle->isDeleted) continue;
         if(!isset($vehicle->tripId) || !$vehicle->tripId) continue;
@@ -39,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,
         ];
@@ -48,10 +56,38 @@
      ksort($this->ttssTrips);
   }
   
   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) {
      $data = file_get_contents($file);
      $feed = new FeedMessage();
      $feed->parse($data);
      $this->gtfsrtDate = $feed->header->timestamp;
      foreach ($feed->getEntityList() as $entity) {
         $vehiclePosition = $entity->getVehicle();
         $position = $vehiclePosition->getPosition();
@@ -69,6 +105,32 @@
      ksort($this->gtfsrtTrips);
   }
   
   public function getGTFSRTDate() {
      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;