#905 fluff

volumes/miovision/sql/open_data/create-function-insert_miovision_open_data_15min.sql

@@ -4,18 +4,19 @@
 --Include/Exclude buses/streetcars?
 --Decision to not include manual anomalous_range 'valid_caveat' notes: SELECT 
 --Including entry/exit information to satisfy ATR related DRs.
-    --> providing exit leg and direction as extra columns rather
-    -- than extra rows to reduce potential for double counting.
+-->> providing exit leg and direction as extra columns rather
+-->> than extra rows to reduce potential for double counting.
 
 --DROP FUNCTION gwolofs.insert_miovision_15min_open_data;
 
 CREATE OR REPLACE FUNCTION gwolofs.insert_miovision_15min_open_data(
-	_date date,
-	intersections integer[] DEFAULT ARRAY[]::integer[])
-    RETURNS void
-    LANGUAGE 'plpgsql'
-    COST 100
-    VOLATILE PARALLEL UNSAFE
+    _date date,
+    integer [] DEFAULT ARRAY[]::integer []
+)
+RETURNS void
+LANGUAGE 'plpgsql'
+COST 100
+VOLATILE PARALLEL UNSAFE
 AS $BODY$
 
     DECLARE
@@ -136,19 +137,19 @@ AS $BODY$
 END;
 $BODY$;
 
-ALTER FUNCTION gwolofs.insert_miovision_15min_open_data(date, integer[])
+ALTER FUNCTION gwolofs.insert_miovision_15min_open_data(date, integer [])
 OWNER TO gwolofs;
 
-GRANT EXECUTE ON FUNCTION gwolofs.insert_miovision_15min_open_data(date, integer[])
+GRANT EXECUTE ON FUNCTION gwolofs.insert_miovision_15min_open_data(date, integer [])
 TO miovision_admins;
 
-GRANT EXECUTE ON FUNCTION gwolofs.insert_miovision_15min_open_data(date, integer[])
+GRANT EXECUTE ON FUNCTION gwolofs.insert_miovision_15min_open_data(date, integer [])
 TO miovision_api_bot;
 
-REVOKE ALL ON FUNCTION gwolofs.insert_miovision_15min_open_data(date, integer[])
-FROM PUBLIC;
+REVOKE ALL ON FUNCTION gwolofs.insert_miovision_15min_open_data(date, integer [])
+FROM public;
 
-COMMENT ON FUNCTION gwolofs.insert_miovision_15min_open_data(date, integer[])
+COMMENT ON FUNCTION gwolofs.insert_miovision_15min_open_data(date, integer [])
 IS 'Function for first deleting then inserting monthly 15
 minute open data volumes into gwolofs.miovision_15min_open_data.
 Contains an optional intersection parameter in case one just one

volumes/miovision/sql/open_data/create-function-insert_miovision_open_data_monthly_summary.sql

@@ -1,12 +1,13 @@
 --DROP FUNCTION gwolofs.insert_miovision_open_data_monthly_summary;
 
 CREATE OR REPLACE FUNCTION gwolofs.insert_miovision_open_data_monthly_summary(
-	_date date,
-	intersections integer[] DEFAULT ARRAY[]::integer[])
-    RETURNS void
-    LANGUAGE 'plpgsql'
-    COST 100
-    VOLATILE PARALLEL UNSAFE
+    _date date,
+    intersections integer [] DEFAULT ARRAY[]::integer []
+)
+RETURNS void
+LANGUAGE 'plpgsql'
+COST 100
+VOLATILE PARALLEL UNSAFE
 AS $BODY$
 
     DECLARE
@@ -180,19 +181,19 @@ AS $BODY$
 END;
 $BODY$;
 
-ALTER FUNCTION gwolofs.insert_miovision_open_data_monthly_summary(date, integer[])
+ALTER FUNCTION gwolofs.insert_miovision_open_data_monthly_summary(date, integer [])
 OWNER TO gwolofs;
 
-GRANT EXECUTE ON FUNCTION gwolofs.insert_miovision_open_data_monthly_summary(date, integer[])
+GRANT EXECUTE ON FUNCTION gwolofs.insert_miovision_open_data_monthly_summary(date, integer [])
 TO miovision_admins;
 
-GRANT EXECUTE ON FUNCTION gwolofs.insert_miovision_open_data_monthly_summary(date, integer[])
+GRANT EXECUTE ON FUNCTION gwolofs.insert_miovision_open_data_monthly_summary(date, integer [])
 TO miovision_api_bot;
 
-REVOKE ALL ON FUNCTION gwolofs.insert_miovision_open_data_monthly_summary(date, integer[])
-FROM PUBLIC;
+REVOKE ALL ON FUNCTION gwolofs.insert_miovision_open_data_monthly_summary(date, integer [])
+FROM public;
 
-COMMENT ON FUNCTION gwolofs.insert_miovision_open_data_monthly_summary(date, integer[])
+COMMENT ON FUNCTION gwolofs.insert_miovision_open_data_monthly_summary(date, integer [])
 IS 'Function for first deleting then inserting monthly summary miovision
 open data into gwolofs.miovision_open_data_monthly_summary.
 Contains an optional intersection parameter in case one just one

volumes/miovision/sql/open_data/create-table-miovision_open_data_15min.sql

@@ -22,7 +22,7 @@ TABLESPACE pg_default;
 CREATE INDEX miovision_15min_od_dt_idx ON
 gwolofs.miovision_15min_open_data USING brin (datetime_15min);
 
-ALTER TABLE IF EXISTS gwolofs.miovision_15min_open_data 
+ALTER TABLE IF EXISTS gwolofs.miovision_15min_open_data
 OWNER TO gwolofs;
 
 REVOKE ALL ON TABLE gwolofs.miovision_15min_open_data FROM bdit_humans;

volumes/miovision/sql/open_data/create-table-miovision_open_data_monthly_summary.sql

@@ -26,7 +26,7 @@ TABLESPACE pg_default;
 CREATE INDEX miovision_monthly_od_dt_idx ON
 gwolofs.miovision_open_data_monthly_summary USING brin (mnth);
 
-ALTER TABLE IF EXISTS gwolofs.miovision_open_data_monthly_summary 
+ALTER TABLE IF EXISTS gwolofs.miovision_open_data_monthly_summary
 OWNER TO gwolofs;
 
 REVOKE ALL ON TABLE gwolofs.miovision_open_data_monthly_summary FROM bdit_humans;

volumes/miovision/sql/open_data/create-view-miovision_wide_tmc.sql

@@ -1,72 +1,117 @@
---Would prefer to omit this, unless we *really* want it for comparison with existing short term TMC open data.
+--Would prefer to omit this, unless we *really* want it for
+--comparison with existing short term TMC open data.
 
 --include u-turns?
 --bikes
 --motorized vehicles/streetcars?
 
 CREATE OR REPLACE VIEW gwolofs.miovision_open_data_wide_15min AS (
 
-SELECT
-    v.intersection_uid,
-    v.datetime_bin,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 3 AND classification_uid = ANY (ARRAY[1]::int []) AND leg = 'S'), 0) AS sb_car_r,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 1 AND classification_uid = ANY (ARRAY[1]::int []) AND leg = 'S'), 0) AS sb_car_t,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 2 AND classification_uid = ANY (ARRAY[1]::int []) AND leg = 'S'), 0) AS sb_car_l,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 3 AND classification_uid = ANY (ARRAY[1]::int []) AND leg = 'N'), 0) AS nb_car_r,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 1 AND classification_uid = ANY (ARRAY[1]::int []) AND leg = 'N'), 0) AS nb_car_t,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 2 AND classification_uid = ANY (ARRAY[1]::int []) AND leg = 'N'), 0) AS nb_car_l,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 3 AND classification_uid = ANY (ARRAY[1]::int []) AND leg = 'W'), 0) AS wb_car_r,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 1 AND classification_uid = ANY (ARRAY[1]::int []) AND leg = 'W'), 0) AS wb_car_t,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 2 AND classification_uid = ANY (ARRAY[1]::int []) AND leg = 'W'), 0) AS wb_car_l,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 3 AND classification_uid = ANY (ARRAY[1]::int []) AND leg = 'E'), 0) AS eb_car_r,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 1 AND classification_uid = ANY (ARRAY[1]::int []) AND leg = 'E'), 0) AS eb_car_t,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 2 AND classification_uid = ANY (ARRAY[1]::int []) AND leg = 'E'), 0) AS eb_car_l,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 3 AND classification_uid = ANY (ARRAY[4,5,9]::int []) AND leg = 'S'), 0) AS sb_truck_r,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 1 AND classification_uid = ANY (ARRAY[4,5,9]::int []) AND leg = 'S'), 0) AS sb_truck_t,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 2 AND classification_uid = ANY (ARRAY[4,5,9]::int []) AND leg = 'S'), 0) AS sb_truck_l,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 3 AND classification_uid = ANY (ARRAY[4,5,9]::int []) AND leg = 'N'), 0) AS nb_truck_r,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 1 AND classification_uid = ANY (ARRAY[4,5,9]::int []) AND leg = 'N'), 0) AS nb_truck_t,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 2 AND classification_uid = ANY (ARRAY[4,5,9]::int []) AND leg = 'N'), 0) AS nb_truck_l,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 3 AND classification_uid = ANY (ARRAY[4,5,9]::int []) AND leg = 'W'), 0) AS wb_truck_r,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 1 AND classification_uid = ANY (ARRAY[4,5,9]::int []) AND leg = 'W'), 0) AS wb_truck_t,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 2 AND classification_uid = ANY (ARRAY[4,5,9]::int []) AND leg = 'W'), 0) AS wb_truck_l,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 3 AND classification_uid = ANY (ARRAY[4,5,9]::int []) AND leg = 'E'), 0) AS eb_truck_r,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 1 AND classification_uid = ANY (ARRAY[4,5,9]::int []) AND leg = 'E'), 0) AS eb_truck_t,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 2 AND classification_uid = ANY (ARRAY[4,5,9]::int []) AND leg = 'E'), 0) AS eb_truck_l,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 3 AND classification_uid = ANY (ARRAY[3]::int []) AND leg = 'S'), 0) AS sb_bus_r,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 1 AND classification_uid = ANY (ARRAY[3]::int []) AND leg = 'S'), 0) AS sb_bus_t,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 2 AND classification_uid = ANY (ARRAY[3]::int []) AND leg = 'S'), 0) AS sb_bus_l,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 3 AND classification_uid = ANY (ARRAY[3]::int []) AND leg = 'N'), 0) AS nb_bus_r,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 1 AND classification_uid = ANY (ARRAY[3]::int []) AND leg = 'N'), 0) AS nb_bus_t,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 2 AND classification_uid = ANY (ARRAY[3]::int []) AND leg = 'N'), 0) AS nb_bus_l,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 3 AND classification_uid = ANY (ARRAY[3]::int []) AND leg = 'W'), 0) AS wb_bus_r,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 1 AND classification_uid = ANY (ARRAY[3]::int []) AND leg = 'W'), 0) AS wb_bus_t,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 2 AND classification_uid = ANY (ARRAY[3]::int []) AND leg = 'W'), 0) AS wb_bus_l,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 3 AND classification_uid = ANY (ARRAY[3]::int []) AND leg = 'E'), 0) AS eb_bus_r,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 1 AND classification_uid = ANY (ARRAY[3]::int []) AND leg = 'E'), 0) AS eb_bus_t,
-    COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = 2 AND classification_uid = ANY (ARRAY[3]::int []) AND leg = 'E'), 0) AS eb_bus_l,
-    COALESCE(SUM(v.volume) FILTER (WHERE classification_uid = 6 AND leg = 'N'), 0) AS nx_peds,
-    COALESCE(SUM(v.volume) FILTER (WHERE classification_uid = 6 AND leg = 'S'), 0) AS sx_peds,
-    COALESCE(SUM(v.volume) FILTER (WHERE classification_uid = 6 AND leg = 'E'), 0) AS ex_peds,
-    COALESCE(SUM(v.volume) FILTER (WHERE classification_uid = 6 AND leg = 'W'), 0) AS wx_peds,
-    COALESCE(SUM(v.volume) FILTER (WHERE classification_uid = 2 AND leg = 'N'), 0) AS nx_bike,
-    COALESCE(SUM(v.volume) FILTER (WHERE classification_uid = 2 AND leg = 'S'), 0) AS sx_bike,
-    COALESCE(SUM(v.volume) FILTER (WHERE classification_uid = 2 AND leg = 'E'), 0) AS ex_bike,
-    COALESCE(SUM(v.volume) FILTER (WHERE classification_uid = 2 AND leg = 'W'), 0) AS wx_bike
-FROM miovision_api.volumes_15min_mvt AS v
-JOIN miovision_api.classifications AS c USING (classification_uid)
-JOIN miovision_api.movements AS m USING (movement_uid)
-WHERE
-    datetime_bin >= '2024-02-01'::date
-    AND datetime_bin < '2024-03-01'::date
-    --AND intersection_uid = 1
-    --AND classification_uid NOT IN (2,10) --exclude bikes due to reliability
-GROUP BY
-    v.intersection_uid,
-    v.datetime_bin
-ORDER BY
-    v.intersection_uid,
-    v.datetime_bin
+    SELECT
+        v.intersection_uid,
+        v.datetime_bin,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 3
+            AND v.classification_uid = ANY(ARRAY[1]::int []) AND v.leg = 'S'), 0) AS sb_car_r,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 1
+            AND v.classification_uid = ANY(ARRAY[1]::int []) AND v.leg = 'S'), 0) AS sb_car_t,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 2
+            AND v.classification_uid = ANY(ARRAY[1]::int []) AND v.leg = 'S'), 0) AS sb_car_l,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 3
+            AND v.classification_uid = ANY(ARRAY[1]::int []) AND v.leg = 'N'), 0) AS nb_car_r,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 1
+            AND v.classification_uid = ANY(ARRAY[1]::int []) AND v.leg = 'N'), 0) AS nb_car_t,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 2
+            AND v.classification_uid = ANY(ARRAY[1]::int []) AND v.leg = 'N'), 0) AS nb_car_l,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 3
+            AND v.classification_uid = ANY(ARRAY[1]::int []) AND v.leg = 'W'), 0) AS wb_car_r,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 1
+            AND v.classification_uid = ANY(ARRAY[1]::int []) AND v.leg = 'W'), 0) AS wb_car_t,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 2
+            AND v.classification_uid = ANY(ARRAY[1]::int []) AND v.leg = 'W'), 0) AS wb_car_l,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 3
+            AND v.classification_uid = ANY(ARRAY[1]::int []) AND v.leg = 'E'), 0) AS eb_car_r,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 1
+            AND v.classification_uid = ANY(ARRAY[1]::int []) AND v.leg = 'E'), 0) AS eb_car_t,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 2
+            AND v.classification_uid = ANY(ARRAY[1]::int []) AND v.leg = 'E'), 0) AS eb_car_l,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 3
+            AND v.classification_uid = ANY(ARRAY[4,5,9]::int []) AND v.leg = 'S'), 0) AS sb_truck_r,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 1
+            AND v.classification_uid = ANY(ARRAY[4,5,9]::int []) AND v.leg = 'S'), 0) AS sb_truck_t,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 2
+            AND v.classification_uid = ANY(ARRAY[4,5,9]::int []) AND v.leg = 'S'), 0) AS sb_truck_l,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 3
+            AND v.classification_uid = ANY(ARRAY[4,5,9]::int []) AND v.leg = 'N'), 0) AS nb_truck_r,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 1
+            AND v.classification_uid = ANY(ARRAY[4,5,9]::int []) AND v.leg = 'N'), 0) AS nb_truck_t,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 2
+            AND v.classification_uid = ANY(ARRAY[4,5,9]::int []) AND v.leg = 'N'), 0) AS nb_truck_l,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 3
+            AND v.classification_uid = ANY(ARRAY[4,5,9]::int []) AND v.leg = 'W'), 0) AS wb_truck_r,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 1
+            AND v.classification_uid = ANY(ARRAY[4,5,9]::int []) AND v.leg = 'W'), 0) AS wb_truck_t,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 2
+            AND v.classification_uid = ANY(ARRAY[4,5,9]::int []) AND v.leg = 'W'), 0) AS wb_truck_l,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 3
+            AND v.classification_uid = ANY(ARRAY[4,5,9]::int []) AND v.leg = 'E'), 0) AS eb_truck_r,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 1
+            AND v.classification_uid = ANY(ARRAY[4,5,9]::int []) AND v.leg = 'E'), 0) AS eb_truck_t,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 2
+            AND v.classification_uid = ANY(ARRAY[4,5,9]::int []) AND v.leg = 'E'), 0) AS eb_truck_l,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 3
+            AND v.classification_uid = ANY(ARRAY[3]::int []) AND v.leg = 'S'), 0) AS sb_bus_r,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 1
+            AND v.classification_uid = ANY(ARRAY[3]::int []) AND v.leg = 'S'), 0) AS sb_bus_t,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 2
+            AND v.classification_uid = ANY(ARRAY[3]::int []) AND v.leg = 'S'), 0) AS sb_bus_l,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 3
+            AND v.classification_uid = ANY(ARRAY[3]::int []) AND v.leg = 'N'), 0) AS nb_bus_r,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 1
+            AND v.classification_uid = ANY(ARRAY[3]::int []) AND v.leg = 'N'), 0) AS nb_bus_t,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 2
+            AND v.classification_uid = ANY(ARRAY[3]::int []) AND v.leg = 'N'), 0) AS nb_bus_l,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 3
+            AND v.classification_uid = ANY(ARRAY[3]::int []) AND v.leg = 'W'), 0) AS wb_bus_r,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 1
+            AND v.classification_uid = ANY(ARRAY[3]::int []) AND v.leg = 'W'), 0) AS wb_bus_t,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 2
+            AND v.classification_uid = ANY(ARRAY[3]::int []) AND v.leg = 'W'), 0) AS wb_bus_l,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 3
+            AND v.classification_uid = ANY(ARRAY[3]::int []) AND v.leg = 'E'), 0) AS eb_bus_r,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 1
+            AND v.classification_uid = ANY(ARRAY[3]::int []) AND v.leg = 'E'), 0) AS eb_bus_t,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = 2
+            AND v.classification_uid = ANY(ARRAY[3]::int []) AND v.leg = 'E'), 0) AS eb_bus_l,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.classification_uid = 6
+            AND v.leg = 'N'), 0) AS nx_peds,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.classification_uid = 6
+            AND v.leg = 'S'), 0) AS sx_peds,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.classification_uid = 6
+            AND v.leg = 'E'), 0) AS ex_peds,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.classification_uid = 6
+            AND v.leg = 'W'), 0) AS wx_peds,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.classification_uid = 2
+            AND v.leg = 'N'), 0) AS nx_bike,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.classification_uid = 2
+            AND v.leg = 'S'), 0) AS sx_bike,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.classification_uid = 2
+            AND v.leg = 'E'), 0) AS ex_bike,
+        COALESCE(SUM(v.volume) FILTER (WHERE v.classification_uid = 2
+            AND v.leg = 'W'), 0) AS wx_bike
+    FROM miovision_api.volumes_15min_mvt AS v
+    JOIN miovision_api.classifications AS c USING (classification_uid)
+    JOIN miovision_api.movements AS m USING (movement_uid)
+    WHERE
+        datetime_bin >= '2024-02-01'::date
+        AND datetime_bin < '2024-03-01'::date
+        --AND intersection_uid = 1
+        --AND v.classification_uid NOT IN (2,10) --exclude bikes due to reliability
+    GROUP BY
+        v.intersection_uid,
+        v.datetime_bin
+    ORDER BY
+        v.intersection_uid,
+        v.datetime_bin
 ); 
 
 SELECT * FROM gwolofs.miovision_open_data_wide_15min LIMIT 10000;
@@ -75,9 +120,9 @@ SELECT * FROM gwolofs.miovision_open_data_wide_15min LIMIT 10000;
 
 SELECT col_name FROM (
 SELECT
-    'COALESCE(SUM(v.volume) FILTER (WHERE movement_uid = ' || movement_uid::text ||
-    ' AND classification_uid = ANY (ARRAY[' || string_agg(classification_uid::text, ',') || ']::int [])' ||
-    ' AND leg = ''' || leg || '''), 0) AS ' ||
+    'COALESCE(SUM(v.volume) FILTER (WHERE v.movement_uid = ' || movement_uid::text ||
+    ' AND v.classification_uid = ANY(ARRAY[' || string_agg(classification_uid::text, ',') || ']::int [])' ||
+    ' AND v.leg = ''' || leg || '''), 0) AS ' ||
     dir || '_' ||
     CASE classification WHEN 'Light' THEN 'car' WHEN 'Bus' THEN 'bus' WHEN 'SingleUnitTruck' THEN 'truck' WHEN 'ArticulatedTruck' THEN 'truck' WHEN 'MotorizedVehicle' THEN 'truck' END || '_' ||
     CASE movement_name WHEN 'left' THEN 'l' WHEN 'thru' THEN 't' WHEN 'right' THEN 'r' END || ',' AS col_name
@@ -107,8 +152,8 @@ UNION ALL
 
 SELECT col_name FROM (
     SELECT
-        'COALESCE(SUM(v.volume) FILTER (WHERE classification_uid = ' || classification_uid::text ||
-        ' AND leg = ''' || leg || '''), 0) AS ' ||
+        'COALESCE(SUM(v.volume) FILTER (WHERE v.classification_uid = ' || classification_uid::text ||
+        ' AND v.leg = ''' || leg || '''), 0) AS ' ||
         dir || '_' ||
         CASE classification WHEN 'Bicycle' THEN 'bike' WHEN 'Pedestrian' THEN 'peds' END || ',' AS col_name
     FROM miovision_api.classifications