| | |
|---|
| | | |
|---|
| | | from log_module.log import logger_kpl_block_can_buy, logger_kpl_jx_out, logger_kpl_jx_in, logger_debug |
|---|
| | | from third_data.kpl_util import KPLPlatManager |
|---|
| | | from trade import trade_manager, l2_trade_util, trade_constant |
|---|
| | | from trade import l2_trade_util, trade_constant |
|---|
| | | |
|---|
| | | # 代码精选板块管理 |
|---|
| | | from utils.kpl_data_db_util import KPLLimitUpDataUtil |
|---|
| | |
|---|
| | | __TargetCodePlateKeyManager = TargetCodePlateKeyManager() |
|---|
| | | __LimitUpCodesPlateKeyManager = LimitUpCodesPlateKeyManager() |
|---|
| | | __CodesHisReasonAndBlocksManager = CodesHisReasonAndBlocksManager() |
|---|
| | | __CodesTradeStateManager = trade_manager.CodesTradeStateManager() |
|---|
| | | __can_buy_compute_result_dict = {} |
|---|
| | | |
|---|
| | | @classmethod |
|---|
| | | def __remove_from_l2(cls, code, msg): |
|---|
| | | # 根据身位移除代码 |
|---|
| | | # return |
|---|
| | | # 下过单的代码不移除 |
|---|
| | | if trade_manager.CodesTradeStateManager().get_trade_state_cache(code) != trade_constant.TRADE_STATE_NOT_TRADE: |
|---|
| | | # 只要下过单的就不移除 |
|---|
| | | return |
|---|
| | | l2_trade_util.forbidden_trade(code, msg=msg) |
|---|
| | | logger_kpl_block_can_buy.info(msg) |
|---|
| | | |
|---|
| | | # 是否需要积极买 |
|---|
| | | @classmethod |
|---|
| | |
|---|
| | | @classmethod |
|---|
| | | def __compute_can_buy_blocks(cls, code, current_limit_up_datas, limit_up_record_datas, |
|---|
| | | yesterday_current_limit_up_codes, before_blocks_dict, |
|---|
| | | current_limit_up_block_codes_dict, high_level_general_code_blocks): |
|---|
| | | current_limit_up_block_codes_dict, high_level_general_code_blocks, codes_delegate, codes_success): |
|---|
| | | # 根据代码泛化板块获取泛化板块的代码集合 |
|---|
| | | high_level_general_block_codes = {} |
|---|
| | | for c in high_level_general_code_blocks: |
|---|
| | |
|---|
| | | high_level_general_block_codes) |
|---|
| | | if not blocks_compute_results: |
|---|
| | | return False, True, f"没有找到板块", [], keys, [] |
|---|
| | | codes_delegate = set(cls.__CodesTradeStateManager.get_codes_by_trade_states_cache( |
|---|
| | | {trade_constant.TRADE_STATE_BUY_DELEGATED, trade_constant.TRADE_STATE_BUY_PLACE_ORDER})) |
|---|
| | | codes_success = set(cls.__CodesTradeStateManager.get_codes_by_trade_states_cache( |
|---|
| | | {trade_constant.TRADE_STATE_BUY_SUCCESS})) |
|---|
| | | |
|---|
| | | codes = codes_delegate | codes_success |
|---|
| | | # 统计成交代码的板块 |
|---|
| | | trade_codes_blocks_dict = {} |
|---|
| | |
|---|
| | | @classmethod |
|---|
| | | def update_can_buy_blocks(cls, code, current_limit_up_datas, limit_up_record_datas, |
|---|
| | | latest_current_limit_up_records, |
|---|
| | | before_blocks_dict, current_limit_up_block_codes_dict): |
|---|
| | | before_blocks_dict, current_limit_up_block_codes_dict, delegate_codes, deal_codes): |
|---|
| | | yesterday_current_limit_up_codes = set() |
|---|
| | | yesterday_current_limit_up_records_dict = {} |
|---|
| | | yesterday_current_limit_up_records = latest_current_limit_up_records[0][1] |
|---|
| | |
|---|
| | | yesterday_current_limit_up_codes, |
|---|
| | | before_blocks_dict, |
|---|
| | | current_limit_up_block_codes_dict, |
|---|
| | | high_level_general_code_blocks) |
|---|
| | | high_level_general_code_blocks, delegate_codes, deal_codes) |
|---|
| | | # 保存板块计算结果 |
|---|
| | | cls.__can_buy_compute_result_dict[code] = ( |
|---|
| | | can_buy_blocks, unique, msg, can_buy_strong_blocks, keys, active_buy_blocks) |
|---|
