new tables

fact_daily_space_presence_duration/fact_daily_space_presence_duration.sql

@@ -0,0 +1,74 @@
+WITH start_date AS (
+    SELECT 
+        device.uuid AS device_id,
+        device.space_device_uuid AS space_id,
+        -- Mark none_flag if value is 'none'
+        CASE 
+            WHEN "device-status-log".value = 'none' THEN 1 
+            ELSE 0 
+        END AS none_flag,
+        "device-status-log".event_time::timestamp AS event_time,
+        LAG("device-status-log".event_time::timestamp) 
+            OVER (PARTITION BY device.uuid  
+                  ORDER BY "device-status-log".event_time) AS prev_timestamp,
+        LAG(
+            CASE 
+                WHEN "device-status-log".value = 'none' THEN 1 
+                ELSE 0 
+            END
+        ) OVER (PARTITION BY device.uuid  
+                ORDER BY "device-status-log".event_time) AS prev_none_flag
+    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 = 'hps'
+      AND "device-status-log".code = 'presence_state'
+    ORDER BY device.uuid, "device-status-log".event_time
+),
+
+time_intervals AS (
+    SELECT
+        device_id,
+        space_id,
+        prev_none_flag AS none_flag,
+        prev_timestamp AS start_time,
+        event_time AS end_time
+    FROM start_date
+    WHERE prev_none_flag = 1 -- Only consider intervals where the previous state was 'none'
+),
+
+simultaneous_none_intervals AS (
+    SELECT
+        t1.space_id,
+        GREATEST(t1.start_time, t2.start_time) AS overlap_start,
+        LEAST(t1.end_time, t2.end_time) AS overlap_end,
+        COUNT(DISTINCT t1.device_id) AS simultaneous_none_count
+    FROM time_intervals t1
+    JOIN time_intervals t2
+        ON t1.space_id = t2.space_id
+       AND t1.device_id != t2.device_id
+       AND GREATEST(t1.start_time, t2.start_time) < LEAST(t1.end_time, t2.end_time)
+    WHERE t1.none_flag = 1 AND t2.none_flag = 1
+    GROUP BY t1.space_id, GREATEST(t1.start_time, t2.start_time), LEAST(t1.end_time, t2.end_time)
+),
+
+daily_occupancy_duration AS (
+    SELECT
+        space_id,
+        DATE(overlap_start) AS occupancy_date,
+        SUM(EXTRACT(EPOCH FROM (overlap_end - overlap_start))) AS total_occupancy_seconds
+    FROM simultaneous_none_intervals
+    WHERE simultaneous_none_count = (
+        SELECT COUNT(DISTINCT uuid)
+        FROM device
+        WHERE space_device_uuid = simultaneous_none_intervals.space_id
+    ) -- Ensure all devices in the space detect 'none' simultaneously
+    GROUP BY space_id, DATE(overlap_start)
+)
+
+SELECT * 
+FROM daily_occupancy_duration
+ORDER BY space_id, occupancy_date;
+