5d57593f5d
If we have a block with NO `share_id` we abort the entire process. Less of an issue with proportional since PPS is still being paid out, but a block round will never actually end. This will allow for manual intervention by the user. Otherwise blocks found after the one having issues might trigger the payout process and pay out shares of the old block in a more recently found one. Please use #392 for further help on this, I have yet to replicate the unknown block finder issue with the proper amount of upstream shares.
114 lines
4.5 KiB
PHP
Executable File
114 lines
4.5 KiB
PHP
Executable File
#!/usr/bin/php
|
|
<?php
|
|
|
|
/*
|
|
|
|
Copyright:: 2013, Sebastian Grewe
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
|
|
*/
|
|
|
|
// Include all settings and classes
|
|
require_once('shared.inc.php');
|
|
|
|
// Check if we are set as the payout system
|
|
if ($config['payout_system'] != 'prop') {
|
|
verbose("Please activate this cron in configuration via payout_system = prop\n");
|
|
exit(0);
|
|
}
|
|
|
|
// Fetch all unaccounted blocks
|
|
$aAllBlocks = $block->getAllUnaccounted('ASC');
|
|
if (empty($aAllBlocks)) {
|
|
verbose("No new unaccounted blocks found\n");
|
|
exit(0);
|
|
}
|
|
|
|
$count = 0;
|
|
foreach ($aAllBlocks as $iIndex => $aBlock) {
|
|
if (!$aBlock['accounted']) {
|
|
$iPreviousShareId = @$aAllBlocks[$iIndex - 1]['share_id'] ? $aAllBlocks[$iIndex - 1]['share_id'] : 0;
|
|
$iCurrentUpstreamId = $aBlock['share_id'];
|
|
if (!is_numeric($iCurrentUpstreamId)) die("Block " . $aBlock['height'] . " has no share_id associated with it, not going to continue\n");
|
|
$aAccountShares = $share->getSharesForAccounts($iPreviousShareId, $aBlock['share_id']);
|
|
$iRoundShares = $share->getRoundShares($iPreviousShareId, $aBlock['share_id']);
|
|
$config['reward_type'] == 'block' ? $dReward = $aBlock['amount'] : $dReward = $config['reward'];
|
|
|
|
if (empty($aAccountShares)) {
|
|
verbose("\nNo shares found for this block: " . $aBlock['height'] . " \n\n");
|
|
sleep(2);
|
|
continue;
|
|
}
|
|
|
|
// Table header for account shares
|
|
verbose("ID\tUsername\tValid\tInvalid\tPercentage\tPayout\t\tDonation\tFee\t\tStatus\n");
|
|
|
|
// Loop through all accounts that have found shares for this round
|
|
foreach ($aAccountShares as $key => $aData) {
|
|
// Payout based on shares, PPS system
|
|
$aData['percentage'] = number_format(round(( 100 / $iRoundShares ) * $aData['valid'], 8), 8);
|
|
$aData['payout'] = number_format(round(( $aData['percentage'] / 100 ) * $dReward, 8), 8);
|
|
// Defaults
|
|
$aData['fee' ] = 0;
|
|
$aData['donation'] = 0;
|
|
|
|
if ($config['fees'] > 0)
|
|
$aData['fee'] = number_format(round($config['fees'] / 100 * $aData['payout'], 8), 8);
|
|
// Calculate donation amount, fees not included
|
|
$aData['donation'] = number_format(round($user->getDonatePercent($user->getUserId($aData['username'])) / 100 * ( $aData['payout'] - $aData['fee']), 8), 8);
|
|
|
|
// Verbose output of this users calculations
|
|
verbose($aData['id'] . "\t" .
|
|
$aData['username'] . "\t" .
|
|
$aData['valid'] . "\t" .
|
|
$aData['invalid'] . "\t" .
|
|
$aData['percentage'] . "\t" .
|
|
$aData['payout'] . "\t" .
|
|
$aData['donation'] . "\t" .
|
|
$aData['fee'] . "\t");
|
|
|
|
$strStatus = "OK";
|
|
// Update user share statistics
|
|
if (!$statistics->updateShareStatistics($aData, $aBlock['id']))
|
|
$strStatus = "Stats Failed";
|
|
// Add new credit transaction
|
|
if (!$transaction->addTransaction($aData['id'], $aData['payout'], 'Credit', $aBlock['id']))
|
|
$strStatus = "Transaction Failed";
|
|
// Add new fee debit for this block
|
|
if ($aData['fee'] > 0 && $config['fees'] > 0)
|
|
if (!$transaction->addTransaction($aData['id'], $aData['fee'], 'Fee', $aBlock['id']))
|
|
$strStatus = "Fee Failed";
|
|
// Add new donation debit
|
|
if ($aData['donation'] > 0)
|
|
if (!$transaction->addTransaction($aData['id'], $aData['donation'], 'Donation', $aBlock['id']))
|
|
$strStatus = "Donation Failed";
|
|
verbose("\t$strStatus\n");
|
|
}
|
|
|
|
// Move counted shares to archive before this blockhash upstream share
|
|
if ($config['archive_shares']) $share->moveArchive($iCurrentUpstreamId, $aBlock['id'], $iPreviousShareId);
|
|
// Delete all accounted shares
|
|
if (!$share->deleteAccountedShares($iCurrentUpstreamId, $iPreviousShareId)) {
|
|
verbose("\nERROR : Failed to delete accounted shares from $iPreviousShareId to $iCurrentUpstreamId, aborting!\n");
|
|
exit(1);
|
|
}
|
|
// Mark this block as accounted for
|
|
if (!$block->setAccounted($aBlock['id'])) {
|
|
verbose("\nERROR : Failed to mark block as accounted! Aborting!\n");
|
|
}
|
|
|
|
verbose("------------------------------------------------------------------------\n\n");
|
|
}
|
|
}
|