| | |
|---|
| | | val = json.loads(val) |
|---|
| | | cls.__max_price_info_cache[code] = val |
|---|
| | | |
|---|
| | | def set_price_info(self, code, price, time): |
|---|
| | | def set_price_info(self, code, price, time, sell1_info): |
|---|
| | | """ |
|---|
| | | 设置价格信息 |
|---|
| | | @param sell1_info: 卖1信息：(卖1价, 卖1量) |
|---|
| | | @param code: |
|---|
| | | @param price: |
|---|
| | | @param time: |
|---|
| | |
|---|
| | | old_price_info = self.__max_price_info_cache.get(code) |
|---|
| | | if old_price_info and old_price_info[0] >= price: |
|---|
| | | return |
|---|
| | | price_info = (price, time) |
|---|
| | | price_info = (price, time, sell1_info) |
|---|
| | | tool.CodeDataCacheUtil.set_cache(self.__max_price_info_cache, code, price_info) |
|---|
| | | RedisUtils.setex_async( |
|---|
| | | self.__db, "max_price_info-{}".format(code), tool.get_expire(), json.dumps(price_info)) |
|---|
