| | |
|---|
| | | hx_logger_l2_orderdetail, hx_logger_l2_market_data, logger_l2_g_cancel, logger_debug, \ |
|---|
| | | logger_system, logger_trade, logger_l2_radical_buy |
|---|
| | | from third_data import block_info, kpl_data_manager, history_k_data_manager, huaxin_l1_data_manager, kpl_api, kpl_util |
|---|
| | | from third_data.code_plate_key_manager import KPLCodeJXBlockManager, CodePlateKeyBuyManager, RealTimeKplMarketData |
|---|
| | | from third_data.code_plate_key_manager import KPLCodeJXBlockManager, CodePlateKeyBuyManager, RealTimeKplMarketData, \ |
|---|
| | | KPLPlateForbiddenManager |
|---|
| | | from third_data.history_k_data_util import JueJinApi, HistoryKDatasUtils |
|---|
| | | from third_data.kpl_limit_up_data_manager import LatestLimitUpBlockManager |
|---|
| | | from trade import l2_trade_util, \ |
|---|
| | | trade_data_manager, trade_constant, buy_open_limit_up_strategy |
|---|
| | | from trade.buy_radical import radical_buy_data_manager, radical_buy_strategy |
|---|
| | |
|---|
| | | L2TradeSingleDataManager.set_callback(l2_trade_single_callback) |
|---|
| | | # 加载自由流通量 |
|---|
| | | global_data_loader.load_zyltgb_volume_from_db() |
|---|
| | | # 获取最近7天涨停数最多的板块 |
|---|
| | | try: |
|---|
| | | if not KPLPlateForbiddenManager().list_all_cache(): |
|---|
| | | # 没有添加过的时候需要重新添加 |
|---|
| | | datas_ = LatestLimitUpBlockManager().statistics_limit_up_block_infos() |
|---|
| | | if datas_: |
|---|
| | | plates = [d[0] for d in datas_[:3]] |
|---|
| | | for p in plates: |
|---|
| | | KPLPlateForbiddenManager().save_plate(p) |
|---|
| | | except: |
|---|
| | | pass |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_read, trade_ipc_addr): |
|---|
