81 lines
1.7 KiB
Python
81 lines
1.7 KiB
Python
import os
|
|
import sys
|
|
|
|
print(sys.path)
|
|
print(os.environ)
|
|
|
|
import vnctp # noqa
|
|
from vnctp import (
|
|
CThostFtdcTraderApi,
|
|
CThostFtdcTraderSpi,
|
|
CThostFtdcRspAuthenticateField,
|
|
CThostFtdcRspInfoField,
|
|
CThostFtdcRspUserLoginField,
|
|
CThostFtdcUserLogoutField,
|
|
) # noqa
|
|
|
|
print(vnctp)
|
|
print(dir(vnctp))
|
|
|
|
for i in dir(vnctp):
|
|
print(f"{i} : {vnctp.__dict__[i]}")
|
|
|
|
print("creating ctp api")
|
|
api = CThostFtdcTraderApi.CreateFtdcTraderApi("flow2")
|
|
|
|
print("creating ctp spi")
|
|
|
|
|
|
class Spi(CThostFtdcTraderSpi):
|
|
def OnFrontConnected(self) -> None:
|
|
print("OnFrontConnected!")
|
|
|
|
def OnFrontDisconnected(self, nReason: int) -> None:
|
|
print("OnFrontDisconnected!")
|
|
|
|
def OnRspAuthenticate(
|
|
self,
|
|
pRspAuthenticateField: CThostFtdcRspAuthenticateField,
|
|
pRspInfo: CThostFtdcRspInfoField,
|
|
nRequestID: int,
|
|
bIsLast: bool,
|
|
) -> None:
|
|
print("OnRspAuthenticate!")
|
|
|
|
def OnRspUserLogin(
|
|
self,
|
|
pRspUserLogin: CThostFtdcRspUserLoginField,
|
|
pRspInfo: CThostFtdcRspInfoField,
|
|
nRequestID: int,
|
|
bIsLast: bool,
|
|
) -> None:
|
|
print("OnRspUserLogin!")
|
|
|
|
def OnRspUserLogout(
|
|
self,
|
|
pUserLogout: CThostFtdcUserLogoutField,
|
|
pRspInfo: CThostFtdcRspInfoField,
|
|
nRequestID: int,
|
|
bIsLast: bool,
|
|
) -> None:
|
|
print("OnRspUserLogout!")
|
|
|
|
def OnRspError(
|
|
self, pRspInfo: CThostFtdcRspInfoField, nRequestID: int, bIsLast: bool
|
|
) -> None:
|
|
print("OnRspError!")
|
|
|
|
|
|
spi = Spi()
|
|
|
|
print("registering spi")
|
|
api.RegisterSpi(spi)
|
|
print("registering front")
|
|
api.RegisterFront("tcp://180.168.146.187:10030")
|
|
print("Init() ...")
|
|
api.Init()
|
|
|
|
print("Join() ...")
|
|
while True:
|
|
pass
|