LBRYFoundation/pool
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/pool.git synced 2025-08-23 17:37:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

db: save payout errors

Browse source
This commit is contained in:
Tanguy Pruvot 2016-02-17 08:22:08 +01:00
parent 71de6d635b
commit 2022170777
2 changed files with 28 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
sql/2016-02-17-payouts_errmsg.sql Normal file
View file

@ -0,0 +1,3 @@
-- Recent additions to add after db init (.gz)
ALTER TABLE `payouts` ADD `errmsg` text NULL AFTER `tx`;

30
web/yaamp/core/backend/payment.php
View file

@ -186,27 +186,36 @@ function BackendCoinPayments($coin)
else else
$tx = $remote->sendmany($account, $addresses, 1, YAAMP_SITE_NAME); $tx = $remote->sendmany($account, $addresses, 1, YAAMP_SITE_NAME);
$errmsg = NULL;
if(!$tx) { if(!$tx) {
debuglog("sendmany: unable to send $total_to_pay {$remote->error} ".json_encode($addresses)); debuglog("sendmany: unable to send $total_to_pay {$remote->error} ".json_encode($addresses));
return; $errmsg = $remote->error;
} }
else if(!is_string($tx)) { else if(!is_string($tx)) {
debuglog("sendmany: result is not a string tx=".json_encode($tx)); debuglog("sendmany: result is not a string tx=".json_encode($tx));
return; $errmsg = json_encode($tx);
} }
// save processed payouts (tx) // save processed payouts (tx)
foreach($payouts as $id => $uid) { foreach($payouts as $id => $uid) {
$payout = getdbo('db_payouts', $id); $payout = getdbo('db_payouts', $id);
if ($payout && $payout->id == $id) { if ($payout && $payout->id == $id) {
$payout->tx = $tx; $payout->errmsg = $errmsg;
if (empty($errmsg)) {
$payout->tx = $tx;
$payout->completed = 1;
}
$payout->save(); $payout->save();
} else { } else {
debuglog("payout $id for $uid not found!"); debuglog("payout $id for $uid not found!");
} }
} }
debuglog("payment done"); if (!empty($errmsg)) {
return;
}
debuglog("{$coin->symbol} payment done");
sleep(2); sleep(2);
@ -249,8 +258,19 @@ function BackendCoinPayments($coin)
if(empty($tx)) { if(empty($tx)) {
debuglog($remote->error); debuglog($remote->error);
send_email_alert('payouts', "{$coin->symbol} payout problems detected", $mailmsg);
foreach ($payouts as $id => $uid) {
$payout = getdbo('db_payouts', $id);
if ($payout && $payout->id == $id) {
$payout->errmsg = $remote->error;
$payout->save();
}
}
send_email_alert('payouts', "{$coin->symbol} payout problems detected\n {$remote->error}", $mailmsg);
} else { } else {
foreach ($payouts as $id => $uid) { foreach ($payouts as $id => $uid) {
$payout = getdbo('db_payouts', $id); $payout = getdbo('db_payouts', $id);
if ($payout && $payout->id == $id) { if ($payout && $payout->id == $id) {