| | |
|---|
| | | codes = self.list_code() |
|---|
| | | self.__want_buy_codes_cache.clear() |
|---|
| | | if codes: |
|---|
| | | self.__want_buy_codes_cache += set(codes) |
|---|
| | | self.__want_buy_codes_cache |= set(codes) |
|---|
| | | |
|---|
| | | def is_in(self, code): |
|---|
| | | return RedisUtils.sismember(self.__get_redis(), self.__redis_key, code) |
|---|
| | |
|---|
| | | # 与黑名单的区别是暂停交易代码只是不交易，不能移除L2监控位 |
|---|
| | | class PauseBuyCodesManager: |
|---|
| | | __instance = None |
|---|
| | | redisManager = redis_manager.RedisManager(0) |
|---|
| | | __redis_key = "pause_buy_codes" |
|---|
| | | |
|---|
| | | def __new__(cls, *args, **kwargs): |
|---|
| | | if not cls.__instance: |
|---|
| | | cls.__instance = super(PauseBuyCodesManager, cls).__new__(cls, *args, **kwargs) |
|---|
| | | # 初始化设置 |
|---|
| | | # 获取交易窗口的锁 |
|---|
| | | cls.__instance.redisManager = redis_manager.RedisManager(0) |
|---|
| | | cls.__instance.__redis_key = "pause_buy_codes" |
|---|
| | | cls.__instance.__pause_buy_codes_cache = RedisUtils.smembers(cls.__instance.__get_redis(), |
|---|
| | | cls.__instance.__redis_key) |
|---|
| | | cls.__instance.__pause_buy_codes_cache = RedisUtils.smembers(cls.__get_redis(), |
|---|
| | | cls.__redis_key) |
|---|
| | | return cls.__instance |
|---|
| | | |
|---|
| | | def __get_redis(self): |
|---|
