lib/mapper.php

@@ -1,7 +1,4 @@
<?php
require_once(__DIR__.'/../vendor/autoload.php');
require_once(__DIR__.'/vehicle_types.php');

use transit_realtime\FeedMessage;

class Mapper {
@@ -37,13 +34,16 @@
         if(!isset($vehicle->name) || !$vehicle->name) continue;
         if(!isset($vehicle->latitude) || !$vehicle->latitude) continue;
         if(!isset($vehicle->longitude) || !$vehicle->longitude) continue;
         foreach($this->specialNames as $name) {
            if(substr($vehicle->name, -strlen($name)) == $name) {
         list($line, $direction) = explode(' ', $vehicle->name, 2);
         foreach($this->specialNames as $specialName) {
            if(substr($vehicle->name, -strlen($specialName)) == $specialName) {
               continue;
            }
         }
         $this->ttssTrips[(int)$vehicle->tripId] = [
            'id' => $vehicle->id,
         $this->ttssTrips[(string)$vehicle->tripId] = [
            'id' => (string)$vehicle->id,
            'line' => $line,
            'direction' => $direction,
            'latitude' => (float)$vehicle->latitude / 3600000.0,
            'longitude' => (float)$vehicle->longitude / 3600000.0,
         ];
@@ -53,6 +53,10 @@
   
   public function getTTSSDate() {
      return $this->ttssDate / 1000.0;
   }
	
   public function getTTSSTrips() {
      return $this->ttssTrips;
   }
   
   public function loadGTFSRT($file) {
@@ -67,7 +71,7 @@
         $trip = $vehiclePosition->getTrip();
         $tripId = $trip->getTripId();
         $this->gtfsrtTrips[self::convertTripId($tripId)] = [
            'id' => $entity->getId(),
            'id' => (string)$entity->getId(),
            'num' => $vehicle->getLicensePlate(),
            'tripId' => $tripId,
            'latitude' => $position->getLatitude(),
@@ -126,23 +130,12 @@
      return $bestOffset;
   }
   
   public function mapUsingOffset($offset, $mapper) {
   public function mapUsingOffset($offset) {
      $result = [];
      foreach($this->gtfsrtTrips as $gtfsTripId => $gtfsTrip) {
         $ttssTripId = $gtfsTripId + $offset;
         if(isset($this->ttssTrips[$ttssTripId])) {
            $data = $mapper($gtfsTrip['id']);
            $num = $gtfsTrip['num'];
            if(!is_array($data) || !isset($data['num'])) {
               $data = [
                  'num' => $num ?: '??'.$gtfsTrip['id'],
                  'low' => NULL,
               ];
            } elseif($data['num'] != $num) {
               // Ignore due to incorrect depot markings in the data
               //$this->logger->warn('Got '.$num.', database has '.$data['num']);
            }
            $result[$this->ttssTrips[$ttssTripId]['id']] = $data;
            $result[$this->ttssTrips[$ttssTripId]['id']] = $gtfsTrip['id'];
         }
      }
      return $result;