| | |
| | | except Exception as e: |
| | | pass |
| | | |
| | | |
| | | def test_trade(self): |
| | | threading.Thread(target=async_log_util.run_sync, daemon=True).start() |
| | | code = "600203" |
| | |
| | | l2_market_datas = l2_market_datas.get(code) |
| | | if l2_market_datas: |
| | | l2_market_datas.reverse() |
| | | |
| | | |
| | | pos_list = log_export.get_l2_process_position(code) |
| | | # pos_list.insert(108,(375,448)) |
| | |
| | | time_str = "0" + time_str |
| | | time_str = time_str[:6] |
| | | time_str = f"{time_str[0:2]}:{time_str[2:4]}:{time_str[4:6]}" |
| | | L2MarketSellManager().set_current_total_sell_data(code,time_str,l2_m["totalAskVolume"]*l2_m["avgAskPrice"]) |
| | | L2MarketSellManager().set_current_total_sell_data(code, time_str, |
| | | l2_m["totalAskVolume"] * l2_m["avgAskPrice"]) |
| | | break |
| | | |
| | | l2.l2_data_manager_new.L2TradeDataProcessor.process_add_datas(code, total_datas[indexs[0]:indexs[1] + 1], 0, |