ammar/backend
1
0
Fork 0
mirror of https://github.com/SyncrowIOT/backend.git synced 2025-11-26 11:54:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #389 from SyncrowIOT/DATA-daily-space-aqi-model

Browse Source 
Air quality and AQI for space model
This commit is contained in:
Karim Hussami
2025-06-01 14:31:13 -04:00
committed by GitHub
parent b989338790 90fc44ab53
commit 59161d4049
1 changed files with 54 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

54
libs/common/src/sql/queries/fact_daily_space_aqi_score/fact_daily_space_aqi_score.sql Normal file
View File

@ -0,0 +1,54 @@
WITH device_space AS (
SELECT
device.uuid AS device_id,
device.created_at,
device.space_device_uuid AS space_id,
"device-status-log".event_time::date,
"device-status-log".code,
"device-status-log".value,
"device-status-log".log
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,
space_id,
AVG(CASE WHEN code = 'voc_value' THEN value::numeric END) AS voc_avg,
AVG(CASE WHEN code = 'pm1' THEN value::numeric END) AS pm1_avg,
AVG(CASE WHEN code = 'pm25_value' THEN value::numeric END) AS pm25_avg,
AVG(CASE WHEN code = 'pm10' THEN value::numeric END) AS pm10_avg,
AVG(CASE WHEN code = 'ch2o_value' THEN value::numeric END) AS ch2o_avg,
AVG(CASE WHEN code = 'co2_value' THEN value::numeric END) AS co2_avg,
AVG(CASE WHEN code = 'air_quality_index' then level_to_numeric(value) END) as air_quality_index
FROM device_space
--WHERE code IN ('pm25_value', 'pm10')
GROUP BY space_id, event_time
)
SELECT
event_time::date as date,
space_id,
pm1_avg,
pm25_avg,
pm10_avg,
voc_avg,
ch2o_avg,
co2_avg,
--calculate_aqi('pm25', pm25_avg) AS aqi_pm25,
--calculate_aqi('pm10', pm10_avg) AS aqi_pm10,
GREATEST(
calculate_aqi('pm25', pm25_avg),
calculate_aqi('pm10', pm10_avg),
calculate_aqi('voc_value', voc_avg),
calculate_aqi('co2_value', co2_avg),
calculate_aqi('ch2o_value', ch2o_avg)
) AS overall_AQI,
air_quality_index as avg_space_device_aqi
FROM average_pollutants;