107 lines
3.1 KiB
PHP
107 lines
3.1 KiB
PHP
|
<?php
|
||
|
|
class RecordManager{
|
||
|
|
public static $records;
|
||
|
|
|
||
|
|
public static function createWithSubId ($subDeviceId, $value) {
|
||
|
|
try {
|
||
|
|
$record = [
|
||
|
|
'execuded' => 1,
|
||
|
|
];
|
||
|
|
Db::edit ('records', $record, 'WHERE subdevice_id = ?', array ($subDeviceId));
|
||
|
|
$record = array (
|
||
|
|
'subdevice_id' => $subDeviceId,
|
||
|
|
'value' => $value,
|
||
|
|
);
|
||
|
|
return Db::add ('records', $record);
|
||
|
|
} catch(PDOException $error) {
|
||
|
|
echo $error->getMessage();
|
||
|
|
die();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public static function create ($deviceId, $type, $value) {
|
||
|
|
$subDeviceId = Db::loadOne('SELECT * FROM subdevices WHERE device_id = ? AND type = ?;', array($deviceId, $type))['subdevice_id'];
|
||
|
|
if ($subDeviceId == '') {
|
||
|
|
return false;
|
||
|
|
};
|
||
|
|
try {
|
||
|
|
$record = [
|
||
|
|
'execuded' => 1,
|
||
|
|
];
|
||
|
|
Db::edit ('records', $record, 'WHERE subdevice_id = ?', array ($subDeviceId));
|
||
|
|
$record = array (
|
||
|
|
'subdevice_id' => $subDeviceId,
|
||
|
|
'value' => $value,
|
||
|
|
);
|
||
|
|
return Db::add ('records', $record);
|
||
|
|
} catch(PDOException $error) {
|
||
|
|
echo $error->getMessage();
|
||
|
|
die();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
public static function setExecuted($recordId) {
|
||
|
|
try {
|
||
|
|
Db::edit ('records', ['execuded' => 1], 'WHERE record_id = ?', array($recordId));
|
||
|
|
} catch(PDOException $error) {
|
||
|
|
echo $error->getMessage();
|
||
|
|
die();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public static function getRecordById($recordId) {
|
||
|
|
return Db::loadOne('SELECT * FROM records WHERE record_id = ?;', array($recordId));
|
||
|
|
}
|
||
|
|
|
||
|
|
public static function getLastInsertedRecordId() {
|
||
|
|
return Db::insertId();
|
||
|
|
}
|
||
|
|
|
||
|
|
public static function getLastRecord($subDeviceId, $num = 1) {
|
||
|
|
if ($num == 1)
|
||
|
|
return Db::loadOne('SELECT * FROM records WHERE subdevice_id = ? AND value != ? ORDER BY time DESC;', array($subDeviceId, 999));
|
||
|
|
return Db::loadAll('SELECT * FROM records WHERE subdevice_id = ? AND value != ? ORDER BY time DESC LIMIT ?;', array($subDeviceId, 999, $num));
|
||
|
|
}
|
||
|
|
|
||
|
|
public static function getLastRecordNotNull($subDeviceId) {
|
||
|
|
return Db::loadOne('SELECT * FROM records WHERE subdevice_id = ? AND value != ? ORDER BY time DESC;', array($subDeviceId, 0));
|
||
|
|
}
|
||
|
|
|
||
|
|
public static function getAllRecord($subDeviceId, $timeFrom, $timeTo) {
|
||
|
|
return Db::loadAll('SELECT * FROM records WHERE subdevice_id = ? AND time >= ? AND time <= ? AND value != ? ORDER BY time;', array($subDeviceId, $timeFrom, $timeTo, 999));
|
||
|
|
}
|
||
|
|
|
||
|
|
public static function getAllRecordForGraph($subDeviceId, $period = "day", $groupBy = "hour") {
|
||
|
|
$periodLocal = '- 1 ' . strtoupper($period);
|
||
|
|
$dateTime = new DateTime();
|
||
|
|
$dateTime = $dateTime->modify($periodLocal);
|
||
|
|
$dateTime = $dateTime->format('Y-m-d');
|
||
|
|
$groupBy = strtoupper($groupBy).'(time)';
|
||
|
|
$sql = 'SELECT value, time FROM records
|
||
|
|
WHERE
|
||
|
|
subdevice_id = ?
|
||
|
|
AND
|
||
|
|
value != 999
|
||
|
|
AND
|
||
|
|
time > ?
|
||
|
|
GROUP BY '.$groupBy.'
|
||
|
|
ORDER BY time ASC';
|
||
|
|
//TODO: Prasárna Opravit
|
||
|
|
return Db::loadAll($sql, array($subDeviceId, $dateTime));
|
||
|
|
}
|
||
|
|
|
||
|
|
public static function clean ($day) {
|
||
|
|
if (isset($day)) {
|
||
|
|
Db::command ('DELETE FROM records WHERE `time` < ADDDATE(NOW(), INTERVAL -? DAY);', array($day));
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
//TODO: zkontrolovat jestli neco nezbilo po smazaní
|
||
|
|
public static function cleanSubdeviceRecords ($subDeviceId) {
|
||
|
|
Db::command ('DELETE FROM records WHERE subdevice_id = ?);', array($subDeviceId));
|
||
|
|
}
|
||
|
|
}
|
||
|
|
?>
|