| | |
| | | """ |
| | | import time |
| | | |
| | | from log_module.log import hx_logger_trade_debug |
| | | from log_module.log import hx_logger_trade_debug, logger_real_place_order_position |
| | | |
| | | _place_order_info_dict = {} |
| | | |
| | | |
| | | # 下单 |
| | | def place_order(code, price, volume, exec_index): |
| | | logger_real_place_order_position.info("下单:code-{} price-{} volume-{} exec-index-{}", code, price, volume, |
| | | exec_index) |
| | | _place_order_info_dict[code] = (price, volume, exec_index, time.time()) |
| | | |
| | | |
| | | # 获取下单信息 |
| | | def get_order_info(code): |
| | | info = _place_order_info_dict.get(code) |
| | | logger_real_place_order_position.info("get_order_info:data-{}", info) |
| | | if info and time.time() - info[3] > 3: |
| | | logger_real_place_order_position.info("get_order_info 间隔3s以上:code-{}", code) |
| | | # 间隔3s以上就无效了 |
| | | info = None |
| | | _place_order_info_dict.pop(code) |
| | |
| | | continue |
| | | # 获取到了下单位置 |
| | | hx_logger_trade_debug.info(f"真实下单位置:{code}-{d['index']}") |
| | | logger_real_place_order_position.info(f"真实下单位置:{code}-{d['index']}") |
| | | return d["index"] |
| | | return None |