| | |
|---|
| | | from third_data import kpl_util, kpl_data_manager, block_info |
|---|
| | | from third_data.code_plate_key_manager import LimitUpCodesPlateKeyManager, CodePlateKeyBuyManager |
|---|
| | | from third_data.kpl_data_manager import KPLDataManager |
|---|
| | | from trade import trade_data_manager, current_price_process_manager, l2_trade_util, trade_manager |
|---|
| | | from trade import trade_data_manager, current_price_process_manager, l2_trade_util, trade_manager, l2_trade_factor |
|---|
| | | import l2.l2_data_manager_new, l2.l2_data_manager, l2.l2_data_util, l2.cancel_buy_strategy |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | # hook |
|---|
| | | tool.get_now_time_str = mock.Mock(return_value="09:35:00") |
|---|
| | | CodePlateKeyBuyManager.can_buy = mock.Mock(return_value=(["测试"], False, "",[])) |
|---|
| | | CodePlateKeyBuyManager.can_buy = mock.Mock(return_value=(["测试"], False, "", [])) |
|---|
| | | |
|---|
| | | # 获取交易进度 |
|---|
| | | trade_progress_list, buy_queues = log_export.get_trade_progress(code) |
|---|
| | |
|---|
| | | l2.l2_data_manager_new.L2TradeDataProcessor.process_add_datas(code, total_datas[indexs[0]:indexs[1] + 1], 0, |
|---|
| | | 0) |
|---|
| | | |
|---|
| | | @unittest.skip("跳过此单元测试") |
|---|
| | | def test_place_order(self): |
|---|
| | | code = "002241" |
|---|
| | | def test_s_cancel(self): |
|---|
| | | code = "603363" |
|---|
| | | l2.l2_data_util.load_l2_data(code) |
|---|
| | | total_datas = deepcopy(l2.l2_data_util.local_today_datas[code]) |
|---|
| | | huaxin_delegate_postion_manager.place_order(code, 17.36, 100, total_datas[753]) |
|---|
| | | huaxin_delegate_postion_manager.get_l2_place_order_position(code, total_datas[755:1038]) |
|---|
| | | l2.l2_data_util.local_today_datas[code] = l2.l2_data_util.local_today_datas[code][:222] |
|---|
| | | l2.cancel_buy_strategy.SCancelBigNumComputer().set_real_place_order_index(code, 153) |
|---|
| | | |
|---|
| | | TradeBuyQueue.get_traded_index = mock.Mock(return_value=(117, False)) |
|---|
| | | order_begin_pos = l2_data_manager.OrderBeginPosInfo(buy_single_index=117, buy_exec_index=122) |
|---|
| | | sell_order_info = [1517999, [[2996226, 300000, 5.06, (10223471, 4876395), (10223471, 4876395)]]] |
|---|
| | | l2.cancel_buy_strategy.SCancelBigNumComputer().set_big_sell_order_info_for_cancel(code, sell_order_info, |
|---|
| | | order_begin_pos) |
|---|
| | | |
|---|
| | | sell_order_info = [508507, [[5564445, 100100, 5.08, (10372994, 4876545), (10372994, 4876546)]]] |
|---|
| | | l2.cancel_buy_strategy.SCancelBigNumComputer().set_big_sell_order_info_for_cancel(code, sell_order_info, |
|---|
| | | order_begin_pos) |
|---|
| | | l2.cancel_buy_strategy.SCancelBigNumComputer().set_big_sell_order_info_for_cancel(code, sell_order_info, |
|---|
| | | order_begin_pos) |
|---|
| | | l2.cancel_buy_strategy.SCancelBigNumComputer().need_cancel_for_down(code, 154, 222) |
|---|
| | | |
|---|
| | | @unittest.skip("跳过此单元测试") |
|---|
| | | def test_h_cancel(self): |
|---|
