2019-01-15 15:46:24 +00:00
|
|
|
<?php
|
|
|
|
|
|
|
|
namespace AirQuality\Repositories;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Fetches device info from a MariaDB database.
|
|
|
|
*/
|
|
|
|
class MariaDBMeasurementTypeRepository implements IMeasurementTypeRepository {
|
|
|
|
public static $table_name = "reading_value_types";
|
|
|
|
|
|
|
|
public static $column_id = "id";
|
2019-02-18 20:39:35 +00:00
|
|
|
public static $column_short_description = "short_descr";
|
2019-01-15 15:46:24 +00:00
|
|
|
public static $column_friendly_text = "friendly_text";
|
|
|
|
|
|
|
|
// ------------------------------------------------------------------------
|
|
|
|
|
|
|
|
/**
|
|
|
|
* The database connection.
|
|
|
|
* @var \AirQuality\Database
|
|
|
|
*/
|
|
|
|
private $database;
|
|
|
|
|
2019-06-21 21:05:13 +00:00
|
|
|
/**
|
|
|
|
* Functions that get a static variable by it's name. Useful in preparing SQL queries.
|
|
|
|
* @var callable
|
|
|
|
*/
|
2019-01-15 16:16:00 +00:00
|
|
|
private $get_static;
|
2019-06-21 21:05:13 +00:00
|
|
|
/**
|
|
|
|
* Functions that get a static variable by it's class and property names. Useful in preparing SQL queries.
|
|
|
|
* @var callable
|
|
|
|
*/
|
2019-02-07 19:15:38 +00:00
|
|
|
private $get_static_extra;
|
2019-01-15 16:16:00 +00:00
|
|
|
|
2019-01-15 15:46:24 +00:00
|
|
|
function __construct(\AirQuality\Database $in_database) {
|
|
|
|
$this->database = $in_database;
|
2019-01-15 16:16:00 +00:00
|
|
|
$this->get_static = function($name) { return self::$$name; };
|
2019-02-07 19:15:38 +00:00
|
|
|
$this->get_static_extra = function($class_name, $name) {
|
|
|
|
return $class_name::$$name;
|
|
|
|
};
|
2019-01-15 15:46:24 +00:00
|
|
|
}
|
|
|
|
|
2019-02-18 20:39:35 +00:00
|
|
|
public function is_valid_type(int $id) : bool {
|
2019-01-15 16:16:00 +00:00
|
|
|
$s = $this->get_static;
|
2019-01-15 15:57:39 +00:00
|
|
|
return !empty($this->database->query(
|
2019-02-18 20:39:35 +00:00
|
|
|
"SELECT {$s("column_id")} FROM {$s("table_name")} WHERE {$s("column_id")} = :id;", [
|
|
|
|
"id" => $id
|
|
|
|
]
|
2019-01-15 15:57:39 +00:00
|
|
|
)->fetchColumn());
|
2019-01-15 15:46:24 +00:00
|
|
|
}
|
2019-02-18 20:39:35 +00:00
|
|
|
|
2019-02-20 17:39:45 +00:00
|
|
|
public function get_id(string $short_descr) {
|
2019-02-18 20:39:35 +00:00
|
|
|
$s = $this->get_static;
|
|
|
|
|
|
|
|
$result = $this->database->query(
|
|
|
|
"SELECT {$s("column_id")} FROM {$s("table_name")} WHERE {$s("column_short_description")} = :short_descr", [
|
|
|
|
"short_descr" => $short_descr
|
|
|
|
]
|
|
|
|
)->fetchColumn();
|
|
|
|
|
|
|
|
if($result == false)
|
|
|
|
return null;
|
|
|
|
|
|
|
|
return $result;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function get_friendly_name(int $id) : string {
|
2019-01-15 16:16:00 +00:00
|
|
|
// TODO: Cache results here? Maybe https://packagist.org/packages/thumbtack/querycache will be of some use
|
|
|
|
|
|
|
|
$s = $this->get_static;
|
2019-01-15 15:57:39 +00:00
|
|
|
return $this->database->query(
|
2019-02-18 20:39:35 +00:00
|
|
|
"SELECT {$s("column_friendly_text")} FROM {$s("table_name")} WHERE $this->column_id = :id;", [
|
|
|
|
"id" => $id
|
2019-01-15 15:57:39 +00:00
|
|
|
]
|
|
|
|
)->fetchColumn();
|
2019-01-15 15:46:24 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
public function get_all_types() {
|
2019-01-15 16:16:00 +00:00
|
|
|
$s = $this->get_static;
|
2019-01-15 15:57:39 +00:00
|
|
|
return $this->database->query(
|
2019-01-15 16:16:00 +00:00
|
|
|
"SELECT * FROM {$s("table_name")}"
|
2019-01-15 15:57:39 +00:00
|
|
|
)->fetchAll();
|
2019-01-15 15:46:24 +00:00
|
|
|
}
|
2019-02-07 19:15:38 +00:00
|
|
|
|
2019-11-07 18:43:28 +00:00
|
|
|
public function get_types_by_device($device_id, $days_to_analyse = -1) {
|
2019-11-07 19:04:05 +00:00
|
|
|
$data = [
|
|
|
|
"device_id" => $device_id
|
|
|
|
];
|
|
|
|
if($days_to_analyse >= 0)
|
|
|
|
$data["days"] = $days_to_analyse;
|
|
|
|
|
2019-02-07 19:15:38 +00:00
|
|
|
$s = $this->get_static;
|
|
|
|
$o = $this->get_static_extra;
|
|
|
|
return $this->database->query(
|
|
|
|
"SELECT
|
|
|
|
{$s("table_name")}.*,
|
|
|
|
COUNT({$s("table_name")}.{$s("column_id")}) AS count
|
|
|
|
FROM {$o(MariaDBMeasurementDataRepository::class, "table_name_values")}
|
|
|
|
JOIN {$o(MariaDBMeasurementDataRepository::class, "table_name_metadata")} ON
|
|
|
|
{$o(MariaDBMeasurementDataRepository::class, "table_name_metadata")}.{$o(MariaDBMeasurementDataRepository::class, "column_metadata_id")} = {$o(MariaDBMeasurementDataRepository::class, "table_name_values")}.{$o(MariaDBMeasurementDataRepository::class, "column_values_reading_id")}
|
|
|
|
JOIN {$s("table_name")} ON
|
|
|
|
{$s("table_name")}.{$s("column_id")} = {$o(MariaDBMeasurementDataRepository::class, "table_name_values")}.{$o(MariaDBMeasurementDataRepository::class, "column_values_reading_type")}
|
2019-11-07 18:43:28 +00:00
|
|
|
WHERE
|
|
|
|
{$o(MariaDBMeasurementDataRepository::class, "table_name_metadata")}.{$o(MariaDBMeasurementDataRepository::class, "column_metadata_device_id")} = :device_id
|
2019-11-07 19:04:05 +00:00
|
|
|
" . ($days_to_analyse >= 0 ? "AND DATEDIFF(NOW(),s_or_r) = :days" : "") . "
|
|
|
|
GROUP BY {$s("table_name")}.{$s("column_id")};",
|
|
|
|
$data
|
2019-02-07 19:15:38 +00:00
|
|
|
)->fetchAll();
|
|
|
|
}
|
2019-01-15 15:46:24 +00:00
|
|
|
}
|