板块拉黑重新定义

Administrator

2025-03-04 5e66b4bb954b2cc3650d50e60be86c328fcdc158

 main.py

@@ -13,6 +13,7 @@

from task import task_manager
from third_data import hx_qc_value_util
from third_data.code_plate_key_manager import KPLPlateForbiddenManager

logger_system.info("程序启动Pre：{}", os.getpid())

@@ -97,6 +98,14 @@

        logger_system.info("主进程ID：{}", os.getpid())

        fix_codes = set()
        open_buy_codes = gpcode_manager.BuyOpenLimitUpCodeManager().get_codes()
        if open_buy_codes:
            fix_codes |= set(open_buy_codes)
        # 要监控的高标
        high_codes = KPLPlateForbiddenManager().get_watch_high_codes()
        if high_codes:
            fix_codes |= set(high_codes)
        # L1订阅数据
        l1Process = multiprocessing.Process(target=huaxin_client.l1_client.run,
                                            args=(queue_l1_w_strategy_r, queue_l1_r_strategy_w,