1
0
moha/class/db.php

96 lines
2.8 KiB
PHP
Raw Normal View History

<?php
2022-01-28 23:05:58 +01:00
logger(DEBUG, _("Including db.php"));
class db extends mysqli
{
2022-01-23 09:46:06 +01:00
public $mysqlServer = "127.0.0.1"; // Your production server
public $username = "moha";
public $passwd = "MysqlMoha";
public $database = "moha";
2022-01-17 00:18:50 +01:00
public $result;
2022-01-17 00:18:50 +01:00
function __construct()
{
2022-01-23 09:46:06 +01:00
global $testMode;
$flagError = false;
if ($testMode)
2022-01-17 00:18:50 +01:00
{
2022-01-23 09:46:06 +01:00
$this->mysqlServer = "192.168.1.253"; // Your test server
}
while ($this->connect($this->mysqlServer, $this->username, $this->passwd, $this->database) === false)
{
2022-01-28 23:05:58 +01:00
logger(ERROR,_("Connection to sql server error :") . $this->connect_error, __FILE__ . ":" . __LINE__);
2022-01-23 09:46:06 +01:00
sleep(5);
$flagError = true;
}
if ($flagError === true)
{
2022-01-28 23:05:58 +01:00
logger(ERROR, _("Connection to sql server ready"), __FILE__ . ":" . __LINE__);
2022-01-17 00:18:50 +01:00
}
$result = new mysqli_result($this);
}
function protect($string)
{
return $this->real_escape_string($string);
}
2022-02-23 10:23:16 +01:00
function logProperty($device, $property, $value, $oldValue = 0)
{
2022-01-19 00:22:34 +01:00
global $mohaDB, $properties2log, $testMode;
2022-01-17 00:18:50 +01:00
$precision = 0;
2022-01-19 00:22:34 +01:00
//echo "############## logProperty ################\nproperty => " . $propertyTree .EOL;
2022-02-23 10:23:16 +01:00
if (array_key_exists($property, $properties2log))
2022-01-17 00:18:50 +01:00
{
//echo "logging in database";
//var_dump($device);
2022-01-17 00:18:50 +01:00
$ieeeAddress = $device->ieeeAddress;
//print_r($ieeeAddress);
$query = "INSERT INTO logs (device, property, value) VALUES('" . $this->protect($ieeeAddress) . "', '" . $this->protect($property) . "', '" . $this->protect(bool2string($value)) . "')";
2022-02-23 10:23:16 +01:00
echo $query;
if (is_numeric($value) and !empty($properties2log[$property]))
2022-01-17 00:18:50 +01:00
{
2022-01-19 00:22:34 +01:00
// calculate a min/max value for storing data
2022-02-23 10:23:16 +01:00
$minMax = $properties2log[$property];
if (is_callable($minMax))
2022-01-19 00:22:34 +01:00
{
$minMax = $minMax($value);
2022-01-19 00:22:34 +01:00
}
2022-01-28 23:05:58 +01:00
//echo "minMax = " .$minMax . EOL;
2022-01-17 00:18:50 +01:00
//echo "oldValue = " . $oldValue . EOL;
//echo "Value = " . $value . EOL;
if ($value >= $oldValue - $minMax and $value <= $oldValue + $minMax)
{
//echo "========>>>>>>>>>not changed" . EOL;
return 0;
}
}
2022-01-19 00:22:34 +01:00
if ($testMode)
2022-01-17 00:18:50 +01:00
{
2022-01-28 23:05:58 +01:00
logger(INFO, _("Test mode on: not storing in DB "), __FILE__ . ":" . __LINE__);
2022-01-19 00:22:34 +01:00
}else
{
if(!$this->result = $this->query($query))
{
2022-01-28 23:05:58 +01:00
logger(ERROR, _("mysql query errror: ") . $this->error, __FILE__ . ":" . __LINE__);
2022-01-19 00:22:34 +01:00
}
2022-01-17 00:18:50 +01:00
}
2022-02-23 10:23:16 +01:00
logger(INFO, sprintf(_("New value (%s) of property: '%s' of device: %s stored in database"), bool2string($value), $property, $device->friendlyName), __FILE__ . ":" . __LINE__);
2022-01-17 00:18:50 +01:00
}
}
function moyenne($deviceObject, $property, $time)
{
$query = "SELECT AVG(value) FROM logs WHERE device='" . $deviceObject->ieeeAddress . "' AND property='" . $property . "' AND TIMEDIFF(NOW(), 'date') < " . $time;
if(!$this->result = $this->query($query))
{
logger(ERROR, _("mysql query errror: ") . $this->error, __FILE__ . ":" . __LINE__);
}
var_dump($this->result);
}
}
2022-01-17 00:18:50 +01:00
$mohaDB = new db();
?>