diff options
| author | Derf Null <derf@finalrewind.org> | 2023-03-10 16:57:31 +0100 |
|---|---|---|
| committer | Derf Null <derf@finalrewind.org> | 2023-03-10 16:57:31 +0100 |
| commit | f79e34fb622ddb5cf394da9928fa981c36ba3ad8 (patch) | |
| tree | e71f6a09cd13bccec9bdf942ab6d803ccd8b5e93 | |
| parent | 609d7b3ebc2ed0f190799da2565910cec7d79339 (diff) | |
worker: select on arr and dep eva for all arr/dep updates
still missing (TODO): add_route_timestamps
| -rw-r--r-- | lib/Travelynx/Command/work.pm | 9 | ||||
| -rw-r--r-- | lib/Travelynx/Model/InTransit.pm | 8 |
2 files changed, 13 insertions, 4 deletions
diff --git a/lib/Travelynx/Command/work.pm b/lib/Travelynx/Command/work.pm index 8af88bd..7af988c 100644 --- a/lib/Travelynx/Command/work.pm +++ b/lib/Travelynx/Command/work.pm @@ -64,9 +64,11 @@ sub run { } $self->app->in_transit->update_departure( - uid => $uid, - train => $train, - route => [ $self->app->iris->route_diff($train) ] + uid => $uid, + train => $train, + dep_eva => $dep, + arr_eva => $arr, + route => [ $self->app->iris->route_diff($train) ] ); if ( $train->departure_is_cancelled and $arr ) { @@ -143,6 +145,7 @@ sub run { uid => $uid, train => $train, route => [ $self->app->iris->route_diff($train) ], + dep_eva => $dep, arr_eva => $arr, ); diff --git a/lib/Travelynx/Model/InTransit.pm b/lib/Travelynx/Model/InTransit.pm index 78fd297..6d445d5 100644 --- a/lib/Travelynx/Model/InTransit.pm +++ b/lib/Travelynx/Model/InTransit.pm @@ -333,6 +333,8 @@ sub update_departure { my ( $self, %opt ) = @_; my $uid = $opt{uid}; my $db = $opt{db} // $self->{pg}->db; + my $dep_eva = $opt{dep_eva}; + my $arr_eva = $opt{arr_eva}; my $train = $opt{train}; my $route = $opt{route}; my $json = JSON->new; @@ -358,7 +360,9 @@ sub update_departure { }, { user_id => $uid, - train_no => $train->train_no + train_no => $train->train_no, + checkin_station_id => $dep_eva, + checkout_station_id => $arr_eva, } ); } @@ -395,6 +399,7 @@ sub update_arrival { my ( $self, %opt ) = @_; my $uid = $opt{uid}; my $db = $opt{db} // $self->{pg}->db; + my $dep_eva = $opt{dep_eva}; my $arr_eva = $opt{arr_eva}; my $train = $opt{train}; my $route = $opt{route}; @@ -424,6 +429,7 @@ sub update_arrival { { user_id => $uid, train_no => $train->train_no, + checkin_station_id => $dep_eva, checkout_station_id => $arr_eva, } )->rows; |