111 lines
2.3 KiB
Perl
111 lines
2.3 KiB
Perl
package Travelynx::Command::work;
|
|
use Mojo::Base 'Mojolicious::Command';
|
|
|
|
use DateTime;
|
|
use List::Util qw(first);
|
|
|
|
has description =>
|
|
'Perform automatic checkout when users arrive at their destination';
|
|
|
|
has usage => sub { shift->extract_usage };
|
|
|
|
sub run {
|
|
my ($self) = @_;
|
|
|
|
my $now = DateTime->now( time_zone => 'Europe/Berlin' );
|
|
|
|
my $db = $self->app->pg->db;
|
|
|
|
for my $entry (
|
|
$db->select( 'in_transit_str', '*', { cancelled => 0 } )->hashes->each )
|
|
{
|
|
|
|
my $uid = $entry->{user_id};
|
|
my $dep = $entry->{dep_ds100};
|
|
my $arr = $entry->{arr_ds100};
|
|
my $train = $entry->{train_id};
|
|
|
|
$self->app->log->debug("Processing $uid");
|
|
|
|
eval {
|
|
if ( $now->epoch - $entry->{real_dep_ts} < 300 ) {
|
|
$self->app->log->debug(" - updating departure");
|
|
my $status = $self->app->get_departures( $dep, 30, 30 );
|
|
if ( $status->{errstr} ) {
|
|
die("get_departures($dep): $status->{errstr}\n");
|
|
}
|
|
|
|
my ($train)
|
|
= first { $_->train_id eq $train } @{ $status->{results} };
|
|
|
|
if ( not $train ) {
|
|
die("could not find train $train at $dep\n");
|
|
}
|
|
|
|
$db->update(
|
|
'in_transit',
|
|
{ real_departure => $train->departure },
|
|
{ user_id => $uid }
|
|
);
|
|
}
|
|
};
|
|
if ($@) {
|
|
$self->app->log->error("work($uid)/departure: $@");
|
|
}
|
|
|
|
eval {
|
|
if (
|
|
$entry->{arr_name}
|
|
and ( not $entry->{real_arr_ts}
|
|
or $now->epoch - $entry->{real_arr_ts} < 60 )
|
|
)
|
|
{
|
|
$self->app->log->debug(" - updating arrival");
|
|
my $status = $self->app->get_departures( $arr, 20, 220 );
|
|
if ( $status->{errstr} ) {
|
|
die("get_departures($arr): $status->{errstr}\n");
|
|
}
|
|
|
|
my ($train)
|
|
= first { $_->train_id eq $train } @{ $status->{results} };
|
|
|
|
if ( not $train ) {
|
|
die("could not find train $train at $arr\n");
|
|
}
|
|
|
|
$db->update(
|
|
'in_transit',
|
|
{
|
|
sched_arrival => $train->sched_arrival,
|
|
real_arrival => $train->arrival,
|
|
},
|
|
{ user_id => $uid }
|
|
);
|
|
}
|
|
elsif ( $entry->{real_arr_ts} ) {
|
|
$self->app->log->debug(" - checking out");
|
|
my ( undef, $error ) = $self->app->checkout( $arr, 1, $uid );
|
|
if ($error) {
|
|
die("${error}\n");
|
|
}
|
|
}
|
|
};
|
|
if ($@) {
|
|
$self->app->log->error("work($uid)/arrival: $@");
|
|
}
|
|
|
|
eval { }
|
|
}
|
|
}
|
|
|
|
1;
|
|
|
|
__END__
|
|
|
|
=head1 SYNOPSIS
|
|
|
|
Usage: index.pl work
|
|
|
|
Work Work Work.
|
|
|
|
Should be called from a cronjob every three minutes or so.
|