策略优化

Administrator

2024-12-06 0a82a3db5496751b3c39915b6c159e5a8ecd7a67

 third_data/code_plate_key_manager.py

@@ -364,12 +364,10 @@
        score = 60
        if cls.__market_strong is not None:
            score = int(cls.__market_strong)
        score = score // 10
        if score >= 10:
            score = 9
        if score < 6:
            score = 5
        return score * 2 - 2
        for info in constant.RADICAL_BUY_TOP_IN_COUNT_BY_MARKET_STRONG:
            if info[0]<=score<info[1]:
                return info[2]
        return 10

    @classmethod
    def set_market_jingxuan_blocks(cls, datas):
@@ -379,10 +377,11 @@
        @return:
        """
        # 流入阈值
        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
        # 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
        THRESHOLD_MONEY = 0
        # 最大数量
        MAX_COUNT = cls.get_jingxuan_in_block_threshold_count()

@@ -417,7 +416,7 @@
            if count >= MAX_COUNT:
                break
        # 记录精选流出日志
        async_log_util.info(logger_kpl_jx_in, f"原数据：{datas[:20]} 板块：{blocks}")
        async_log_util.info(logger_kpl_jx_in, f"原数据：{datas[:50]} 板块：{blocks}")
        blocks = list(blocks)
        blocks.sort(key=lambda x: fblock_money.get(x), reverse=True)
        cls.__top_jx_blocks = blocks
@@ -473,6 +472,20 @@
        return cls.__top_jx_out_blocks

    @classmethod
    def get_block_info_at_block_in(cls, b):
        """
        获取板块的净流入情况
        @param b:
        @return: (板块名称,身位,流入金额)
        """
        for i in range(0, len(cls.top_in_list_cache)):
            if cls.top_in_list_cache[i][1] == b:
                return b, i, cls.top_in_list_cache[i][3]
        return b, -1, 0



    @classmethod
    def set_top_5_industry(cls, datas):
        for d in datas:
            cls.total_industry_dict[d[1]] = d