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)
|
