| | |
|---|
| | | |
|---|
| | | from log_module.log import logger_kpl_block_can_buy, logger_debug, logger_kpl_jx_out |
|---|
| | | from third_data.kpl_util import KPLPlatManager |
|---|
| | | from trade import trade_manager, l2_trade_util, trade_constant |
|---|
| | | from trade import trade_manager, l2_trade_util, trade_constant, radical_buy_data_manager |
|---|
| | | |
|---|
| | | # 代码精选板块管理 |
|---|
| | | from utils.kpl_data_db_util import KPLLimitUpDataUtil |
|---|
| | |
|---|
| | | if history_index == 1: |
|---|
| | | # 当前代码为老2，要判断老大是否可买 |
|---|
| | | if RadicalBuyDataManager.is_code_can_buy(history_before_codes_info[0][0], |
|---|
| | | DealAndDelegateWithBuyModeDataManager().get_deal_codes())[0]: |
|---|
| | | DealAndDelegateWithBuyModeDataManager().get_deal_codes(), is_refered=True)[0]: |
|---|
| | | return False, f"开1数量：{count}，前排代码可买：{history_before_codes_info[0]}" |
|---|
| | | return True, f"开1数量：{count}，前排代码不可买：{history_before_codes_info[0]}，历史前排-{history_before_codes_info}，开1代码-{open_limit_up_block_codes}" |
|---|
| | | return True, f"开1数量：{count}，历史-{history_index + 1} 实时-{current_index + 1}， 前排代码-{current_before_codes_info}, 开1代码-{open_limit_up_block_codes}" |
|---|
| | |
|---|
| | | @classmethod |
|---|
| | | def __filter_before_codes(cls, block, index, before_codes_info, yesterday_codes): |
|---|
| | | """ |
|---|
| | | 过滤前排涨停原因不正的代码 |
|---|
| | | 过滤前排涨停原因不正/不算身位的代码 |
|---|
| | | @param code: |
|---|
| | | @param block:板块 |
|---|
| | | @param index: 目标代码位置 |
|---|
| | |
|---|
| | | temp_before_codes_info = [] |
|---|
| | | for b in before_codes_info: |
|---|
| | | # 当作目标票获取扫入板块 |
|---|
| | | blocks = LimitUpCodesBlockRecordManager().get_radical_buy_blocks(b[0]) |
|---|
| | | code_ = b[0] |
|---|
| | | blocks = LimitUpCodesBlockRecordManager().get_radical_buy_blocks(code_) |
|---|
| | | blocks = BlockMapManager().filter_blocks(blocks) |
|---|
| | | need_delete = False |
|---|
| | | # 判断原因不正 |
|---|
| | | if block not in blocks and b[0] not in yesterday_codes: |
|---|
| | | # 首板涨停原因不正 |
|---|
| | | need_delete = True |
|---|
| | | # 判断是否是不计算身位 |
|---|
| | | if not need_delete: |
|---|
| | | if radical_buy_data_manager.ExcludeIndexComputeCodesManager.is_in_cache(code_): |
|---|
| | | need_delete = True |
|---|
| | | if need_delete: |
|---|
| | | temp_index -= 1 |
|---|
| | | else: |
|---|
| | | temp_before_codes_info.append(b) |
|---|
| | | |
|---|
| | | return temp_index, temp_before_codes_info |
|---|
| | | except Exception as e: |
|---|
| | | async_log_util.error(logger_debug, f"扫入板块过滤出错：{str(e)}") |
|---|
| | |
|---|
| | | pre_code = history_before_codes_info[0][0] |
|---|
| | | # pre_code不能买，才能买 |
|---|
| | | if RadicalBuyDataManager.is_code_can_buy(pre_code, |
|---|
| | | DealAndDelegateWithBuyModeDataManager().get_deal_codes())[0]: |
|---|
| | | DealAndDelegateWithBuyModeDataManager().get_deal_codes(), is_refered=True)[0]: |
|---|
| | | return False, f"前排代码可买：{pre_code}" |
|---|
| | | # 前面一个代码不能买，前一个代码必须与前前个代码涨停时间相差15分钟内 |
|---|
| | | for i in range(len(all_history_before_codes_info) - 1, -1, -1): |
|---|
