| | |
|---|
| | | from log_module.log import hx_logger_contact_debug, hx_logger_trade_callback, \ |
|---|
| | | hx_logger_l2_orderdetail, hx_logger_l2_market_data, logger_l2_g_cancel, logger_debug, \ |
|---|
| | | logger_system, logger_trade, logger_local_huaxin_l1_trade_info, logger_l2_codes_subscript |
|---|
| | | from third_data import block_info, kpl_data_manager, history_k_data_manager |
|---|
| | | from third_data import block_info, kpl_data_manager, history_k_data_manager, huaxin_l1_data_manager |
|---|
| | | from third_data.code_plate_key_manager import KPLCodeJXBlockManager, CodePlateKeyBuyManager |
|---|
| | | from third_data.history_k_data_util import JueJinApi |
|---|
| | | from trade import trade_manager, l2_trade_util, \ |
|---|
| | |
|---|
| | | __GCancelBigNumComputer = GCancelBigNumComputer() |
|---|
| | | __sell_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=10) |
|---|
| | | __process_l1_data_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=10) |
|---|
| | | current_buy1_dict = {} |
|---|
| | | __updating_jx_blocks_codes = set() |
|---|
| | | |
|---|
| | | @classmethod |
|---|
| | |
|---|
| | | # 格式 (代码,现价,涨幅,量,更新时间,买1价格,买1量) |
|---|
| | | price = d[1] |
|---|
| | | L1DataManager.set_l1_current_price(code, price) |
|---|
| | | cls.current_buy1_dict[code] = (d[5], d[6]) |
|---|
| | | huaxin_l1_data_manager.set_buy1_data(code,d[5], d[6]) |
|---|
| | | |
|---|
| | | # 获取L1现价 |
|---|
| | | @classmethod |
|---|
