| | |
|---|
| | | return time_str, volumn |
|---|
| | | |
|---|
| | | |
|---|
| | | # 买1实时价格管理器 |
|---|
| | | class Buy1PriceManager: |
|---|
| | | __redisManager = redis_manager.RedisManager(0) |
|---|
| | | |
|---|
| | | def __init__(self): |
|---|
| | | self.latest_prices = {} |
|---|
| | | |
|---|
| | | def __get_redis(self): |
|---|
| | | return self.__redisManager.getRedis() |
|---|
| | | |
|---|
| | | def __save_recod(self, code, price): |
|---|
| | | # 保存每一次的 |
|---|
| | | key = "buy1_price-{}".format(code) |
|---|
| | | self.__get_redis().setex(key, tool.get_expire(), price) |
|---|
| | | |
|---|
| | | def __get_record(self, code): |
|---|
| | | key = "buy1_price-{}".format(code) |
|---|
| | | val = self.__get_redis().get(key) |
|---|
| | | return val |
|---|
| | | |
|---|
| | | # 保存数据 |
|---|
| | | def save(self, code, price): |
|---|
| | | if self.latest_prices.get(code) == price: |
|---|
| | | return |
|---|
| | | self.latest_prices[code] = price |
|---|
| | | self.__save_recod(code, price) |
|---|
| | | |
|---|
| | | def get_price(self, code): |
|---|
| | | return self.__get_record(code) |
|---|
| | | |
|---|
| | | |
|---|
| | | class thsl2tradequeuemanager: |
|---|
