| | |
|---|
| | | # 获取基本信息 |
|---|
| | | code_datas = juejin.JueJinManager.get_gp_latest_info(gpset) |
|---|
| | | codes = [] |
|---|
| | | name_codes = {} |
|---|
| | | for _data in code_datas: |
|---|
| | | # 正常的股票 |
|---|
| | | if _data["sec_type"] == 1 and _data["sec_level"] == 1: |
|---|
| | | code = _data["symbol"].split(".")[1] |
|---|
| | | if code.find("30") != 0 and code.find("68") != 0: |
|---|
| | | name = _data["sec_name"] |
|---|
| | | codes.append(code) |
|---|
| | | # 保存代码对应的名称 |
|---|
| | | name_codes[name] = code |
|---|
| | | |
|---|
| | | redis_instance = __redisManager.getRedis() |
|---|
| | | # 删除之前的 |
|---|
| | | redis_instance.delete("gp_list") |
|---|
| | | redis_instance.delete("gp_list_names") |
|---|
| | | for d in codes: |
|---|
| | | redis_instance.sadd("gp_list", d) |
|---|
| | | redis_instance.set("gp_list_names", json.dumps(name_codes)) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 获取名称对应的代码 |
|---|
| | | def get_name_code(name): |
|---|
| | | redis_instance = __redisManager.getRedis() |
|---|
| | | val = redis_instance.get("gp_list_names") |
|---|
| | | if not val: |
|---|
| | | return None |
|---|
| | | val = json.loads(val) |
|---|
| | | return val.get(name) |
|---|
| | | |
|---|
| | | |
|---|
| | | def get_name_codes(): |
|---|
| | | redis_instance = __redisManager.getRedis() |
|---|
| | | val = redis_instance.get("gp_list_names") |
|---|
| | | if not val: |
|---|
| | | return None |
|---|
| | | val = json.loads(val) |
|---|
| | | return val |
|---|
| | | |
|---|
| | | |
|---|
| | | # 涨停犁碑坳 |
|---|
| | | def set_limit_up_list(gpset): |
|---|
| | | if gpset is None: |
|---|
| | | return |
|---|
| | | # 保存到内存中 |
|---|
| | | global_util.add_limit_up_codes(gpset) |
|---|
| | | # 获取基本信息 |
|---|
| | |
|---|
| | | value = redis_instance.get(key) |
|---|
| | | # print("redis:", key,value) |
|---|
| | | return value |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | # 设置位置的监听代码 |
|---|
