添加由于l2数据而不能买的接口

Administrator

2024-01-23 77da8f7f017bd63fab4b49c24014b27ab615f5e1

 log_module/log_export.py

@@ -112,6 +112,12 @@
    return time_


def __get_async_log_time(line):
    line = line.split(" - ")[1]
    time_str = line[line.find("[") + 1:line.find("[") + 9]
    return time_str


# 获取L2每次批量处理数据的位置范围
def get_l2_process_position(code, date=None):
    if not date:
@@ -224,6 +230,30 @@
        except:
            pass
    return index_list, buy_queues


# 获取l2不能买的原因
def get_l2_cant_buy_reasons(code, date=None):
    if not date:
        date = datetime.datetime.now().strftime("%Y-%m-%d")
    fdatas = []
    path_str = "{}/logs/gp/l2/l2_not_buy_reasons.{}.log".format(constant.get_path_prefix(), date)
    lines = __load_file_content(path_str)
    for line in lines:
        if not line:
            break
        if line.find(f"{code}#") < 0:
            continue

        line = line.split(" - ")[1]
        time_str = line[line.find("[") + 1:line.find("[") + 9]
        data = line[line.find("]") + 1:].strip()
        code_ = data.split("#")[0].strip()
        data = data.split("#")[1].strip()
        if code_ != code:
            continue
        fdatas.append((time_str, data))
    return fdatas


# 获取H级撤单计算结果
@@ -447,9 +477,9 @@
                        if data.startswith("["):
                            data = data[data.find("]") + 1:].strip()
                        code = data.split("#")[0]
                        l2_data = eval( data.split("#")[1])
                        l2_data = eval(data.split("#")[1])
                        if code not in fdatas:
                            fdatas[code]=[]
                            fdatas[code] = []
                        fdatas[code].append(l2_data)
                    except:
                        pass