from l2.l2_transaction_data_manager import HuaXinSellOrderStatisticManager
|
from log_module import log_export, async_log_util
|
from utils import tool
|
|
|
def load_sell_info():
|
date = tool.get_now_date_str()
|
data_map = log_export.load_huaxin_transaction_map(date=date)
|
for code in data_map:
|
if code != '002562':
|
continue
|
datas = data_map[code]
|
for d in datas:
|
big_sell_order_info = HuaXinSellOrderStatisticManager.add_transaction_datas(code, d)
|
async_log_util.run_sync()
|
|
|
def test_sell_order_info():
|
code = "603967"
|
date = tool.get_now_date_str()
|
data_map = log_export.load_huaxin_transaction_map(date=date)
|
datas = data_map.get(code)
|
start_print = False
|
for i in range(len(datas)):
|
d = datas[i]
|
if d[0][7] == 11181370:
|
start_print = True
|
if start_print:
|
print(d)
|
big_sell_order_info = HuaXinSellOrderStatisticManager.add_transaction_datas(code, d)
|
if big_sell_order_info[0] < 50 * 10000:
|
continue
|
# print(big_sell_order_info)
|
|
|
if __name__ == '__main__':
|
test_sell_order_info()
|
