订阅

Administrator

2024-12-10 4231dc5dba02568b70e2caa4a0fe7c6455223c5c

 trade/current_price_process_manager.py

@@ -11,15 +11,19 @@
import constant
from code_attribute import gpcode_manager
from third_data.kpl_data_constant import LimitUpCodesBlockRecordManager, LimitUpDataConstant
from trade.buy_radical import radical_buy_data_manager
from trade.buy_radical.block_special_codes_manager import BlockSpecialCodesManager
from trade.buy_radical.radical_buy_data_manager import RadicalBuyBlockManager, RadicalBuyDataManager
from utils import tool, import_util
from trade import trade_manager, l2_trade_util, trade_constant
from trade.trade_data_manager import CodeActualPriceProcessor, RadicalBuyDealCodesManager
import concurrent.futures

trade_gui = import_util.import_lib("trade.trade_gui")

__actualPriceProcessor = CodeActualPriceProcessor()

__pre_big_order_deal_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=10)

latest_add_codes = set()

@@ -179,17 +183,19 @@
            # 是否和上次一样
            try:
                add_code_set = set(add_code_list)
                # global latest_add_codes
                # if not latest_add_codes:
                #     latest_add_codes = set()
                global latest_add_codes
                if not latest_add_codes:
                    latest_add_codes = set()
                # # 判断设置的代码是否相同
                # dif1 = latest_add_codes - add_code_set
                # dif2 = add_code_set - latest_add_codes
                # if dif1 or dif2:
                dif2 = add_code_set - latest_add_codes
                if dif2:
                    # 新增加的订阅需要拉取之前的大单
                    for c in dif2:
                        __pre_big_order_deal_thread_pool.submit(radical_buy_data_manager.pull_pre_deal_big_orders, c)
                if True:
                    global latest_add_codes
                    async_log_util.info(logger_l2_codes_subscript,
                                        f"({request_id})预处理新增订阅代码：{add_code_set - latest_add_codes}")
                                        f"({request_id})预处理新增订阅代码：{dif2}")
                    latest_add_codes = add_code_set
                    add_datas = []
                    for d in add_code_list: