新题材代码视为辨识度/日志修改

Administrator

2025-03-18 eec1b72145c1ed7e49c1b062bb2bbbd0004d45b9

新题材代码视为辨识度/日志修改

 servers/data_server.py

@@ -1108,7 +1108,11 @@
                        if reasons:
                            for r in reasons:
                                for c in block_codes[r]:
                                    LimitUpCodesBlockRecordManager().add_new_blocks(c, r)
                                    add_result = LimitUpCodesBlockRecordManager().add_new_blocks(c, r)
                                    if add_result:
                                        # 增加新题材是否成功， 临时将票加入辨识度
                                        BlockSpecialCodesManager().add_code_block_for_temp(c, r)

                    except:
                        pass
                    self.__kplDataManager.save_data(type_, result_list_)

 third_data/kpl_data_constant.py

@@ -6,6 +6,7 @@
from log_module.log import logger_debug
from third_data import kpl_util
from third_data.third_blocks_manager import BlockMapManager
from trade import trade_record_log_util

from utils import tool
from utils.kpl_data_db_util import KPLLimitUpDataUtil
@@ -214,19 +215,21 @@
        添加新题材的板块
        @param code:
        @param block:
        @return:
        @return: 返回增加新题材是否成功
        """
        if block in constant.KPL_INVALID_BLOCKS:
            return
            return False
        old_blocks = self.__radical_buy_reasons_dict.get(code)
        if old_blocks is None:
            old_blocks = set()
        if block in old_blocks:
            return
            return False
        self.__new_blocks.add(block)
        old_blocks.add(block)
        trade_record_log_util.add_temp_special_codes(code, f"新题材辨识度：{block}")
        async_log_util.info(logger_debug, f"今日新增概念：{code} - {block}")
        self.__radical_buy_reasons_dict[code] = old_blocks
        return True

    def get_total_before_blocks(self):
        """

 trade/buy_radical/block_special_codes_manager.py

@@ -42,6 +42,23 @@
    def get_code_blocks_dict(self):
        return self.__code_blocks_dict

    def add_code_block_for_temp(self, code, block):
        """
        临时添加代码的辨识度板块
        @param code:
        @param block:
        @return:
        """
        if code not in self.__code_blocks_dict:
            self.__code_blocks_dict[code] = set()
        self.__code_blocks_dict[code].add(block)

        if code not in self.__block_codes_dict:
            self.__block_codes_dict[block] = set()
        self.__block_codes_dict[block].add(code)



    def set_block_codes_list(self, datas):
        """
        设置数据
@@ -54,6 +71,8 @@
            self.mysql.execute(sql)




class AnalysisBlockSpecialCodesManager:
    __mysql = mysql_data.Mysqldb()


 trade/trade_record_log_util.py

@@ -165,6 +165,12 @@
    __add_log(TYPE_ACTION, code, {"type": "移想", "msg": msg})


# 加临时辨识度票
def add_temp_special_codes(code, msg=""):
    __add_log(TYPE_ACTION, code, {"type": "新题材", "msg": msg})



# 加白
def add_common_msg(code, type_, msg=""):
    __add_log(TYPE_ACTION, code, {"type": type_, "msg": msg})