1

我在 Javascript 上创建了一个交易机器人（我之前没有使用这种语言的经验）。追踪止损函数的运行方式是：

  • Websocket 收到当前市场价格
  • “active”是一个布尔变量，如果为真，运行代码
  • 如果价格上涨 %，取消旧的止损并增加一个更高的新止损。

我遇到的问题是代码没有按正确的顺序运行。如果你看图片，我不明白为什么如果 active 为 false，蓝色框仍然执行。而且由于程序有时以错误的顺序运行，websocket 会停止或按不应该的方式运行。

输出

这是我的追踪止损 websocket 代码：

function binanceTrailingSLOrder(symbol, orderId, quantity, oldPrice, percentage, active) {

    const clean_trade = client.ws.trades([symbol], trade => { //run websocket
        var livePrice = parseFloat(binance_symbols[symbol]["close"]); //set new price to live price

        if (active == true) {
            binanceCheckOrderStatus(symbol, orderId).then(r => {
                switch (r.status) {
                    case "PENDING":
                        if (livePrice >= (oldPrice * ((100 + percentage) / 100)) && active == true) {
                            active = false;
                            binanceCancelOrder(symbol, orderId).then((r4) => { //Cancel previous SL
                                var newSL = livePrice * ((100 - percentage) / 100);
                                binanceStopOrder(symbol, 'SELL', r4.origQty, newSL, newSL).then((r5) => { //Set new SL
                                    orderId = r5.orderId; quantity = r5.origQty; oldPrice = r5.price;
                                    active = true;
                                }).catch((err) => {
                                    console.log(err);
                                });
                            });
                        }
                        break;
                    default:
                        break;
                }

            });
        }
    });

}

查询订单状态功能：

//Get specific order status
function binanceCheckOrderStatus(symbol, orderId) {
    if(!orderId){
        console.log("order Id not found");
        return false;
    } else {
        var client = loadBinanceKeys2();

        return client.getOrder({
            symbol: symbol,
            orderId: orderId,
            recvWindow: 1000000
        }).then((order) => {
            return order;
        }).catch((err) => {
            console.log(err);
        });
    }
}
4

1 回答 1

2

Javascript本质上是异步的。该函数binanceCheckOrderStatus()返回一个承诺。执行引擎将调用此函数，然后继续执行下一行。after 的代码块仅在's完成后.then(r =>执行。现在在这个时间段内，active 可能在其他请求中已经变为 false。新开发人员可能会感到困惑。由于您在代码中使用了很多，因此您必须了解该部分仅在函数完成执行之前执行。所以花费更少时间的函数将执行它binanceCheckOrderStatusgetOrder().then().then().then().then().then()部分先于其他部分。所以简而言之，除非您知道每个函数将花费多少时间，否则您无法在这种情况下控制顺序，这可能无法确认。为了克服这个问题，你必须使用async / await。或者，您需要更改您的逻辑，以减少对深层承诺的依赖。

我不太确定您要在这里实现什么，但这里是关于如何解决订购问题的想法。这只是一个参考代码，我没有测试过。只是关于如何保持线程以确保代码使用async / await按顺序运行的想法。

async function binanceTrailingSLOrder(symbol, orderId, quantity, oldPrice, percentage, active) {

    const clean_trade = client.ws.trades([symbol], async trade => { //run websocket
        var livePrice = parseFloat(binance_symbols[symbol]["close"]); //set new price to live price

        if (active == true) {

            try {

            const order = await binanceCheckOrderStatus(symbol, orderId);

            if (!order) {
                throw new Error('order not found')
            }
                switch (order.status) {
                    case "PENDING":
                        if (livePrice >= (oldPrice * ((100 + percentage) / 100)) && active == true) {
                            active = false;

                            const r4 = await binanceCancelOrder(symbol, orderId);
                            if (r4) {
                                var newSL = livePrice * ((100 - percentage) / 100);
                                var r5 = binanceStopOrder(symbol, 'SELL', r4.origQty, newSL, newSL);

                                if (r5) {
                                    orderId = r5.orderId; quantity = r5.origQty; oldPrice = r5.price;
                                    active = true;
                                }
                            }
                        }
                        break;
                    default:
                        break;
                }
            }

            catch(error) {
                console.log('error found: ', error);
            }

        }
    });

}



async function binanceCheckOrderStatus(symbol, orderId) {
    if(!orderId){
        console.log("order Id not found");
        return false;
    } else {
        var client = loadBinanceKeys2();

        return new Promise((resolve, reject) => {
            client.getOrder({
                symbol: symbol,
                orderId: orderId,
                recvWindow: 1000000
            }).then((order) => {
                resolve(order);
            }).catch((err) => {
                reject(err);
            });
        });
    }
}
于 2019-04-14T04:44:22.453 回答