diff options
| -rwxr-xr-x | lib/Travelynx.pm | 7 | ||||
| -rw-r--r-- | lib/Travelynx/Command/work.pm | 2 | ||||
| -rw-r--r-- | lib/Travelynx/Model/InTransit.pm | 24 |
3 files changed, 32 insertions, 1 deletions
diff --git a/lib/Travelynx.pm b/lib/Travelynx.pm index c8c96b8..78642ff 100755 --- a/lib/Travelynx.pm +++ b/lib/Travelynx.pm @@ -1615,6 +1615,13 @@ sub startup { rt_arrival => ( $stop->[2]{rt_arr} || $stop->[2]{sched_arr} ) ); + if ($stop->[2]{platform}) { + $self->in_transit->set_arrival_platform( + uid => $uid, + db => $db, + arrival_platform => $stop->[2]{platform} + ); + } if ( $now > ( $stop->[2]{rt_arr} || $stop->[2]{sched_arr} ) ) { diff --git a/lib/Travelynx/Command/work.pm b/lib/Travelynx/Command/work.pm index 071befa..5ce7e8d 100644 --- a/lib/Travelynx/Command/work.pm +++ b/lib/Travelynx/Command/work.pm @@ -76,7 +76,7 @@ sub run { eval { Mojo::Promise->timer( - $dbris_rate_limited ? 4.5 : ( $backend ? 1.2 : 1.0 ) ) + $dbris_rate_limited ? 4.5 : ( $backend ? 2.0 : 1.0 ) ) ->then( sub { return $self->app->dbris->get_journey_p( diff --git a/lib/Travelynx/Model/InTransit.pm b/lib/Travelynx/Model/InTransit.pm index 11177dd..16946ff 100644 --- a/lib/Travelynx/Model/InTransit.pm +++ b/lib/Travelynx/Model/InTransit.pm @@ -160,6 +160,7 @@ sub add { isCancelled => $j_stop->is_cancelled, arr_delay => $j_stop->arr_delay, dep_delay => $j_stop->dep_delay, + platform => $j_stop->platform, efa_load => $j_stop->occupancy, lat => $j_stop->latlon->[0], lon => $j_stop->latlon->[1], @@ -214,6 +215,7 @@ sub add { rt_dep => _epoch( $j_stop->rt_dep ), arr_delay => $j_stop->arr_delay, dep_delay => $j_stop->dep_delay, + platform => $j_stop->platform, load => $j_stop->load, lat => $j_stop->loc->lat, lon => $j_stop->loc->lon, @@ -284,6 +286,7 @@ sub add { isCancelled => $j_stop->is_cancelled, arr_delay => $j_stop->arr_delay, dep_delay => $j_stop->dep_delay, + platform => $j_stop->platform, load => { FIRST => $j_stop->occupancy_first, SECOND => $j_stop->occupancy_second @@ -364,6 +367,7 @@ sub add { _epoch( $journey_stopover->realtime_departure ), arr_delay => $journey_stopover->arrival_delay, dep_delay => $journey_stopover->departure_delay, + platform => $journey_stopover->track, lat => $journey_stopover->stop->lat, lon => $journey_stopover->stop->lon, } @@ -770,6 +774,22 @@ sub set_arrival_eva { ); } +sub set_arrival_platform { + my ( $self, %opt ) = @_; + + my $uid = $opt{uid}; + my $db = $opt{db} // $self->{pg}->db; + my $platform = $opt{arrival_platform}; + + $db->update( + 'in_transit', + { + arr_platform => $platform, + }, + { user_id => $uid } + ); +} + sub set_arrival_times { my ( $self, %opt ) = @_; @@ -1235,6 +1255,7 @@ sub update_arrival_dbris { isCancelled => $j_stop->is_cancelled, arr_delay => $j_stop->arr_delay, dep_delay => $j_stop->dep_delay, + platform => $j_stop->platform, load => { FIRST => $j_stop->occupancy_first, SECOND => $j_stop->occupancy_second @@ -1302,6 +1323,7 @@ sub update_arrival_efa { isCancelled => $j_stop->is_cancelled, arr_delay => $j_stop->arr_delay, dep_delay => $j_stop->dep_delay, + platform => $j_stop->platform, efa_load => $j_stop->occupancy, lat => $j_stop->latlon->[0], lon => $j_stop->latlon->[1], @@ -1356,6 +1378,7 @@ sub update_arrival_motis { rt_dep => _epoch( $journey_stopover->realtime_departure ), arr_delay => $journey_stopover->arrival_delay, dep_delay => $journey_stopover->departure_delay, + platform => $journey_stopover->track, lat => $journey_stopover->stop->lat, lon => $journey_stopover->stop->lon, } @@ -1416,6 +1439,7 @@ sub update_arrival_hafas { rt_dep => _epoch( $j_stop->rt_dep ), arr_delay => $j_stop->arr_delay, dep_delay => $j_stop->dep_delay, + platform => $j_stop->platform, load => $j_stop->load, lat => $j_stop->loc->lat, lon => $j_stop->loc->lon, |