ammar/backend
1
0
Fork 0
mirror of https://github.com/SyncrowIOT/backend.git synced 2025-07-16 02:36:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

device model fix timestamp and null pm25

Browse Source
This commit is contained in:
khuss
2025-05-27 22:44:47 -04:00
parent a7c4bf1c3d
commit 478c4ca498
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
libs/common/src/sql/queries/fact_daily_device_aqi_score/fact_daily_device_aqi_score.sql
View File

@ -58,7 +58,7 @@ WITH device_space AS (
device.created_at, device.created_at,
device.space_device_uuid AS space_id, device.space_device_uuid AS space_id,
"device-status-log".event_id, "device-status-log".event_id,
"device-status-log".event_time::timestamp, "device-status-log".event_time::date,
"device-status-log".code, "device-status-log".code,
"device-status-log".value, "device-status-log".value,
"device-status-log".log "device-status-log".log
@ -73,7 +73,7 @@ WITH device_space AS (
-- Aggregate air sensor data per device per day -- Aggregate air sensor data per device per day
air_data AS ( air_data AS (
SELECT SELECT
DATE_TRUNC('day', event_time) AS date, event_time AS date,
device_id, device_id,
space_id, space_id,
@ -88,9 +88,9 @@ air_data AS (
AVG(CASE WHEN code = 'pm1' THEN value::numeric END) AS pm1_avg, AVG(CASE WHEN code = 'pm1' THEN value::numeric END) AS pm1_avg,
-- PM2.5 -- PM2.5
MIN(CASE WHEN code = 'pm25' THEN value::numeric END) AS pm25_min, MIN(CASE WHEN code = 'pm25_value' THEN value::numeric END) AS pm25_min,
MAX(CASE WHEN code = 'pm25' THEN value::numeric END) AS pm25_max, MAX(CASE WHEN code = 'pm25_value' THEN value::numeric END) AS pm25_max,
AVG(CASE WHEN code = 'pm25' THEN value::numeric END) AS pm25_avg, AVG(CASE WHEN code = 'pm25_value' THEN value::numeric END) AS pm25_avg,
-- PM10 -- PM10
MIN(CASE WHEN code = 'pm10' THEN value::numeric END) AS pm10_min, MIN(CASE WHEN code = 'pm10' THEN value::numeric END) AS pm10_min,