Flutter 区块链集成插件 dashchain 的使用

dashchain pub 包

dashchain 是一个 Dart 库，用于与某些加密货币交易所（目前仅支持 Binance）进行交互。

通过使用该库，您可以获取最新的加密市场报价、检查订单簿、编写回测并管理您的资产！

示例代码

import 'package:dashchain/dashchain.dart';

// 忽略以下代码中的打印语句
void main() async {
  // 使用 API 密钥初始化 BinanceRestApi 对象
  const apiKey = 'apiKey'; // 请在此处编辑
  const apiSecretKey = 'apiSecretKey'; // 请在此处编辑
  final binance = BinanceRestApi.withKeys(
    apiKey: apiKey,
    apiSecretKey: apiSecretKey,
  );

  try {
    // 尝试获取可用服务器
    final apiOK = await binance.ping();
    if (apiOK) {
      print('Binance REST API 已启动并运行在 $defaultUri，让我们开始吧！');
      await _testAPI(binance, defaultUri);
    } else {
      print('Binance REST API 主集群似乎已关闭，将尝试获取备用集群...');
      String? endpointUri;
      try {
        endpointUri = await binance.getFallbackUri();
      } catch (e) {
        print('Binance REST API 确定已关闭...($e)');
      }
      if (endpointUri != null) {
        print('Binance REST API 已启动并运行在 $endpointUri，让我们开始吧！');
        await _testAPI(binance, endpointUri);
      }
    }
  } catch (e) {
    print('执行脚本期间出现错误...($e)');
  }
  binance.dispose();
}

Future<void> _testAPI(BinanceRestApi api, String endpointUri) async {
  // 检查服务器时间并打印客户端时间差异
  await _checkApiTime(api, endpointUri);
  // 获取整个交易所信息，并查找处于交易阶段的符号
  final tradeableSymbols = await _getTradeableSymbols(api, endpointUri);
  // 尝试获取一些交易对
  const someCoinIHave = 'BUSD'; // 请在此处编辑
  const theCoinIWant = 'BNB'; // 请在此处编辑
  final maybeTargetPair = _maybeGetPair(someCoinIHave, theCoinIWant, tradeableSymbols);
  if (maybeTargetPair != null) {
    // 如果找到，则发送一个最小数量的报价资产的限价买入订单
    const targetPrice = 100.0; // 请在此处编辑
    await _sendLimitBuyOrder(api, endpointUri, maybeTargetPair, targetPrice);
  }
}

Future<void> _checkApiTime(BinanceRestApi api, String endpointUri) async {
  final time = await api.checkApiTime(baseUri: endpointUri);
  final readableTime = DateTime.fromMillisecondsSinceEpoch(time);
  final difference = DateTime.now().difference(readableTime);
  print('Binance 服务器时间是 $time ($readableTime, 差异: ${difference.inMilliseconds}ms)');
}

Future<Iterable<BinanceSymbol>> _getTradeableSymbols(BinanceRestApi api, String endpointUri) async {
  print('将检查可用于交易的符号...');
  final info = await api.exchangeInfo(baseUri: endpointUri);
  final tradeableSymbols = info.symbols.where((s) => s.status == BinanceTradingStatus.trading.value);
  print('发现 ${info.symbols.length} 个列出的符号，其中 ${tradeableSymbols.length} 个可用于交易！');
  return tradeableSymbols;
}

BinanceSymbol? _maybeGetPair(String someCoinIHave, String theCoinIWant, Iterable<BinanceSymbol> tradeableSymbols) {
  List<BinanceSymbol> symbolsICouldTrade = List<BinanceSymbol>.from(tradeableSymbols.where((s) => s.quoteAsset == someCoinIHave));
  if (symbolsICouldTrade.isNotEmpty) {
    print('发现 ${symbolsICouldTrade.length} 个带有 $someCoinIHave 作为报价资产的符号！');
    if (symbolsICouldTrade.any((s) => s.baseAsset == theCoinIWant)) {
      print('发现一些带有 $theCoinIWant 作为基础资产的符号！');
      return symbolsICouldTrade.firstWhere((s) => s.baseAsset == theCoinIWant);
    } else {
      print('未找到带有 $theCoinIWant 作为基础资产的符号...');
    }
  } else {
    print('未找到带有 $theCoinIWant 作为报价资产的符号...');
  }
}

Future<void> _sendLimitBuyOrder(BinanceRestApi api, String endpointUri, BinanceSymbol targetPair, double targetPrice) async {
  // 10.0 通常是报价资产的最小数量
  const minimumQuoteQty = 10.0;
  // 获取最小数量，保留三位小数
  var minimumQty = (minimumQuoteQty / targetPrice).toPrecision(3);
  // 检查是否确实超过了最小数量，并根据需要调整
  if (minimumQty * targetPrice < minimumQuoteQty) {
    print('调整数量，因为 $minimumQty 不足以被接受');
    do {
      minimumQty += 0.001;
    } while (minimumQty * targetPrice < minimumQuoteQty);
    print('数量现在为 $minimumQty');
  }
  // 获取当前价格（这里仅用于日志记录，但您可以想象用 BinancePriceTicker 对象做些其他事情）
  final currentPrice = double.parse((await api.priceTicker(
    baseUri: endpointUri,
    symbol: targetPair.symbol,
  )).first.price);
  print('正在发送买入订单 ${targetPair.symbol} : '
      '$minimumQty BNB 以 $targetPrice ${targetPair.quoteAsset}（~$minimumQuoteQty BUSD）...当前价格: $currentPrice ${targetPair.quoteAsset}');
  // 发送限价买入订单，检查状态并取消
  await api.sendOrder(
    baseUri: endpointUri,
    symbol: targetPair.symbol,
    quantity: minimumQty,
    price: targetPrice,
  ).then((orderResponse) async {
    print('检查订单状态...');
    final orderStatus = await api.getOrderStatus(
      symbol: orderResponse.symbol,
      orderId: orderResponse.orderId,
    );
    if (orderStatus.status == 'NEW' && orderStatus.isWorking!) {
      print('订单确实是待处理的！');
      print('取消订单...');
      final cancelOrder = await api.cancelOrder(
        symbol: orderStatus.symbol,
        orderId: orderStatus.orderId,
      );
      if (cancelOrder.status == 'CANCELED') {
        print('订单成功取消！');
      } else {
        print('Oops..! 订单无法正确取消...');
      }
    } else {
      print('意外的订单状态 :o\n$orderStatus');
    }
  });
}