| | |
|---|
| | | return max60, yesterday |
|---|
| | | |
|---|
| | | |
|---|
| | | __today_volumn_cache = {} |
|---|
| | | |
|---|
| | | |
|---|
| | | # 量的变化大保存 |
|---|
| | | |
|---|
| | | # 设置今日量 |
|---|
| | | def set_today_volumn(code, volumn): |
|---|
| | | logger_day_volumn.info("code:{} volumn:{}".format(code, volumn)) |
|---|
| | | redis = __redis_manager.getRedis() |
|---|
| | | global_util.today_volumn[code] = volumn |
|---|
| | | # 有1000手的变化才保存 |
|---|
| | | if code in __today_volumn_cache and volumn - __today_volumn_cache[code] < 100000: |
|---|
| | | return |
|---|
| | | __today_volumn_cache[code] = volumn |
|---|
| | | redis = __redis_manager.getRedis() |
|---|
| | | RedisUtils.setex(redis, "volumn_today-{}".format(code), tool.get_expire(), volumn) |
|---|
| | | |
|---|
| | | |
|---|
