summaryrefslogtreecommitdiff
path: root/lib/Travelynx
diff options
context:
space:
mode:
Diffstat (limited to 'lib/Travelynx')
-rwxr-xr-xlib/Travelynx/Controller/Traveling.pm11
-rw-r--r--lib/Travelynx/Model/InTransit.pm10
2 files changed, 16 insertions, 5 deletions
diff --git a/lib/Travelynx/Controller/Traveling.pm b/lib/Travelynx/Controller/Traveling.pm
index 6a91f0e..cba28cf 100755
--- a/lib/Travelynx/Controller/Traveling.pm
+++ b/lib/Travelynx/Controller/Traveling.pm
@@ -717,11 +717,12 @@ sub travel_action {
$promise->then(
sub {
return $self->checkin_p(
- dbris => $params->{dbris},
- hafas => $params->{hafas},
- station => $params->{station},
- train_id => $params->{train},
- ts => $params->{ts},
+ dbris => $params->{dbris},
+ hafas => $params->{hafas},
+ station => $params->{station},
+ train_id => $params->{train},
+ train_suffix => $params->{suffix},
+ ts => $params->{ts},
);
}
)->then(
diff --git a/lib/Travelynx/Model/InTransit.pm b/lib/Travelynx/Model/InTransit.pm
index 34c78f7..bf117bf 100644
--- a/lib/Travelynx/Model/InTransit.pm
+++ b/lib/Travelynx/Model/InTransit.pm
@@ -95,6 +95,7 @@ sub add {
my $db = $opt{db} // $self->{pg}->db;
my $backend_id = $opt{backend_id};
my $train = $opt{train};
+ my $train_suffix = $opt{train_suffix};
my $journey = $opt{journey};
my $stop = $opt{stop};
my $checkin_station_id = $opt{departure_eva};
@@ -194,6 +195,14 @@ sub add {
}
elsif ( $journey and $stop ) {
+ my $line;
+ if ( $train_suffix
+ and $journey->number
+ and $train_suffix ne $journey->number )
+ {
+ $line = $train_suffix;
+ }
+
# DBRIS
my @route;
for my $j_stop ( $journey->route ) {
@@ -231,6 +240,7 @@ sub add {
checkin_time => DateTime->now( time_zone => 'Europe/Berlin' ),
dep_platform => $stop->platform,
train_type => $journey->type,
+ train_line => $line,
train_no => $journey->number,
train_id => $data->{trip_id},
sched_departure => $stop->sched_dep,