l2/l2_transaction_data_manager.py
@@ -308,11 +308,11 @@ # 统计所有的成交量 __deal_volume_list_dict = {} # 统计主动买的成交量 # 统计涨停主动买的成交量 __deal_active_buy_volume_list_dict = {} @classmethod def statistic_total_deal_volume(cls, code, datas): def statistic_total_deal_volume(cls, code, datas, limit_up_price): # 只统计被动买 if code not in cls.__deal_volume_list_dict: cls.__deal_volume_list_dict[code] = [] @@ -349,6 +349,9 @@ # 只统计主动买 if d[7] > d[6]: continue # 只统计涨停买 if d[1] != limit_up_price: continue if d[3] in time_dict: time_str = time_dict[d[3]] else:
