| | |
|---|
| | | from log_module import async_log_util, log_export |
|---|
| | | 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_l2_radical_buy |
|---|
| | | logger_system, logger_trade, logger_l2_radical_buy, logger_l2_not_buy_reasons |
|---|
| | | 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, \ |
|---|
| | | KPLPlateForbiddenManager |
|---|
| | |
|---|
| | | result_cache = (time.time() + 3, radical_result) |
|---|
| | | self.__radical_buy_by_blocks_result_cache[code] = result_cache |
|---|
| | | RadicalBuyDealCodesManager().set_code_blocks(code, radical_result[0]) |
|---|
| | | if not radical_result[0]: |
|---|
| | | async_log_util.info(logger_l2_not_buy_reasons, f"{code}#{radical_result[1]}") |
|---|
| | | # 取缓存 |
|---|
| | | result = result_cache[1] |
|---|
| | | if result[0]: |
|---|
