From 80e89dd035d2acb356bc412bec51b5343fffe2aa Mon Sep 17 00:00:00 2001 From: khuss Date: Wed, 4 Jun 2025 17:20:25 -0400 Subject: [PATCH] fix name of snapshot table --- .../proceduce_select_daily_space_aqi.sql | 401 ++---------------- .../proceduce_update_daily_space_aqi.sql | 2 +- .../procedure_insert_all_daily_space_aqi.sql | 2 +- 3 files changed, 35 insertions(+), 370 deletions(-) diff --git a/libs/common/src/sql/procedures/fact_daily_space_aqi/proceduce_select_daily_space_aqi.sql b/libs/common/src/sql/procedures/fact_daily_space_aqi/proceduce_select_daily_space_aqi.sql index 993f3d0..4c4c6ab 100644 --- a/libs/common/src/sql/procedures/fact_daily_space_aqi/proceduce_select_daily_space_aqi.sql +++ b/libs/common/src/sql/procedures/fact_daily_space_aqi/proceduce_select_daily_space_aqi.sql @@ -1,374 +1,39 @@ -WITH params AS ( - SELECT - TO_DATE(NULLIF($1, ''), 'YYYY-MM-DD') AS event_date, - $2::uuid AS space_id -), - --- Query Pipeline Starts Here -WITH device_space AS ( - SELECT - device.uuid AS device_id, - device.space_device_uuid AS space_id, - "device-status-log".event_time::timestamp AS event_time, - "device-status-log".code, - "device-status-log".value - FROM device - LEFT JOIN "device-status-log" - ON device.uuid = "device-status-log".device_id - LEFT JOIN product - ON product.uuid = device.product_device_uuid - WHERE product.cat_name = 'hjjcy' -), - -average_pollutants AS ( - SELECT - event_time::date AS event_date, - date_trunc('hour', event_time) AS event_hour, - space_id, - - -- PM1 - MIN(CASE WHEN code = 'pm1' THEN value::numeric END) AS pm1_min, - AVG(CASE WHEN code = 'pm1' THEN value::numeric END) AS pm1_avg, - MAX(CASE WHEN code = 'pm1' THEN value::numeric END) AS pm1_max, - - -- PM25 - MIN(CASE WHEN code = 'pm25_value' THEN value::numeric END) AS pm25_min, - AVG(CASE WHEN code = 'pm25_value' THEN value::numeric END) AS pm25_avg, - MAX(CASE WHEN code = 'pm25_value' THEN value::numeric END) AS pm25_max, - - -- PM10 - MIN(CASE WHEN code = 'pm10' THEN value::numeric END) AS pm10_min, - AVG(CASE WHEN code = 'pm10' THEN value::numeric END) AS pm10_avg, - MAX(CASE WHEN code = 'pm10' THEN value::numeric END) AS pm10_max, - - -- VOC - MIN(CASE WHEN code = 'voc_value' THEN value::numeric END) AS voc_min, - AVG(CASE WHEN code = 'voc_value' THEN value::numeric END) AS voc_avg, - MAX(CASE WHEN code = 'voc_value' THEN value::numeric END) AS voc_max, - - -- CH2O - MIN(CASE WHEN code = 'ch2o_value' THEN value::numeric END) AS ch2o_min, - AVG(CASE WHEN code = 'ch2o_value' THEN value::numeric END) AS ch2o_avg, - MAX(CASE WHEN code = 'ch2o_value' THEN value::numeric END) AS ch2o_max, - - -- CO2 - MIN(CASE WHEN code = 'co2_value' THEN value::numeric END) AS co2_min, - AVG(CASE WHEN code = 'co2_value' THEN value::numeric END) AS co2_avg, - MAX(CASE WHEN code = 'co2_value' THEN value::numeric END) AS co2_max - - FROM device_space - GROUP BY space_id, event_hour, event_date -), - -filled_pollutants AS ( - SELECT - *, - -- AVG - COALESCE(pm25_avg, LAG(pm25_avg) OVER (PARTITION BY space_id ORDER BY event_hour)) AS pm25_avg_f, - COALESCE(pm10_avg, LAG(pm10_avg) OVER (PARTITION BY space_id ORDER BY event_hour)) AS pm10_avg_f, - COALESCE(voc_avg, LAG(voc_avg) OVER (PARTITION BY space_id ORDER BY event_hour)) AS voc_avg_f, - COALESCE(co2_avg, LAG(co2_avg) OVER (PARTITION BY space_id ORDER BY event_hour)) AS co2_avg_f, - COALESCE(ch2o_avg, LAG(ch2o_avg) OVER (PARTITION BY space_id ORDER BY event_hour)) AS ch2o_avg_f, - - -- MIN - COALESCE(pm25_min, LAG(pm25_min) OVER (PARTITION BY space_id ORDER BY event_hour)) AS pm25_min_f, - COALESCE(pm10_min, LAG(pm10_min) OVER (PARTITION BY space_id ORDER BY event_hour)) AS pm10_min_f, - COALESCE(voc_min, LAG(voc_min) OVER (PARTITION BY space_id ORDER BY event_hour)) AS voc_min_f, - COALESCE(co2_min, LAG(co2_min) OVER (PARTITION BY space_id ORDER BY event_hour)) AS co2_min_f, - COALESCE(ch2o_min, LAG(ch2o_min) OVER (PARTITION BY space_id ORDER BY event_hour)) AS ch2o_min_f, - - -- MAX - COALESCE(pm25_max, LAG(pm25_max) OVER (PARTITION BY space_id ORDER BY event_hour)) AS pm25_max_f, - COALESCE(pm10_max, LAG(pm10_max) OVER (PARTITION BY space_id ORDER BY event_hour)) AS pm10_max_f, - COALESCE(voc_max, LAG(voc_max) OVER (PARTITION BY space_id ORDER BY event_hour)) AS voc_max_f, - COALESCE(co2_max, LAG(co2_max) OVER (PARTITION BY space_id ORDER BY event_hour)) AS co2_max_f, - COALESCE(ch2o_max, LAG(ch2o_max) OVER (PARTITION BY space_id ORDER BY event_hour)) AS ch2o_max_f - FROM average_pollutants -), - -hourly_results AS ( +ITH params AS ( SELECT - space_id, - event_date, - event_hour, - pm1_min, pm1_avg, pm1_max, - pm25_min_f, pm25_avg_f, pm25_max_f, - pm10_min_f, pm10_avg_f, pm10_max_f, - voc_min_f, voc_avg_f, voc_max_f, - co2_min_f, co2_avg_f, co2_max_f, - ch2o_min_f, ch2o_avg_f, ch2o_max_f, - - GREATEST( - calculate_aqi('pm25', pm25_min_f), - calculate_aqi('pm10', pm10_min_f) - ) AS hourly_min_aqi, - - GREATEST( - calculate_aqi('pm25', pm25_avg_f), - calculate_aqi('pm10', pm10_avg_f) - ) AS hourly_avg_aqi, - - GREATEST( - calculate_aqi('pm25', pm25_max_f), - calculate_aqi('pm10', pm10_max_f) - ) AS hourly_max_aqi, - - classify_aqi(GREATEST( - calculate_aqi('pm25', pm25_avg_f), - calculate_aqi('pm10', pm10_avg_f) - )) AS aqi_category, - - classify_aqi(calculate_aqi('pm25',pm25_avg_f)) as pm25_category, - classify_aqi(calculate_aqi('pm10',pm10_avg_f)) as pm10_category, - classify_aqi(calculate_aqi('voc',voc_avg_f)) as voc_category, - classify_aqi(calculate_aqi('co2',co2_avg_f)) as co2_category, - classify_aqi(calculate_aqi('ch2o',ch2o_avg_f)) as ch2o_category - - FROM filled_pollutants -), - -daily_category_counts AS ( - SELECT space_id, event_date, aqi_category AS category, 'aqi' AS pollutant, COUNT(*) AS category_count - FROM hourly_results - GROUP BY space_id, event_date, aqi_category - - UNION ALL - - SELECT space_id, event_date, pm25_category AS category, 'pm25' AS pollutant, COUNT(*) AS category_count - FROM hourly_results - GROUP BY space_id, event_date, pm25_category - - UNION ALL - - SELECT space_id, event_date, pm10_category AS category, 'pm10' AS pollutant, COUNT(*) AS category_count - FROM hourly_results - GROUP BY space_id, event_date, pm10_category - - UNION ALL - - SELECT space_id, event_date, voc_category AS category, 'voc' AS pollutant, COUNT(*) AS category_count - FROM hourly_results - GROUP BY space_id, event_date, voc_category - - UNION ALL - - SELECT space_id, event_date, co2_category AS category, 'co2' AS pollutant, COUNT(*) AS category_count - FROM hourly_results - GROUP BY space_id, event_date, co2_category - - UNION ALL - - SELECT space_id, event_date, ch2o_category AS category, 'ch2o' AS pollutant, COUNT(*) AS category_count - FROM hourly_results - GROUP BY space_id, event_date, ch2o_category -), - -daily_totals AS ( - SELECT - space_id, - event_date, - SUM(category_count) AS total_count - FROM daily_category_counts - where pollutant = 'aqi' - GROUP BY space_id, event_date -), - --- Pivot Categories into Columns -daily_percentages AS ( - select - dt.space_id, - dt.event_date, - -- AQI CATEGORIES - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Good' and dcc.pollutant = 'aqi' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS good_aqi_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Moderate' and dcc.pollutant = 'aqi' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS moderate_aqi_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Unhealthy for Sensitive Groups' and dcc.pollutant = 'aqi' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS unhealthy_sensitive_aqi_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Unhealthy' and dcc.pollutant = 'aqi' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS unhealthy_aqi_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Very Unhealthy' and dcc.pollutant = 'aqi' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS very_unhealthy_aqi_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Hazardous' and dcc.pollutant = 'aqi' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS hazardous_aqi_percentage, - -- PM25 CATEGORIES - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Good' and dcc.pollutant = 'pm25' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS good_pm25_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Moderate' and dcc.pollutant = 'pm25' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS moderate_pm25_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Unhealthy for Sensitive Groups' and dcc.pollutant = 'pm25' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS unhealthy_sensitive_pm25_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Unhealthy' and dcc.pollutant = 'pm25' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS unhealthy_pm25_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Very Unhealthy' and dcc.pollutant = 'pm25' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS very_unhealthy_pm25_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Hazardous' and dcc.pollutant = 'pm25' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS hazardous_pm25_percentage, - -- PM10 CATEGORIES - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Good' and dcc.pollutant = 'pm10' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS good_pm10_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Moderate' and dcc.pollutant = 'pm10' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS moderate_pm10_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Unhealthy for Sensitive Groups' and dcc.pollutant = 'pm10' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS unhealthy_sensitive_pm10_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Unhealthy' and dcc.pollutant = 'pm10' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS unhealthy_pm10_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Very Unhealthy' and dcc.pollutant = 'pm10' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS very_unhealthy_pm10_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Hazardous' and dcc.pollutant = 'pm10' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS hazardous_pm10_percentage, - -- VOC CATEGORIES - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Good' and dcc.pollutant = 'voc' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS good_voc_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Moderate' and dcc.pollutant = 'voc' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS moderate_voc_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Unhealthy for Sensitive Groups' and dcc.pollutant = 'voc' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS unhealthy_sensitive_voc_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Unhealthy' and dcc.pollutant = 'voc' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS unhealthy_voc_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Very Unhealthy' and dcc.pollutant = 'voc' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS very_unhealthy_voc_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Hazardous' and dcc.pollutant = 'voc' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS hazardous_voc_percentage, - -- CO2 CATEGORIES - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Good' and dcc.pollutant = 'co2' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS good_co2_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Moderate' and dcc.pollutant = 'co2' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS moderate_co2_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Unhealthy for Sensitive Groups' and dcc.pollutant = 'co2' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS unhealthy_sensitive_co2_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Unhealthy' and dcc.pollutant = 'co2' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS unhealthy_co2_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Very Unhealthy' and dcc.pollutant = 'co2' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS very_unhealthy_co2_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Hazardous' and dcc.pollutant = 'co2' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS hazardous_co2_percentage, - -- CH20 CATEGORIES - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Good' and dcc.pollutant = 'ch2o' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS good_ch2o_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Moderate' and dcc.pollutant = 'ch2o' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS moderate_ch2o_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Unhealthy for Sensitive Groups' and dcc.pollutant = 'ch2o' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS unhealthy_sensitive_ch2o_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Unhealthy' and dcc.pollutant = 'ch2o' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS unhealthy_ch2o_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Very Unhealthy' and dcc.pollutant = 'ch2o' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS very_unhealthy_ch2o_percentage, - ROUND(COALESCE(SUM(CASE WHEN dcc.category = 'Hazardous' and dcc.pollutant = 'ch2o' THEN dcc.category_count ELSE 0 END) * 100.0 / dt.total_count, 0), 2) AS hazardous_ch2o_percentage - FROM daily_totals dt - LEFT JOIN daily_category_counts dcc - ON dt.space_id = dcc.space_id AND dt.event_date = dcc.event_date - GROUP BY dt.space_id, dt.event_date, dt.total_count -), - -daily_averages AS ( - SELECT - space_id, - event_date, - -- AQI - ROUND(AVG(hourly_min_aqi)::numeric, 2) AS daily_min_aqi, - ROUND(AVG(hourly_avg_aqi)::numeric, 2) AS daily_avg_aqi, - ROUND(AVG(hourly_max_aqi)::numeric, 2) AS daily_max_aqi, - -- PM25 - ROUND(AVG(pm25_min_f)::numeric, 2) AS daily_min_pm25, - ROUND(AVG(pm25_avg_f)::numeric, 2) AS daily_avg_pm25, - ROUND(AVG(pm25_max_f)::numeric, 2) AS daily_max_pm25, - -- PM10 - ROUND(AVG(pm10_min_f)::numeric, 2) AS daily_min_pm10, - ROUND(AVG(pm10_avg_f)::numeric, 2) AS daily_avg_pm10, - ROUND(AVG(pm10_max_f)::numeric, 2) AS daily_max_pm10, - -- VOC - ROUND(AVG(voc_min_f)::numeric, 2) AS daily_min_voc, - ROUND(AVG(voc_avg_f)::numeric, 2) AS daily_avg_voc, - ROUND(AVG(voc_max_f)::numeric, 2) AS daily_max_voc, - -- CO2 - ROUND(AVG(co2_min_f)::numeric, 2) AS daily_min_co2, - ROUND(AVG(co2_avg_f)::numeric, 2) AS daily_avg_co2, - ROUND(AVG(co2_max_f)::numeric, 2) AS daily_max_co2, - -- CH2O - ROUND(AVG(ch2o_min_f)::numeric, 2) AS daily_min_ch2o, - ROUND(AVG(ch2o_avg_f)::numeric, 2) AS daily_avg_ch2o, - ROUND(AVG(ch2o_max_f)::numeric, 2) AS daily_max_ch2o - - FROM hourly_results - GROUP BY space_id, event_date -), - -final_data as( -SELECT - p.space_id, - p.event_date, - p.good_aqi_percentage, p.moderate_aqi_percentage, p.unhealthy_sensitive_aqi_percentage, p.unhealthy_aqi_percentage, p.very_unhealthy_aqi_percentage, p.hazardous_aqi_percentage, - a.daily_avg_aqi,a.daily_max_aqi, a.daily_min_aqi, - p.good_pm25_percentage, p.moderate_pm25_percentage, p.unhealthy_sensitive_pm25_percentage, p.unhealthy_pm25_percentage, p.very_unhealthy_pm25_percentage, p.hazardous_pm25_percentage, - a.daily_avg_pm25,a.daily_max_pm25, a.daily_min_pm25, - p.good_pm10_percentage, p.moderate_pm10_percentage, p.unhealthy_sensitive_pm10_percentage, p.unhealthy_pm10_percentage, p.very_unhealthy_pm10_percentage, p.hazardous_pm10_percentage, - a.daily_avg_pm10, a.daily_max_pm10, a.daily_min_pm10, - p.good_voc_percentage, p.moderate_voc_percentage, p.unhealthy_sensitive_voc_percentage, p.unhealthy_voc_percentage, p.very_unhealthy_voc_percentage, p.hazardous_voc_percentage, - a.daily_avg_voc, a.daily_max_voc, a.daily_min_voc, - p.good_co2_percentage, p.moderate_co2_percentage, p.unhealthy_sensitive_co2_percentage, p.unhealthy_co2_percentage, p.very_unhealthy_co2_percentage, p.hazardous_co2_percentage, - a.daily_avg_co2,a.daily_max_co2, a.daily_min_co2, - p.good_ch2o_percentage, p.moderate_ch2o_percentage, p.unhealthy_sensitive_ch2o_percentage, p.unhealthy_ch2o_percentage, p.very_unhealthy_ch2o_percentage, p.hazardous_ch2o_percentage, - a.daily_avg_ch2o,a.daily_max_ch2o, a.daily_min_ch2o -FROM daily_percentages p -LEFT JOIN daily_averages a - ON p.space_id = a.space_id AND p.event_date = a.event_date -ORDER BY p.space_id, p.event_date) - - -INSERT INTO public.space_daily_pollutant_stats ( - space_uuid, - event_date, - good_aqi_percentage, moderate_aqi_percentage, unhealthy_sensitive_aqi_percentage, unhealthy_aqi_percentage, very_unhealthy_aqi_percentage, hazardous_aqi_percentage, - daily_avg_aqi, daily_max_aqi, daily_min_aqi, - good_pm25_percentage, moderate_pm25_percentage, unhealthy_sensitive_pm25_percentage, unhealthy_pm25_percentage, very_unhealthy_pm25_percentage, hazardous_pm25_percentage, - daily_avg_pm25, daily_max_pm25, daily_min_pm25, - good_pm10_percentage, moderate_pm10_percentage, unhealthy_sensitive_pm10_percentage, unhealthy_pm10_percentage, very_unhealthy_pm10_percentage, hazardous_pm10_percentage, - daily_avg_pm10, daily_max_pm10, daily_min_pm10, - good_voc_percentage, moderate_voc_percentage, unhealthy_sensitive_voc_percentage, unhealthy_voc_percentage, very_unhealthy_voc_percentage, hazardous_voc_percentage, - daily_avg_voc, daily_max_voc, daily_min_voc, - good_co2_percentage, moderate_co2_percentage, unhealthy_sensitive_co2_percentage, unhealthy_co2_percentage, very_unhealthy_co2_percentage, hazardous_co2_percentage, - daily_avg_co2, daily_max_co2, daily_min_co2, - good_ch2o_percentage, moderate_ch2o_percentage, unhealthy_sensitive_ch2o_percentage, unhealthy_ch2o_percentage, very_unhealthy_ch2o_percentage, hazardous_ch2o_percentage, - daily_avg_ch2o, daily_max_ch2o, daily_min_ch2o + $1::uuid AS space_uuid, + TO_DATE(NULLIF($2, ''), 'YYYY-MM') AS event_month ) + SELECT - space_id, - event_date, - good_aqi_percentage, moderate_aqi_percentage, unhealthy_sensitive_aqi_percentage, unhealthy_aqi_percentage, very_unhealthy_aqi_percentage, hazardous_aqi_percentage, - daily_avg_aqi, daily_max_aqi, daily_min_aqi, - good_pm25_percentage, moderate_pm25_percentage, unhealthy_sensitive_pm25_percentage, unhealthy_pm25_percentage, very_unhealthy_pm25_percentage, hazardous_pm25_percentage, - daily_avg_pm25, daily_max_pm25, daily_min_pm25, - good_pm10_percentage, moderate_pm10_percentage, unhealthy_sensitive_pm10_percentage, unhealthy_pm10_percentage, very_unhealthy_pm10_percentage, hazardous_pm10_percentage, - daily_avg_pm10, daily_max_pm10, daily_min_pm10, - good_voc_percentage, moderate_voc_percentage, unhealthy_sensitive_voc_percentage, unhealthy_voc_percentage, very_unhealthy_voc_percentage, hazardous_voc_percentage, - daily_avg_voc, daily_max_voc, daily_min_voc, - good_co2_percentage, moderate_co2_percentage, unhealthy_sensitive_co2_percentage, unhealthy_co2_percentage, very_unhealthy_co2_percentage, hazardous_co2_percentage, - daily_avg_co2, daily_max_co2, daily_min_co2, - good_ch2o_percentage, moderate_ch2o_percentage, unhealthy_sensitive_ch2o_percentage, unhealthy_ch2o_percentage, very_unhealthy_ch2o_percentage, hazardous_ch2o_percentage, - daily_avg_ch2o, daily_max_ch2o, daily_min_ch2o -FROM final_data -ON CONFLICT (space_uuid, event_date) DO UPDATE -SET - good_aqi_percentage = EXCLUDED.good_aqi_percentage, - moderate_aqi_percentage = EXCLUDED.moderate_aqi_percentage, - unhealthy_sensitive_aqi_percentage = EXCLUDED.unhealthy_sensitive_aqi_percentage, - unhealthy_aqi_percentage = EXCLUDED.unhealthy_aqi_percentage, - very_unhealthy_aqi_percentage = EXCLUDED.very_unhealthy_aqi_percentage, - hazardous_aqi_percentage = EXCLUDED.hazardous_aqi_percentage, - daily_avg_aqi = EXCLUDED.daily_avg_aqi, - daily_max_aqi = EXCLUDED.daily_max_aqi, - daily_min_aqi = EXCLUDED.daily_min_aqi, - good_pm25_percentage = EXCLUDED.good_pm25_percentage, - moderate_pm25_percentage = EXCLUDED.moderate_pm25_percentage, - unhealthy_sensitive_pm25_percentage = EXCLUDED.unhealthy_sensitive_pm25_percentage, - unhealthy_pm25_percentage = EXCLUDED.unhealthy_pm25_percentage, - very_unhealthy_pm25_percentage = EXCLUDED.very_unhealthy_pm25_percentage, - hazardous_pm25_percentage = EXCLUDED.hazardous_pm25_percentage, - daily_avg_pm25 = EXCLUDED.daily_avg_pm25, - daily_max_pm25 = EXCLUDED.daily_max_pm25, - daily_min_pm25 = EXCLUDED.daily_min_pm25, - good_pm10_percentage = EXCLUDED.good_pm10_percentage, - moderate_pm10_percentage = EXCLUDED.moderate_pm10_percentage, - unhealthy_sensitive_pm10_percentage = EXCLUDED.unhealthy_sensitive_pm10_percentage, - unhealthy_pm10_percentage = EXCLUDED.unhealthy_pm10_percentage, - very_unhealthy_pm10_percentage = EXCLUDED.very_unhealthy_pm10_percentage, - hazardous_pm10_percentage = EXCLUDED.hazardous_pm10_percentage, - daily_avg_pm10 = EXCLUDED.daily_avg_pm10, - daily_max_pm10 = EXCLUDED.daily_max_pm10, - daily_min_pm10 = EXCLUDED.daily_min_pm10, - good_voc_percentage = EXCLUDED.good_voc_percentage, - moderate_voc_percentage = EXCLUDED.moderate_voc_percentage, - unhealthy_sensitive_voc_percentage = EXCLUDED.unhealthy_sensitive_voc_percentage, - unhealthy_voc_percentage = EXCLUDED.unhealthy_voc_percentage, - very_unhealthy_voc_percentage = EXCLUDED.very_unhealthy_voc_percentage, - hazardous_voc_percentage = EXCLUDED.hazardous_voc_percentage, - daily_avg_voc = EXCLUDED.daily_avg_voc, - daily_max_voc = EXCLUDED.daily_max_voc, - daily_min_voc = EXCLUDED.daily_min_voc, - good_co2_percentage = EXCLUDED.good_co2_percentage, - moderate_co2_percentage = EXCLUDED.moderate_co2_percentage, - unhealthy_sensitive_co2_percentage = EXCLUDED.unhealthy_sensitive_co2_percentage, - unhealthy_co2_percentage = EXCLUDED.unhealthy_co2_percentage, - very_unhealthy_co2_percentage = EXCLUDED.very_unhealthy_co2_percentage, - hazardous_co2_percentage = EXCLUDED.hazardous_co2_percentage, - daily_avg_co2 = EXCLUDED.daily_avg_co2, - daily_max_co2 = EXCLUDED.daily_max_co2, - daily_min_co2 = EXCLUDED.daily_min_co2, - good_ch2o_percentage = EXCLUDED.good_ch2o_percentage, - moderate_ch2o_percentage = EXCLUDED.moderate_ch2o_percentage, - unhealthy_sensitive_ch2o_percentage = EXCLUDED.unhealthy_sensitive_ch2o_percentage, - unhealthy_ch2o_percentage = EXCLUDED.unhealthy_ch2o_percentage, - very_unhealthy_ch2o_percentage = EXCLUDED.very_unhealthy_ch2o_percentage, - hazardous_ch2o_percentage = EXCLUDED.hazardous_ch2o_percentage, - daily_avg_ch2o = EXCLUDED.daily_avg_ch2o, - daily_max_ch2o = EXCLUDED.daily_max_ch2o, - daily_min_ch2o = EXCLUDED.daily_min_ch2o; + sdp.space_uuid, + sdp.event_date, + sdp.good_aqi_percentage, sdp.moderate_aqi_percentage, sdp.unhealthy_sensitive_aqi_percentage, sdp.unhealthy_aqi_percentage, + sdp.very_unhealthy_aqi_percentage, sdp.hazardous_aqi_percentage, + sdp.daily_avg_aqi, sdp.daily_max_aqi, sdp.daily_min_aqi, + sdp.good_pm25_percentage, sdp.moderate_pm25_percentage, sdp.unhealthy_sensitive_pm25_percentage, sdp.unhealthy_pm25_percentage, + sdp.very_unhealthy_pm25_percentage, sdp.hazardous_pm25_percentage, + sdp.daily_avg_pm25, sdp.daily_max_pm25, sdp.daily_min_pm25, + sdp.good_pm10_percentage, sdp.moderate_pm10_percentage, sdp.unhealthy_sensitive_pm10_percentage, sdp.unhealthy_pm10_percentage, + sdp.very_unhealthy_pm10_percentage, sdp.hazardous_pm10_percentage, + sdp.daily_avg_pm10, sdp.daily_max_pm10, sdp.daily_min_pm10, + sdp.good_voc_percentage, sdp.moderate_voc_percentage, sdp.unhealthy_sensitive_voc_percentage, sdp.unhealthy_voc_percentage, + sdp.very_unhealthy_voc_percentage, sdp.hazardous_voc_percentage, + sdp.daily_avg_voc, sdp.daily_max_voc, sdp.daily_min_voc, + + sdp.good_co2_percentage, sdp.moderate_co2_percentage, sdp.unhealthy_sensitive_co2_percentage, sdp.unhealthy_co2_percentage, + sdp.very_unhealthy_co2_percentage, sdp.hazardous_co2_percentage, + sdp.daily_avg_co2, sdp.daily_max_co2, sdp.daily_min_co2, + + sdp.good_ch2o_percentage, sdp.moderate_ch2o_percentage, sdp.unhealthy_sensitive_ch2o_percentage, sdp.unhealthy_ch2o_percentage, + sdp.very_unhealthy_ch2o_percentage, sdp.hazardous_ch2o_percentage, + sdp.daily_avg_ch2o, sdp.daily_max_ch2o, sdp.daily_min_ch2o + +FROM public."space-daily-pollutant-stats" AS sdp +CROSS JOIN params p +WHERE + (p.space_uuid IS NULL OR sdp.space_uuid = p.space_uuid) + AND (p.event_month IS NULL OR TO_CHAR(sdp.event_date, 'YYYY-MM') = TO_CHAR(p.event_month, 'YYYY-MM')) +ORDER BY sdp.space_uuid, sdp.event_date; \ No newline at end of file diff --git a/libs/common/src/sql/procedures/fact_daily_space_aqi/proceduce_update_daily_space_aqi.sql b/libs/common/src/sql/procedures/fact_daily_space_aqi/proceduce_update_daily_space_aqi.sql index 993f3d0..e2466f2 100644 --- a/libs/common/src/sql/procedures/fact_daily_space_aqi/proceduce_update_daily_space_aqi.sql +++ b/libs/common/src/sql/procedures/fact_daily_space_aqi/proceduce_update_daily_space_aqi.sql @@ -281,7 +281,7 @@ LEFT JOIN daily_averages a ORDER BY p.space_id, p.event_date) -INSERT INTO public.space_daily_pollutant_stats ( +INSERT INTO public."space-daily-pollutant-stats" ( space_uuid, event_date, good_aqi_percentage, moderate_aqi_percentage, unhealthy_sensitive_aqi_percentage, unhealthy_aqi_percentage, very_unhealthy_aqi_percentage, hazardous_aqi_percentage, diff --git a/libs/common/src/sql/procedures/fact_daily_space_aqi/procedure_insert_all_daily_space_aqi.sql b/libs/common/src/sql/procedures/fact_daily_space_aqi/procedure_insert_all_daily_space_aqi.sql index aeb211b..0ed029b 100644 --- a/libs/common/src/sql/procedures/fact_daily_space_aqi/procedure_insert_all_daily_space_aqi.sql +++ b/libs/common/src/sql/procedures/fact_daily_space_aqi/procedure_insert_all_daily_space_aqi.sql @@ -275,7 +275,7 @@ LEFT JOIN daily_averages a ORDER BY p.space_id, p.event_date) -INSERT INTO public.space_daily_pollutant_stats ( +INSERT INTO public."space-daily-pollutant-stats" ( space_uuid, event_date, good_aqi_percentage, moderate_aqi_percentage, unhealthy_sensitive_aqi_percentage, unhealthy_aqi_percentage, very_unhealthy_aqi_percentage, hazardous_aqi_percentage,