| | |
|---|
| | | cls.__instance.redisManager = redis_manager.RedisManager(0) |
|---|
| | | cls.__instance.__first_code_record_cache = RedisUtils.smembers(cls.__instance.__get_redis(), |
|---|
| | | "first_code_record") |
|---|
| | | cls.__instance.__first_code_limited_up_record_cache = RedisUtils.smembers(cls.__instance.__get_redis(), |
|---|
| | | "first_code_limited_up_record") |
|---|
| | | return cls.__instance |
|---|
| | | |
|---|
| | | def __get_redis(self): |
|---|
| | |
|---|
| | | |
|---|
| | | def is_in_first_record_cache(self, code): |
|---|
| | | return code in self.__first_code_record_cache |
|---|
| | | |
|---|
| | | # 加入首板涨停过代码集合 |
|---|
| | | def add_limited_up_record(self, codes): |
|---|
| | | hasChanged = False |
|---|
| | | for code in codes: |
|---|
| | | if code not in self.__first_code_limited_up_record_cache: |
|---|
| | | RedisUtils.sadd_async(self.__db, "first_code_limited_up_record", code) |
|---|
| | | hasChanged = True |
|---|
| | | self.__first_code_limited_up_record_cache.add(code) |
|---|
| | | if hasChanged: |
|---|
| | | RedisUtils.expire_async(self.__db, "first_code_limited_up_record", tool.get_expire()) |
|---|
| | | |
|---|
| | | # 是否涨停过 |
|---|
| | | def is_limited_up(self, code): |
|---|
| | | if RedisUtils.sismember(self.__get_redis(), "first_code_limited_up_record", code): |
|---|
| | | return True |
|---|
| | | else: |
|---|
| | | return False |
|---|
| | | |
|---|
| | | def is_limited_up_cache(self, code): |
|---|
| | | return code in self.__first_code_limited_up_record_cache |
|---|
| | | |
|---|
| | | |
|---|
| | | # 想要买的代码 |
|---|
