| | |
|---|
| | | def set_code_special_watch_volume(self, code, volume): |
|---|
| | | # 有效期为2s |
|---|
| | | self.special_code_volume_for_order_dict[code] = (volume, time.time() + 2) |
|---|
| | | async_log_util.info(logger_local_huaxin_l2_subscript,f"设置下单量监听：{code}-{volume}") |
|---|
| | | |
|---|
| | | |
|---|
| | | async_log_util.info(logger_local_huaxin_l2_subscript, f"设置下单量监听：{code}-{volume}") |
|---|
| | | |
|---|
| | | def OnFrontConnected(self): |
|---|
| | | print("OnFrontConnected") |
|---|
| | | |
|---|
| | | logger_system.info(f"l2_client OnFrontConnected 线程ID:{tool.get_thread_id()}") |
|---|
| | | logout_req = lev2mdapi.CTORATstpUserLogoutField() |
|---|
| | | self.__api.ReqUserLogout(logout_req, 1) |
|---|
| | | time.sleep(1) |
|---|
| | |
|---|
| | | pipe_strategy = None |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(pipe_trade, _pipe_strategy, _l2_data_callback: l2_data_transform_protocol.L2DataCallBack)->None: |
|---|
| | | def run(pipe_trade, _pipe_strategy, _l2_data_callback: l2_data_transform_protocol.L2DataCallBack) -> None: |
|---|
| | | logger_system.info("L2进程ID：{}", os.getpid()) |
|---|
| | | logger_system.info(f"l2_client 线程ID:{tool.get_thread_id()}") |
|---|
| | | try: |
|---|
