| | |
|---|
| | | from third_data import kpl_util, kpl_data_manager, block_info |
|---|
| | | from third_data.code_plate_key_manager import LimitUpCodesPlateKeyManager, CodePlateKeyBuyManager, KPLCodeJXBlockManager |
|---|
| | | from third_data.kpl_data_manager import KPLDataManager |
|---|
| | | from trade import trade_data_manager, current_price_process_manager, l2_trade_util |
|---|
| | | from trade import trade_data_manager, current_price_process_manager, l2_trade_util, trade_manager |
|---|
| | | from trade.trade_queue_manager import THSBuy1VolumnManager |
|---|
| | | import l2.l2_data_manager_new, l2.l2_data_manager, l2.l2_data_util, l2.cancel_buy_strategy |
|---|
| | | |
|---|
| | |
|---|
| | | except Exception as e: |
|---|
| | | pass |
|---|
| | | |
|---|
| | | @unittest.skip("跳过此单元测试") |
|---|
| | | # @unittest.skip("跳过此单元测试") |
|---|
| | | def test_trade(self): |
|---|
| | | trade_manager.TradeStateManager().open_buy() |
|---|
| | | threading.Thread(target=async_log_util.run_sync, daemon=True).start() |
|---|
| | | code = "000026" |
|---|
| | | code = "002528" |
|---|
| | | clear_trade_data(code) |
|---|
| | | l2.l2_data_util.load_l2_data(code) |
|---|
| | | total_datas = deepcopy(l2.l2_data_util.local_today_datas[code]) |
|---|
| | |
|---|
| | | current_price_process_manager.set_trade_price(code, round(float(gpcode_manager.get_limit_up_price(code)), 2)) |
|---|
| | | |
|---|
| | | pss_server, pss_strategy = multiprocessing.Pipe() |
|---|
| | | huaxin_trade_api.run_pipe_trade(pss_server, None) |
|---|
| | | huaxin_trade_api.run_pipe_trade(pss_server, None, None) |
|---|
| | | |
|---|
| | | for indexs in pos_list: |
|---|
| | | l2_log.threadIds[code] = mock.Mock( |
|---|
