a006ea782a
* Added SQL code to support both balances * Added sidebar entries * Modified auto_payout to use new index * Mofified account page to use new index Addresses #140 but needs to be tested!
239 lines
7.9 KiB
PHP
239 lines
7.9 KiB
PHP
<?php
|
|
|
|
// Make sure we are called from index.php
|
|
if (!defined('SECURITY'))
|
|
die('Hacking attempt');
|
|
|
|
class Transaction {
|
|
private $sError = '';
|
|
private $table = 'transactions';
|
|
private $tableBlocks = 'blocks';
|
|
|
|
public function __construct($debug, $mysqli, $config, $block) {
|
|
$this->debug = $debug;
|
|
$this->mysqli = $mysqli;
|
|
$this->config = $config;
|
|
$this->block = $block;
|
|
$this->debug->append("Instantiated Transaction class", 2);
|
|
}
|
|
|
|
// get and set methods
|
|
private function setErrorMessage($msg) {
|
|
$this->sError = $msg;
|
|
}
|
|
public function getError() {
|
|
return $this->sError;
|
|
}
|
|
|
|
/**
|
|
* Add a new transaction to our class table
|
|
* @param account_id int Account ID to book transaction for
|
|
* @param amount float Coin amount
|
|
* @param type string Transaction type [Credit, Debit_AP, Debit_MP, Fee, Donation, Orphan_Credit, Orphan_Fee, Orphan_Donation]
|
|
* @param block_id int Block ID to link transaction to [optional]
|
|
* @param coin_address string Coin address for this transaction [optional]
|
|
* @return bool
|
|
**/
|
|
public function addTransaction($account_id, $amount, $type='Credit', $block_id=NULL, $coin_address=NULL) {
|
|
$stmt = $this->mysqli->prepare("INSERT INTO $this->table (account_id, amount, block_id, type, coin_address) VALUES (?, ?, ?, ?, ?)");
|
|
if ($this->checkStmt($stmt)) {
|
|
$stmt->bind_param("idiss", $account_id, $amount, $block_id, $type, $coin_address);
|
|
if ($stmt->execute()) {
|
|
$this->setErrorMessage("Failed to store transaction");
|
|
$stmt->close();
|
|
return true;
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* Sometimes transactions become orphans when a block associated to them is orphaned
|
|
* Updates the transaction types to Orphan_<type>
|
|
* @param block_id int Orphaned block ID
|
|
* @return bool
|
|
**/
|
|
public function setOrphan($block_id) {
|
|
$this->debug->append("STA " . __METHOD__, 4);
|
|
$aOrphans = array(
|
|
'Credit' => 'Orphan_Credit',
|
|
'Fee' => 'Orphan_Fee',
|
|
'Donation' => 'Orphan_Donation',
|
|
'Bonus' => 'Orphan_Bonus'
|
|
);
|
|
foreach ($aOrphans as $from => $to) {
|
|
$stmt = $this->mysqli->prepare("
|
|
UPDATE $this->table
|
|
SET type = '$to'
|
|
WHERE type = '$from'
|
|
AND block_id = ?
|
|
");
|
|
if (!($this->checkStmt($stmt) && $stmt->bind_param('i', $block_id) && $stmt->execute())) {
|
|
$this->debug->append("Failed to set orphan $from => $to transactions for $block_id");
|
|
return false;
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* Get all transactions from start for account_id
|
|
* @param account_id int Account ID
|
|
* @param start int Starting point, id of transaction
|
|
* @return data array Database fields as defined in SELECT
|
|
**/
|
|
public function getTransactions($account_id, $start=0) {
|
|
$this->debug->append("STA " . __METHOD__, 4);
|
|
$stmt = $this->mysqli->prepare("
|
|
SELECT
|
|
t.id AS id,
|
|
t.type AS type,
|
|
t.amount AS amount,
|
|
t.coin_address AS coin_address,
|
|
t.timestamp AS timestamp,
|
|
b.height AS height,
|
|
b.confirmations AS confirmations
|
|
FROM transactions AS t
|
|
LEFT JOIN blocks AS b ON t.block_id = b.id
|
|
WHERE t.account_id = ?
|
|
ORDER BY id DESC");
|
|
if ($this->checkStmt($stmt)) {
|
|
if(!$stmt->bind_param('i', $account_id)) return false;
|
|
$stmt->execute();
|
|
$result = $stmt->get_result();
|
|
return $result->fetch_all(MYSQLI_ASSOC);
|
|
}
|
|
$this->debug->append('Unable to fetch transactions');
|
|
return false;
|
|
}
|
|
|
|
private function checkStmt($bState) {
|
|
if ($bState ===! true) {
|
|
$this->debug->append("Failed to prepare statement: " . $this->mysqli->error);
|
|
$this->setErrorMessage('Internal application Error');
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* Get total balance for all users locked in wallet
|
|
* This includes any outstanding unconfirmed transactions!
|
|
* @param none
|
|
* @return data double Amount locked for users
|
|
**/
|
|
public function getLockedBalance() {
|
|
$this->debug->append("STA " . __METHOD__, 4);
|
|
$stmt = $this->mysqli->prepare("
|
|
SELECT ROUND(IFNULL(t1.credit, 0) - IFNULL(t2.debit, 0) - IFNULL(t3.other, 0), 8) AS balance
|
|
FROM
|
|
(
|
|
SELECT sum(t.amount) AS credit
|
|
FROM $this->table AS t
|
|
LEFT JOIN " . $this->block->getTableName() . " AS b ON t.block_id = b.id
|
|
WHERE (
|
|
( t.type IN ('Credit','Bonus') AND b.confirmations >= ? ) OR
|
|
( t.type = 'Credit_PPS' )
|
|
)
|
|
) AS t1,
|
|
(
|
|
SELECT sum(t.amount) AS debit
|
|
FROM $this->table AS t
|
|
WHERE t.type IN ('Debit_MP', 'Debit_AP')
|
|
) AS t2,
|
|
(
|
|
SELECT sum(t.amount) AS other
|
|
FROM " . $this->table . " AS t
|
|
LEFT JOIN " . $this->block->getTableName() . " AS b ON t.block_id = b.id
|
|
WHERE (
|
|
( t.type IN ('Donation','Fee') AND b.confirmations >= ? ) OR
|
|
t.type IN ('Donation_PPS','Fee_PPS')
|
|
)
|
|
) AS t3");
|
|
if ($this->checkStmt($stmt) && $stmt->bind_param('ii', $this->config['confirmations'], $this->config['confirmations']) && $stmt->execute() && $stmt->bind_result($dBalance) && $stmt->fetch())
|
|
return $dBalance;
|
|
// Catchall
|
|
$this->setErrorMessage('Unable to find locked credits for all users');
|
|
$this->debug->append('MySQL query failed : ' . $this->mysqli->error);
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* Get an accounts total balance
|
|
* @param account_id int Account ID
|
|
* @return data float Credit - Debit - Fees - Donation
|
|
**/
|
|
public function getBalance($account_id) {
|
|
$this->debug->append("STA " . __METHOD__, 4);
|
|
$stmt = $this->mysqli->prepare("
|
|
SELECT
|
|
ROUND(IFNULL(t1.credit, 0) - IFNULL(t2.debit, 0) - IFNULL(t3.other, 0), 8) AS confirmed,
|
|
ROUND(IFNULL(t4.credit, 0) - IFNULL(t5.other, 0), 8) AS unconfirmed
|
|
FROM
|
|
(
|
|
SELECT sum(t.amount) AS credit
|
|
FROM $this->table AS t
|
|
LEFT JOIN " . $this->block->getTableName() . " AS b ON t.block_id = b.id
|
|
WHERE
|
|
(
|
|
( t.type IN ('Credit','Bonus') AND b.confirmations >= ? ) OR
|
|
( t.type = 'Credit_PPS' )
|
|
)
|
|
AND t.account_id = ?
|
|
) AS t1,
|
|
(
|
|
SELECT sum(t.amount) AS debit
|
|
FROM $this->table AS t
|
|
WHERE t.type IN ('Debit_MP', 'Debit_AP')
|
|
AND t.account_id = ?
|
|
) AS t2,
|
|
(
|
|
SELECT sum(t.amount) AS other
|
|
FROM $this->table AS t
|
|
LEFT JOIN " . $this->block->getTableName() . " AS b ON t.block_id = b.id
|
|
WHERE
|
|
(
|
|
( t.type IN ('Donation','Fee') AND b.confirmations >= ? ) OR
|
|
( t.type IN ('Donation_PPS', 'Fee_PPS') )
|
|
)
|
|
AND t.account_id = ?
|
|
) AS t3,
|
|
(
|
|
SELECT sum(t.amount) AS credit
|
|
FROM $this->table AS t
|
|
LEFT JOIN " . $this->block->getTableName() . " AS b ON t.block_id = b.id
|
|
WHERE
|
|
(
|
|
( t.type = 'Credit' AND b.confirmations < ? ) OR
|
|
( t.type = 'Credit_PPS' )
|
|
)
|
|
AND t.account_id = ?
|
|
) AS t4,
|
|
(
|
|
SELECT sum(t.amount) AS other
|
|
FROM $this->table AS t
|
|
LEFT JOIN " . $this->block->getTableName() . " AS b ON t.block_id = b.id
|
|
WHERE
|
|
(
|
|
( t.type IN ('Donation','Fee') AND b.confirmations < ? ) OR
|
|
( t.type IN ('Donation_PPS', 'Fee_PPS') )
|
|
)
|
|
AND t.account_id = ?
|
|
) AS t5
|
|
");
|
|
if ($this->checkStmt($stmt)) {
|
|
$stmt->bind_param("iiiiiiiii", $this->config['confirmations'], $account_id, $account_id, $this->config['confirmations'], $account_id, $this->config['confirmations'], $account_id, $this->config['confirmations'], $account_id);
|
|
if (!$stmt->execute()) {
|
|
$this->debug->append("Unable to execute statement: " . $stmt->error);
|
|
$this->setErrorMessage("Fetching balance failed");
|
|
}
|
|
$result = $stmt->get_result();
|
|
$stmt->close();
|
|
return $result->fetch_assoc();
|
|
}
|
|
return false;
|
|
}
|
|
}
|
|
|
|
$transaction = new Transaction($debug, $mysqli, $config, $block);
|