| | |
| | | <?php |
| | | require_once(__DIR__.'/../vendor/autoload.php'); |
| | | require_once(__DIR__.'/vehicle_types.php'); |
| | | |
| | | use transit_realtime\FeedMessage; |
| | | |
| | | class Mapper { |
| | |
| | | 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, |
| | | ]; |
| | |
| | | |
| | | public function getTTSSDate() { |
| | | return $this->ttssDate / 1000.0; |
| | | } |
| | | |
| | | public function getTTSSTrips() { |
| | | return $this->ttssTrips; |
| | | } |
| | | |
| | | public function loadGTFSRT($file) { |
| | |
| | | $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(), |
| | |
| | | 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 ?: '', |
| | | 'low' => 2, |
| | | ]; |
| | | } 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; |