LBRYFoundation/pool
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/pool.git synced 2025-09-21 02:19:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

cron: update new coin balance fields (from db)

Browse source
This commit is contained in:
Tanguy Pruvot 2016-11-25 04:23:27 +01:00
parent ad3f2e2714
commit a4af6b856f
2 changed files with 37 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
web/yaamp/core/backend/blocks.php
View file

@ -65,6 +65,7 @@ function BackendBlockNew($coin, $db_block)
}
/////////////////////////////////////////////////////////////////////////////////////////////////
// Import new blocks (notified by the stratum)
function BackendBlockFind1($coinid = NULL)
{
@ -144,6 +145,7 @@ function BackendBlockFind1($coinid = NULL)
}
/////////////////////////////////////////////////////////////////////////////////
// Refresh immature blocks status (confirmations)
function BackendBlocksUpdate($coinid = NULL)
{
@ -239,9 +241,12 @@ function BackendBlocksUpdate($coinid = NULL)
}
////////////////////////////////////////////////////////////////////////////////////////////
// Search new block transactions
function BackendBlockFind2($coinid = NULL)
{
$t1 = microtime(true);
$sqlFilter = $coinid ? "id=".intval($coinid) : 'enable=1';
$coins = getdbolist('db_coins', $sqlFilter);
@ -325,8 +330,39 @@ function BackendBlockFind2($coinid = NULL)
$coin->save();
}
$d1 = microtime(true) - $t1;
controller()->memcache->add_monitoring_function(__FUNCTION__, $d1);
//debuglog(__FUNCTION__." took ".round($d1,3)." sec");
}
////////////////////////////////////////////////////////////////////////////////////////////
// Update coin totals from the db blocks/earnings (allow triggers and easier balance sums)
function BackendUpdatePoolBalances($coinid = NULL)
{
$t1 = microtime(true);
$sqlFilter = $coinid ? "id=".intval($coinid) : 'enable=1';
$coins = getdbolist('db_coins', $sqlFilter);
foreach($coins as $coin)
{
$coin->immature = (double) dboscalar("SELECT SUM(amount) FROM blocks WHERE category='immature' AND coin_id=".intval($coin->id));
$coin->cleared = (double) dboscalar("SELECT SUM(balance) FROM accounts WHERE coinid=".intval($coin->id));
$pending = (double) dboscalar("SELECT SUM(amount) FROM earnings WHERE status=1 AND coinid=".intval($coin->id)); // (to be cleared)
$coin->available = (double) $coin->balance - $coin->cleared - $pending;
//if ($pending) debuglog("{$coin->symbol} immature {$coin->immature}, cleared {$coin->cleared}, pending {$pending}, available {$coin->available}");
$coin->save();
}
$d1 = microtime(true) - $t1;
controller()->memcache->add_monitoring_function(__FUNCTION__, $d1);
//debuglog(__FUNCTION__." took ".round($d1,3)." sec");
}
////////////////////////////////////////////////////////////////////////////////////////////
function MonitorBTC()
{
// debuglog(__FUNCTION__);

1
web/yaamp/modules/thread/CronjobController.php
View file

@ -164,6 +164,7 @@ class CronjobController extends CommonController
case 6:
BackendBlockFind2();
BackendUpdatePoolBalances();
break;
case 7: