4fe46cbd2a
* [RENAMED] sessionTimeoutStamp to last_login * [UPDATE] user class to store login time after successful login * [ADDED] SQL Upgrade file for new column * [UPDATE] Updated base SQL file Fixes #1162 once merged.
267 lines
8.3 KiB
PHP
267 lines
8.3 KiB
PHP
<?php
|
|
|
|
// Make sure we are called from index.php
|
|
if (!defined('SECURITY'))
|
|
die('Hacking attempt');
|
|
|
|
/**
|
|
* Our base class that we extend our other classes from
|
|
*
|
|
* It supplies some basic features as cross-linking with other classes
|
|
* after loading a newly created class.
|
|
**/
|
|
class Base {
|
|
private $sError = '';
|
|
private $sCronError = '';
|
|
protected $table = '';
|
|
private $values = array(), $types = '';
|
|
|
|
public function getTableName() {
|
|
return $this->table;
|
|
}
|
|
public function setDebug($debug) {
|
|
$this->debug = $debug;
|
|
}
|
|
public function setMysql($mysqli) {
|
|
$this->mysqli = $mysqli;
|
|
}
|
|
public function setMail($mail) {
|
|
$this->mail = $mail;
|
|
}
|
|
public function setSalt($salt) {
|
|
$this->salt = $salt;
|
|
}
|
|
public function setSmarty($smarty) {
|
|
$this->smarty = $smarty;
|
|
}
|
|
public function setUser($user) {
|
|
$this->user = $user;
|
|
}
|
|
public function setConfig($config) {
|
|
$this->config = $config;
|
|
}
|
|
public function setErrorCodes(&$aErrorCodes) {
|
|
$this->aErrorCodes =& $aErrorCodes;
|
|
}
|
|
public function setToken($token) {
|
|
$this->token = $token;
|
|
}
|
|
public function setBlock($block) {
|
|
$this->block = $block;
|
|
}
|
|
public function setTransaction($transaction) {
|
|
$this->transaction = $transaction;
|
|
}
|
|
public function setMemcache($memcache) {
|
|
$this->memcache = $memcache;
|
|
}
|
|
public function setStatistics($statistics) {
|
|
$this->statistics = $statistics;
|
|
}
|
|
public function setSetting($setting) {
|
|
$this->setting = $setting;
|
|
}
|
|
public function setTools($tools) {
|
|
$this->tools = $tools;
|
|
}
|
|
public function setBitcoin($bitcoin) {
|
|
$this->bitcoin = $bitcoin;
|
|
}
|
|
public function setTokenType($tokentype) {
|
|
$this->tokentype = $tokentype;
|
|
}
|
|
public function setShare($share) {
|
|
$this->share = $share;
|
|
}
|
|
public function setErrorMessage($msg) {
|
|
$this->sError = $msg;
|
|
// Default to same error for crons
|
|
$this->sCronError = $msg;
|
|
}
|
|
public function setCronMessage($msg) {
|
|
// Used to overwrite any errors with a custom cron one
|
|
$this->sCronError = $msg;
|
|
}
|
|
public function getError() {
|
|
return $this->sError;
|
|
}
|
|
/**
|
|
* Additional information in error string for cronjobs logging
|
|
**/
|
|
public function getCronError() {
|
|
return $this->sCronError;
|
|
}
|
|
|
|
/**
|
|
* Get error message from error code array
|
|
* @param errCode string Error code string
|
|
* @param optional string Optional addtitional error strings to append
|
|
* @retrun string Error Message
|
|
**/
|
|
public function getErrorMsg($errCode='') {
|
|
if (!is_array($this->aErrorCodes)) return 'Error codes not loaded';
|
|
if (!array_key_exists($errCode, $this->aErrorCodes)) return 'Unknown Error Code: ' . $errCode;
|
|
if (func_num_args() > 1) {
|
|
$args = func_get_args();
|
|
array_shift($args);
|
|
$param_count = substr_count($this->aErrorCodes[$errCode], '%s');
|
|
if ($param_count == count($args)) {
|
|
return vsprintf($this->aErrorCodes[$errCode], $args);
|
|
} else {
|
|
return $this->aErrorCodes[$errCode] . ' (missing information to complete string)';
|
|
}
|
|
} else {
|
|
return $this->aErrorCodes[$errCode];
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Fetch count of all entries in table
|
|
* @param none
|
|
* @param data mixed Count or false
|
|
**/
|
|
public function getCount() {
|
|
$this->debug->append("STA " . __METHOD__, 4);
|
|
$stmt = $this->mysqli->prepare("SELECT COUNT(id) AS count FROM $this->table");
|
|
if ($this->checkStmt($stmt) && $stmt->execute() && $result = $stmt->get_result())
|
|
return $result->fetch_object()->count;
|
|
return $this->sqlError();
|
|
}
|
|
|
|
/**
|
|
* Fetch count of all entries in table filtered by a column/value
|
|
* @param none
|
|
* @param data mixed Count or false
|
|
**/
|
|
public function getCountFiltered($column='id', $value=NULL, $type='i') {
|
|
$this->debug->append("STA " . __METHOD__, 4);
|
|
$stmt = $this->mysqli->prepare("SELECT COUNT(id) AS count FROM $this->table WHERE $column = ?");
|
|
if ($this->checkStmt($stmt) && $stmt->bind_param($type, $value) && $stmt->execute() && $result = $stmt->get_result())
|
|
return $result->fetch_object()->count;
|
|
return $this->sqlError();
|
|
}
|
|
|
|
/**
|
|
* Fetch all entries as an assoc array from a table
|
|
* This should, in general, not be used but sometimes it's just easier
|
|
* @param none
|
|
* @return array Assoc array of all rows found in table
|
|
**/
|
|
public function getAllAssoc() {
|
|
$this->debug->append("STA " . __METHOD__, 4);
|
|
$stmt = $this->mysqli->prepare("SELECT * FROM $this->table");
|
|
if ($this->checkStmt($stmt) && $stmt->execute() && $result = $stmt->get_result())
|
|
return $result->fetch_all(MYSQLI_ASSOC);
|
|
return $this->sqlError();
|
|
}
|
|
|
|
/**
|
|
* Get a single row as an assoc array
|
|
* @param value string Value to search for
|
|
* @param field string Column to search for
|
|
* @param type string Type of value
|
|
* @return array Resulting row
|
|
**/
|
|
protected function getSingleAssoc($value, $field='id', $type='i') {
|
|
$this->debug->append("STA " . __METHOD__, 4);
|
|
$stmt = $this->mysqli->prepare("SELECT * FROM $this->table WHERE $field = ? LIMIT 1");
|
|
if ($this->checkStmt($stmt) && $stmt->bind_param($type, $value) && $stmt->execute() && $result = $stmt->get_result())
|
|
return $result->fetch_assoc();
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* Get a single value from a row matching the query specified
|
|
* @param value string Value to search for
|
|
* @param search Return column to search for
|
|
* @param field string Search column
|
|
* @param type string Type of value
|
|
* @param lower bool try with LOWER comparision
|
|
* @return array Return result
|
|
**/
|
|
protected function getSingle($value, $search='id', $field='id', $type="i", $lower=false) {
|
|
$this->debug->append("STA " . __METHOD__, 4);
|
|
$sql = "SELECT $search FROM $this->table WHERE";
|
|
$lower ? $sql .= " LOWER($field) = LOWER(?)" : $sql .= " $field = ?";
|
|
$sql .= " LIMIT 1";
|
|
$stmt = $this->mysqli->prepare($sql);
|
|
if ($this->checkStmt($stmt)) {
|
|
$stmt->bind_param($type, $value);
|
|
$stmt->execute();
|
|
$stmt->bind_result($retval);
|
|
$stmt->fetch();
|
|
$stmt->close();
|
|
return $retval;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* Check if the prepared statement is valid
|
|
* @param $bState Statement return value
|
|
* @return bool true or false
|
|
**/
|
|
function checkStmt($bState) {
|
|
$this->debug->append("STA " . __METHOD__, 4);
|
|
if ($bState ===! true)
|
|
return $this->sqlError();
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* Catch SQL errors with this method
|
|
* @param error_code string Error code to read
|
|
**/
|
|
protected function sqlError($error_code='E0020') {
|
|
// More human-readable error for UI
|
|
if (func_num_args() == 0) {
|
|
$this->setErrorMessage($this->getErrorMsg($error_code));
|
|
} else {
|
|
$this->setErrorMessage(call_user_func_array(array($this, 'getErrorMsg'), func_get_args()));
|
|
}
|
|
// Default to SQL error for debug and cron errors
|
|
$this->debug->append($this->getErrorMsg('E0019', $this->mysqli->error));
|
|
$this->setCronMessage($this->getErrorMsg('E0019', $this->mysqli->error));
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* @param userID int Account ID
|
|
* Update a single row in a table
|
|
* @param field string Field to update
|
|
* @return bool
|
|
**/
|
|
protected function updateSingle($id, $field, $table='') {
|
|
if (empty($table)) $table = $this->table;
|
|
$this->debug->append("STA " . __METHOD__, 4);
|
|
$stmt = $this->mysqli->prepare("UPDATE $table SET " . $field['name'] . " = ? WHERE id = ? LIMIT 1");
|
|
if ($this->checkStmt($stmt) && $stmt->bind_param($field['type'].'i', $field['value'], $id) && $stmt->execute())
|
|
return true;
|
|
$this->debug->append("Unable to update " . $field['name'] . " with " . $field['value'] . " for ID $id");
|
|
return $this->sqlError();
|
|
}
|
|
|
|
/**
|
|
* We may need to generate our bind_param list
|
|
**/
|
|
public function addParam($type, &$value) {
|
|
$this->values[] = $value;
|
|
$this->types .= $type;
|
|
}
|
|
public function getParam() {
|
|
$array = array_merge(array($this->types), $this->values);
|
|
// Clear the data
|
|
$this->values = NULL;
|
|
$this->types = NULL;
|
|
// See here why we need this: http://stackoverflow.com/questions/16120822/mysqli-bind-param-expected-to-be-a-reference-value-given
|
|
if (strnatcmp(phpversion(),'5.3') >= 0) {
|
|
$refs = array();
|
|
foreach($array as $key => $value)
|
|
$refs[$key] = &$array[$key];
|
|
return $refs;
|
|
}
|
|
return $array;
|
|
}
|
|
}
|
|
?>
|