| | |
| | | |
| | | trading_dates = HistoryKDatasUtils.get_latest_trading_date(9) |
| | | max_day = trading_dates[0] |
| | | min_day = tool.date_sub(max_day, 180) |
| | | min_day = tool.date_sub(max_day, 120) |
| | | |
| | | block_map = self.__get_block_map() |
| | | # 统计最近180天涨停数据 |
| | | # 统计最近120天涨停数据 |
| | | # [(板块名称,代码, 日期, 是否炸板)] |
| | | code_block_infos = self.__list_code_blocks(min_day, max_day) |
| | | |
| | |
| | | temp_data_dict[k][2] += 1 |
| | | code_block_infos = [temp_data_dict[k] for k in temp_data_dict] |
| | | |
| | | min_day = tool.date_sub(max_day, 180) |
| | | min_day = tool.date_sub(max_day, 120) |
| | | |
| | | code_block_dict = {} # {"代码":{"板块": 涨停次数}} |
| | | for b in code_block_infos: |
| | |
| | | block_codes_dict[b] = [] |
| | | block_codes_dict[b].append((code, code_block_dict[code][b])) |
| | | |
| | | # 统计最近180天的涨停数据 {"代码": (涨停次数, 名称, 自由流通市值)} |
| | | # 统计最近120天的涨停数据 {"代码": (涨停次数, 名称, 自由流通市值)} |
| | | limit_up_info_map = self.__get_limit_up_info(min_day) |
| | | fdatas = [] |
| | | for b in block_codes_dict: |
| | |
| | | temp_codes = [x[0] for x in zylt_list] |
| | | code_info_list.sort(key=lambda x: x[1], reverse=True) |
| | | limit_up_count_max = code_info_list[:2] |
| | | for i in range(2, len(code_info_list)): |
| | | if code_info_list[i][1] == limit_up_count_max[-1][1]: |
| | | limit_up_count_max.append(code_info_list[i]) |
| | | else: |
| | | break |
| | | rank2_codes = set() |
| | | for d in limit_up_count_max: |
| | | if d[1] >= 6: |
| | |
| | | # print(datas) |
| | | datas = AnalysisBlockSpecialCodesManager().get_block_special_codes() |
| | | # print(datas) |
| | | for d in datas: |
| | | print(d) |
| | | BlockSpecialCodesManager().set_block_codes_list(datas) |
| | | # for d in datas: |
| | | # print(d) |
| | | # BlockSpecialCodesManager().set_block_codes_list(datas) |
| | | # print(BlockSpecialCodesManager().get_code_blocks("002582")) |