| | |
|---|
| | | from l2 import l2_data_util |
|---|
| | | from l2.l2_data_manager_new import L2TradeDataProcessor |
|---|
| | | from l2.l2_sell_manager import L2MarketSellManager |
|---|
| | | |
|---|
| | | if __name__ == "__main__": |
|---|
| | | codes = ["600603"] |
|---|
| | | codes = ["002194"] |
|---|
| | | 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() |
|---|
| | | L2MarketSellManager().set_current_total_sell_data(code,"10:20:54",1500000,45612,(8.94,1200)) |
|---|
| | | L2TradeDataProcessor.test__compute_active_order_begin_pos(code, 1, 5886, 5896) |
|---|
