扫入选票策略修改/主力流入前排板块修改

Administrator

2024-11-27 abd7affcd9d83487001ce23a7a9596528554a258

 third_data/code_plate_key_manager.py

@@ -13,6 +13,7 @@
from third_data import kpl_block_util, kpl_api, kpl_util
from settings.trade_setting import MarketSituationManager
from third_data.kpl_data_constant import LimitUpCodesBlockRecordManager
from third_data.kpl_limit_up_data_manager import ContainsLimitupCodesBlocksManager
from third_data.third_blocks_manager import BlockMapManager
from utils import global_util, tool, buy_condition_util
from log_module import async_log_util
@@ -333,7 +334,7 @@

# 实时开盘啦市场数据
class RealTimeKplMarketData:
    # 流入缓存
    # 流入缓存 [ID, 板块名称, 板块涨幅, 流入金额]
    top_in_list_cache = []
    # 流出缓存
    top_out_list_cache = []
@@ -361,7 +362,7 @@
        @return:
        """
        # 流入阈值
        THRESHOLD_MONEY = 100* (tool.trade_time_sub(tool.get_now_time_str(), "09:30:00")//60)+1000
        THRESHOLD_MONEY = 100 * (tool.trade_time_sub(tool.get_now_time_str(), "09:30:00") // 60) + 1000
        THRESHOLD_MONEY = min(THRESHOLD_MONEY, 10000)
        THRESHOLD_MONEY = max(THRESHOLD_MONEY, 1000)
        THRESHOLD_MONEY = THRESHOLD_MONEY * 10000
@@ -380,10 +381,21 @@
            fb = BlockMapManager().filter_blocks({data[1]})
            if blocks & fb:
                continue


            for b in fb:
                fblock_money[b] = data[3]
            blocks |= fb
            count += 1

            # 如果该原因没有涨停票要往后移一位
            has_code = False
            for b in fb:
                if ContainsLimitupCodesBlocksManager().get_block_codes(b):
                    has_code = True
                    break
            if has_code:
                count += 1

            if count >= 10:
                break
        # 记录精选流出日志