2026-03-02 21:08:38 +00:00
parent 7010e15f16
commit 7560529699
3 changed files with 191 additions and 0 deletions
							
							
							
						
@@ -0,0 +1,91 @@
<?php
class MeasurementModel extends mfBaseModel
{
    public static function search($filter = [])
    {
        $db = FronkDB::singleton();
        $where = [];
        $params = [];
        if (isset($filter['device_id'])) {
            if (is_array($filter['device_id'])) {
                $where[] = "device_id IN (" . implode(',', array_map('intval', $filter['device_id'])) . ")";
            } else {
                $where[] = "device_id = " . intval($filter['device_id']);
            }
        }
        if (isset($filter['sensor_id'])) {
            if (is_array($filter['sensor_id'])) {
                $where[] = "sensor_id IN (" . implode(',', array_map('intval', $filter['sensor_id'])) . ")";
            } else {
                $where[] = "sensor_id = " . intval($filter['sensor_id']);
            }
        }
        $whereClause = '';
        if (count($where)) {
            $whereClause = ' WHERE ' . implode(' AND ', $where);
        }
        $order = ' ORDER BY `create` DESC';
        if (isset($filter['order'])) {
            $order = ' ORDER BY ' . $db->escape($filter['order']);
        }
        $limit = '';
        if (isset($filter['limit'])) {
            $limit = ' LIMIT ' . intval($filter['limit']);
        }
        $sql = "SELECT * FROM Measurement" . $whereClause . $order . $limit;
        $res = $db->query($sql);
        $measurements = [];
        while ($row = $db->fetch_object($res)) {
            $measurement = new Measurement();
            $measurement->load($row);
            $measurements[] = $measurement;
        }
        return $measurements;
    }
    public static function getLatestGroupedByDeviceAndSensor($limit = 50)
    {
        $db = FronkDB::singleton();
        // Get the most recent measurements, grouped by unique device_id and sensor_id combinations
        // This query gets the latest measurement for each device_id/sensor_id combination
        $sql = "
            SELECT m.*
            FROM Measurement m
            INNER JOIN (
                SELECT device_id, sensor_id, MAX(`create`) as max_create
                FROM (
                    SELECT device_id, sensor_id, `create`
                    FROM Measurement
                    ORDER BY `create` DESC
                    LIMIT 1000
                ) AS recent
                GROUP BY device_id, sensor_id
            ) AS latest
            ON m.device_id = latest.device_id
            AND m.sensor_id = latest.sensor_id
            AND m.`create` = latest.max_create
            ORDER BY m.`create` DESC
            LIMIT " . intval($limit);
        $res = $db->query($sql);
        $measurements = [];
        while ($row = $db->fetch_object($res)) {
            $measurement = new Measurement();
            $measurement->load($row);
            $measurements[] = $measurement;
        }
        return $measurements;
    }
}