|
|
|
@ -383,11 +383,11 @@ app.get('/miner/:address/stats', function (req, res) {
|
|
|
|
|
let payment_id = address_parts[1];
|
|
|
|
|
let cachedData = global.database.getCache(address);
|
|
|
|
|
let paidQuery = "SELECT SUM(amount) as amt FROM payments WHERE payment_address = ? AND payment_id = ?";
|
|
|
|
|
let txnCount = "SELECT count(id) as amt FROM payments WHERE payment_address = ? AND payment_id = ?";
|
|
|
|
|
let txnQuery = "SELECT count(id) as amt FROM payments WHERE payment_address = ? AND payment_id = ?";
|
|
|
|
|
let unpaidQuery = "SELECT SUM(amount) as amt FROM balance WHERE payment_address = ? AND payment_id = ?";
|
|
|
|
|
if (typeof(payment_id) === 'undefined') {
|
|
|
|
|
paidQuery = "SELECT SUM(amount) as amt FROM payments WHERE payment_address = ? AND payment_id IS ?";
|
|
|
|
|
txnCount = "SELECT count(id) as amt FROM payments WHERE payment_address = ? AND payment_id IS ?";
|
|
|
|
|
txnQuery = "SELECT count(id) as amt FROM payments WHERE payment_address = ? AND payment_id IS ?";
|
|
|
|
|
unpaidQuery = "SELECT SUM(amount) as amt FROM balance WHERE payment_address = ? AND payment_id IS ?";
|
|
|
|
|
}
|
|
|
|
|
async.waterfall([
|
|
|
|
@ -421,12 +421,12 @@ app.get('/miner/:address/stats', function (req, res) {
|
|
|
|
|
returnData.amtDue = 0;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return callback(true, returnData);
|
|
|
|
|
return callback(null, returnData);
|
|
|
|
|
});
|
|
|
|
|
},
|
|
|
|
|
function (returnData, callback) {
|
|
|
|
|
debug(threadName + "Checking MySQL total amount unpaid for /miner/address/stats");
|
|
|
|
|
global.mysql.query(txnCount, [address_pt, payment_id]).then(function (rows) {
|
|
|
|
|
global.mysql.query(txnQuery, [address_pt, payment_id]).then(function (rows) {
|
|
|
|
|
if (typeof(rows[0]) === 'undefined') {
|
|
|
|
|
returnData.txnCount = 0;
|
|
|
|
|
} else {
|
|
|
|
|