# 涨停时间管理器
|
"""
|
涨停时间管理器
|
"""
|
|
|
import redis_manager
|
import tool
|
import global_util
|
|
_redisManager = redis_manager.RedisManager(0)
|
|
|
def save_limit_up_time(code, time):
|
_time = get_limit_up_time(code)
|
if _time is None:
|
redis = _redisManager.getRedis()
|
redis.setex("limit_up_time-{}".format(code), tool.get_expire(), time)
|
global_util.limit_up_time[code] = time
|
|
|
def get_limit_up_time(code):
|
time = global_util.limit_up_time.get(code)
|
if time is None:
|
redis = _redisManager.getRedis()
|
time = redis.get("limit_up_time-{}".format(code))
|
if time is not None:
|
redis = _redisManager.getRedis()
|
redis.setex("limit_up_time-{}".format(code), tool.get_expire(), time)
|
|
return time
|
