import re
import ast
import datetime
import os
import constant
from log_module.log import logger_debug, logger_common
# 获取logger实例
logger = logger_common


# 读取log日志并转换格式
def read_and_parse_log(log_file_path):
    # 打开并读取日志文件
    with open(log_file_path, 'r', encoding='utf-8') as log_file:
        lines = log_file.readlines()
        # print(f"lines=={lines}")

    # 初始化一个列表数据 来安置转换好的日志文件
    parsed_logs = []

    # 正则表达式匹配日志格式，例如：YYYY-MM-DD HH:MM:SS LEVEL PID TID MESSAGE
    # 这里我们假设一个简化的格式：HH:MM:SS LEVEL MESSAGE
    # 正则表达式匹配日志格式，例如：YYYY-MM-DD HH:MM:SS.mmm | LEVEL | MODULE:FUNCTION:LINE - MESSAGE
    log_regex = re.compile(
        r'^\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}\.\d{3} \|\s*(\w+)\s*\|\s*([\w.]+:\w+:\d+) -\s*(.*)$')

    for line in lines:
        match = log_regex.match(line.strip())
        if match:
            # 提取时间戳、日志级别和日志信息
            timestamp, level, message = match.groups()
            # 这里我们不添加时间戳和日志级别到parsed_logs，只添加日志信息
            parsed_logs.append(message)

    return parsed_logs


# 找到具体目标个股L2中有无大单记录
def find_L2_big_order_of_code(code):
    # 获取当前日期，并格式化为 'YYYY-MM-DD'
    current_date = datetime.datetime.now().strftime('%Y-%m-%d')
    # 声明要转义的文件的路径
    log_file_path = f'{constant.LOG_PATH}/transaction.{current_date}.log'
    # 检查文件是否存在,如果存在则继续处理，如果不存在则就此打住
    if not os.path.exists(log_file_path):
        logger.info(f"Error错误:{log_file_path}----文件不存在！")
        return
    parsed_logs = read_and_parse_log(log_file_path)
    # 使用列表推导式和 ast.literal_eval() 将字符串转换为列表
    true_lists = [ast.literal_eval(log) for log in parsed_logs]

    # 初始化一个标志变量，用于检查是否找到了特定股票代码
    found = False

    # 遍历转换后的列表
    for sublist in true_lists:
        if sublist and sublist[0] and sublist[0][0] == code:
            logger.info(f"找到大单的对应行列表 sublist[0]===={sublist[0]}")
            # print(f"找到大单的对应行列表 sublist[0]===={sublist[0]}")
            found = True  # 设置标志为 True，表示找到了

    # 检查是否没有找到特定股票代码
    if not found:
        logger.info(f"没有找到这个货：{code}")
        # print(f"没有找到这个货：{code}")


# 测试的时候可以调用一下
find_L2_big_order_of_code('002384')

# # 如果你需要将解析后的日志保存到新文件中，可以使用以下代码：
# output_file_path = 'path/to/your/parsed_logfile.txt'
# with open(output_file_path, 'w', encoding='utf-8') as output_file:
#     for log in parsed_logs:
#         output_file.write(log + '\n')