| | |
|---|
| | | from l2.l2_sell_manager import L2MarketSellManager |
|---|
| | | from l2.l2_transaction_data_manager import HuaXinSellOrderStatisticManager |
|---|
| | | from log_module import log, log_export, async_log_util |
|---|
| | | from trade.huaxin import huaxin_trade_api |
|---|
| | | from trade.radical_buy_data_manager import RedicalBuyDataManager |
|---|
| | | from trade.buy_radical.radical_buy_data_manager import RadicalBuyDataManager, RadicalBuyBlockManager |
|---|
| | | from utils import tool, init_data_util |
|---|
| | | from db import redis_manager_delegate as redis_manager |
|---|
| | | from l2 import l2_log, l2_data_manager, transaction_progress, l2_data_manager_new, l2_transaction_data_processor, \ |
|---|
| | | cancel_buy_strategy |
|---|
| | | from l2.transaction_progress import TradeBuyQueue |
|---|
| | | from third_data import kpl_util, kpl_data_manager, block_info |
|---|
| | | from third_data.code_plate_key_manager import LimitUpCodesPlateKeyManager, CodePlateKeyBuyManager, \ |
|---|
| | | RadicalBuyBlockManager |
|---|
| | | from third_data.code_plate_key_manager import LimitUpCodesPlateKeyManager |
|---|
| | | from third_data.kpl_data_manager import KPLDataManager |
|---|
| | | from trade import trade_data_manager, current_price_process_manager, l2_trade_util, trade_manager |
|---|
| | | import l2.l2_data_manager_new, l2.l2_data_manager, l2.l2_data_util, l2.cancel_buy_strategy |
|---|
| | |
|---|
| | | limit_up_price = gpcode_manager.get_limit_up_price(code) |
|---|
| | | if limit_up_price is None: |
|---|
| | | init_data_util.re_set_price_pre(code) |
|---|
| | | current_price_process_manager.set_trade_price(code, round(float(gpcode_manager.get_limit_up_price(code)), 2)) |
|---|
| | | current_price_process_manager.set_trade_price(code, gpcode_manager.get_limit_up_price_as_num(code)) |
|---|
| | | |
|---|
| | | pss_server, pss_strategy = multiprocessing.Pipe() |
|---|
| | | # huaxin_trade_api.run_pipe_trade(pss_server, None, None) |
|---|
| | |
|---|
| | | |
|---|
| | | # @unittest.skip("跳过此单元测试") |
|---|
| | | def test_block(self): |
|---|
| | | codes_str = "603778" |
|---|
| | | codes_str = "300390" |
|---|
| | | codes = codes_str.split(",") # ["002889", "300337", "001298", "002771"] |
|---|
| | | kpl_data_manager.KPLLimitUpDataRecordManager.load_total_datas() |
|---|
| | | kpl_data_manager.KPLLimitUpDataRecordManager.save_record(tool.get_now_date_str(), |
|---|
| | |
|---|
| | | result = RadicalBuyBlockManager.is_radical_buy(code, yesterday_codes) |
|---|
| | | print(code, result) |
|---|
| | | if result[0]: |
|---|
| | | can_buy_result = RedicalBuyDataManager.can_buy(code) |
|---|
| | | can_buy_result = RadicalBuyDataManager.is_code_can_buy(code) |
|---|
| | | if can_buy_result[0]: |
|---|
| | | print("可以买", code, result) |
|---|
| | | else: |
|---|
| | |
|---|
| | | for d in fdatas: |
|---|
| | | l2_transaction_data_processor.HuaXinTransactionDatasProcessor().process_huaxin_transaction_datas(code, d) |
|---|
| | | |
|---|
| | | def test_cancel(self): |
|---|
| | | code = "603300" |
|---|
| | | l2.l2_data_util.load_l2_data(code) |
|---|
| | | TradeBuyQueue.get_traded_index = mock.Mock(return_value=(3742, False)) |
|---|
| | | l2.cancel_buy_strategy.RDCancelBigNumComputer._RDCancelBigNumComputer__watch_indexes_cache ={ code: {3686, 3691, 3693, 3694, 3699, 3700}} |
|---|
| | | l2.cancel_buy_strategy.RDCancelBigNumComputer().need_cancel(code, 4370, 4372) |
|---|
| | | |
|---|
| | | |
|---|
| | | class TestTradedProgress(unittest.TestCase): |
|---|
| | | @unittest.skip("跳过此单元测试") |
|---|
