|  |  |  | 
|---|
|  |  |  | use transit_realtime\FeedMessage; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | class Mapper { | 
|---|
|  |  |  | private $ttssDate = NULL; | 
|---|
|  |  |  | private $ttssTrips = []; | 
|---|
|  |  |  | private $gtfsrtDate = NULL; | 
|---|
|  |  |  | private $gtfsrtTrips = []; | 
|---|
|  |  |  | private $logger = NULL; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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; | 
|---|
|  |  |  | 
|---|
|  |  |  | ksort($this->ttssTrips); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public function getTTSSDate() { | 
|---|
|  |  |  | return $this->ttssDate / 1000.0; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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(); | 
|---|
|  |  |  | 
|---|
|  |  |  | ksort($this->gtfsrtTrips); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public function getGTFSRTDate() { | 
|---|
|  |  |  | return $this->gtfsrtDate; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public function findOffset() { | 
|---|
|  |  |  | if(count($this->ttssTrips) == 0 || count($this->gtfsrtTrips) == 0) { | 
|---|
|  |  |  | return NULL; | 
|---|