Skip to content

#1260 add bluecity + backlog of vds detector_inventory changes #1261

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

#1260 add bluecity + backlog of vds detector_inventory changes #1261

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
137 changes: 79 additions & 58 deletions volumes/vds/sql/views/create-view-detector_inventory.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,56 +14,71 @@
cl_vds.centreline_id,
cl.geom AS centreline_geom,
dtypes.det_type,
CASE dtypes.det_type = 'RESCU Detectors'
WHEN TRUE THEN CASE substring(substring(c.detector_id, 'D\w{8}'), 2, 1)
CASE dtypes.det_type = 'RESCU Detectors'::text
WHEN TRUE THEN CASE substring(substring(c.detector_id::text, 'D\w{8}'::text), 2, 1)
WHEN 'N' THEN 'DVP/Allen North' --North of Don Mills
WHEN 'S' THEN 'DVP South' --South of Don Mills
WHEN 'E' THEN 'Gardiner/Lakeshore East' --East of Yonge
WHEN 'W' THEN 'Gardiner/Lakeshore West' --West of Yonge
WHEN 'K' THEN 'Kingston Rd'
WHEN 'K'::text THEN 'Kingston Rd'::text
ELSE NULL::text
END
ELSE NULL::text
END AS det_loc,
CASE dtypes.det_type = 'RESCU Detectors'
WHEN TRUE THEN CASE substring(substring(c.detector_id, 'D\w{8}'), 9, 1)
WHEN 'D' THEN 'DVP'
WHEN 'L' THEN 'Lakeshore'
WHEN 'G' THEN 'Gardiner'
WHEN 'A' THEN 'Allen'
WHEN 'K' THEN 'Kingston Rd'
WHEN 'R' THEN 'On-Ramp'
CASE dtypes.det_type = 'RESCU Detectors'::text
WHEN true THEN
CASE substring(substring(c.detector_id::text, 'D\w{8}'::text), 9, 1)
WHEN 'D'::text THEN 'DVP'::text
WHEN 'L'::text THEN 'Lakeshore'::text
WHEN 'G'::text THEN 'Gardiner'::text
WHEN 'A'::text THEN 'Allen'::text
WHEN 'K'::text THEN 'Kingston Rd'::text
WHEN 'R'::text THEN 'On-Ramp'::text
ELSE NULL::text
END
ELSE NULL::text
END AS det_group,
CASE dtypes.det_type = 'RESCU Detectors'
WHEN TRUE THEN CASE substring(substring(c.detector_id, 'D\w{8}'), 8, 1)
WHEN 'E' THEN 'Eastbound'
WHEN 'W' THEN 'Westbound'
WHEN 'S' THEN 'Southbound'
WHEN 'N' THEN 'Northbound'
CASE dtypes.det_type = 'RESCU Detectors'::text
WHEN true THEN
CASE substring(substring(c.detector_id::text, 'D\w{8}'::text), 8, 1)
WHEN 'E'::text THEN 'Eastbound'::text
WHEN 'W'::text THEN 'Westbound'::text
WHEN 'S'::text THEN 'Southbound'::text
WHEN 'N'::text THEN 'Northbound'::text
ELSE NULL::text
END
ELSE NULL::text
END AS direction,
--new cases need to be updated manually and then updated in vds.count_15min%.
CASE
WHEN c.division_id = 8001 THEN 1 --15 min bins
--remainder are division_id = 2
WHEN
dtypes.det_type = 'Smartmicro Sensors'
OR c.detector_id SIMILAR TO 'SMARTMICRO - D\w{8}' THEN 3 --5 min bins
WHEN dtypes.det_type = 'RESCU Detectors' THEN 45 --20 sec bins
WHEN dtypes.det_type = 'Blue City AI' THEN 1 --15 min bins
WHEN dtypes.det_type = 'Houston Radar' THEN 1 --15 min bins
dtypes.det_type = 'Smartmicro Sensors'::text
OR c.detector_id::text ~ similar_to_escape('SMARTMICRO - D\w{8}'::text) THEN 3 --5 min bins
WHEN
lower(comms.source_id::text) ~ similar_to_escape('%whd%'::text)
OR lower(comms.source_id::text) ~ similar_to_escape('%wavetronix%'::text) THEN 45 --20 sec bins
WHEN dtypes.det_type = 'RESCU Detectors'::text THEN 45 --20 sec bins
WHEN dtypes.det_type = 'Blue City AI'::text THEN 1 --15 min bins
WHEN dtypes.det_type = 'Houston Radar'::text THEN 1 --15 min bins
--some unique cases
WHEN pairs.vdsconfig_uid = ANY (ARRAY[5621308, 5621332]) THEN 30
WHEN pairs.vdsconfig_uid = ANY (ARRAY[3683400, 3683403]) THEN 3
ELSE NULL::integer
END AS expected_bins,
comms.source_id AS comms_desc,
--rescu techology type, determined by communication device in some cases.
CASE dtypes.det_type = 'RESCU Detectors'
WHEN TRUE THEN CASE
WHEN
lower(comms.source_id) SIMILAR TO '%smartmicro%'
OR lower(c.detector_id) SIMILAR TO '%smartmicro%'
THEN 'Smartmicro'
WHEN lower(comms.source_id) SIMILAR TO '%whd%'
THEN 'Wavetronix'
ELSE 'Inductive'
END
CASE
WHEN
lower(comms.source_id::text) ~ similar_to_escape('%smartmicro%'::text)
OR lower(c.detector_id::text) ~ similar_to_escape('%smartmicro%'::text) THEN 'Smartmicro'::text
WHEN
lower(comms.source_id::text) ~ similar_to_escape('%whd%'::text)
OR lower(comms.source_id::text) ~ similar_to_escape('%wavetronix%'::text) THEN 'Wavetronix'::text
WHEN lower(c.detector_id::text) ~ similar_to_escape('%(whalespout)|(houstonradar)%'::text) THEN 'Radar'::text
WHEN dtypes.det_type = 'RESCU Detectors'::text THEN 'Inductive'::text
ELSE NULL::text
END AS det_tech
FROM vds.last_active AS pairs
LEFT JOIN vds.vdsconfig AS c
Expand All @@ -76,38 +91,44 @@
LEFT JOIN vds.config_comms_device AS comms
ON comms.fss_id = c.fss_id
AND comms.division_id = c.division_id
AND tsrange(c.start_timestamp, COALESCE(c.end_timestamp, now()::timestamp))
&& tsrange(comms.start_timestamp, COALESCE(comms.end_timestamp, now()::timestamp)),
AND tsrange(c.start_timestamp, COALESCE(c.end_timestamp, now()::timestamp without time zone))
&& tsrange(comms.start_timestamp, COALESCE(comms.end_timestamp, now()::timestamp without time zone)),
LATERAL (
SELECT CASE
WHEN c.division_id = 2 AND (
c.detector_id SIMILAR TO 'D\w{8}%'
WHEN c.detector_id::text ~~ 'QWS%'::text
THEN 'Smartmicro Sensors'::text
WHEN
c.division_id = 2 AND (c.detector_id::text ~ similar_to_escape('D\w{8}%'::text)
--smartmicro installed in place of old rescu sensors on highways
OR c.detector_id SIMILAR TO 'SMARTMICRO - D\w{8}'
) THEN 'RESCU Detectors'
WHEN c.detector_id SIMILAR TO 'PX[0-9]{4}-DET%' AND c.division_id = 8001
THEN 'Signal Detectors'
WHEN c.detector_id SIMILAR TO 'PX[0-9]{4}-SF%' AND c.division_id = 8001
THEN 'Signal Special Function'
WHEN c.detector_id SIMILAR TO 'PX[0-9]{4}-PE%' AND c.division_id = 8001
THEN 'Signal Preemption'
WHEN c.detector_id LIKE 'BCT%' THEN 'Blue City AI'
WHEN c.detector_id LIKE '%WHALESPOUT%' THEN 'Houston Radar'
OR c.detector_id::text ~ similar_to_escape('SMARTMICRO - D\w{8}'::text))
THEN 'RESCU Detectors'::text
WHEN
c.detector_id::text ~ similar_to_escape('PX[0-9]{4}-DET%'::text)
AND c.division_id = 8001
THEN 'Signal Detectors'::text
WHEN
c.detector_id::text ~ similar_to_escape('PX[0-9]{4}-SF%'::text)
AND c.division_id = 8001
THEN 'Signal Special Function'::text
WHEN
c.detector_id::text ~ similar_to_escape('PX[0-9]{4}-PE%'::text) AND c.division_id = 8001
THEN 'Signal Preemption'::text
WHEN
(c.detector_id::text ~~ 'BCT%'::text OR c.detector_id::text ~~ 'OBC%'::text)
THEN 'Blue City AI'::text
WHEN
lower(comms.source_id::text) ~~ '%wavetronix%'::text THEN 'Wavetronix'::text
WHEN
lower(c.detector_id::text) ~ similar_to_escape('%(whalespout)|(houstonradar)%'::text)
THEN 'Houston Radar'::text
WHEN
c.detector_id LIKE ANY(
'{"%SMARTMICRO%", "%YONGE HEATH%",
"%YONGE DAVISVILLE%", "%YONGE AND ROXBOROUGH%"}'
)
(c.detector_id::text ~~ ANY ('{%SMARTMICRO%,"%YONGE HEATH%","%YONGE DAVISVILLE%","%YONGE AND ROXBOROUGH%"}'::text[]))

Check failure on line 125 in volumes/vds/sql/views/create-view-detector_inventory.sql

View workflow job for this annotation

GitHub Actions / SQLFluff Lint

SQLFluff 

TMP: Failed to parse Jinja syntax. Correct the syntax or select an alternative templater. Error: Encountered unknown tag 'SMARTMICRO'.
--new lakeshore/spadina smartmicro sensors
OR c.vds_id IN (
6949838, 6949843, 6949845, 7030552, 7030554, 7030564, 7030575, 7030577,
7030578, 7030591
)
OR (c.vds_id = ANY (ARRAY[6949838, 6949843, 6949845, 7030552, 7030554, 7030564, 7030575, 7030577, 7030578, 7030591]))
--new lakeshore smartmicro sensors
OR (
c.vds_id >= 7011490 AND c.vds_id <= 7011519
)
THEN 'Smartmicro Sensors'
OR c.vds_id >= 7011490 AND c.vds_id <= 7011519
THEN 'Smartmicro Sensors'::text
ELSE NULL::text
END AS det_type
) AS dtypes
ORDER BY
Expand Down
Loading