| | |
| | | @param datas: |
| | | @return: |
| | | """ |
| | | # blocks = set() |
| | | # 老版本实现方式 |
| | | # for data in datas: |
| | | # if data[3] <= 0: |
| | | # break |
| | | # blocks.add(data[1]) |
| | | # cls.__top_jx_blocks = blocks |
| | | blocks = set() |
| | | for data in datas: |
| | | if data[3] <= 0: |
| | | break |
| | | if data[1] in constant.KPL_INVALID_BLOCKS: |
| | | continue |
| | | if data[3] < 1e8: |
| | | continue |
| | | blocks.add(data[1]) |
| | | cls.__top_jx_blocks = blocks |
| | | if len(blocks) >= 10: |
| | | break |
| | | blocks.add(kpl_util.filter_block(data[1])) |
| | | # 记录精选流出日志 |
| | | cls.__top_jx_blocks = BlockMapManager().filter_blocks(blocks) |
| | | |
| | | @classmethod |
| | | def set_market_jingxuan_out_blocks(cls, datas): |
| | |
| | | @return: |
| | | """ |
| | | blocks = set() |
| | | for i in range(0, len(datas)): |
| | | if i >= 10 and int(tool.get_now_time_str().replace(":", "")) < int("100000"): |
| | | # 10点前看前10,十点后不看前10 |
| | | break |
| | | data = datas[i] |
| | | if data[3] > 0 - 5e7: |
| | | for data in datas: |
| | | if data[1] in constant.KPL_INVALID_BLOCKS: |
| | | continue |
| | | if data[3] > -1e8: |
| | | # 过滤5千万以上的 |
| | | break |
| | | blocks.add(data[1]) |
| | | if len(blocks) >= 10: |
| | | break |
| | | blocks.add(kpl_util.filter_block(data[1])) |
| | | |
| | | # 记录精选流出日志 |
| | | async_log_util.info(logger_kpl_jx_out, f"原数据:{datas[:10]} 板块:{blocks}") |
| | | cls.__top_jx_out_blocks = blocks |
| | | cls.__top_jx_out_blocks = BlockMapManager().filter_blocks(blocks) |
| | | |
| | | @classmethod |
| | | def get_top_market_jingxuan_blocks(cls): |
| | |
| | | cls.__can_buy_compute_result_dict[code] = ( |
| | | can_buy_blocks, unique, msg, can_buy_strong_blocks, keys, active_buy_blocks) |
| | | |
| | | |
| | | if __name__ == "__main__": |
| | | pass |