1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
| """
| L2大单管理器
| """
|
| # 大单管理
| from db import redis_manager
| from db.redis_manager import RedisUtils
| from utils import tool
|
| __redisManager = redis_manager.RedisManager(0)
|
|
| # 是否为大单
| def is_big_num(val):
| if int(val["num"]) >= 8000 or int(val["num"]) * float(val["price"]) >= 30000:
| return True
| else:
| return False
|
|
| def add_num(code, num):
| RedisUtils.incrby(__redisManager.getRedis(), "big_money-{}".format(code), num)
|
|
| # 设置过期时间
| def expire(code):
| RedisUtils.expire(__redisManager.getRedis(), "big_money-{}".format(code), tool.get_expire())
|
|
| def reset(code):
| RedisUtils.set(__redisManager.getRedis(), "big_money-{}".format(code), 0)
|
|
| def get_num(code):
| num = RedisUtils.get(__redisManager.getRedis(), "big_money-{}".format(code))
| if num is None:
| return 0
| return round(int(num) / 1000 / 4)
|
|
| def reset_all():
| redis = __redisManager.getRedis()
| try:
| keys = RedisUtils.keys(redis, "big_money-*", auto_free=False)
| for k in keys:
| RedisUtils.setex(redis, k, tool.get_expire(), 0, auto_free=False)
| finally:
| RedisUtils.realse(redis)
|
|
| if __name__ == "__main__":
| add_num("000332", 0)
| expire("000332")
|
|
