| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950 |
- const BinanceSpot = require('./BinanceSpot.js')
- const Config = require('./Config.js')
- const ListenConfig = require('./ListenConfig.js')
- const PrivateConfig = require('./PrivateConfig.js')
- const MyKit = require('./kit/MyKit.js')
- const bs = new BinanceSpot(PrivateConfig.binanceAPIKey, PrivateConfig.binanceSecretKey)
- function findBalanceBySymbol (accountInfo, symbol='BUSD') {
- for (const asset of accountInfo.balances) {
- if (asset.asset === symbol) {
- return parseFloat(asset.free)
- }
- }
- return 0
- }
- async function onTick () {
- const accountInfo = await bs.accountInfo()
- if (accountInfo && accountInfo.balances) {
- for (const token of ListenConfig.tokenList) {
- const amount = MyKit._N(findBalanceBySymbol(accountInfo, token.symbol), token.binanceDecimals)
- const pair = token.symbol + Config.baseToken.symbol
- if (amount >= Math.pow(10, -token.binanceDecimals)) {
- const orderRst = await bs.sell(pair, -1, amount)
- const time = MyKit.getTimeByMillisecond(new Date().getTime())
- console.log(`[${time} 二级交易所产生新的卖出]币种:${token.symbol}, 数量:${amount}, 卖出(${Config.baseToken.symbol}):${orderRst.cummulativeQuoteQty}.`)
- console.log(`下单回执:${JSON.stringify(orderRst)}\n\n\n`)
- }
- }
- }
- }
- async function main () {
- while (true) {
- try {
- await onTick()
- } catch (e) {
- console.log(e)
- }
- await MyKit.sleep(5000)
- }
- }
- main()
|