From 478c4ca498a9ca4865e5606f4c01868c8a8f2fab Mon Sep 17 00:00:00 2001 From: khuss Date: Tue, 27 May 2025 22:44:47 -0400 Subject: [PATCH] device model fix timestamp and null pm25 --- .../fact_daily_device_aqi_score.sql | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/libs/common/src/sql/queries/fact_daily_device_aqi_score/fact_daily_device_aqi_score.sql b/libs/common/src/sql/queries/fact_daily_device_aqi_score/fact_daily_device_aqi_score.sql index 45603be..1a37b17 100644 --- a/libs/common/src/sql/queries/fact_daily_device_aqi_score/fact_daily_device_aqi_score.sql +++ b/libs/common/src/sql/queries/fact_daily_device_aqi_score/fact_daily_device_aqi_score.sql @@ -58,7 +58,7 @@ WITH device_space AS ( device.created_at, device.space_device_uuid AS space_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".value, "device-status-log".log @@ -73,7 +73,7 @@ WITH device_space AS ( -- Aggregate air sensor data per device per day air_data AS ( SELECT - DATE_TRUNC('day', event_time) AS date, + event_time AS date, device_id, space_id, @@ -88,9 +88,9 @@ air_data AS ( AVG(CASE WHEN code = 'pm1' THEN value::numeric END) AS pm1_avg, -- PM2.5 - MIN(CASE WHEN code = 'pm25' THEN value::numeric END) AS pm25_min, - MAX(CASE WHEN code = 'pm25' THEN value::numeric END) AS pm25_max, - AVG(CASE WHEN code = 'pm25' THEN value::numeric END) AS pm25_avg, + MIN(CASE WHEN code = 'pm25_value' THEN value::numeric END) AS pm25_min, + MAX(CASE WHEN code = 'pm25_value' THEN value::numeric END) AS pm25_max, + AVG(CASE WHEN code = 'pm25_value' THEN value::numeric END) AS pm25_avg, -- PM10 MIN(CASE WHEN code = 'pm10' THEN value::numeric END) AS pm10_min,