代码异常保护

Administrator

2024-11-04 65afea1ba534b51f947cbe7989d7f4d650bbc9e6

 code_attribute/gpcode_manager.py

@@ -1,6 +1,7 @@
"""
股票代码管理器
"""
import copy
import json
import time

@@ -17,6 +18,47 @@

__redisManager = redis_manager.RedisManager(0)
__db = 0


class BuyOpenLimitUpCodeManager:
    """
    排1代码管理
    """
    __db = 2
    __redisManager = redis_manager.RedisManager(2)
    __instance = None
    __codes_cache = set()

    def __new__(cls, *args, **kwargs):
        if not cls.__instance:
            cls.__instance = super(BuyOpenLimitUpCodeManager, cls).__new__(cls, *args, **kwargs)
            cls.__load_data()
        return cls.__instance

    @classmethod
    def __get_redis(cls):
        return cls.__redisManager.getRedis()

    @classmethod
    def __load_data(cls):
        val = RedisUtils.get(cls.__get_redis(), "buy_open_limit_up_codes")
        if val:
            val = json.loads(val)
            cls.__codes_cache = set(val)

    def set_codes(self, codes):
        self.__codes_cache = copy.deepcopy(codes)
        RedisUtils.set_async(self.__db, "buy_open_limit_up_codes", json.dumps(list(codes)))

    def get_codes(self):
        return self.__codes_cache

    def is_in_cache(self, code):
        if not self.__codes_cache:
            return False
        if code in self.__codes_cache:
            return True
        return False


class CodesNameManager:
@@ -63,6 +105,18 @@
            cls.__mysqldb.execute(f"insert into code_name(code,code_name,update_time ) values('{code}','{name}',now())")

    @classmethod
    def add_code_names(cls, code_name_dict):
        """
        批量添加代码名称
        @param code_name_dict:
        @return:
        """
        for code in code_name_dict:
            if code in cls.__code_name_dict and cls.__code_name_dict[code] == code_name_dict[code]:
                continue
            cls.add_code_name(code, code_name_dict[code])

    @classmethod
    def add_first_code_name(cls, code, name):
        cls.add_code_name(code, name)