交易结果整理

Administrator

2023-02-08 3ec79004bd769828c8dc18ed35280f81cfb473ff

 log.py

@@ -291,6 +291,31 @@
    return pos_list


# 获取交易进度
def get_trade_progress(code, date=None):
    if not date:
        date = datetime.datetime.now().strftime("%Y-%m-%d")
    index_list = []
    buy_queues = []
    with open("D:/logs/gp/l2/l2_trade_buy_queue.{}.log".format(date), mode='r', encoding="utf-8") as f:
        while True:
            line = f.readline()
            if not line:
                break
            time_ = __get_log_time(line).strip()
            if int(time_.replace(":", "")) > int("150000"):
                continue

            if line.find(f"{code}-[") >= 0:
                buy_queues.append((eval(line.split(f"{code}-")[1]), time_))

            if line.find("获取成交位置成功： code-{}".format(code)) < 0:
                continue
            index = int(line.split("index-")[1].split(" ")[0])
            index_list.append((index, time_))
    return index_list, buy_queues


def export_logs(code):
    code_name = gpcode_manager.get_code_name(code)
    date = datetime.datetime.now().strftime("%Y-%m-%d")
@@ -310,7 +335,7 @@

if __name__ == '__main__':
    # logger_l2_process_time.info("test123")
    codes = ["002842"]
    codes = ["002963"]
    for code in codes:
        export_logs(code)