From 0e68e24f54db11d340785b17570fff2bc5fc7ac6 Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期一, 24 七月 2023 13:05:16 +0800 Subject: [PATCH] bug修复 --- l2/l2_data_util.py | 24 ++++++++++++------------ 1 files changed, 12 insertions(+), 12 deletions(-) diff --git a/l2/l2_data_util.py b/l2/l2_data_util.py index e9ecec0..c7c25d4 100644 --- a/l2/l2_data_util.py +++ b/l2/l2_data_util.py @@ -14,7 +14,7 @@ import constant from code_attribute import gpcode_manager from l2 import l2_data_log, l2_data_source_util -from logs_ import log +from log_module import log from db import redis_manager from utils import tool @@ -32,17 +32,18 @@ local_today_buyno_map = {} -def load_l2_data(code, force=False): +def load_l2_data(code, load_latest=True, force=False): redis = _redisManager.getRedis() # 鍔犺浇鏈�杩戠殑l2鏁版嵁 - if local_latest_datas.get(code) is None or force: - # 鑾峰彇鏈�杩戠殑鏁版嵁 - _data = redis.get("l2-data-latest-{}".format(code)) - if _data is not None: - if code in local_latest_datas: - local_latest_datas[code] = json.loads(_data) - else: - local_latest_datas.setdefault(code, json.loads(_data)) + if load_latest : + if local_latest_datas.get(code) is None or force: + # 鑾峰彇鏈�杩戠殑鏁版嵁 + _data = redis.get("l2-data-latest-{}".format(code)) + if _data is not None: + if code in local_latest_datas: + local_latest_datas[code] = json.loads(_data) + else: + local_latest_datas.setdefault(code, json.loads(_data)) # 鑾峰彇浠婃棩鐨勬暟鎹� if local_today_datas.get(code) is None or force: @@ -103,8 +104,7 @@ # 鍙~鍏呬拱鍏ユ暟鎹� key = "{}".format(data["val"]["orderNo"]) if local_today_buyno_map[code].get(key) is None: - local_today_buyno_map[code].setdefault(key, []) - local_today_buyno_map[code].get(key).append(data) + local_today_buyno_map[code].setdefault(key, data) @tool.async_call -- Gitblit v1.8.0