From 1b49e9a1c5d31a568406a361b883eec211326983 Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期五, 07 六月 2024 14:45:03 +0800 Subject: [PATCH] 自由流通量相关测试 --- code_attribute/gpcode_manager.py | 13 ++++++++----- 1 files changed, 8 insertions(+), 5 deletions(-) diff --git a/code_attribute/gpcode_manager.py b/code_attribute/gpcode_manager.py index 87864f1..568096e 100644 --- a/code_attribute/gpcode_manager.py +++ b/code_attribute/gpcode_manager.py @@ -7,6 +7,8 @@ import constant from db import redis_manager_delegate as redis_manager from db.redis_manager_delegate import RedisUtils +from log_module import log_export +from log_module.log import logger_pre_close_price from utils import tool import decimal @@ -710,9 +712,9 @@ # 鑾峰彇鏀剁洏浠� @classmethod def get_price_pre(cls, code): - result = RedisUtils.get(cls.__redisManager.getRedis(), "price-pre-{}".format(code)) - if result is not None: - return float(result) + fdatas = log_export.load_pre_close_price() + if code in fdatas: + return round(float(fdatas.get(code)), 2) return None # 鑾峰彇缂撳瓨 @@ -731,8 +733,9 @@ codes = get_gp_list() if code not in codes and not FirstCodeManager().is_in_first_record_cache(code) and not force: return - RedisUtils.setex(cls.__redisManager.getRedis(), "price-pre-{}".format(code), tool.get_expire(), str(price)) - cls.__price_pre_cache[code] = float(price) + price = round(float(price), 2) + logger_pre_close_price.info(f"{code}-{price}") + cls.__price_pre_cache[code] = price __limit_up_price_dict = {} -- Gitblit v1.8.0