futuquant_demo/TradeDemo.py at master · g1im2/futuquant_demo · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
# -*- coding:utf-8 -*-

import futuquant as ft


class TradeDemo(object):
    """
    author : smith
    date   : 2018-08-05
    desc   : trade demo with futu quant
    """

    # 初始化
    def __init__(self):
        self.trd_ctx = ft.OpenHKTradeContext(host='127.0.0.1', port=11111)

    # 关闭
    def close(self):
        self.trd_ctx.close()

    # --------------------------------- 交易操作 API ---------------------------------
    # 获取交易业务账户列表
    def print_acc_list(self):
        print(self.trd_ctx.get_acc_list())

    # 解锁交易
    def print_unlock_trade(self):
        var_unlock_trade = self.trd_ctx.unlock_trade(password="123456", password_md5=None, is_unlock=True)
        print(var_unlock_trade)

    # 获取账户资金数据
    def print_accinfo_query(self):
        var_acc_info = self.trd_ctx.accinfo_query(trd_env=ft.TrdEnv.SIMULATE, acc_id=0)
        print(var_acc_info)

    # 获取账户持仓列表
    def print_position_list_query(self):
        var_position_list = self.trd_ctx.position_list_query()
        print(var_position_list)

    # 下单
    def action_place_order(self):
        var_order = self.trd_ctx.place_order(
            price=100,                                  # 订单价格
            qty=99,                                     # 订单数量
            code='HK.00010',                            # 股票代码
            trd_side=ft.TrdSide.SELL,                   # 交易类型-sell or buy
            order_type=ft.OrderType.ABSOLUTE_LIMIT,     # 订单类型-真实账户 or 模拟账户
            adjust_limit=1,                             # 调整限制方向
            trd_env=ft.TrdEnv.SIMULATE,                 # 交易环境-真实环境 or 仿真环境
            acc_id=0                                    # 交易业务账户 ID
        )
        print(var_order)

    # 获取订单列表
    def print_order_list_query(self):
        var_order_list = self.trd_ctx.order_list_query(
            order_id='',                                # 订单号过滤
            status_filter_list='',                      # 订单状态过滤
            code='',                                    # 代码过滤
            start='2018-08-01',                         # 开始时间
            end='2018-08-05',                           # 结束时间
            trd_env=ft.TrdEnv.SIMULATE,                 # 交易环境
            acc_id=0                                    # 交易业务账户 ID
        )
        print(var_order_list)

    # 修改订单
    def action_modify_order(self):
        var_modify_order = self.trd_ctx.modify_order(
            modify_order_op=ft.ModifyOrderOp.DISABLE,   # 改单操作类型
            order_id='',                                # 订单号
            qty=100,                                    # 订单数量
            price=99,                                   # 新的订单价格
            adjust_limit=2,                             # 调整限定
            trd_env=ft.TrdEnv.SIMULATE,                 # 交易环境
            acc_id=0                                    # 交易业务账户 ID
        )
        print(var_modify_order)

    # 修改订单（老接口）
    def action_change_order(self):
        var_change_order = self.trd_ctx.change_order(
            modify_order_op=ft.ModifyOrderOp.DISABLE,  # 改单操作类型
            order_id='',  # 订单号
            qty=100,  # 订单数量
            price=99,  # 新的订单价格
            adjust_limit=2,  # 调整限定
            trd_env=ft.TrdEnv.SIMULATE,  # 交易环境
            acc_id=0  # 交易业务账户 ID
        )
        print(var_change_order)

    # 获取成交列表
    def print_deal_list_query(self):
        var_deal_list = self.trd_ctx.deal_list_query(
            code='200032',                              # 代码过滤
            trd_env=ft.TrdEnv.SIMULATE,                 # 交易环境
            acc_id=0                                    # 交易业务账户 ID
        )
        print(var_deal_list)

    # 获取历史订单列表
    def print_history_order_list_query(self):
        var_history_order_list = self.trd_ctx.history_order_list_query(
            status_filter_list=[],                      # 状态数组
            code='',                                    # 代码过滤
            start='2018-05-01',                         # 开始时间
            end='2018-05-31',                           # 结束时间
            trd_env=ft.TrdEnv.SIMULATE,                 # 交易环境
            acc_id=0                                    # 交易业务账户 ID
        )
        print(var_history_order_list)

    # 获取历史成交列表
    def print_history_deal_list_query(self):
        var_history_deal_list = self.trd_ctx.history_deal_list_query(
            code='',  # 代码过滤
            start='2018-05-01',  # 开始时间
            end='2018-05-31',  # 结束时间
            trd_env=ft.TrdEnv.SIMULATE,  # 交易环境
            acc_id=0  # 交易业务账户 ID
        )
        print(var_history_deal_list)

    # --------------------------------- 交易操作回调类 ---------------------------------
    # 响应成交推送基类
    class TTradeDealHandlerBase(ft.TradeDealHandlerBase):

        def on_recv_rsp(self, rsp_pb):
            ret_code, data = super(self).on_recv_rsp(rsp_pb)
            return ret_code, data

    # 响应订单推送基类
    class TTradeOrderhandlerBase(ft.TradeOrderHandlerBase):

        def on_recv_rsp(self, rsp_pb):
            ret_code, data = super(self).on_recv_rsp(rsp_pb)
            return ret_code, data


if __name__ == '__main__':
    trader = TradeDemo()
    trader.close()