| | |
| | | def set_market_jingxuan_blocks(cls, datas): |
| | | """ |
| | | 设置精选流入数据 |
| | | @param datas: |
| | | @param datas:[(板块编号,板块名称,涨幅, 板块流入金额)] |
| | | @return: |
| | | """ |
| | | # 流入阈值 |
| | |
| | | fb = BlockMapManager().filter_blocks({data[1]}) |
| | | if blocks & fb: |
| | | continue |
| | | |
| | | |
| | | for b in fb: |
| | | fblock_money[b] = data[3] |
| | |
| | | @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, codes_delegate, codes_success): |
| | | 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: |
| | |
| | | yesterday_current_limit_up_codes, |
| | | before_blocks_dict, |
| | | current_limit_up_block_codes_dict, |
| | | high_level_general_code_blocks, delegate_codes, deal_codes) |
| | | 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) |