| | |
| | | import json |
| | | |
| | | from db.redis_manager_delegate import RedisUtils |
| | | from log_module import async_log_util |
| | | from utils import global_util, tool |
| | | from db import redis_manager_delegate as redis_manager |
| | | from log_module.log import logger_day_volumn |
| | |
| | | |
| | | # 设置今日量 |
| | | def set_today_volumn(code, volumn): |
| | | logger_day_volumn.info("code:{} volumn:{}".format(code, volumn)) |
| | | async_log_util.info(logger_day_volumn, "code:{} volumn:{}".format(code, volumn)) |
| | | global_util.today_volumn[code] = volumn |
| | | # 有1000手的变化才保存 |
| | | if code in __today_volumn_cache and volumn - __today_volumn_cache[code] < 100000: |
| | |
| | | def set_today_volumns(datas): |
| | | for d in datas: |
| | | code, volumn = d |
| | | logger_day_volumn.info("code:{} volumn:{}".format(code, volumn)) |
| | | async_log_util.info(logger_day_volumn, "code:{} volumn:{}".format(code, volumn)) |
| | | global_util.today_volumn[code] = volumn |
| | | # 有1000手的变化才保存 |
| | | if code in __today_volumn_cache and volumn - __today_volumn_cache[code] < 100000: |