From c20c3c10635ce78db4a86ce9c0bb1d02e90f525d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 08 八月 2023 17:40:42 +0800
Subject: [PATCH] 单例+缓存优化

---
 code_attribute/gpcode_manager.py |   17 +++++++++++++++--
 1 files changed, 15 insertions(+), 2 deletions(-)

diff --git a/code_attribute/gpcode_manager.py b/code_attribute/gpcode_manager.py
index 465250e..fa562e6 100644
--- a/code_attribute/gpcode_manager.py
+++ b/code_attribute/gpcode_manager.py
@@ -254,8 +254,9 @@
                                                                          cls.__redis_key)
         return cls.__instance
 
-    def __get_redis(self):
-        return self.redisManager.getRedis()
+    @classmethod
+    def __get_redis(cls):
+        return cls.redisManager.getRedis()
 
     def clear(self):
         self.__pause_buy_codes_cache.clear()
@@ -575,6 +576,18 @@
     RedisUtils.setex(__redisManager.getRedis(), "price-{}".format(code), tool.get_expire(), price)
 
 
+# datas:[(code,price)]
+def set_prices(datas):
+    pipe =  __redisManager.getRedis().pipeline()
+    for d in datas:
+        code, price = d[0], d[1]
+        if code in __current_price_cache and __current_price_cache[code] == price:
+            continue
+        __current_price_cache[code] = price
+        RedisUtils.setex(pipe, "price-{}".format(code), tool.get_expire(), price)
+    pipe.execute()
+
+
 # 鑾峰彇姝e湪鐩戝惉鐨勪唬鐮�
 def get_listen_codes():
     redis_instance = __redisManager.getRedis()

--
Gitblit v1.8.0