| | |
| | | """ |
| | | |
| | | # 大单管理 |
| | | from db import redis_manager |
| | | from db.redis_manager import RedisUtils |
| | | from db import redis_manager_delegate as redis_manager |
| | | from db.redis_manager_delegate import RedisUtils |
| | | from utils import tool |
| | | |
| | | __redisManager = redis_manager.RedisManager(0) |
| | | __db = 0 |
| | | __redisManager = redis_manager.RedisManager(__db) |
| | | |
| | | |
| | | # 是否为大单 |
| | | def is_big_num(val): |
| | | if int(val["num"]) >= 8000 or int(val["num"]) * float(val["price"]) >= 30000: |
| | | if int(val["num"]) >= 8999 or int(val["num"]) * float(val["price"]) >= 29900: |
| | | return True |
| | | else: |
| | | return False |
| | |
| | | if code not in __big_money_cache: |
| | | __big_money_cache[code] = 0 |
| | | __big_money_cache[code] += num |
| | | RedisUtils.incrby_async(__redisManager.getRedis(), "big_money-{}".format(code), num) |
| | | RedisUtils.incrby_async(__db, "big_money-{}".format(code), num) |
| | | |
| | | |
| | | # 设置过期时间 |