| | |
|---|
| | | |
|---|
| | | |
|---|
| | | class TradeBuyQueue: |
|---|
| | | __db = 0 |
|---|
| | | __redis_manager = redis_manager.RedisManager(0) |
|---|
| | | |
|---|
| | | def __init__(self): |
|---|
| | |
|---|
| | | def __save_buy_progress_index(self, code, index, is_default): |
|---|
| | | tool.CodeDataCacheUtil.set_cache(buy_progress_index_cache, code, (index, is_default)) |
|---|
| | | key = "trade_buy_progress_index-{}".format(code) |
|---|
| | | RedisUtils.setex_async(self.__getRedis(), key, tool.get_expire(), json.dumps((index, is_default))) |
|---|
| | | RedisUtils.setex_async(self.__db, key, tool.get_expire(), json.dumps((index, is_default))) |
|---|
| | | # 返回数据与更新时间 |
|---|
| | | |
|---|
| | | def __get_buy_progress_index(self, code): |
|---|
