| | |
|---|
| | | from l2 import l2_log, l2_data_manager, transaction_progress |
|---|
| | | from l2.safe_count_manager import BuyL2SafeCountManager |
|---|
| | | from l2.transaction_progress import TradeBuyQueue |
|---|
| | | from third_data import kpl_util |
|---|
| | | from third_data import kpl_util, kpl_data_manager |
|---|
| | | from third_data.code_plate_key_manager import RealTimeKplMarketData, LimitUpCodesPlateKeyManager |
|---|
| | | from third_data.kpl_data_manager import KPLDataManager |
|---|
| | | from trade import trade_data_manager, current_price_process_manager |
|---|
| | |
|---|
| | | |
|---|
| | | # @unittest.skip("跳过此单元测试") |
|---|
| | | def test_trade(self): |
|---|
| | | code = "000826" |
|---|
| | | code = "600292" |
|---|
| | | clear_trade_data(code) |
|---|
| | | l2.l2_data_util.load_l2_data(code) |
|---|
| | | total_datas = deepcopy(l2.l2_data_util.local_today_datas[code]) |
|---|
| | |
|---|
| | | LimitUpCodesPlateKeyManager().set_today_limit_up( |
|---|
| | | KPLDataManager().get_from_file(kpl_util.KPLDataType.LIMIT_UP, tool.get_now_date_str())) |
|---|
| | | |
|---|
| | | kpl_data_manager.KPLLimitUpDataRecordManager.load_total_datas() |
|---|
| | | |
|---|
| | | current_price_process_manager.set_trade_price(code, round(float(gpcode_manager.get_limit_up_price(code)), 2)) |
|---|
| | | |
|---|
| | | pss_server, pss_strategy = multiprocessing.Pipe() |
|---|
