Удалить 'htdocs/includes/repositories/packetweatherrepository.class.php'
This commit is contained in:
parent
1b090bde2f
commit
80a6a08ca3
|
|
@ -1,157 +0,0 @@
|
|||
<?php
|
||||
|
||||
class PacketWeatherRepository extends ModelRepository
|
||||
{
|
||||
|
||||
private static $_singletonInstance = null;
|
||||
|
||||
public function __construct()
|
||||
{
|
||||
parent::__construct('PacketWeather');
|
||||
}
|
||||
|
||||
/**
|
||||
* Returnes an initiated PacketWeatherRepository
|
||||
*
|
||||
* @return PacketWeatherRepository
|
||||
*/
|
||||
public static function getInstance()
|
||||
{
|
||||
if (self::$_singletonInstance === null) {
|
||||
self::$_singletonInstance = new PacketWeatherRepository();
|
||||
}
|
||||
|
||||
return self::$_singletonInstance;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get object by id
|
||||
*
|
||||
* @param int $id
|
||||
* @param int $timestamp
|
||||
* @return PacketWeather
|
||||
*/
|
||||
public function getObjectById($id, $timestamp)
|
||||
{
|
||||
if (!isInt($id) || !isInt($timestamp)) {
|
||||
return new PacketWeather(0);
|
||||
}
|
||||
return $this->getObjectFromSql('select * from packet_weather where id = ? and timestamp = ?', [$id, $timestamp]);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get object by packet id
|
||||
*
|
||||
* @param int $id
|
||||
* @param int $timestamp
|
||||
* @return PacketWeather
|
||||
*/
|
||||
public function getObjectByPacketId($id, $timestamp)
|
||||
{
|
||||
if (!isInt($id) || !isInt($timestamp)) {
|
||||
return new PacketWeather(0);
|
||||
}
|
||||
return $this->getObjectFromSql('select * from packet_weather where packet_id = ? and timestamp = ?', [$id, $timestamp]);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get latest object list by station id (useful for creating a chart)
|
||||
*
|
||||
* @param int $stationId
|
||||
* @param int $endTimestamp
|
||||
* @param int $hours
|
||||
* @param array $columns
|
||||
* @return array
|
||||
*/
|
||||
public function getLatestDataListByStationId($stationId, $endTimestamp, $hours, $columns)
|
||||
{
|
||||
if (!isInt($stationId) || !isInt($endTimestamp) || !isInt($hours)) {
|
||||
return [];
|
||||
}
|
||||
$minTimestamp = $endTimestamp - (60*60*$hours);
|
||||
|
||||
$sql = 'select ' . implode(',', $columns) . ' from packet_weather
|
||||
where station_id = ?
|
||||
and timestamp >= ?
|
||||
and timestamp <= ?
|
||||
order by timestamp';
|
||||
$arg = [$stationId, $minTimestamp, $endTimestamp];
|
||||
|
||||
$pdo = PDOConnection::getInstance();
|
||||
$stmt = $pdo->prepareAndExec($sql, $arg);
|
||||
return $stmt->fetchAll(PDO::FETCH_ASSOC);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get latest object list by station id
|
||||
*
|
||||
* @param int $stationId
|
||||
* @param int $limit
|
||||
* @param int $offset
|
||||
* @param int $maxDays
|
||||
* @return array
|
||||
*/
|
||||
public function getLatestObjectListByStationIdAndLimit($stationId, $limit, $offset, $maxDays = 7)
|
||||
{
|
||||
if (!isInt($stationId) || !isInt($limit) || !isInt($offset) || !isInt($maxDays)) {
|
||||
return [];
|
||||
}
|
||||
return $this->getObjectListFromSql(
|
||||
'select * from packet_weather
|
||||
where station_id = ?
|
||||
and timestamp > ?
|
||||
and (humidity is not null
|
||||
or pressure is not null
|
||||
or rain_1h is not null
|
||||
or rain_24h is not null
|
||||
or rain_since_midnight is not null
|
||||
or temperature is not null
|
||||
or wind_direction is not null
|
||||
or wind_gust is not null
|
||||
or wind_speed is not null
|
||||
or luminosity is not null
|
||||
or snow is not null)
|
||||
order by timestamp desc limit ? offset ?', [$stationId, (time() - 24*60*60*$maxDays), $limit, $offset]
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get latest number of packets by station id
|
||||
*
|
||||
* @param int $stationId
|
||||
* @param int $maxDays
|
||||
* @return int
|
||||
*/
|
||||
public function getLatestNumberOfPacketsByStationIdAndLimit($stationId, $maxDays = 7)
|
||||
{
|
||||
if (!isInt($stationId) || !isInt($maxDays)) {
|
||||
return 0;
|
||||
}
|
||||
$sql = 'select count(*) c from packet_weather
|
||||
where station_id = ?
|
||||
and timestamp > ?
|
||||
and (humidity is not null
|
||||
or pressure is not null
|
||||
or rain_1h is not null
|
||||
or rain_24h is not null
|
||||
or rain_since_midnight is not null
|
||||
or temperature is not null
|
||||
or wind_direction is not null
|
||||
or wind_gust is not null
|
||||
or wind_speed is not null
|
||||
or luminosity is not null
|
||||
or snow is not null)';
|
||||
$parameters = [$stationId, (time() - 24*60*60*$maxDays)];
|
||||
|
||||
$pdo = PDOConnection::getInstance();
|
||||
$stmt = $pdo->prepareAndExec($sql, $parameters);
|
||||
$rows = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
||||
|
||||
$sum = 0;
|
||||
foreach($rows as $row) {
|
||||
$sum += $row['c'];
|
||||
}
|
||||
|
||||
return $sum;
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue