| | |
| | | L2_SOURCE_TYPE = L2_SOURCE_TYPE_HUAXIN |
| | | JUEJIN_LOCAL_API = False |
| | | TRADE_WAY = TRADE_WAY_HUAXIN |
| | | TRADE_ENABLE = False |
| | | TRADE_ENABLE = True |
| | |
| | | |
| | | @classmethod |
| | | def __set_real_order_index(cls, code, index): |
| | | cls.__getRedis().setex(f"d_cancel_real_order_index-{code}", index) |
| | | cls.__getRedis().setex(f"d_cancel_real_order_index-{code}", tool.get_expire(), f"{index}") |
| | | |
| | | @classmethod |
| | | def __get_real_order_index(cls, code): |
| | |
| | | # 获取下单位置 |
| | | place_order_index = huaxin_delegate_postion_manager.get_l2_place_order_position(code, datas) |
| | | if place_order_index: |
| | | logger_l2_process.info("code:{} 获取到下单真实位置:{}",code,place_order_index) |
| | | DCancelBigNumComputer.set_real_order_index(code, place_order_index) |
| | | |
| | | __start_time = round(t.time() * 1000) |
| | |
| | | cls.volume_rate_info[code] = (volume_rate, volume_rate_index) |
| | | |
| | | latest_time = add_datas[len(add_datas) - 1]["val"]["time"] |
| | | |
| | | __start_time = l2_data_log.l2_time(code, round(t.time() * 1000) - __start_time, |
| | | "l2数据准备时间") |
| | | # 时间差不能太大才能处理 |
| | | if not l2_trade_util.is_in_forbidden_trade_codes(code): |
| | | # 判断是否已经挂单 |