From 11a349588bd3a277ef87ff186cb338093c7287f3 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 13 十二月 2023 17:10:56 +0800
Subject: [PATCH] 09:25之前订阅持仓代码的L2数据/修改代码板块的获取接口
---
code_attribute/gpcode_manager.py | 117 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 113 insertions(+), 4 deletions(-)
diff --git a/code_attribute/gpcode_manager.py b/code_attribute/gpcode_manager.py
index 3a8cc06..87e08a3 100644
--- a/code_attribute/gpcode_manager.py
+++ b/code_attribute/gpcode_manager.py
@@ -13,6 +13,7 @@
from ths import l2_listen_pos_health_manager, client_manager
__redisManager = redis_manager.RedisManager(0)
+__db = 0
class CodesNameManager:
@@ -293,6 +294,109 @@
return self.__pause_buy_codes_cache
+class WhiteListCodeManager:
+ __instance = None
+ __redis_manager = redis_manager.RedisManager(2)
+
+ def __new__(cls, *args, **kwargs):
+ if not cls.__instance:
+ cls.__instance = super(WhiteListCodeManager, cls).__new__(cls, *args, **kwargs)
+ # 鍒濆鍖栬缃�
+ # 鑾峰彇浜ゆ槗绐楀彛鐨勯攣
+ cls.__instance.__white_codes_cache = RedisUtils.smembers(cls.__get_redis(), "white_list_codes")
+
+ return cls.__instance
+
+ @classmethod
+ def __get_redis(cls):
+ return cls.__redis_manager.getRedis()
+
+ def sync(self):
+ data = RedisUtils.smembers(self.__get_redis(), "white_list_codes")
+ self.__white_codes_cache.clear()
+ if data:
+ self.__white_codes_cache |= data
+
+ def add_code(self, code):
+ self.__white_codes_cache.add(code)
+ RedisUtils.sadd(self.__get_redis(), "white_list_codes", code)
+ RedisUtils.expire(self.__get_redis(), "white_list_codes", tool.get_expire())
+
+ def remove_code(self, code):
+ self.__white_codes_cache.discard(code)
+ RedisUtils.srem(self.__get_redis(), "white_list_codes", code)
+
+ def is_in(self, code):
+ return RedisUtils.sismember(self.__get_redis(), "white_list_codes", code)
+
+ def is_in_cache(self, code):
+ return code in self.__white_codes_cache
+
+ def list_codes(self):
+ return RedisUtils.smembers(self.__get_redis(), "white_list_codes")
+
+ def list_codes_cache(self):
+ return self.__white_codes_cache
+
+ def clear(self):
+ self.__white_codes_cache.clear()
+ RedisUtils.delete(self.__get_redis(), "white_list_codes")
+
+
+class BlackListCodeManager:
+ __instance = None
+ __db = 2
+ __redis_manager = redis_manager.RedisManager(2)
+
+ def __new__(cls, *args, **kwargs):
+ if not cls.__instance:
+ cls.__instance = super(BlackListCodeManager, cls).__new__(cls, *args, **kwargs)
+ # 鍒濆鍖栬缃�
+ # 鑾峰彇浜ゆ槗绐楀彛鐨勯攣
+ cls.__instance.__forbidden_trade_codes_cache = RedisUtils.smembers(cls.__get_redis(),
+ "forbidden-trade-codes")
+
+ return cls.__instance
+
+ @classmethod
+ def __get_redis(cls):
+ return cls.__redis_manager.getRedis()
+
+ def add_code(self, code):
+ self.__forbidden_trade_codes_cache.add(code)
+ RedisUtils.sadd_async(self.__db, "forbidden-trade-codes", code)
+ RedisUtils.expire_async(self.__db, "forbidden-trade-codes", tool.get_expire())
+
+ def sync(self):
+ data = RedisUtils.smembers(self.__get_redis(),
+ "forbidden-trade-codes")
+ self.__forbidden_trade_codes_cache.clear()
+ if data:
+ self.__forbidden_trade_codes_cache |= data
+
+ def remove_code(self, code):
+ self.__forbidden_trade_codes_cache.discard(code)
+ RedisUtils.srem(self.__get_redis(), "forbidden-trade-codes", code)
+
+ def is_in(self, code):
+ return RedisUtils.sismember(self.__get_redis(), "forbidden-trade-codes", code)
+
+ def is_in_cache(self, code):
+ return code in self.__forbidden_trade_codes_cache
+
+ def list_codes(self):
+ codes = RedisUtils.smembers(self.__get_redis(), "forbidden-trade-codes")
+ self.__forbidden_trade_codes_cache = codes
+ return codes
+
+ def list_codes_cache(self):
+ return self.__forbidden_trade_codes_cache
+
+ def clear(self):
+ self.__forbidden_trade_codes_cache.clear()
+ RedisUtils.delete(self.__get_redis(), "forbidden-trade-codes")
+
+
def __parse_codes_data(code_datas):
codes = []
name_codes = {}
@@ -510,7 +614,8 @@
def is_in_gp_pool(code):
- return RedisUtils.sismember(__redisManager.getRedis(), "gp_list", code) or FirstGPCodesManager().is_in_first_gp_codes_cache(code)
+ return RedisUtils.sismember(__redisManager.getRedis(), "gp_list",
+ code) or FirstGPCodesManager().is_in_first_gp_codes_cache(code)
def get_gp_list():
@@ -585,6 +690,12 @@
return limit_up_price
+def get_limit_up_price_cache(code):
+ if code in __limit_up_price_dict:
+ return __limit_up_price_dict[code]
+ return None
+
+
def get_limit_up_price_by_preprice(price):
if price is None:
return None
@@ -620,14 +731,12 @@
# 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()
+ RedisUtils.setex_async(__db, "price-{}".format(code), tool.get_expire(), price)
# 鑾峰彇姝ｅ湪鐩戝惉鐨勪唬鐮�
--
Gitblit v1.8.0