diff --git a/open_bus_stride_api/routers/gtfs_rides_agg.py b/open_bus_stride_api/routers/gtfs_rides_agg.py index abcee0e..fb38b8e 100644 --- a/open_bus_stride_api/routers/gtfs_rides_agg.py +++ b/open_bus_stride_api/routers/gtfs_rides_agg.py @@ -63,11 +63,15 @@ def list_(limit: int = common.param_limit(default_limit=DEFAULT_LIMIT), where agg.gtfs_route_id = rt.id and agg.gtfs_route_date >= :date_from - and agg.gtfs_route_date <= :date_to + and agg.gtfs_route_date <= :date_to + and rt.date >= :rt_date_from + and rt.date <= :rt_date_to """ sql_params = { 'date_from': date_from, 'date_to': date_to, + 'rt_date_from': date_from - datetime.timedelta(days=1), + 'rt_date_to': date_from + datetime.timedelta(days=1), } if exclude_hours_from: @@ -116,10 +120,14 @@ def group_by_(date_from: datetime.date = common.doc_param('date', filter_type='d agg.gtfs_route_id = rt.id and agg.gtfs_route_date >= :date_from and agg.gtfs_route_date <= :date_to + and rt.date >= :rt_date_from + and rt.date <= :rt_date_to """) sql_params = { 'date_from': date_from, 'date_to': date_to, + 'rt_date_from': date_from - datetime.timedelta(days=1), + 'rt_date_to': date_from + datetime.timedelta(days=1), } if exclude_hours_from: