| | |
| | | |
| | | |
| | | # 设置历史量 |
| | | 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: |
| | |
| | | |
| | | |
| | | # 获取量参考日期 |
| | | # 返回(参考量日期,距今的交易日个数) |
| | | def get_volume_refer_date(code): |
| | | max60, yesterday = get_histry_volumn(code) |
| | | if max60 is None or yesterday is None: |
| | | raise Exception("获取失败") |
| | | if int(max60[0]) >= int(yesterday): |
| | | return max60[1] |
| | | return max60[1], max60[2] |
| | | else: |
| | | return "上个交易日" |
| | | return "上个交易日", 0 |
| | | |
| | | |
| | | # 获取量比索引 |