diff options
Diffstat (limited to 'lib/Travelynx/Command/work.pm')
| -rw-r--r-- | lib/Travelynx/Command/work.pm | 26 |
1 files changed, 18 insertions, 8 deletions
diff --git a/lib/Travelynx/Command/work.pm b/lib/Travelynx/Command/work.pm index 7a7ce22..f3bf71c 100644 --- a/lib/Travelynx/Command/work.pm +++ b/lib/Travelynx/Command/work.pm @@ -215,8 +215,11 @@ sub run { exclude => $dep, ); $self->app->dbris->get_connections_p( - station => $arr, - timestamp => $entry->{real_arr}, + station => $arr, + timestamp => DateTime->from_epoch( + epoch => $entry->{real_arr_ts}, + time_zone => 'Europe/Berlin' + ), destinations => \@destinations )->then( sub { @@ -348,9 +351,12 @@ sub run { exclude => $dep, ); $self->app->efa->get_connections_p( - service => $entry->{backend_name}, - name => $arr, - timestamp => $entry->{real_arr}, + service => $entry->{backend_name}, + name => $arr, + timestamp => DateTime->from_epoch( + epoch => $entry->{real_arr_ts}, + time_zone => 'Europe/Berlin' + ), destinations => \@destinations )->then( sub { @@ -782,7 +788,8 @@ sub run { $self->app->add_stationinfo( $uid, 0, $train->train_id, $dep, $arr ); } - if ( defined $entry->{real_arr_ts} + if ( $suggestions_enabled + and defined $entry->{real_arr_ts} and $now->epoch - $entry->{real_arr_ts} < 900 ) { my @destinations @@ -793,8 +800,11 @@ sub run { exclude => $dep, ); $self->app->iris->get_connections_p( - station => $arr, - timestamp => $entry->{real_arr}, + station => $arr, + timestamp => DateTime->from_epoch( + epoch => $entry->{real_arr_ts}, + time_zone => 'Europe/Berlin' + ), destinations => \@destinations )->then( sub { |