从 async.waterfall 调用外部函数

Question

我对 JS 有点陌生，并且使用现有的分叉库（它非常复杂且文档很少）- 所以请耐心等待。

我正在开发一个矿池系统，特别是添加一个功能，用户可以在其中设置自定义支付金额而不是较低的矿池限制。我已经整理好将用户工作地址的值写入 redis。

我现在要做的是添加逻辑：

使用工作的工作人员地址，看看他们是否设置了自定义支付值（下面是我的外部函数）
如果已设置，一些逻辑可以确定他们是应该立即付款还是将其添加到他们的余额中

现有的瀑布脚本在这里：https://github.com/mardock2009/Ravencoin-Pool/blob/master/libs/paymentProcessor.js#L575

在瀑布之前，我添加了一个类似于此的函数（我已经尝试了很多次迭代）：

getCustomPayoutAmount = function(worker, cback) {
    var logger = loggerFactory.getLogger('PaymentProcessing', 'getCustomPayoutAmount');

    var redisClient = redis.createClient(portalConfig.redis.port, portalConfig.redis.host);             
    logger.debug('Getting custom Payout for worker: %s', worker);
    var payoutAmount = new BigNumber(0);

    redisClient.hget('ravencoin:workers:customPayoutAmount', worker,  function(error, result) {
        if (error) {
            logger.error('Error getCustomPayoutAmount: %s', error);
            payoutAmount = 0;
        }
        logger.debug('Got custom payout amount for worker: %s, Payout Amount: %s', worker, result);
        if (result > 10) {
            payoutAmount = new BigNumber(result);
            logger.debug('Parsed Float Amount: %s', payoutAmount);
        } else {
            logger.debug('Else lower than: %s', payoutAmount);
            payoutAmount = new BigNumber(0);
        }       
    });
    cback( new BigNumber(payoutAmount));    
};

然后在第 575 行左右，我调用它（也许？）：

                    var customPayoutAmount = new BigNumber(0);

                    getCustomPayoutAmount(worker, function(returnCustomPayoutAmount) {
                        logger.debug('Callback customPayoutAmount = %s', returnCustomPayoutAmount);
                        customPayoutAmount = returnCustomPayoutAmount;
                    });

                    logger.debug('PP> customPayoutAmount = %s', customPayoutAmount);

最后，一些 if/elseif 处理不同情况的逻辑：

if (toSend.isGreaterThanOrEqualTo(minPayment)) {

                        if (toSend.isGreaterThanOrEqualTo(customPayoutAmount) && !customPayoutAmount.isZero()) {
                            //Amount Sent is higher than the custom amount set for this worker. Pay it out.
                            logger.debug('PP> Worker %s have their custom minimum payout amount: (%s above minimum %s)', w, toSend.toString(10), customPayoutAmount.toString(10));
                            totalSent = totalSent.plus(toSend);              
                            logger.debug('PP> totalSent = %s', totalSent.toString(10));
                            var address = worker.address = (worker.address || getProperAddress(w));              
                            logger.debug('PP> address = %s', address);
                            worker.sent = addressAmounts[address] = toSend;
                            logger.debug('PP> worker.sent = %s', worker.sent.toString(10));
                            worker.balanceChange = BigNumber.min(worker.balance, worker.sent).multipliedBy(new BigNumber(-1));
                            logger.debug('PP> worker.balanceChange = %s', worker.balanceChange.toString(10));

                        } else if (toSend.isLessThan(customPayoutAmount) && !customPayoutAmount.isZero()){
                            //Amount is higher than the minimum payment but not higher than the custom amount set for this worker. Add it to their balance.
                            //Did not meet the pool minimum, no custom amount. Add to balance.
                            logger.debug('PP> Worker %s have not reached minimum payout from their custom set payout amount threshold %s', w, customPayoutAmount.toString(10));
                            worker.balanceChange = BigNumber.max(toSend.minus(worker.balance), new BigNumber(0));
                            logger.debug('PP> worker.balanceChange = %s', worker.balanceChange.toString(10));
                            worker.sent = new BigNumber(0);
                            logger.debug('PP> worker.sent = %s', worker.sent.toString(10));
                            if (worker.balanceChange > 0) {
                                if (balanceAmounts[address] != null && balanceAmounts[address].isGreaterThan(0)) {
                                    balanceAmounts[address] = balanceAmounts[address].plus(worker.balanceChange);
                                } else {
                                    balanceAmounts[address] = worker.balanceChange;
                                }
                            }
                        }
                        
                        if (toSend.isGreaterThanOrEqualTo(minPayment) && customPayoutAmount.isZero()) {
                            //Meets the pool minimum payment, no custom amount. Pay out based on the pool minimum payment.
                            logger.debug('PP> Worker %s have reached minimum payout threshold (%s above minimum %s)', w, toSend.toString(10), minPayment.toString(10));
                            totalSent = totalSent.plus(toSend);              
                            logger.debug('PP> totalSent = %s', totalSent.toString(10));
                            var address = worker.address = (worker.address || getProperAddress(w));              
                            logger.debug('PP> address = %s', address);
                            worker.sent = addressAmounts[address] = toSend;
                            logger.debug('PP> worker.sent = %s', worker.sent.toString(10));
                            worker.balanceChange = BigNumber.min(worker.balance, worker.sent).multipliedBy(new BigNumber(-1));
                            logger.debug('PP> worker.balanceChange = %s', worker.balanceChange.toString(10));
                        }

                        
                    } else {
                        //Did not meet the pool minimum, no custom amount. Add to balance.
                        logger.debug('PP> Worker %s have not reached minimum payout threshold %s', w, minPayment.toString(10));
                        worker.balanceChange = BigNumber.max(toSend.minus(worker.balance), new BigNumber(0));
                        logger.debug('PP> worker.balanceChange = %s', worker.balanceChange.toString(10));
                        worker.sent = new BigNumber(0);
                        logger.debug('PP> worker.sent = %s', worker.sent.toString(10));
                        if (worker.balanceChange > 0) {
                            if (balanceAmounts[address] != null && balanceAmounts[address].isGreaterThan(0)) {
                                balanceAmounts[address] = balanceAmounts[address].plus(worker.balanceChange);
                            } else {
                                balanceAmounts[address] = worker.balanceChange;
                            }
                        }
                    }

我遇到的主要问题是我无法从在瀑布内部调用它的 redis 取回值。我假设是因为它是异步的并且我没有编写异步代码 - 这也导致它在我需要值时不一定运行按顺序排列。

再一次，我知道这是一团糟，我可能做错了，所以希望有人对这个可怜的菜鸟有一些了解。

Answer 1

您可以使用async.each()

function(workers, rounds, addressAccount, callback) {
  var trySend = function(withholdPercent) {
    ...
    async.each(workers, function(worker, callback) {
      ...
      getCustomPayoutAmount(worker, function(customPayoutAmount) {
        ...
        if (toSend.isGreaterThanOrEqualTo(minPayment)) {
          if (toSend.isGreaterThanOrEqualTo(customPayoutAmount) && !customPayoutAmount.isZero()) {
            ...
          }
          ...
        }
        callback();
      });
    })
    .then(function() {
      if (Object.keys(addressAmounts).length === 0) {
        logger.info('PP> No workers was chosen for paying out');
        callback(null, workers, rounds, []);
        return;
      }
      ...
      daemon.cmd('sendmany', [addressAccount || '', addressAmounts, 1, ""], function(result) {
        ...
      }
    });
  };
  trySend(new BigNumber(0);
}

并且在 'getCustomPayoutAmount' 中，应该在 'redisClient.hget()' 的回调中调用 'cback()`，如下所示

getCustomPayoutAmount = function(worker, cback) {
    ...

    redisClient.hget('ravencoin:workers:customPayoutAmount', worker,  function(error, result) {
        ...
        cback(payoutAmount);   
    });
     
};

从 async.waterfall 调用外部函数

Calling external function from async.waterfall

javascript

node.js

async.js