| | |
| | | request_id = data.get('request_id') |
| | | use_time = time.time() - data.get('time') |
| | | data = data.get('data') |
| | | cls.action_callback.OnTrade(None, request_id, None, 2, data) |
| | | async_log_util.info(logger_local_huaxin_trade_debug, f"下单通信耗时: {use_time}s") |
| | | cls.action_callback.OnTrade(None, request_id, None, 1, data) |
| | | async_log_util.info(logger_local_huaxin_trade_debug, f"下单通信耗时: {round(use_time*1000,3)}ms request_id:{request_id}") |
| | | except Exception as e: |
| | | logger_local_huaxin_trade_debug.exception(e) |
| | | finally: |
| | |
| | | use_time = time.time() - data.get('time') |
| | | data = data.get('data') |
| | | cls.action_callback.OnTrade(None, request_id, None, 2, data) |
| | | async_log_util.info(logger_local_huaxin_trade_debug, f"撤单通信耗时: {use_time}s") |
| | | async_log_util.info(logger_local_huaxin_trade_debug, f"撤单通信耗时: {round(use_time*1000,3)}ms request_id:{request_id}") |
| | | |
| | | except Exception as e: |
| | | logger_local_huaxin_trade_debug.exception(e) |
| | |
| | | |
| | | |
| | | def __test_order(): |
| | | for i in range(10): |
| | | time.sleep(60) |
| | | order_ref = huaxin_util.create_order_ref() |
| | | order(1, "000333", 100, 1.00, price_type=2, blocking=False, order_ref=order_ref, shadow_price=0.99) |
| | | time.sleep(60) |
| | | cancel_order(1, "000333", '', orderRef=order_ref, blocking=False) |
| | | cancel_order(1, "000333", '123123', orderRef=order_ref, blocking=False) |
| | | |
| | | |
| | | # 设置交易通信队列 |