forked from QuantFans/quantdigger
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathapi.py
More file actions
166 lines (125 loc) · 3.41 KB
/
api.py
File metadata and controls
166 lines (125 loc) · 3.41 KB
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
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
# -*- coding: utf-8 -*-
from quantdigger.event import OrderEvent
from abc import ABCMeta, abstractmethod
class Trader(object):
__metaclass__ = ABCMeta
""" 交易类,包含了回调注册等高级封装。 """
def __init__(self, arg):
pass
@abstractmethod
def connect(self):
""" 连接器 """
pass
@abstractmethod
def query_contract(self, contract, sync=False):
""" 合约查询 """
pass
@abstractmethod
def query_tick(self, contract, sync=False):
""" 深度行情数据 """
pass
@abstractmethod
def query_captital(self, sync=False):
""" 查询资金账户 """
pass
@abstractmethod
def query_position(self, sync=False):
""" 查询投资者持仓"""
pass
@abstractmethod
def order(self, order, sync=False):
""" 下单请求
:param Order order: 委托订单。
"""
pass
@abstractmethod
def cancel_order(self, orderid, sync=False):
""" 撤单操作请求 """
pass
def on_transaction(self, trans):
""" 委托成交回调 """
pass
def on_tick(self, tick):
""" tick数据回调 """
pass
def on_capital(self, tick):
""" 资金查询回调 """
pass
def on_position(self, tick):
""" 持仓查询回调 """
pass
class CtpTraderAPI(object):
""" Ctp交易类 """
def __init__(self):
pass
def connect(self):
""" 连接"""
pass
def query_contract(self, contract):
""" 合约查询 """
pass
def query_tick(self, contract):
""" 深度行情数据 """
pass
def query_captital(self):
""" 查询资金账户 """
pass
def query_position(self):
""" 查询投资者持仓"""
pass
def order(self, order):
""" 下单请求 """
pass
def cancel_order(self, orderid):
""" 撤单操作请求 """
pass
def on_transaction(self, trans):
""" 委托成交回调 """
pass
def on_tick(self, tick):
""" tick数据回调 """
pass
def on_capital(self, tick):
""" 资金查询回调 """
pass
def on_position(self, tick):
""" 持仓查询回调 """
pass
class SimulateTraderAPI(Trader):
""" 模拟交易下单接口 """
def __init__(self, blotter, events_pool):
self._blotter = blotter
self._events = events_pool
def connect(self):
""" 连接"""
pass
def query_contract(self, contract):
""" 合约查询 """
pass
def query_tick(self, contract):
""" 深度行情数据 """
pass
def query_captital(self):
""" 查询资金账户 """
pass
def query_position(self):
""" 查询投资者持仓"""
pass
def order(self, order):
""" 模拟下单 """
self._events.put(OrderEvent(order))
def cancel_order(self, orderid):
""" 撤单操作请求 """
pass
def on_transaction(self, trans):
""" 模拟委托成交回调 """
self._blotter.update_fill(trans)
def on_tick(self, tick):
""" tick数据回调 """
pass
def on_capital(self, tick):
""" 资金查询回调 """
pass
def on_position(self, tick):
""" 持仓查询回调 """
pass