| | |
| | | """ |
| | | 涨停时间管理器 |
| | | """ |
| | | from db import redis_manager |
| | | from db.redis_manager import RedisUtils |
| | | from db import redis_manager_delegate as redis_manager |
| | | from db.redis_manager_delegate import RedisUtils |
| | | from utils import global_util, tool |
| | | |
| | | |
| | | class LimitUpTimeManager: |
| | | __limit_up_time_cache = {} |
| | | __db = 0 |
| | | _redisManager = redis_manager.RedisManager(0) |
| | | __instance = None |
| | | |
| | |
| | | global_util.limit_up_time[code] = time |
| | | tool.CodeDataCacheUtil.set_cache(self.__limit_up_time_cache, code, time) |
| | | RedisUtils.setex_async( |
| | | self._redisManager.getRedis(), "limit_up_time-{}".format(code), tool.get_expire(), time) |
| | | self.__db, "limit_up_time-{}".format(code), tool.get_expire(), time) |
| | | |
| | | def get_limit_up_time(self, code): |
| | | time = global_util.limit_up_time.get(code) |