import logging

from l2.l2_transaction_data_manager import HuaXinSellOrderStatisticManager

if __name__ == "__main__":

    fdatas = {}
    with open("D:\\test\\transaction.log", 'r') as f:
        lines = f.readlines()
        for line in lines:
            if line.find("run_sync") < 0:
                continue
            line = line[line.find(']') + 1:].strip()
            data = eval(line)
            if data["SecurityID"] not in fdatas:
                fdatas[data["SecurityID"]] = []
            fdatas[data["SecurityID"]].append(
                (data['SecurityID'], data['TradePrice'], data['TradeVolume'],
                 data['OrderTime'], data['MainSeq'], data['SubSeq'], data['BuyNo'],
                 data['SellNo'], data['ExecType']))
    for code in fdatas:
        try:
            HuaXinSellOrderStatisticManager.statistic_total_deal_volume(code, fdatas[code])
            print(HuaXinSellOrderStatisticManager.get_latest_3s_continue_deal_volumes(code))
            pass
        except Exception as e:
            logging.exception(e)