redis上级缓存添加

Administrator

2023-08-03 2c46e85017e57d8919783d4fcfed0069ff201761

 code_attribute/gpcode_first_screen_manager.py

@@ -8,13 +8,16 @@
from db.redis_manager import RedisUtils
from utils import tool
from db import redis_manager
from third_data import  block_info
from third_data import block_info

__redisManager = redis_manager.RedisManager(0)


def __get_redis():
    return __redisManager.getRedis()


__first_code_data_cache = {}


# 保存首板票的数据
@@ -24,7 +27,8 @@
# 4.最近炸开时间
# 5.是否已经涨停
def __save_first_code_data(code, data):
    RedisUtils.setex(__redisManager.getRedis(),f"first_code_data-{code}", tool.get_expire(), json.dumps(data))
    tool.CodeDataCacheUtil.set_cache(__first_code_data_cache, code, data)
    RedisUtils.setex(__redisManager.getRedis(), f"first_code_data-{code}", tool.get_expire(), json.dumps(data))


def __get_first_code_data(code):
@@ -32,6 +36,15 @@
    if val is None:
        return None
    return json.loads(val)


def __get_first_code_data_cache(code):
    cache_result = tool.CodeDataCacheUtil.get_cache(__first_code_data_cache, code)
    if cache_result[0]:
        return cache_result[1]
    val = __get_first_code_data(code)
    tool.CodeDataCacheUtil.set_cache(__first_code_data_cache, code, val)
    return val


# 添加进首板未筛选票
@@ -52,7 +65,7 @@
    redis = __redisManager.getRedis()
    if codes:
        for code in codes:
            redis.srem("first_no_screen_codes", code)
            RedisUtils.srem(redis, "first_no_screen_codes", code)


def __get_first_no_screen_codes():
@@ -67,7 +80,7 @@
    for price in prices:
        code = price["code"]
        time_ = price["time"]
        old_data = __get_first_code_data(code)
        old_data = __get_first_code_data_cache(code)
        if old_data is None:
            continue
        limit_up = price["limit_up"]