diff options
Diffstat (limited to 'lib')
| -rwxr-xr-x | lib/Travelynx.pm | 25 | ||||
| -rw-r--r-- | lib/Travelynx/Command/database.pm | 13 |
2 files changed, 31 insertions, 7 deletions
diff --git a/lib/Travelynx.pm b/lib/Travelynx.pm index 6434e00..1e7c965 100755 --- a/lib/Travelynx.pm +++ b/lib/Travelynx.pm @@ -1445,8 +1445,9 @@ sub startup { my $interchange_real = 0; my $num_trains = 0; my $num_journeys = 0; + my @inconsistencies; - my $next_departure = 0; + my $next_departure = epoch_to_dt(0); for my $journey (@journeys) { $num_trains++; @@ -1472,18 +1473,27 @@ sub startup { # Note that journeys are sorted from recent to older entries if ( $journey->{rt_arrival} - and $next_departure - and $next_departure - $journey->{rt_arrival}->epoch + and $next_departure->epoch + and $next_departure->epoch - $journey->{rt_arrival}->epoch < ( 60 * 60 ) ) { - $interchange_real - += ( $next_departure - $journey->{rt_arrival}->epoch ) - / 60; + if ( $next_departure->epoch - $journey->{rt_arrival}->epoch + < 0 ) + { + push( @inconsistencies, + $next_departure->strftime('%d.%m.%Y %H:%M') ); + } + else { + $interchange_real + += ( $next_departure->epoch + - $journey->{rt_arrival}->epoch ) + / 60; + } } else { $num_journeys++; } - $next_departure = $journey->{rt_departure}->epoch; + $next_departure = $journey->{rt_departure}; } return { km_route => $km_route, @@ -1495,6 +1505,7 @@ sub startup { min_interchange_real => $interchange_real, delay_dep => $delay_dep, delay_arr => $delay_arr, + inconsistencies => \@inconsistencies, }; } ); diff --git a/lib/Travelynx/Command/database.pm b/lib/Travelynx/Command/database.pm index b5e8cf5..bd22512 100644 --- a/lib/Travelynx/Command/database.pm +++ b/lib/Travelynx/Command/database.pm @@ -330,6 +330,19 @@ my @migrations = ( } $db->update( 'schema_version', { version => 4 } ); }, + + # v4 -> v5 + # Handle inconsistent data (overlapping journeys) in statistics. Introduces + # the "inconsistencies" stats key -> rebuild all stats. + sub { + my ($db) = @_; + $db->query( + qq{ + truncate journey_stats; + update schema_version set version = 5; + } + ); + }, ); sub setup_db { |