| | |
|---|
| | | can_buy_blocks = [] |
|---|
| | | for block in keys: |
|---|
| | | is_top_8_record, top_8_record = kpl_block_util.is_record_top_block(code, block, limit_up_record_datas, |
|---|
| | | yesterday_current_limit_up_codes, 20) |
|---|
| | | yesterday_current_limit_up_codes, 50) |
|---|
| | | is_top_4_current, top_4_current = kpl_block_util.is_current_top_block(code, block, current_limit_up_datas, |
|---|
| | | yesterday_current_limit_up_codes, 10) |
|---|
| | | yesterday_current_limit_up_codes, 50) |
|---|
| | | is_top_4 = is_top_8_record and is_top_4_current |
|---|
| | | msg_list.append(f"\n实时top10: {top_4_current}(涨停数量：{len(current_limit_up_datas)})") |
|---|
| | | msg_list.append(f"历史top20: {top_8_record}") |
|---|
| | | msg_list.append(f"\n实时top10(涨停数量：{len(current_limit_up_datas)})") |
|---|
| | | msg_list.append(f"历史top20(涨停数量：{len(top_8_record)})") |
|---|
| | | |
|---|
| | | # 获取主板实时身位,剔除高位板 |
|---|
| | | current_shsz_rank = kpl_block_util.get_code_current_rank(code, block, current_limit_up_datas, |
|---|
| | |
|---|
| | | # ---------------------------------加载已经下单/成交的代码信息------------start------------- |
|---|
| | | # match_reasons = match_limit_up_result.keys() |
|---|
| | | # 判断匹配到的原因是否已经有下单/买入成功的代码 |
|---|
| | | codes_delegate = set(trade_manager.get_codes_by_trade_states( |
|---|
| | | codes_delegate = set(trade_manager.CodesTradeStateManager().get_codes_by_trade_states_cache( |
|---|
| | | {trade_manager.TRADE_STATE_BUY_DELEGATED, trade_manager.TRADE_STATE_BUY_PLACE_ORDER})) |
|---|
| | | codes_success = set(trade_manager.get_codes_by_trade_states( |
|---|
| | | codes_success = set(trade_manager.CodesTradeStateManager().get_codes_by_trade_states_cache( |
|---|
| | | {trade_manager.TRADE_STATE_BUY_SUCCESS})) |
|---|
| | | |
|---|
| | | codes = codes_delegate | codes_success |
|---|
