| | |
|---|
| | | result = self.__api.SubscribeMarketData(sz, lev2mdapi.TORA_TSTP_EXD_SZSE) |
|---|
| | | logger_local_huaxin_l2_subscript.info(f"市场订阅结果sz：{result}") |
|---|
| | | |
|---|
| | | def __process_codes_data(self, codes_data, from_cache=False, delay=0): |
|---|
| | | def __process_codes_data(self, codes_data, from_cache=False, delay=0.0): |
|---|
| | | |
|---|
| | | if not self.is_login and not constant.TEST: |
|---|
| | | raise Exception("L2尚未登录") |
|---|
| | |
|---|
| | | print("----L2行情登录成功----") |
|---|
| | | self.is_login = True |
|---|
| | | # 初始设置值 |
|---|
| | | t1 = threading.Thread( |
|---|
| | | target=lambda: self.__process_codes_data(self.__get_latest_datas(), from_cache=True, delay=6), |
|---|
| | | daemon=True) |
|---|
| | | # 后台运行 |
|---|
| | | t1.start() |
|---|
| | | threading.Thread( |
|---|
| | | target=lambda: self.__process_codes_data(self.__get_latest_datas(), from_cache=True, delay=6.0), |
|---|
| | | daemon=True).start() |
|---|
| | | |
|---|
| | | def OnRspSubMarketData(self, pSpecificSecurity, pRspInfo, nRequestID, bIsLast): |
|---|
| | | print("OnRspSubMarketData") |
|---|
