from l2 import l2_data_util
|
|
if __name__ == "__main__":
|
codes = ["600603"]
|
for code in codes:
|
l2_data_util.load_l2_data(code)
|
total_datas = l2_data_util.local_today_datas.get(code)
|
latest_index = -1
|
for d in total_datas:
|
if d["index"] - latest_index != 1:
|
print(d["index"], d)
|
latest_index = d["index"]
|
# print(total_datas[0])
|
# print(len(total_datas))
|
# print(l2_data_util.l2_data_is_normal(code))
|
|
# threading.Thread(target=async_log_util.run_sync, daemon=True).start()
|
# map_ = log_export.load_huaxin_transaction_map()
|
# for datas in map_[code]:
|
# total_sell_info = HuaXinSellOrderStatisticManager.add_transaction_datas(code, datas)
|
# if total_sell_info[0] > 0 and total_sell_info[1]:
|
# print(total_sell_info)
|
# input()
|
