def __init__(self, k_queue):
super().__init__()
self.S_SCREEN_NO = "0001"
self.MARKET_LIST = {
0: '??',
3: 'ELW',
4: '?????',
5: '?????',
6: '??',
8: 'ETF',
9: '??????',
10: '???',
30: '?3??'
}
self.q = k_queue
self.qs = {
'OnReceiveTrData': queue.Queue(),
'OnReceiveRealData': queue.Queue(),
'OnReceiveMsg': queue.Queue(),
'OnReceiveChejanData': queue.Queue(),
'OnEventConnect': queue.Queue(),
'OnReceiveRealCondition': queue.Queue(),
'OnReceiveTrCondition': queue.Queue(),
'OnReceiveConditionVer': queue.Queue()
}
self.ocx = QAxWidget("KHOPENAPI.KHOpenAPICtrl.1")
self.ocx.OnReceiveTrData[str, str, str, str, str, int, str, str, str].connect(self.OnReceiveTrData)
self.ocx.OnReceiveRealData[str, str, str].connect(self.OnReceiveRealData)
self.ocx.OnReceiveMsg[str, str, str, str].connect(self.OnReceiveMsg)
self.ocx.OnReceiveChejanData[str, int, str].connect(self.OnReceiveChejanData)
self.ocx.OnEventConnect[int].connect(self.OnEventConnect)
self.ocx.OnReceiveRealCondition[str, str, str, str].connect(self.OnReceiveRealCondition)
self.ocx.OnReceiveTrCondition[str, str, str, int, int].connect(self.OnReceiveTrCondition)
self.ocx.OnReceiveConditionVer[int, str].connect(self.OnReceiveConditionVer)
atexit.register(self.quit)
####################################################
# Interface Methods
####################################################
评论列表
文章目录