# 成交量管理
|
|
# 设置历史量
|
# max60 60天最大量
|
# yesterday 昨天的量
|
import global_util
|
import redis_manager
|
import tool
|
|
__redis_manager = redis_manager.RedisManager(0)
|
|
|
# 设置历史量
|
def set_histry_volumn(code, max60, yesterday):
|
redis = __redis_manager.getRedis()
|
global_util.max60_volumn[code] = max60
|
global_util.yesterday_volumn[code] = yesterday
|
redis.setex("volumn_max60-{}".format(code), tool.get_expire(), max60)
|
redis.setex("volumn_yes-{}".format(code), tool.get_expire(), yesterday)
|
|
|
# 获取历史量
|
def get_histry_volumn(code):
|
max60 = global_util.max60_volumn.get(code)
|
yesterday = global_util.yesterday_volumn.get(code)
|
redis = __redis_manager.getRedis()
|
if max60 is None:
|
max60 = redis.get("volumn_max60-{}".format(code))
|
if yesterday is None:
|
yesterday = redis.get("volumn_yes-{}".format(code))
|
return max60, yesterday
|
|
|
# 设置今日量
|
def set_today_volumn(code, volumn):
|
redis = __redis_manager.getRedis()
|
global_util.today_volumn[code] = volumn
|
redis.setex("volumn_today-{}".format(code), tool.get_expire(), volumn)
|
|
|
# 获取今日量
|
def get_today_volumn(code):
|
_volumn = global_util.today_volumn.get(code)
|
redis = __redis_manager.getRedis()
|
if _volumn is None:
|
_volumn = redis.get("volumn_today-{}".format(code))
|
return _volumn
|
|
|
# 保存今日量
|
def save_today_volumn(code, volumn, volumnUnit):
|
_volumn = None
|
if volumnUnit == 0:
|
_volumn = round(float(volumn) * 100000000)
|
elif volumnUnit == 1:
|
_volumn = round(float(volumn) * 10000)
|
elif volumnUnit == 2:
|
_volumn = int(volumn)
|
if _volumn is not None:
|
set_today_volumn(code,_volumn*100)
|
|
|
|
# 将量从数据库加入内存
|
def load():
|
redis = __redis_manager.getRedis()
|
keys = redis.keys("volumn_max60-*")
|
if keys is not None:
|
for k in keys:
|
code = k.split("-")[1]
|
global_util.max60_volumn[code] = redis.get(k)
|
keys = redis.keys("volumn_yes-*")
|
if keys is not None:
|
for k in keys:
|
code = k.split("-")[1]
|
global_util.yesterday_volumn[code] = redis.get(k)
|
