首页  思维导图  详情

测试下单功能

2021-09-15 10:24:50   0  举报





仅支持查看

AI智能生成

测试

缺陷处理

作者其他创作

大纲/内容

操作指南

td路径

/root/axe/octopus/build/bin

启动命令

./trader

kungfu strategy

所在容器

axe23

策略py文件在宿主机上路径

/opt/data/strategy/test2/v1.1.1rc23_tdbybit/test.py

启动命令

docker exec -it axe23 /bin/bash
/opt/data/kungfu/kungfu/kungfu/core/build/kfc/kfc -H /opt/data/kungfu/test3 strategy -n risk_demo -p /opt/data/strategy/test.py

1.设置好配置
2启动td
3在容器axe23里启动strategy

更改配置

td下单器配置

配置服务地址:/root/axe/gocode/test3.go

修改td下单器配置:

举例 :curl "http://127.0.0.1:10943/api/v1/change-exch-product?exch=7&&product=5&&api_key=f23682a356e0ffdf814c8e75599bdf291d1fae8d78f17537b640f7ae5b4195b7&&secret_key=02c20530bd9f700b825e5e4f22967f8febaa004aedf38a46ee73193c358c95c4"

可以修改exch(交易所)、product(产品类型)、api_key、secret_key

exch的枚举

enum Exch
{
    ExchUnknown = 0;
    ExchBitmex =  1;
    ExchOkex = 2;
    ExchBybit = 3;
    ExchBitstamp = 4;
    ExchCoinbasePro = 5;
    ExchKraken = 6;
    ExchBinance = 7;
    ExchHuobiGlobal = 8;
    ExchPhemex = 9;
    ExchBybitCross = 10;
    ExchFtx = 11;
    ExchDeribit = 12;
    ExchKucoin = 13;
    ExchGateio = 14;
    ExchHotbit = 15;
    ExchMxc = 16;
}

product的枚举

enum product
{ProductUnknown = 0,
ProductSpot = 1,
ProductUSDTFuture = 2,
ProductCoinFuture = 3,
ProductUSDTSwap = 4,
ProductCoinSwap = 5，
ProductOption = 6}

目前支持的exch和product

binance(exch:7)

ProductUSDTSwap（4）

ProductCoinSwap(5)

ProductUSDTFuture（2）

ProductCoinFuture(3)

ProductSpot(1)

ftx(exch:11)

ProductCoinSwap（5）

ProductCoinFuture(3)

查询td下单器的配置

curl "http://127.0.0.1:10943/api/v1/open/stg-external"

策略配置

sid(内部交易symbol的id)

[
          {
            "sid": 10000,
            "exch": 7,
            "product": 4,
            "symbol": "BTCUSDT",
            "name": "binance_swap_BTCUSDT"
          },
          {
            "sid": 10001,
            "exch": 7,
            "product": 5,
            "symbol": "BTCUSD_PERP",
            "name": "binance_swap_BTCUSD_PERP"
          },
          {
            "sid": 10002,
            "exch": 7,
            "product": 2,
            "symbol": "BTCUSDT_210924",
            "name": "binance_future_BTCUSDT_210924"
          },
          {
            "sid": 10003,
            "exch": 7,
            "product": 3,
            "symbol": "BTCUSD_210924",
            "name": "binance_future_BTCUSD_210924"
          },
          {
            "sid": 10004,
            "exch": 7,
            "product": 1,
            "symbol": "BTCUSDT",
            "name": "binance_spot_BTCUSDT"
          },
          {
            "sid": 10010,
            "exch": 11,
            "product": 5,
            "symbol": "DOGE-PREP",
            "name": "ftx_coinswap_DOGE_PREP"
          },
    {
            "sid": 10010,
            "exch": 11,
            "product": 3,
            "symbol": "DOGE-0924",
            "name": "ftx_coinfuture_DOGE_0924"
          }
        ]

td下单器的配置需要和策略里的sid配置相匹配

下单

下单函数

context.ReqInsertOrder(acct,context.InsertOrder)

下单结构体

InsertOrder

struct InsertOrder
    {
        uint32_t logicAccountId_;//内部交易账号
        uint32_t sid_;//内部symbolId
uint64_t clientOrderId_;//自定义委托单号 //algo_Id+connecttime+increaseid(algo_id+连接时间+自增ID)
        double price_;//价格
        double qty_;//数量
        Side side_;//买卖方向
        OrderType orderType_;//报单类型
        Offset offset_;//开平方向
        TimeInForce timeInForce_;//报单有效时间类型
    }__attribute__((packed));

相关枚举

//报单状态
    enum class OrderStatus : int8_t
    {
        //未知0
        Unknown,
        //等待报入1
        PendingNew,
        //等待撤单2
        PendingCancel,
        //已报入3
        New,
        //部分成交4
        PartiallyFilled,
        //全部成交5
        Filled,
        //已撤单6
        Cancelled,
        //已拒单7
        Rejected,
        //Trade Server内部拒单8
        InternalRejected,
        Error
    };

报单变化和成交的推送函数on_order

报单(包含成交)的结构体Order

struct Order
    {
        uint32_t logicAccountId_;//内部交易账号
        uint32_t sid_;//内部symbol_id
        Side side_;//买卖方向
        OrderStatus orderStatus_;//报单状态
        OrderType orderType_;//报单类型
        Offset offset_;//开平方向
        TimeInForce timeInForce_;//报单有效时间类型
        PositionSide positionSide_;//持仓方向
        MarginMode marginMode_;//保证金模式
        double orderPrice_;//价格
        double originQty_;//委托量
        double execPrice_;//最近成交价
        double execQty_;//最近成交量
        double fee_;//手续费
        double cumExecQty_;//累计成交量
        double avgExecPrice_;//平均成交价
        char orderId_[36];//交易所委托单号
        char tradeId_[36];//成交号
uint64_t clientOrderId_;//自定义委托单号
        int64_t insertTsE9_;//下单时间的纳秒时间戳
        int64_t updateTsE9_;//报单最近更新时间的纳秒时间戳
        int64_t  execTsE9_;//最近一次成交时间的纳秒时间戳
    }__attribute__((packed));

下单场景

下单成功

回调rsp_insert_order

insert_order.errCode_为0

回调on_order

order.status_为New

下单失败

回调rsp_insert_order

insert_order.errCode不为0

成交

回调on_order

order.trade_id不为0

撤单

撤单函数

context.cancel_order(acct,context.CancelOrder)

撤单结构体

CancelOrder

//撤单
    struct CancelOrder
    {
        uint32_t logicAccountId_;//内部交易账号
        uint32_t sid_;//内部symbolId
        char     orderId_[36];//交易所报单号
uint64_t clientOrderId_;//algo自定义的报单号
    }__attribute__((packed));

撤单举例

context.CancelOrder.sid_ = 10000

context.CancelOrder.logicAccountId_ = 1

context.CancelOrder.clientOrderId_ =1

context.CancelOrder.orderId_ = "1"

context.cancel_order(acct,context.CancelOrder)

回调函数

撤单响应函数rsp_cancel_order

撤单响应结构体RspCancelOrder

struct RspCancelOrder
    {
        uint32_t sid_;//内部symbol的ID
        char        orderId_[36];//交易所报单号
uint64_t clientOrderId_;//自定义委托单号
        uint64_t errCode_;//error
    }__attribute__((packed));

撤单场景

撤单成功

回调rsp_cancel_order

errCode_为0

回调on_order

status为canceled

撤单失败

回调rsp_cancel_order

errCode不为0