测试影子订单

Administrator

2023-10-13 fddfc0e7c3b2938f70637e54d214faab478f7ca4

 l2/huaxin/huaxin_delegate_postion_manager.py

@@ -13,17 +13,17 @@


# 下单
def place_order(code, price, volume, data):
def place_order(code, price, volume, data, order_ref):
    async_log_util.info(logger_real_place_order_position,
                        f"下单：code-{code} price-{price} volume-{volume} exec-index-{data['index']}")
    _place_order_info_dict[code] = (price, volume, data, time.time())
                        f"下单：code-{code} price-{price} volume-{volume} exec-index-{data['index']} order_ref-{order_ref}")
    _place_order_info_dict[code] = (price, volume, data, time.time(), order_ref)


# 获取下单信息
def get_order_info(code):
    info = _place_order_info_dict.get(code)
    if info and time.time() - info[3] > 3:
        async_log_util.info(logger_real_place_order_position, "get_order_info 间隔3s以上：code-{}", code)
    if info and time.time() - info[3] > 1:
        async_log_util.info(logger_real_place_order_position, "get_order_info 间隔1s以上：code-{}", code)
        # 间隔3s以上就无效了
        info = None
        _place_order_info_dict.pop(code)
@@ -39,10 +39,11 @@
    price = order_info[0]
    volume = order_info[1]
    exec_data = order_info[2]
    order_ref = order_info[4]
    # 获取量
    is_sz = code.startswith("00")
    # 提交到交易所的时间预估
    min_space_time_ms = 10 if is_sz else 50
    min_space_time_ms = -1 if is_sz else 50
    for d in datas:
        if d["val"]["num"] != volume // 100:
            continue
@@ -59,6 +60,9 @@
        # 时间差不能小于预估下单用时
        if L2DataUtil.time_sub_as_ms(d['val'], exec_data['val']) <= min_space_time_ms:
            continue
        # 真实下单位置与挂单位置不能相差1s
        if L2DataUtil.time_sub_as_ms(d["val"], exec_data['val']) >= 1000:
            continue
        # 获取到了下单位置
        async_log_util.info(hx_logger_trade_debug, f"真实下单位置：{code}-{d['index']}")
        async_log_util.info(logger_real_place_order_position, f"真实下单位置：{code}-{d['index']}")