import json def __parseLimitUpItemData(data): # (代码, 名称, 首次涨停时间, 最近涨停时间, 几板, 涨停原因, 板块, 实际流通, 主力净额, 涨停原因代码, 涨停原因代码数量) return data[0], data[1], data[4], data[4], data[18], data[5], data[12], data[13], data[8], data[19], data[20] def parseLimitUpData(data): if type(data) == str: data = json.loads(data) if int(data["errcode"]) != 0: raise Exception(f"解析数据出错,errcode:{data['errcode']}") list_ = data["list"] fresult_ = [] for d in list_: pdata = __parseLimitUpItemData(d) if pdata: fresult_.append(pdata) return fresult_ def parseMarketIndustry(data): if type(data) == str: data = json.loads(data) if int(data["errcode"]) != 0: raise Exception(f"解析数据出错,errcode:{data['errcode']}") list_ = data["list"] fresult_ = [] for d in list_: # (代码,名称,涨幅,主力净额) fresult_.append((d[0], d[1], d[3], d[6])) return fresult_ def parseMarketJingXuan(data): if type(data) == str: data = json.loads(data) if int(data["errcode"]) != 0: raise Exception(f"解析数据出错,errcode:{data['errcode']}") list_ = data["list"] fresult_ = [] for d in list_: # (代码,名称,强度,主力净额) fresult_.append((d[0], d[1], d[2], d[6])) return fresult_ def filter_block(block): if not block: return block return block.replace("概念", "")