| | |
|---|
| | | cls.__redis_key) |
|---|
| | | return cls.__instance |
|---|
| | | |
|---|
| | | def __get_redis(self): |
|---|
| | | return self.redisManager.getRedis() |
|---|
| | | @classmethod |
|---|
| | | def __get_redis(cls): |
|---|
| | | return cls.redisManager.getRedis() |
|---|
| | | |
|---|
| | | def clear(self): |
|---|
| | | self.__pause_buy_codes_cache.clear() |
|---|
| | |
|---|
| | | RedisUtils.setex(__redisManager.getRedis(), "price-{}".format(code), tool.get_expire(), price) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 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() |
|---|
| | | |
|---|
| | | |
|---|
| | | # 获取正在监听的代码 |
|---|
| | | def get_listen_codes(): |
|---|
| | | redis_instance = __redisManager.getRedis() |
|---|
