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