bug修复

Administrator

2023-07-24 0e68e24f54db11d340785b17570fff2bc5fc7ac6

 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