import re import ast import datetime import os import constant from log_module.log import logger_debug, logger_common from strategy import data_cache from utils import huaxin_util # 获取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): # 初始化一个标志变量,用于检查是否找到了特定股票代码 found = False # 遍历转换后的列表 for sublist in data_cache.big_order_deal_dict.get(code, []): if sublist and sublist[0] and sublist[0][0] == code: # print(f"找到大单的对应行列表 sublist[0]===={sublist[0]}") # 格式 # sublist[0]====['002413', 0, [3996643, 287200, 1421640, 93453070, 4.95]] # sublist[0]====['股票代码', 买入, [订单号, 手数, 订单金额, 时间, 成交价]] # 时间是华鑫格式要转换一下 if sublist[0][2][3] is not None: huaxin_time_format = sublist[0][2][3] order_transaction_time = huaxin_util.convert_time(huaxin_time_format) logger.info(f"找到L2大单,对应行列表: sublist[0]===={sublist[0]} 大单金额:{sublist[0][2][2]}元 ,转换后时间格式:{order_transaction_time}") found = True # 设置标志为 True,表示找到了 # 检查是否没有找到特定股票代码 if not found: logger.info(f"没有找到L2大单:{code}") # print(f"没有找到这个货:{code}") return found if __name__ == '__main__': # 测试的时候可以调用一下 find_L2_big_order_of_code('002384')