FTP -> GIT (SYNC)

2019-09-19 14:48:31 +02:00
parent ad3118799f
commit 8f709bfb30
85 changed files with 310 additions and 173 deletions
--- a/app/class/RecordManager.php
+++ b/app/class/RecordManager.php
@@ -0,0 +1,80 @@
+<?php
+class RecordManager{
+	public static $records;
+
+	public 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;
+		};
+		$record = array (
+			'subdevice_id' => $subDeviceId,
+			'value' => $value,
+		);
+		try {
+			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 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));
+	}
+}
+?>