| | |
| | | def OnMoney(self, client_id, request_id): |
| | | pass |
| | | |
| | | # 测试 |
| | | def OnTest(self, client_id, request_id, data): |
| | | pass |
| | | |
| | | |
| | | class L2ActionCallback(object): |
| | | # 监听L2数据 |
| | |
| | | cls.action_callback.OnDelegateList(client_id, request_id, can_cancel) |
| | | elif _type == CLIENT_TYPE_POSITION_LIST: |
| | | cls.action_callback.OnPositionList(client_id, request_id) |
| | | elif _type == "test": |
| | | cls.action_callback.OnTest(client_id, request_id, data) |
| | | except Exception as e: |
| | | logger_local_huaxin_trade_debug.debug(f"__process_command出错:{result_json}") |
| | | logging.exception(e) |
| | |
| | | t1 = threading.Thread(target=lambda: cls.__process_command(_type, None, val), daemon=True) |
| | | t1.start() |
| | | except Exception as e: |
| | | logger_local_huaxin_trade_debug.exception(e) |
| | | logging.exception(e) |
| | | |
| | | # 维护连接数的稳定 |