| | |
| | | import enum |
| | | import json |
| | | |
| | | from db import mysql_data_delegate as mysql_data |
| | | |
| | | |
| | | def parse_kpl_datas(results): |
| | | start_y = -1 |
| | |
| | | # (代码,名称,强度,主力净额) |
| | | fresult_.append((d[0], d[1], d[2], d[6])) |
| | | return fresult_ |
| | | |
| | | |
| | | class KPLPlatManager: |
| | | def save_plat(self, _id, name): |
| | | if not _id: |
| | | return |
| | | mysqldb = mysql_data.Mysqldb() |
| | | key = f"{_id}-{name}" |
| | | results = mysqldb.select_one(f"select * from kpl_plate where _name='{name}'") |
| | | if not results: |
| | | mysqldb.execute(f"insert into kpl_plate(_id,_name,_key) values({_id},'{name}','{key}')") |
| | | |
| | | def get_plat(self, name): |
| | | mysqldb = mysql_data.Mysqldb() |
| | | results = mysqldb.select_one(f"select * from kpl_plate where _name='{name}'") |
| | | if results: |
| | | return results[0] |
| | | return None |
| | | |
| | | def get_same_plat_names(self, name): |
| | | mysqldb = mysql_data.Mysqldb() |
| | | plate = self.get_plat(name) |
| | | if not plate: |
| | | return {name} |
| | | results = mysqldb.select_all(f"select _name from kpl_plate where _id='{plate}'") |
| | | return set([r[0] for r in results]) |
| | | |
| | | def get_same_plat_names_by_id(self, id_): |
| | | mysqldb = mysql_data.Mysqldb() |
| | | results = mysqldb.select_all(f"select _name from kpl_plate where _id='{id_}'") |
| | | return set([r[0] for r in results]) |
| | | |
| | | |
| | | # 获取高位板的数量 |
| | | def get_high_level_count(key): |
| | | if key.find("连板") >= 0: |
| | | # 形式如: 3连板 |
| | | return int(key.replace("连板", "")) |
| | | elif key.find("天") >= 0 and key.find("板") >= 0: |
| | | # 形式如:5天4板 |
| | | return int(key.split("天")[1].replace("板", "")) |
| | | # 形式如:首板 |
| | | return 1 |
| | | |
| | | |
| | | if __name__ == "__main__": |
| | | print(get_high_level_count("首板")) |
| | | print(get_high_level_count("5天4板")) |
| | | print(get_high_level_count("2连板")) |
| | | print(get_high_level_count("4连板")) |