| | |
| | | block_codes_dict[b] = set() |
| | | block_count_dict[b].add(day) |
| | | block_codes_dict[b] |= self.__block_day_datas[day][b][2] |
| | | |
| | | # [(板块,涨停日期集合)] |
| | | block_count_list = [(k, block_count_dict[k]) for k in block_count_dict] |
| | | block_count_list.sort(key=lambda x: x[1], reverse=True) |
| | | block_count_list.sort(key=lambda x: len(x[1]), reverse=True) |
| | | block_count_list = block_count_list[:50] |
| | | # [(涨停原因,累计涨停次数,连续次数)] |
| | | fdatas = [] |
| | |
| | | for day in self.__days: |
| | | if day not in self.__block_day_datas: |
| | | continue |
| | | if b in self.__block_day_datas[day]: |
| | | total_limit_up_count = self.__block_day_datas[day][b][0] + self.__block_day_datas[day][b][1] |
| | | if b in self.__block_day_datas[day] and total_limit_up_count >= 3: |
| | | # 板块代码数量>=3个 |
| | | temp.append(day) |
| | | else: |
| | | c = len(temp) |