| | |
|---|
| | | pre_real_order_index) |
|---|
| | | if real_order_index: |
|---|
| | | try: |
|---|
| | | exec_data = order_info[2] |
|---|
| | | exec_index = order_info[6] |
|---|
| | | order_begin_pos = cls.__get_order_begin_pos( |
|---|
| | | code) |
|---|
| | | async_log_util.info(logger_debug, |
|---|
| | | f"下单位矫正：真实下单位-{real_order_index} 订单信息-{order_info} 下单信息-{order_begin_pos}") |
|---|
| | | if order_begin_pos and order_begin_pos.buy_exec_index == exec_data["index"]: |
|---|
| | | f"下单位矫正：真实下单位-{real_order_index} 订单信息-{order_info} 下单信息-{order_begin_pos.to_dict()}") |
|---|
| | | if order_begin_pos and order_begin_pos.buy_exec_index == exec_index: |
|---|
| | | cls.set_real_place_order_index(code, real_order_index, order_begin_pos) |
|---|
| | | async_log_util.info(logger_real_place_order_position, |
|---|
| | | f"真实下单位矫正：{code}-{real_order_index} 下单数据：{order_info}") |
|---|
| | |
|---|
| | | try: |
|---|
| | | l2_log.debug(code, "开始执行买入") |
|---|
| | | trade_manager.start_buy(code, capture_timestamp, last_data, |
|---|
| | | last_data_index, order_begin_pos.mode) |
|---|
| | | last_data_index, order_begin_pos.mode, order_begin_pos.buy_exec_index) |
|---|
| | | l2_log.debug(code, "执行买入成功") |
|---|
| | | ################下单成功处理################ |
|---|
| | | trade_result_manager.real_buy_success(code, cls.__TradePointManager) |
|---|
