Administrator
2024-02-05 8c7f84cbd0afde7600b0c67a8032fa19c57d8c41
code_attribute/code_volumn_manager.py
@@ -18,12 +18,13 @@
# 设置历史量
def set_histry_volumn(code, max60, yesterday, max60_day=''):
def set_histry_volumn(code, max60, yesterday, max60_day, max60_day_count):
    redis = __redis_manager.getRedis()
    global_util.max60_volumn[code] = (max60, max60_day)
    global_util.max60_volumn[code] = (max60, max60_day,max60_day_count)
    global_util.yesterday_volumn[code] = yesterday
    try:
        RedisUtils.setex_async(0, "volumn_max60-{}".format(code), tool.get_expire(), json.dumps((max60, max60_day)),
        RedisUtils.setex_async(0, "volumn_max60-{}".format(code), tool.get_expire(),
                               json.dumps((max60, max60_day, max60_day_count)),
                               auto_free=False)
        RedisUtils.setex_async(0, "volumn_yes-{}".format(code), tool.get_expire(), yesterday, auto_free=False)
    finally:
@@ -98,14 +99,15 @@
# 获取量参考日期
# 返回(参考量日期,距今的交易日个数)
def get_volume_refer_date(code):
    max60, yesterday = get_histry_volumn(code)
    if max60 is None or yesterday is None:
        raise Exception("获取失败")
    if max60[0] >= yesterday[0]:
        return max60[1]
    if int(max60[0]) >= int(yesterday):
        return max60[1], max60[2]
    else:
        return yesterday[1]
        return "上个交易日", 0
# 获取量比索引