From 0acb55dbb2d251472f902b3bb721fd888ab9a31f Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期一, 08 一月 2024 17:37:32 +0800 Subject: [PATCH] 增加获取当前正在委托详情API/下单后立马移除红名单 --- l2/l2_transaction_data_manager.py | 21 +++++++++++++++++++-- 1 files changed, 19 insertions(+), 2 deletions(-) diff --git a/l2/l2_transaction_data_manager.py b/l2/l2_transaction_data_manager.py index 75eeb65..43a6de2 100644 --- a/l2/l2_transaction_data_manager.py +++ b/l2/l2_transaction_data_manager.py @@ -10,11 +10,13 @@ from db.redis_manager_delegate import RedisUtils from l2 import l2_data_util, l2_data_manager, transaction_progress from l2.cancel_buy_strategy import LCancelRateManager, LCancelBigNumComputer, \ - SecondCancelBigNumComputer, HourCancelBigNumComputer, FastCancelBigNumComputer + SecondCancelBigNumComputer, HourCancelBigNumComputer, FastCancelBigNumComputer, UCancelBigNumComputer +from l2.l2_data_manager_new import L2TradeDataProcessor from l2.l2_data_util import L2DataUtil from log_module import async_log_util from log_module.log import logger_l2_trade_buy_queue, hx_logger_l2_upload, hx_logger_l2_debug, \ - hx_logger_l2_transaction_desc + hx_logger_l2_transaction_desc, logger_debug +from third_data import kpl_data_manager from trade import current_price_process_manager, trade_manager, l2_trade_factor from trade.deal_big_money_manager import DealOrderNoManager from utils import tool @@ -148,6 +150,21 @@ if order_begin_pos and order_begin_pos.buy_exec_index and order_begin_pos.buy_exec_index > -1: HourCancelBigNumComputer().set_transaction_index(code, order_begin_pos.buy_single_index, buy_progress_index) + # ---------------------------------鍒ゆ柇鏉垮潡鏄惁璺熶笂鏉ヤ簡------------------------------- + try: + pass + # order_begin_pos = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache(code) + # volume_rate = 0 + # volume_info = L2TradeDataProcessor.volume_rate_info.get(code) + # if volume_info: + # volume_rate = volume_info[0] + # need_cancel, msg = UCancelBigNumComputer().need_cancel(code, buy_progress_index, order_begin_pos, + # kpl_data_manager.KPLLimitUpDataRecordManager.get_current_reason_codes_dict(), + # volume_rate) + # if need_cancel: + # L2TradeDataProcessor.cancel_buy(code, msg) + except Exception as e: + logger_debug.exception(e) else: pass if order_begin_pos and order_begin_pos.buy_exec_index and order_begin_pos.buy_exec_index > -1: -- Gitblit v1.8.0