From b855b811e3753ffcb35f145c985bb32f4b550038 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 31 十月 2024 18:11:40 +0800
Subject: [PATCH] 排1之前的数据准备
---
code_attribute/gpcode_manager.py | 42 ++++++++++++++++++++++++++++++++++++++++++
1 files changed, 42 insertions(+), 0 deletions(-)
diff --git a/code_attribute/gpcode_manager.py b/code_attribute/gpcode_manager.py
index 38fe868..48ab178 100644
--- a/code_attribute/gpcode_manager.py
+++ b/code_attribute/gpcode_manager.py
@@ -1,6 +1,7 @@
"""
鑲＄エ浠ｇ爜绠＄悊鍣�
"""
+import copy
import json
import time
@@ -19,6 +20,47 @@
__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:
__mysqldb = Mysqldb()
__code_name_dict = {}
--
Gitblit v1.8.0