FutuQuant-Nodejs

FutuQuant量化接口Nodejs版本

说明

基于 FutuQuant v3.2 底层协议封装的 nodejs 版本接口，数据格式使用 protobuf，使用前请先在本地或者服务端启动 FutuOpenD 服务。

  • 使用了async/await语法，要求nodejs版本v7.10.1以上，v7.5.1以上可以使用--harmony或者--harmony-async-await参数开启async/await的支持，v7.6.x 以可以不用开启 flag 直接使用。。
  • 底层协议基于FutuQuant v3.2，参考：FutunnOpen/futuquant。
  • 数据传输格式目前只支持 protobuf。
  • API文档相关：https://yisbug.github.io/nodejs-for-FutuOpenD/doc/index.html

为了方便使用，请注意部分接口参数及返回结果和富途官方版本不完全一致，详细请参考API文档。

安装

npm install futuquant --save

或者

yarn add futuquant

使用

/**
-  **所有行情相关协议获取数据都需要先通过（1005）协议订阅成功后才能查询**
-  **订阅的上限为500个订阅单位。一只股票的一个K线类型占2个订阅单位、分时占2个订阅单位、
-  报价占1个订阅单位、摆盘占5个订阅单位（牛熊为1）、逐笔占5个订阅单位（牛熊为1）、经纪队列占5个订阅单位（牛熊为1）。**
-  **反订阅（1006）的时间限制为１分钟，即订阅某支股票某个订阅位１分钟之后才能反订阅**
-  **30秒内不能超过20次交易请求。**
-  **建议所有行情拉取接口在同一条长连接上。推送数据在第二条长连接上。交易接口在第三条长连接上。**
 */
const fs = require('fs');
const path = require('path');
const FtQuant = require('./src/futuquant');

// 自定义日志对象
const bunyan = require('bunyan');
const bunyanDebugStream = require('bunyan-debug-stream');

const bunyanLogger = bunyan.createLogger({
  name: 'sys',
  streams: [{
    level: 'debug',
    type: 'raw',
    serializers: bunyanDebugStream.serializers,
    stream: bunyanDebugStream({ forceColor: true }),
  }],
});

// 从 opend 的配置文件中获取 userID，pwd
const FutuOpenDXMLPath = path.join(__dirname, '../FutuOpenD_1.01_Mac/FutuOpenD.xml');
const ftOpenDConfig = fs.readFileSync(FutuOpenDXMLPath);
const userID = ftOpenDConfig.match(/login_account>(\d*?)<\/login_account/)[1];
const pwdMd5 = ftOpenDConfig.match(/trade_pwd_md5>(.*?)<\/trade_pwd_md5/)[1];

// openD 配置
const ftConfig = {
  ip: '127.0.0.1',
  port: 11111,
  userID,
  market: 1, // 港股环境
  pwdMd5,
  env: 1, // 0为仿真，1为真实，默认为1。
};

const ft = new FtQuant(ftConfig, bunyanLogger);

const init = async () => {
  await ft.init(); // 初始化 ft 模块，包括调用initConnect、解锁交易接口、设置 TradeHeader

  let res = null;
  res = await ft.getGlobalState(); // 获取全局状态
  console.log('getGlobalState', res);

  // 获取历史成交记录，不再需要手动解锁交易密码以及调用setCommonTradeHeader
  await ft.trdGetHistoryOrderFillList({
    beginTime: '2018-01-01 00:00:00',
    endTime: '2018-02-01 00:00:00',
  });
};

init();

测试

请先修改test/futuquant.test.js中FutuOpenDXMLPath的路径，然后执行npm install或yarn安装相关依赖。

运行测试：

npm test

广告

如有需要，请填写推荐人牛牛号：5894668，谢谢！

更新

最新更新

最新更新 log 不再同步到 readme.md ，详情请点击查看更新日志

3.2.0 - 2018-8-15

  • opt: 修改版本号和官方 futuquant 的大版本号一致，即前两位3.2和官方保持一致，小版本号的更新用于bugfix 和其他的接口调整。
  • opt: 彻底去除 es6 modules，不再需要 babel 编译。
  • feat: 同步更新到官方最新版本 v3.2 。
  • feat: 增加 qotGetReference 获取正股相关股票接口
  • feat: 增加 trdGetMaxTrdQtys 获取最大交易数量接口
  • fix: 获取 k 线相关接口返回的数组增加兼容性支持。
  • feat: qotGetHistoryKLPoints 接口返回参数调整为直接返回数组
  • feat: qotGetTicker 接口返回参数调整为直接返回数组
  • feat: qotGetRT 接口返回参数调整为直接返回数组

0.2.0 - 2018.07.27

  • fix: 优化自定义logger部分
  • feat: 修改qotGetBasicQot方法直接返回数组
  • feat: 修改qotGetOrderBook方法直接返回对象，并增加sellList和buyList两个字段，等同于orderBookAskList和orderBookBidList
  • feat: 修改subQotUpdateOrderBook事件传递的摆盘结果，增加sellList和buyList两个字段，等同于orderBookAskList和orderBookBidList
  • feat: 修改qotGetBroker方法返回结果，增加sellList和buyList两个字段，等同于brokerAskList和brokerBidList
  • feat: 修改subQotUpdateBroker方法事件传递的经纪队列，增加sellList和buyList两个字段，等同于brokerAskList和brokerBidList
  • feat: 修改qotGetStaticInfo返回结果，直接返回数组
  • feat: 修改qotGetSecuritySnapShot返回结果，直接返回数组，并支持超过200支以上股票的查询。
  • feat: 新增按市价下单接口：trdPlaceOrderMarket(param)，直到交易完成成功为止，返回买入/卖出总价
  • feat: 新增取消注册订单更新接口：unsubTrdUpdateOrder()
  • docs: 其他调整

更多请点击查看更新日志