| | |
|---|
| | | from third_data.third_blocks_manager import BlockMapManager |
|---|
| | | from trade.buy_radical import radical_buy_data_manager, new_block_processor |
|---|
| | | from trade.buy_radical.block_special_codes_manager import BlockSpecialCodesManager |
|---|
| | | from trade.buy_radical.new_block_processor import BeforeBlocksComputer |
|---|
| | | from trade.buy_strategy import OpenLimitUpGoodBlocksBuyStrategy |
|---|
| | | from trade.buy_radical.radical_buy_data_manager import RadicalBuyBlockManager, BeforeSubDealBigOrderManager |
|---|
| | | from utils import global_util, tool, data_export_util |
|---|
| | |
|---|
| | | if b not in block_codes: |
|---|
| | | block_codes[b] = set() |
|---|
| | | block_codes[b].add(x[3]) |
|---|
| | | # 所有代码的涨停原因 |
|---|
| | | reasons = set(block_codes.keys()) |
|---|
| | | reasons -= constant.KPL_INVALID_BLOCKS |
|---|
| | | reasons -= LimitUpCodesBlockRecordManager().get_total_before_blocks() |
|---|
| | | # 原来的老题材 |
|---|
| | | reasons -= BeforeBlocksComputer().get_old_blocks() |
|---|
| | | if reasons: |
|---|
| | | # 新板块 |
|---|
| | | update_new_block_plates = [] |
|---|
