Run any Skill in Manus with one click

stock-data-fetcher

Stars7

Forks1

UpdatedJune 28, 2026 at 14:15

A股实时行情数据抓取系统。支持大盘指数、全市场涨幅榜、涨停识别（含连板天数反推）、板块涨跌排行、个股快照、龙虎榜、资金流向、竞价数据、北向资金。触发词：数据、行情、涨停、连板、指数、板块、涨幅榜、日K、反推连板、市场情绪、实时数据、A股数据、龙虎榜、资金流向、北向、竞价。

Installation

Install with Codex or Claude Copy this prompt, paste it into Codex, Claude, or another assistant, and let it review the skill page and install it for you.

Run Skill in Manus

Source

meiwulang

meiwulang/dalh

View GitHub Repository View Creator Repositories

Download

Run Skill in Manus

Related occupationsSOC

Based on SOC occupation classification

Software DevelopersComputer and Mathematical Occupations·SOC 15-1252

SKILL.md

readonly

A股实时行情数据抓取系统

多源聚合数据体系（新浪 + 东方财富 + 腾讯 + mootdx通达信 + 百度 + 同花顺 + 悟道A股），用于全市场短线交易数据的实时采集与分析。

一、数据接口总览

序号	数据源	协议	封IP风险	鉴权	核心用途
1	新浪财经	HTTP	✅ 低	无需	大盘指数、个股实时快照（最稳定兜底）
2	东方财富	HTTP	⚠️ 中	无需	全市场涨幅榜、行业/概念/地区板块排行、个股明细
3	腾讯财经 ⭐	HTTP	✅ 极低	无需	实时价、PE/PB/市值/换手率/涨跌停价/指数/ETF
4	mootdx（通达信） ⭐	TCP:7709	✅ 极低	无需	K线(多周期)+五档盘口+逐笔成交+46字段实时报价
5	百度股市通	HTTP	✅ 极低	无需	日K线自带MA5/MA10/MA20均价
6	同花顺	HTTP	✅ 极低	无需	强势股归类、题材归因、北向资金流向
7	涨停池（东财） ⭐	HTTP	⚠️ 中	无需	涨停股所属行业/概念/5日/10日/20日涨幅/涨停原因
8	昨日涨停BK0815	HTTP	⚠️ 中	无需	连板成功率、涨停溢价、晋级率
9	悟道A股 🔑	HTTP	✅ 低	需API Key	仅涨停梯队ladder可用（数据最丰富，含涨停原因/连板/主营/题材）；龙虎榜等需网页登录JWT不开放
10	akshare 涨停池三件套 ⭐	HTTP	✅ 低	无需	涨停池(含连板数)/炸板池/跌停池 — 替代悟道涨停梯队
11	efinance（东财封装库） ⭐	HTTP	✅ 低	无需	龙虎榜/逐分钟资金流/板块成分股/板块归属 — 替代悟道龙虎榜+资金流

1.1 新浪指数快照（最稳定·兜底）

GET https://hq.sinajs.cn/list={codes}
Header: Referer: https://finance.sina.com.cn

指数编码：

指数	编码
上证指数	`s_sh000001`
深证成指	`s_sz399001`
创业板指	`s_sz399006`
科创50	`s_sh000688`
沪深300	`s_sh000300`
中证1000	`s_sh000852`
北证50	`s_sz899050`

个股编码规则：

沪市：sh{6位代码} → 例：sh600353
深市：sz{6位代码} → 例：sz002141
科创板：sh{6位代码} → 例：sh688598
北交所：bj{6位代码}

批量请求示例：

https://hq.sinajs.cn/list=s_sh000001,s_sz399001,s_sz399006,s_sh000688,sh600353,sz002141,sh688598

返回格式（ISO-8859-1编码，需转UTF-8）：

var hq_str_s_sh000001="上证指数,4100.35,-7.72,-0.19,3628520,85464445";
var hq_str_sz002141="贤丰控股,4.600,4.280,4.710,4.710,4.460,4.710,0.000,52141350,241070243.000,...";

字段含义（指数）：名称, 现价, 涨跌额, 涨跌幅%, 成交量(手), 成交额(元)

字段含义（个股）：名称, 今开, 昨收, 现价, 最高, 最低, 买一价, 卖一价, 成交量(股), 成交额(元), 盘口明细...

1.2 东方财富全市场涨幅榜（核心）

GET https://push2.eastmoney.com/api/qt/clist/get?pn=1&pz=500&po=1&np=1&fltt=2&fid=f3&fs=m:0+t:6,m:0+t:80,m:1+t:2,m:1+t:23,m:0+t:81+s:2048&fields=f12,f13,f14,f2,f3,f4,f5,f6,f8,f15,f16,f17,f18,f20,f21,f62
Header: Referer: https://quote.eastmoney.com

参数说明：

参数	含义
`pn=1`	页码
`pz=500`	每页500条
`po=1`	排序方式（1=升序，0=降序）
`fid=f3`	按涨跌幅排序
`fs=m:0+t:6,m:0+t:80,m:1+t:2,m:1+t:23,m:0+t:81+s:2048`	市场筛选（深主板+创业板+沪主板+科创板+北交所）
`fields=f12,f13,f14,f2,f3,f4,f5,f6,f8,f15,f16,f17,f18,f20,f21,f62`	返回字段

字段含义：

字段	含义
f12	股票代码
f13	市场标识（0=深市，1=沪市）
f14	股票名称
f2	现价
f3	涨跌幅%
f4	涨跌额
f5	成交量(手)
f6	成交额(万)
f8	换手率%
f15	最高价
f16	最低价
f17	今开
f18	昨收
f20	市值
f21	流通市值
f62	量比

1.3 东方财富个股快照

GET https://push2.eastmoney.com/api/qt/stock/get?secid={market}.{code}&fields=f43,f44,f45,f46,f47,f48,f49,f50,f51,f52,f57,f58,f60,f71,f84,f85,f86,f107,f116,f117,f127,f168,f169,f170,f171,f191,f192,f193,f194,f195,f196,f197,f198

secid规则：

市场	secid格式
深市（主板/创业板）	`0.{6位代码}` → 例：`0.002141`
沪市（主板/科创板）	`1.{6位代码}` → 例：`1.600353`
北交所	按接口返回的 `f13.code` 组合

关键字段：

字段	含义
f43	现价
f44	最高
f45	最低
f46	今开
f47	涨停价
f48	跌停价
f57	股票代码
f58	股票名称
f60	昨收
f71	成交量(手)
f84	总市值
f85	流通市值
f86	市盈率
f107	涨跌幅
f116	换手率
f127	涨跌额
f168	换手率(实)
f169	涨跌额
f170	涨跌幅
f171	振幅%

1.4 东方财富日K线（反推连板天数）

GET https://push2his.eastmoney.com/api/qt/stock/kline/get?secid={market}.{code}&fields1=f1,f2,f3,f4,f5,f6&fields2=f51,f52,f53,f54,f55,f56,f57,f58,f59,f60,f61&klt=101&fqt=1&beg=20260601&end=20260618

参数说明：

参数	含义
secid	`{market}.{code}`（同个股快照规则）
fields1	固定为 f1,f2,f3,f4,f5,f6
fields2	f51=日期, f52=开盘, f53=收盘, f54=最高, f55=最低, f56=成交量, f57=成交额, f58=振幅, f59=涨跌幅%, f60=涨跌额, f61=换手率%
klt=101	日K线
fqt=1	前复权
beg/end	起止日期 `YYYYMMDD`

返回格式：

{
  "data": {
    "klines": [
      "2026-06-18,40.55,42.01,42.01,41.50,31050969,1289684694.00,3.82,10.00,3.82,5.46",
      "2026-06-17,35.80,38.19,38.48,35.23,...,...",
      ...
    ]
  }
}

每根K线字段：日期, 开盘, 收盘, 最高, 最低, 成交量, 成交额, 振幅, 涨跌幅%, 涨跌额, 换手率%

反推连板算法：

lines = kline_data.split(';')
board_days = 0
for i, line in enumerate(lines):
    fields = line.split(',')
    chg_pct = float(fields[8])  # 涨跌幅%
    close = float(fields[2])
    if chg_pct >= 9.8:  # 主板涨停标准
        board_days += 1
    elif chg_pct >= 19.5 and secid.startswith('0'):  # 创业板/科创板
        board_days += 1
    else:
        break  # 遇到不涨停的K线就停止计数

1.5 东方财富板块排行（行业·概念·地区）

同一接口，fs 参数区分三种板块类型：

板块类型	`fs` 参数	说明
🗺️ 地区板块（领涨地区）	`m:90+t:1`	各省/直辖市/自治区
🏭 行业板块（领涨板块）	`m:90+t:2`	申万行业分类
💡 概念板块（领涨题材）	`m:90+t:3`	热门概念/题材

请求示例：

# 行业板块（涨跌幅降序，取前20）
GET https://push2.eastmoney.com/api/qt/clist/get?pn=1&pz=20&po=0&np=1&fltt=2&invt=2&fs=m:90+t:2&fields=f2,f3,f4,f8,f12,f14,f20,f21,f62,f104,f105,f128,f136&fid=f3

# 概念板块
GET https://push2.eastmoney.com/api/qt/clist/get?pn=1&pz=20&po=0&np=1&fltt=2&invt=2&fs=m:90+t:3&fields=f2,f3,f4,f8,f12,f14,f20,f21,f62,f104,f105,f128,f136&fid=f3

# 地区板块
GET https://push2.eastmoney.com/api/qt/clist/get?pn=1&pz=20&po=0&np=1&fltt=2&invt=2&fs=m:90+t:1&fields=f2,f3,f4,f8,f12,f14,f20,f21,f62,f104,f105,f128,f136&fid=f3

返回字段含义：

字段	含义
f12	板块代码（如 BK1128）
f14	板块名称
f2	最新价
f3	涨跌幅%
f4	涨跌额
f8	换手率%
f20	总市值
f21	流通市值
f62	量比
f104	上涨家数
f105	下跌家数
f128	领涨股名称
f136	领涨股涨跌幅%

获取板块成分股：拿到板块代码（如 BK1128）后，用以下接口获取成分股：

GET https://push2.eastmoney.com/api/qt/clist/get?pn=1&pz=100&po=0&np=1&fltt=2&fs=b:BK1128&fields=f12,f14,f2,f3,f4,f5,f6,f8,f15,f16,f17,f18,f20,f21&fid=f3

备注：fid=f3 排序可能不生效，建议在应用层按 f3 排序。

1.6 东方财富涨停池接口（备用）

GET https://push2ex.eastmoney.com/getTopicZTPool?ut=7eea3edcaed734bea9cbfc24409ed989&d=20260618&pageindex=0&pagesize=500&sort=fbt:asc

注意：此接口当前返回 data:null，不可靠。改用涨幅榜+日K反推法替代。

1.7 腾讯财经（实时估值·不封IP）⭐

GET https://web.ifzq.gtimg.cn/appstock/app/fqkline/get?param={code},{period},{beg},{end},{limit}

核心端点：

用途	URL
日K线（含MA均线）	`https://web.ifzq.gtimg.cn/appstock/app/fqkline/get?param=sh600519,day,,,10`
实时行情/估值	`https://qt.gtimg.cn/q=sh600519`
批量行情	`https://qt.gtimg.cn/q=sh600519,sz000001,sh600036`

返回格式（批量行情）：

v_sh600519="1
名称,代码,现价,涨跌幅%,涨跌额,成交量(手),成交额(万),总市值,流通市值,PE(TTM),换手率%,最高,最低,今开,昨收,涨停价,跌停价,...

v_sz000001="...

字段含义（按位置索引）：

索引	含义
1	名称
2	代码
3	现价
5	涨跌幅%
6	涨跌额
7	成交量(手)
8	成交额(万)
44	最高
45	最低
46	今开
47	昨收
48	涨停价
49	跌停价
56	换手率%
59	总市值
60	流通市值
62	PE(TTM)

特点：

不封IP，比东方财富更稳定
返回数据包含 PE/PB/市值/换手率（新浪没有的估值数据）
日K线端点返回的数据自带 MA5/MA10/MA20 均线（需解析）
适合作为东方财富的兜底替代

1.8 mootdx 通达信接口（最全K线·盘口·不封IP）⭐

# 安装
pip install 'mootdx[all]'

核心能力：

from mootdx.quotes import Quotes

client = Quotes.factory(market='std')  # 标准通达信行情

# 1. K线数据（多周期）
kline = client.bars(symbol='600519', frequency=9, start=0, count=120)
# frequency: 9=日线, 5=周线, 6=月线, 8=60分钟, 3=30分钟, 2=15分钟, 1=5分钟

# 2. 实时行情（46字段）
quote = client.quotes(symbols=['600519', '000001'])
# 返回：代码、名称、今开、昨收、现价、最高、最低、总手、金额、涨跌、涨幅、换手率、市盈率、市净率、总市值、流通市值...

# 3. 五档盘口
ticks = client.transactions(symbol='600519', start=0, count=100)  # 逐笔成交

# 4. 指数K线
index_kline = client.bars(symbol='000001', frequency=9, start=0, count=120)  # 上证指数

特点：

通达信官方数据通道，极低封IP风险
不需要网页爬取，TCP 协议直连，速度快
K线支持多周期（1/5/15/30/60分钟，日/周/月）
支持五档盘口和逐笔成交（Level-2 级数据）
强烈推荐替代东方财富日K线接口

1.9 百度股市通（K线自带均线）

GET https://gupiao.baidu.com/api/stocks/stockkline?code=sh600519&ktype=day&start_date=20260601&end_date=20260618

特点：

返回直接包含 MA5/MA10/MA20 均价，省去本地计算
极低封IP风险
适合需要均线数据时补充使用

1.10 同花顺热点·北向资金（零鉴权）

北向资金流向：

GET https://data.10jqka.com.cn/funds/ggjj/op=down/globalapi/market/board/north_flow

强势股/题材归类：

GET https://data.10jqka.com.cn/funds/hkgg/field/trade_hf/order/asc/page/1/ajax/1/

特点：

零鉴权，不封IP
数据直接可用，无需解析复杂格式
北向资金适合盘中监控外资动向

1.11 东方财富涨停池（含涨停原因·连板·所属行业）⭐

通过东方财富全市场榜单 + 涨幅筛选，提取涨停池并关联行业/概念/多周期涨幅。

请求地址：同 1.2 全市场涨幅榜，增加以下字段：

字段	含义	用途
f100	所属行业	快速识别涨停股的行业归属
f103	备注（概念标签）	涨停原因/概念归属的关键字段
f109	5日涨跌幅%	中期强度排名
f152	20日涨跌幅%	中期趋势强度
f161	10日涨跌幅%	短期趋势强度

涨停原因获取逻辑：

涨停原因 = 取 f103（备注/概念标签）解析关键词归类
- 如 f103 包含 "AI"、"机器人"、"新能源" 等 → 按对应概念归类
- 结合 f100（所属行业）+ 涨停股所属板块代码交叉验证

简化版涨停池（含连板数据）推荐用 akshare：

import akshare as ak
df = ak.stock_zt_pool_em(date='20260618')
# 返回：代码, 名称, 涨跌幅, 封单金额, 流通市值, 所属行业, 涨停原因, 开板次数, 连板天数

1.12 全市场多周期涨幅排名（5日/10日/20日涨幅）

在东方财富全市场榜单中排序 f109、f161、f152 即可获取多周期涨幅排名：

GET https://push2.eastmoney.com/api/qt/clist/get?pn=1&pz=5000&po=0&np=1&fltt=2&fid=f109&fs=m:0+t:6,m:0+t:80,m:1+t:2,m:1+t:23,m:0+t:81+s:2048&fields=f12,f14,f2,f3,f4,f5,f6,f8,f109,f152,f161,f100,f103

fid=f109&po=0 → 5日涨幅降序（近5日最强）
fid=f152&po=0 → 20日涨幅降序（近1月最强）
fid=f161&po=0 → 10日涨幅降序

1.13 涨跌家数细分统计

通过全市场榜单（pz=5000 拉取全量）在应用层按代码前缀细分统计：

板块	代码前缀	涨/跌判定
沪市主板	60xxxx	f3 > 0 上涨，f3 < 0 下跌
深市主板	00xxxx	同上
创业板	30xxxx	同上
科创板	688xxx	同上
北交所	4xxxxx, 8xxxxx	同上

1.14 昨日涨停今日表现（连板成功率）

GET https://push2.eastmoney.com/api/qt/clist/get?pn=1&pz=500&po=0&np=1&fltt=2&fs=b:BK0815&fields=f12,f14,f2,f3,f4,f5,f6,f8

BK0815 = 东方财富"昨日涨停"板块代码。通过该接口获取昨日涨停股今日的表现，用于计算：

连板成功率 = 今日继续涨停数 / 昨日涨停总数
涨停溢价 = 昨日涨停股今日平均涨幅

1.15 悟道A股 🔑（仅涨停梯队 API 可用·数据最丰富）

⚠️ 2026-06-26 实测真相：悟道官网（stock.quicktiny.cn）注册申请的 lb_ API Key 仅 /api/ladder 一个接口可用。其龙虎榜等接口走 /api/admin/* 路径，需网页登录后的 JWT（cookie+Bearer），不开放给 API Key。本节只保留实测可用的 ladder，原登记的"26 个 API / 龙虎榜 / 竞价 / 资金流向 / 炸板池"等接口路径均不开放给 API Key 调用——这些能力改由本 skill 1.16（akshare 涨停池三件套）和 1.17（efinance）免费覆盖。

获取 API Key：https://stock.quicktiny.cn/developer（注册后在开发者后台拿 lb_ 开头的 Key）

唯一可用接口：涨停梯队

# 涨停梯队（唯一对 API Key 开放的接口，数据极丰富）
curl -s -H "Authorization: Bearer $LB_API_KEY" \
  "https://stock.quicktiny.cn/api/ladder?date=$(date +%Y-%m-%d)"

返回字段（每只涨停股，2MB 量级）：

字段	含义
`continue_num`	连板天数（直接返回，无需反推）
`high_days`	总板数描述（如 `7天6板`）
`limit_up_type`	封板类型（`一字板`/`换手板`等）
`reason_type`	涨停原因（如 `氮化铝+可控核聚变+定增受理`）
`reason_info`	涨停原因详细说明（多段公告摘要）
`primary_theme`	主题材
`industry`	所属行业
`main_business`	主营业务
`business_scope`	经营范围
`first_limit_up_time` / `last_limit_up_time`	首/末次封板时间（Unix 时间戳）
`limitAmount`	封板资金
`tradeAmount`	成交额
`turnover_rate` / `actual_turnover_rate`	换手率（名义/真实）
`kpl_*`	开盘啦系列字段（开盘竞价数据）
`open_num`	开板次数

特点：

✅ ladder 数据质量全 skill 最高——连板天数+涨停原因+主营+题材+封板资金一站式返回，远超 akshare stock_zt_pool_em
✅ 含 kpl_* 开盘啦字段（开盘竞价相关），是其它免费源没有的
⚠️ 仅此一个接口对 API Key 开放；龙虎榜/资金流向/炸板池等需网页登录 JWT，不开放给 API Key
⚠️ Key 有调用频次限制（免费额度）
🔁 龙虎榜需求 → 用 efinance get_daily_billboard（1.17 节，免费）
🔁 资金流向需求 → 用 efinance get_today_bill（1.17 节，免费，逐分钟更细）
🔁 炸板池需求 → 用 akshare stock_zt_pool_zbgc_em（1.16 节，免费）

1.16 akshare 涨停池三件套（免费·替代悟道涨停梯队）⭐

akshare 封装东方财富涨停池专用接口，连板天数/炸板次数/封板资金直接返回，无需自推算、无需 API Key。2026-06-26 实测三接口全部可用。

安装：pip install akshare

import akshare as ak

# 1. 涨停池（含连板数·封板资金·炸板次数·涨停统计·所属行业）
df_zt = ak.stock_zt_pool_em(date='20260625')
# 列：代码, 名称, 涨跌幅, 最新价, 成交额, 流通市值, 总市值, 换手率,
#     封板资金, 首次封板时间, 最后封板时间, 炸板次数, 涨停统计, 连板数, 所属行业
# 例：兴业科技(002674) 连板数=5 涨停统计='5/5' 炸板次数=0 封板资金=4.4亿 所属行业='纺织制造'

# 2. 炸板池（盘中触及涨停但未封住）
df_zb = ak.stock_zt_pool_zbgc_em(date='20260625')
# 列：代码, 名称, 涨跌幅, 最新价, 涨停价, 成交额, 流通市值, 换手率,
#     涨速, 首次封板时间, 炸板次数, 涨停统计, 振幅, 所属行业
# 例：上海港湾(605598) 炸板次数=1 涨停统计='2/1' 振幅=8.51%

# 3. 跌停池（含连续跌停·开板次数·封单资金）
df_dt = ak.stock_zt_pool_dtgc_em(date='20260625')
# 列：代码, 名称, 涨跌幅, 最新价, 成交额, 流通市值, 动态市盈率, 换手率,
#     封单资金, 最后封板时间, 板上成交额, 连续跌停, 开板次数, 所属行业

连板梯队构建（无需自推算）：

df = ak.stock_zt_pool_em(date=YYYYMMDD)
# 直接按"连板数"列分组即得连板梯队
ladder = df.groupby('连板数').apply(
    lambda g: list(zip(g['名称'], g['代码'], g['封板资金'], g['所属行业']))
).to_dict()
# 输出：{5: [('兴业科技','002674',4.4亿,'纺织制造')], 4: [...], 3: [...], ...}

炸板率计算：

zt_n = len(ak.stock_zt_pool_em(date=d))      # 封板数
zb_n = len(ak.stock_zt_pool_zbgc_em(date=d)) # 炸板数
break_rate = zb_n / (zt_n + zb_n) * 100       # 炸板率%

特点：

✅ 连板数直接返回，彻底替代"东财涨幅榜+日K反推"算法
✅ 炸板次数/封板资金直接返回，无需悟道 Key
✅ 涨停统计列格式 '连板天数/封板成功天数'，可识别伪连板
✅ 含所属行业，涨停原因归类一步到位
⚠️ 网络不稳时三个接口可能独立成功/失败，断连时分别重试三个接口，不要因一个失败放弃全部

1.17 efinance 龙虎榜·资金流·板块归属（免费·替代悟道龙虎榜+资金流）⭐

efinance 是基于东方财富爬虫的封装库，API 简洁、零鉴权。2026-06-26 实测龙虎榜/逐分钟资金流/板块归属/板块成分股全部可用。资金流逐分钟返回，比悟道的聚合资金流更细。

安装：pip install efinance

import efinance as ef

# 1. 龙虎榜（当日全部上榜股）— 替代悟道 /dragon-tiger
df_lhb = ef.stock.get_daily_billboard('2026-06-25')
# 列：股票代码, 股票名称, 上榜日期, 解读, 收盘价, 涨跌幅, 换手率,
#     龙虎榜净买额, 龙虎榜买入额, 龙虎榜卖出额, 龙虎榜成交额, 市场总成交额,
#     净买额占总成交比, 成交额占总成交比, 流通市值, 上榜原因
# 例：101行 × 16列；含"上榜原因"和"解读"（如"卖一主卖，成功率50.92%"）

# 2. 逐分钟资金流（主力/超大单/大单/中单/小单）— 替代悟道 /money-flow
df_flow = ef.stock.get_today_bill('600519')
# 列：股票名称, 股票代码, 时间, 主力净流入, 小单净流入, 中单净流入,
#     大单净流入, 超大单净流入
# 例：240行（全天每分钟一行），可计算主力全天累计净流入

# 3. 个股所属全部板块（行业+概念）— 替代东财交叉拼接
df_board = ef.stock.get_belong_board('600519')
# 列：股票名称, 股票代码, 板块代码, 板块名称, 板块涨幅
# 例：29行 × 5列；贵州茅台属于食品饮料、白酒、超级品牌等29个板块

# 4. 板块成分股（按板块名称查）— 替代东财手搓成分股接口
df_mem = ef.stock.get_members('白酒')
# 列：指数代码, 指数名称, 股票代码, 股票名称, 股票权重
# 例：17行 × 5列；含权重，可识别板块龙头

# 5. 最新实时快照（单股，37字段 Series）
snap = ef.stock.get_quote_snapshot('600519')  # pandas Series

# 6. IPO 审核队列（题材打新参考）
df_ipo = ef.stock.get_latest_ipo_info()
# 列：发行人全称, 审核状态, 注册地, 证监会行业, 保荐机构, 会计师事务所,
#     更新日期, 受理日期, 拟上市地点

主力资金全天累计净流入：

df = ef.stock.get_today_bill('600519')
main_net = df['主力净流入'].sum()   # 全天主力净流入（元）
big_net  = df['超大单净流入'].sum() # 超大单累计

龙虎榜净买额排行：

df = ef.stock.get_daily_billboard(date_str)
top_buy = df.sort_values('龙虎榜净买额', ascending=False).head(10)
for _, r in top_buy.iterrows():
    print(f"{r['股票名称']}({r['股票代码']}) 净买{r['龙虎榜净买额']/1e4:.0f}万 原因:{r['上榜原因']}")

特点：

✅ 龙虎榜含上榜原因+解读，比悟道字段更丰富（含"成功率"统计）
✅ 资金流逐分钟返回，可做盘中分时资金流分析（悟道只有聚合值）
✅ 板块归属一键查全量，替代东财"涨幅榜交叉拼接板块代码"的笨办法
✅ 板块成分股按名称查，无需先拿板块代码
✅ IPO 审核队列是当前 skill 完全缺失的数据（打新题材/次新股预热）
⚠️ get_realtime_quotes(全市场批量)和get_quote_history(K线)底层走 push2.eastmoney.com，断连风险同东财原生接口，这两块仍用腾讯/mootdx，efinance 仅用于龙虎榜/资金流/板块

二、涨停筛选规则

市场板块	涨停判定标准
沪市主板(sh60xxxx)	涨幅 >= 9.8%
深市主板(sz00xxxx/sz30xxxx非3开头)	涨幅 >= 9.8%
创业板(sz30xxxx)	涨幅 >= 19.5%
科创板(sh688xxx)	涨幅 >= 19.5%
北交所	涨幅 >= 29%
ST/*ST	涨幅 >= 4.8%

三、数据采集流程

流程1：获取大盘情绪

1. 新浪指数快照 → 获取7大指数实时数据
2. 或：腾讯财经批量行情 → 同步获取指数+估值数据
3. 计算：涨跌家数比、涨停/跌停比
4. 输出：市场情绪温度（冰点/低迷/正常/活跃/高潮）

流程2：获取涨停梯队

方式A（自推算·免费·无需Key）：

1. 东方财富涨幅榜(pz=500) → 全市场涨幅排序
2. 按涨停规则筛选 → 得到当日涨停股列表（含涨幅信息）
3. 对每只涨停股 → mootdx通达信K线(或东财K线兜底) → 反推连续涨停天数
4. 按涨停天数分组 → 输出连板梯队（6板/5板/4板/3板/2板/首板）
5. 统计：严格涨停总数、炸板数（通过涨幅靠近涨停但未封住识别）

方式B（悟道API·需Key·推荐）：

1. 悟道 /ladder → 直接获取连板梯队（含每层个股）
2. 悟道 /break-pool → 获取炸板池（含炸板率）
3. 悟道 /limit-pool → 获取跌停池
4. 合并输出完整情绪数据

流程3：获取板块热点（领涨板块·领涨题材·领涨地区）

方式A（免费·推荐）：

1. 东方财富行业板块排行 t:2 → 🏭 领涨板块 Top 20
2. 东方财富概念板块排行 t:3 → 💡 领涨题材 Top 20
3. 东方财富地区板块排行 t:1 → 🗺️ 领涨地区 Top 10
4. 每板块均含：涨跌幅、上涨/下跌家数、领涨股名称及涨幅
5. 同花顺北向资金 → 监测外资流向
6. 三表交叉验证 → 识别真主线（行业共振+题材配合+地域集中）

方式B（悟道API·需Key）：

1. 悟道 /hot-concept → 最强风口（按涨停聚集度排名）
2. 悟道 /sector-rotation → 板块四象限动量分析
3. 悟道 /concept-constituents → 热点概念成分股

流程4：获取资金流向（新增）

1. 悟道 /money-flow → 个股/板块/大盘资金流向
2. 或：同花顺北向资金接口 → 外资净买入额
3. 识别主力净流入/流出板块

流程5：获取龙虎榜（新增·需悟道Key）

1. 悟道 /dragon-tiger → 当日龙虎榜数据
2. 提取：买入营业部、卖出营业部、净买额
3. 识别：知名游资席位动向（如：中关村、拉萨、深股通等）

流程6：获取竞价数据（新增·需悟道Key）

1. 悟道 /auction → 个股集合竞价成交数据
2. 分析：竞价量能、撮合价格、分歧程度
3. 用于：开盘前的隔夜方向判断

流程7：获取个股详情

轻量版（腾讯·最快·不封IP）：

1. 腾讯 qt.gtimg.cn 批量行情 → PE/PB/市值/换手率/涨停跌停价/五档

标准版（新浪兜底）：

1. 新浪个股快照 → 实时分时数据（稳定兜底）
2. 东方财富个股快照 → 详细指标（市值/换手率/振幅等）

专业版（mootdx·最全）：

1. mootdx quotes() → 46字段实时行情（含盘口深度）
2. mootdx bars() → 多周期K线（替代东财日K）
3. mootdx transactions() → 逐笔成交数据

流程8：涨跌家数细分统计（新增）

1. 全市场涨幅榜(pz=5000) → 拉取全量股票行情
2. 按 f3 涨跌幅统计 → 上涨/下跌/平盘家数
3. 按代码前缀细分 → 沪主板/深主板/创业板/科创板/北交所
4. 累计成交额 → 全市场总成交额(亿)

流程9：多周期涨幅排名（新增）

1. 东方财富全市场榜单 fid=f109 → 5日涨幅降序排名
2. 东方财富全市场榜单 fid=f161 → 10日涨幅降序排名
3. 东方财富全市场榜单 fid=f152 → 20日涨幅降序排名
4. 结合涨停股 → 识别中期强势股

流程10：连板成功率监控（新增）

1. 昨日涨停板块 BK0815 → 获取昨日涨停股今日表现
2. 统计继续涨停数 → 计算连板成功率
3. 统计大阳线数 → 计算溢价率
4. 平均涨幅 → 涨停溢价

四、市场情绪指标体系

4.1 基础情绪指标（免费接口即可获取）

指标	数据来源	说明
涨停数	涨幅榜筛选 / 悟道涨停统计	全市场严格涨停家数
连板数	涨幅榜+日K反推 / 悟道涨停梯队	2板及以上连板股数量
最高板	日K反推 / 悟道涨停梯队	当前最高连板高度
涨停晋级率	昨日首板→今日2板比例	反映接力意愿
跌停数	akshare `stock_zt_pool_dtgc_em(date)`（唯一正确源）	市场亏钱效应
涨跌家数比	涨幅榜	上涨/下跌家数
炸板率	悟道炸板池 / 涨幅榜估算	涨停打开比例
成交额	指数快照 / 腾讯行情	全市场总成交额
涨跌停比	涨停数/跌停数	情绪强度
指数强度	新浪/腾讯指数快照	主要指数涨跌幅
市场温度	综合以上	冰点/低迷/正常/活跃/高潮

4.2 进阶情绪指标（需悟道Key）

指标	数据来源	说明
涨停溢价	悟道涨停溢价	涨停股次日开盘溢价率
封板率	悟道涨跌停统计	封板数/（封板数+炸板数）
最强风口	悟道最强风口	按涨停聚集度排名的板块
封板事件	悟道封板事件流	实时封板/炸板事件，精确到秒
北向资金	悟道资金流向 / 同花顺	外资当日净买入额
主力净流入	悟道资金流向	主力资金流入/流出
板块轮动	悟道板块轮动	板块动量与强度四象限
异动检测	悟道异动检测	个股异常交易行为
龙虎榜	悟道龙虎榜	游资席位动向
竞价数据	悟道竞价数据	集合竞价成交情况

五、输出格式模板

大盘情绪快照输出模板

📊 大盘情绪（YYYY-MM-DD HH:MM）
上证 {点位} {涨跌幅}% | 深证 {点位} {涨跌幅}%
创业板 {点位} {涨跌幅}% | 科创50 {点位} {涨跌幅}%
成交额 {万亿} ｜ 涨停 {N} 只 ｜ 跌停 {N} 只 ｜ 炸板率 {N}%

涨停梯队输出模板

📈 连板梯队
- 4板：{名称}({代码})
- 3板：{名称}({代码})、{名称}({代码})
- 2板：{名称}({代码})、{名称}({代码}) ...
- 首板：共 {N} 只
- 全市场严格涨停：{N} 只

板块排行输出模板

🔥 行业板块涨幅前5
1. {板块名称} {涨幅}% ｜ 领涨：{领涨股}({涨幅}%) ｜ {上涨家数}/{下跌家数}

🔥 概念板块涨幅前5
1. {板块名称} {涨幅}% ｜ 领涨：{领涨股}({涨幅}%) ｜ {上涨家数}/{下跌家数}

🔥 地区板块涨幅前5
1. {省份/直辖市} {涨幅}% ｜ 领涨：{领涨股}({涨幅}%) ｜ {上涨家数}/{下跌家数}

快速调用的 Python 示例

# 一行获取领涨行业
industries = em_board_ranks("t:2", top_n=10)
for b in industries:
    print(f"{b['f14']}: {b['f3']:+.2f}%  领涨:{b['f128']}({b['f136']}%)  {b['f104']}/{b['f105']}家")

# 一行获取领涨题材
concepts = em_board_ranks("t:3", top_n=10)

# 一行获取领涨地区
regions = em_board_ranks("t:1", top_n=10)

龙虎榜输出模板（新增·需悟道Key）

🐅 龙虎榜（YYYY-MM-DD）
{名称}({代码})：净买入 {N} 万
├─ 买一：{营业部} {金额}万
├─ 买二：{营业部} {金额}万
├─ 卖一：{营业部} {金额}万
└─ 卖二：{营业部} {金额}万

资金流向输出模板（新增·需悟道Key）

💰 资金流向
大盘：主力净流入 {N} 亿 ｜ 北向净买入 {N} 亿
板块净流入前3：{板块1}、{板块2}、{板块3}
板块净流出前3：{板块1}、{板块2}、{板块3}

竞价数据输出模板（新增·需悟道Key）

⏰ {名称}({代码}) 集合竞价
竞价量：{N} 万手 ｜ 撮合价：{price}
隔夜方向：{抢筹/分歧/砸盘}

涨跌家数细分模板（新增）

📊 全市场情绪
上涨 {N} 家 ｜ 下跌 {N} 家 ｜ 平盘 {N} 家 ｜ 成交额 {N} 亿
├─ 沪主板: ↑{N} ↓{N}
├─ 深主板: ↑{N} ↓{N}
├─ 创业板: ↑{N} ↓{N}
├─ 科创板: ↑{N} ↓{N}
└─ 北交所: ↑{N} ↓{N}

多周期涨幅排名模板（新增）

📈 5日涨幅 Top 5
1. {名称}({代码}) +{N}% ｜ {所属行业}
2. ...

📈 20日涨幅 Top 5
1. {名称}({代码}) +{N}% ｜ {所属行业}

连板成功率模板（新增）

🎯 连板晋级率
昨日涨停 {N} 只 → 今日继续涨停 {N} 只
晋级率: {N}% ｜ 大阳率(>=7%): {N}% ｜ 平均涨幅: {N}%

六、Python工具函数

import requests, json
from datetime import datetime

# ---------- 新浪接口 ----------
def sina_quote(codes_str: str) -> str:
    """获取新浪实时快照"""
    url = f"https://hq.sinajs.cn/list={codes_str}"
    headers = {"Referer": "https://finance.sina.com.cn"}
    resp = requests.get(url, headers=headers, timeout=10)
    resp.encoding = 'gbk'
    return resp.text

def parse_sina_index(text: str) -> list[dict]:
    """解析新浪指数数据"""
    results = []
    for line in text.strip().split('\n'):
        if not line.startswith('var hq_str_s_'):
            continue
        parts = line.split('="')[1].rstrip('";').split(',')
        name, price, change, pct = parts[0], parts[1], parts[2], parts[3]
        results.append({"name": name, "price": float(price), "change": float(change), "pct": float(pct)})
    return results

def parse_sina_stock(text: str) -> dict:
    """解析新浪个股数据"""
    line = text.strip().split('\n')[0]
    parts = line.split('="')[1].rstrip('";').split(',')
    return {
        "name": parts[0], "open": float(parts[1]), "yclose": float(parts[2]),
        "price": float(parts[3]), "high": float(parts[4]), "low": float(parts[5]),
        "volume": int(parts[8]), "amount": float(parts[9])
    }

# ---------- 东方财富接口 ----------
def em_market_ranks(pz: int = 500) -> list[dict]:
    """获取全市场涨幅榜"""
    url = ("https://push2.eastmoney.com/api/qt/clist/get"
           f"?pn=1&pz={pz}&po=1&np=1&fltt=2&fid=f3"
           "&fs=m:0+t:6,m:0+t:80,m:1+t:2,m:1+t:23,m:0+t:81+s:2048"
           "&fields=f12,f13,f14,f2,f3,f4,f5,f6,f8,f15,f16,f17,f18,f20,f21,f62")
    headers = {"Referer": "https://quote.eastmoney.com"}
    resp = requests.get(url, headers=headers, timeout=15)
    data = resp.json()
    return data.get('data', {}).get('diff', [])

def em_stock_kline(secid: str, beg: str = "20260601", end: str = None) -> list[str]:
    """获取日K线"""
    if end is None:
        end = datetime.now().strftime("%Y%m%d")
    url = (f"https://push2his.eastmoney.com/api/qt/stock/kline/get"
           f"?secid={secid}&fields1=f1,f2,f3,f4,f5,f6"
           f"&fields2=f51,f52,f53,f54,f55,f56,f57,f58,f59,f60,f61"
           f"&klt=101&fqt=1&beg={beg}&end={end}")
    headers = {"Referer": "https://quote.eastmoney.com"}
    resp = requests.get(url, headers=headers, timeout=15)
    data = resp.json()
    return data.get('data', {}).get('klines', [])

def em_board_ranks(board_type: str = "t:2", top_n: int = 20) -> list[dict]:
    """获取板块排行（含重试）
    board_type: 't:1'=地区板块, 't:2'=行业板块, 't:3'=概念板块
    返回字段：板块名称(f14)、涨跌幅(f3)、上涨家数(f104)、下跌家数(f105)、
             领涨股(f128)、领涨股涨幅(f136)、换手率(f8)、总市值(f20)
    """
    import time
    url = (f"https://push2.eastmoney.com/api/qt/clist/get"
           f"?pn=1&pz={top_n}&po=0&np=1&fltt=2&invt=2"
           f"&fs=m:90+{board_type}&fields=f2,f3,f4,f8,f12,f14,f20,f21,f62,f104,f105,f128,f136&fid=f3")
    headers = {"Referer": "https://quote.eastmoney.com"}
    for attempt in range(3):
        try:
            resp = requests.get(url, headers=headers, timeout=15)
            data = resp.json()
            items = data.get('data', {}).get('diff', [])
            return sorted(items, key=lambda x: x.get('f3', 0), reverse=True)
        except Exception:
            if attempt < 2:
                time.sleep(1)
                continue
            return []  # 断连时返回空列表，由调用方决定兜底策略

# ---------- 涨停筛选 ----------
def is_limit_up(item: dict) -> bool:
    """判断是否涨停"""
    pct = float(item.get('f3', 0))
    code = str(item.get('f12', ''))
    if code.startswith(('688', '300')):  # 科创板/创业板
        return pct >= 19.5
    elif code.startswith('4') or code.startswith('8'):  # 北交所
        return pct >= 29.0
    elif item.get('f14', '').startswith(('ST', '*ST')):
        return pct >= 4.8
    else:
        return pct >= 9.8

def calc_board_days(klines: list[str], code: str) -> int:
    """从日K反推连续涨停天数"""
    days = 0
    for kline in klines:
        fields = kline.split(',')
        pct = float(fields[8])  # 涨跌幅%
        if code.startswith(('688', '300')):
            if pct >= 19.5:
                days += 1
            else:
                break
        else:
            if pct >= 9.8:
                days += 1
            else:
                break
    return days

# ---------- 腾讯财经接口（不封IP·最稳定估值） ----------
def tx_quote(codes: str) -> str:
    """获取腾讯批量实时行情"""
    url = f"https://qt.gtimg.cn/q={codes}"
    resp = requests.get(url, timeout=10)
    resp.encoding = 'gbk'
    return resp.text

def parse_tx_quote(text: str) -> list[dict]:
    """解析腾讯行情数据"""
    results = []
    for line in text.strip().split('\n'):
        if not line.startswith('v_'):
            continue
        parts = line.split('="')[1].rstrip('";').split('~')
        results.append({
            "name": parts[1], "code": parts[2], "price": float(parts[3]) if parts[3] else 0,
            "pct": float(parts[32]) if parts[32] else 0, "change": float(parts[31]) if parts[31] else 0,
            "volume": int(parts[6]) if parts[6] else 0, "amount": float(parts[37]) if parts[37] else 0,
            "high": float(parts[33]) if parts[33] else 0, "low": float(parts[34]) if parts[34] else 0,
            "open": float(parts[35]) if parts[35] else 0, "yclose": float(parts[36]) if parts[36] else 0,
            "pe": float(parts[39]) if parts[39] else 0, "turnover": float(parts[38]) if parts[38] else 0,
            "total_mv": float(parts[45]) if parts[45] else 0, "float_mv": float(parts[44]) if parts[44] else 0,
            "high_limit": float(parts[48]) if parts[48] else 0, "low_limit": float(parts[49]) if parts[49] else 0,
        })
    return results

# ---------- mootdx 通达信接口（不封IP·最全K线） ----------
def mootdx_kline(code: str, frequency: int = 9, count: int = 120) -> list:
    """获取mootdx K线数据
    frequency: 9=日线, 5=周线, 6=月线, 8=60分, 3=30分, 2=15分, 1=5分
    """
    try:
        from mootdx.quotes import Quotes
        client = Quotes.factory(market='std')
        return client.bars(symbol=code, frequency=frequency, start=0, count=count)
    except ImportError:
        raise ImportError("请先安装 mootdx: pip install 'mootdx[all]'")

def mootdx_quote(codes: list) -> list:
    """获取mootdx实时行情（46字段）"""
    try:
        from mootdx.quotes import Quotes
        client = Quotes.factory(market='std')
        return client.quotes(symbols=codes)
    except ImportError:
        raise ImportError("请先安装 mootdx: pip install 'mootdx[all]'")

# ---------- 涨跌家数细分统计 ----------
def market_sentiment(pz: int = 5000) -> dict:
    """获取全市场情绪：涨跌家数细分 + 总成交额"""
    items = em_market_ranks(pz=pz)
    result = {
        "total_up": 0, "total_down": 0, "total_flat": 0, "total_amount": 0,
        "sh_main": {"up": 0, "down": 0},         # 沪主板 60xxxx
        "sz_main": {"up": 0, "down": 0},         # 深主板 00xxxx
        "cyb": {"up": 0, "down": 0},             # 创业板 30xxxx
        "kcb": {"up": 0, "down": 0},             # 科创板 688xxx
        "bj": {"up": 0, "down": 0},              # 北交所 4/8xxxx
    }
    for item in items:
        code = str(item.get('f12', ''))
        pct = float(item.get('f3', 0))
        amount = float(item.get('f6', 0))
        result["total_amount"] += amount
        if pct > 0:
            result["total_up"] += 1
        elif pct < 0:
            result["total_down"] += 1
        else:
            result["total_flat"] += 1
        # 按板块细分
        if code.startswith('60'):
            target = result["sh_main"]
        elif code.startswith('00'):
            target = result["sz_main"]
        elif code.startswith('30'):
            target = result["cyb"]
        elif code.startswith('688'):
            target = result["kcb"]
        elif code.startswith(('4', '8')):
            target = result["bj"]
        else:
            continue
        if pct > 0:
            target["up"] += 1
        elif pct < 0:
            target["down"] += 1
    result["total_amount_亿"] = round(result["total_amount"] / 10000, 2)
    return result

# ---------- 多周期涨幅排名 ----------
def multi_day_ranks(period: str = "f109", top_n: int = 20) -> list[dict]:
    """获取多周期涨幅排名
    period: 'f109'=5日, 'f161'=10日, 'f152'=20日
    """
    import time
    url = ("https://push2.eastmoney.com/api/qt/clist/get"
           f"?pn=1&pz={top_n}&po=0&np=1&fltt=2&fid={period}"
           "&fs=m:0+t:6,m:0+t:80,m:1+t:2,m:1+t:23,m:0+t:81+s:2048"
           "&fields=f12,f14,f2,f3,f4,f5,f6,f8,f109,f152,f161,f100,f103")
    headers = {"Referer": "https://quote.eastmoney.com"}
    for attempt in range(3):
        try:
            resp = requests.get(url, headers=headers, timeout=15)
            data = resp.json()
            items = data.get('data', {}).get('diff', [])
            return sorted(items, key=lambda x: x.get(period, 0), reverse=True)
        except Exception:
            if attempt < 2:
                time.sleep(1)
                continue
            return []

# ---------- 昨日涨停今日表现（连板成功率） ----------
def yest_limitup_today() -> list[dict]:
    """获取昨日涨停股今天的表现"""
    url = ("https://push2.eastmoney.com/api/qt/clist/get"
           "?pn=1&pz=500&po=0&np=1&fltt=2"
           "&fs=b:BK0815&fields=f12,f14,f2,f3,f4,f5,f6,f8,f15,f16,f17,f18")
    headers = {"Referer": "https://quote.eastmoney.com"}
    resp = requests.get(url, headers=headers, timeout=15)
    data = resp.json()
    return data.get('data', {}).get('diff', [])

def calc_promotion_rate(items: list[dict]) -> dict:
    """计算连板成功率"""
    total = len(items)
    up2 = sum(1 for i in items if float(i.get('f3', 0)) >= 9.8)
    up7 = sum(1 for i in items if float(i.get('f3', 0)) >= 7)
    avg_pct = sum(float(i.get('f3', 0)) for i in items) / total if total else 0
    return {
        "total": total,
        "continue_limitup": up2,
        "promotion_rate": round(up2/total*100, 1) if total else 0,
        "big_positive_rate": round(up7/total*100, 1) if total else 0,
        "avg_pct": round(avg_pct, 2),
    }

七、完整使用示例

# ==================== 方式一：原始方案（新浪+东财） ====================

# 1. 获取大盘指数（新浪）
text = sina_quote("s_sh000001,s_sz399001,s_sz399006,s_sh000688")
indices = parse_sina_index(text)
for idx in indices:
    print(f"{idx['name']}: {idx['price']}  {idx['pct']:+.2f}%")

# 2. 获取涨停股（东财涨幅榜）
items = em_market_ranks(pz=500)
limit_up_stocks = [i for i in items if is_limit_up(i)]
print(f"涨停总数: {len(limit_up_stocks)}")

# 3. 反推连板天数（东财日K）
for stock in limit_up_stocks[:5]:
    code = stock['f12']
    market = 0 if code.startswith(('00','30')) else 1
    secid = f"{market}.{code}"
    klines = em_stock_kline(secid)
    boards = calc_board_days(klines, code)
    print(f"{stock['f14']}({code}): {boards}连板")


# ==================== 方式二：推荐方案（腾讯+mootdx，不封IP） ====================

# 1. 大盘指数 + 个股估值（腾讯，不封IP）
tx_data = tx_quote("sh000001,sz399001,sz399006,sh000688")
quotes = parse_tx_quote(tx_data)
for q in quotes:
    print(f"{q['name']}: {q['price']}  {q['pct']:+.2f}%  PE={q['pe']}")

# 2. 个股K线（mootdx通达信，不封IP）
kline = mootdx_kline('600519', frequency=9, count=30)
print(kline.tail())  # pandas DataFrame 格式

# 3. 个股实时行情（mootdx，46字段）
quotes = mootdx_quote(['600519', '000001'])
for q in quotes:
    print(f"{q['code']} {q['price']} 涨幅{q['pct']}%")

# ==================== 板块排行（领涨板块·题材·地区） ====================

# 领涨行业板块 Top 10
industries = em_board_ranks("t:2", top_n=10)
print("🏭 领涨行业板块：")
for b in industries:
    print(f"  {b['f14']}: {b['f3']:+.2f}%  领涨:{b.get('f128','')}({b.get('f136',0):+.2f}%)  {b.get('f104',0)}/{b.get('f105',0)}家")

# 领涨概念题材 Top 10
concepts = em_board_ranks("t:3", top_n=10)
print("💡 领涨题材：")
for b in concepts:
    print(f"  {b['f14']}: {b['f3']:+.2f}%  领涨:{b.get('f128','')}({b.get('f136',0):+.2f}%)")

# 领涨地区 Top 10
regions = em_board_ranks("t:1", top_n=10)
print("🗺️ 领涨地区：")
for b in regions:
    print(f"  {b['f14']}: {b['f3']:+.2f}%  领涨:{b.get('f128','')}({b.get('f136',0):+.2f}%)")


# ==================== 涨跌家数细分 ====================

sentiment = market_sentiment(pz=5000)
print(f"📊 全市场: ↑{sentiment['total_up']} / ↓{sentiment['total_down']} / 成交{sentiment['total_amount_亿']}亿")
print(f"  沪主板: ↑{sentiment['sh_main']['up']} / ↓{sentiment['sh_main']['down']}")
print(f"  深主板: ↑{sentiment['sz_main']['up']} / ↓{sentiment['sz_main']['down']}")
print(f"  创业板: ↑{sentiment['cyb']['up']} / ↓{sentiment['cyb']['down']}")
print(f"  科创板: ↑{sentiment['kcb']['up']} / ↓{sentiment['kcb']['down']}")


# ==================== 多周期涨幅排名 ====================

top5 = multi_day_ranks("f109", 5)  # 5日涨幅前5
print("📈 5日涨幅排名：")
for s in top5:
    print(f"  {s['f14']}({s['f12']}): 5日+{s.get('f109',0):.2f}%  所属:{s.get('f100','')}")

top20 = multi_day_ranks("f152", 5)  # 20日涨幅前5
print("📈 20日涨幅排名：")
for s in top20:
    print(f"  {s['f14']}({s['f12']}): 20日+{s.get('f152',0):.2f}%  所属:{s.get('f100','')}")


# ==================== 连板成功率 ====================

items = yest_limitup_today()
rate = calc_promotion_rate(items)
print(f"🎯 连板成功率: {rate['promotion_rate']}% ({rate['continue_limitup']}/{rate['total']})")
print(f"   平均涨幅: {rate['avg_pct']:+.2f}%  | 大阳率(>=7%): {rate['big_positive_rate']}%")


# ==================== 方式三：专业方案（悟道API，需Key） ====================

# import requests
# LB_API_KEY = "your_key_here"
# LB_API_BASE = "https://stock.quicktiny.cn/api"
# headers = {"Authorization": f"Bearer {LB_API_KEY}"}

# # 涨停梯队
# resp = requests.get(f"{LB_API_BASE}/ladder?date=2026-06-18", headers=headers)
# print(resp.json())

# # 龙虎榜
# resp = requests.get(f"{LB_API_BASE}/dragon-tiger?date=2026-06-18", headers=headers)
# print(resp.json())

# # 竞价数据
# resp = requests.get(f"{LB_API_BASE}/auction?code=600519", headers=headers)
# print(resp.json())

八、注意事项

8.1 各数据源注意事项

数据源	注意点
新浪	返回GBK编码，需做 `resp.encoding = 'gbk'` 或 `iconv -f GBK -t UTF-8` 转换
东方财富	`po=1`（升序）从最小涨幅开始排，需结合涨幅筛选使用；偶尔出现 `RemoteDisconnected` 断连。若全市场/板块接口连续返回空或断连，立即用 akshare 兜底：`python3 -m pip install --user -q akshare` 后调用 `stock_zh_a_spot_em()`、`stock_zt_pool_em(date=YYYYMMDD)`、`stock_board_industry_name_em()`、`stock_board_concept_name_em()`；若 `stock_zh_a_spot_em()` 也断连，不要放弃，继续尝试 `stock_zt_pool_em` / `stock_zt_pool_dtgc_em` / `stock_zt_pool_zbgc_em`，涨停池、跌停池、炸板池常可独立成功。
腾讯财经	返回字段较多（60+字段），按位置索引取值，注意空字段保护；不封IP，推荐优先使用
mootdx	首次使用需 `pip install 'mootdx[all]'`；M1/M2 Mac 需用 Rosetta：`arch -x86_64 pip install mootdx`；如连接超时，加 `bestip=True` 参数或手动指定服务器
百度股市通	接口稳定性一般，建议作为辅助数据源
同花顺	接口可能会变化，需定期验证；北向资金接口返回原始数据
悟道A股	需要 API Key（`https://stock.quicktiny.cn/developer` 注册）；免费额度有调用次数限制；MCP 协议配置可选

8.2 数据源选择优先级

场景	首选	兜底
大盘指数	新浪 → 腾讯	东财
涨停股列表	akshare `stock_zt_pool_em`（含连板数）	东财涨幅榜筛选
涨停原因/概念	东财涨停池(f103) / 悟道	akshare `stock_zt_pool_em`（含所属行业）
连板梯队	akshare `stock_zt_pool_em`（连板数列直接分组）	悟道 / 自推算
炸板池/炸板率	akshare `stock_zt_pool_zbgc_em`	悟道炸板池
跌停池	akshare `stock_zt_pool_dtgc_em`（唯一正确源）	⚠️ 禁止用涨幅榜筛选f3<=-9.8%自己算跌停！见下方错误说明

⚠️ 跌停判定错误说明（2026-06-28 修正）

历史错误：自己从全市场行情用涨跌幅阈值判定跌停，导致数据严重偏差。

错误方式	结果	原因
`pct <= -9.8` 判定所有板块跌停	74只（高估2倍+）	把跌超9.8%但未跌停的也算入
688/300开头跌-10%算跌停	多算20+只	科创板/创业板跌停是-20%，跌-10%不是跌停！
新浪API按-10%±0.15%匹配但未区分板块	56只	688/300跌-10%被错误归入主板判定

正确方式：直接调用 ak.stock_zt_pool_dtgc_em(date="YYYYMMDD")，返回东财官方跌停池数据。

import akshare as ak

# ✅ 正确：用跌停池API
df = ak.stock_zt_pool_dtgc_em(date="20260626")
print(f"跌停: {len(df)}只")  # 30只

# ❌ 错误：自己从全市场行情算
# spot = ak.stock_zh_a_spot_em()
# dt = spot[spot['涨跌幅'] <= -9.8]  # 会多算很多非跌停股！

跌停幅度规则（仅作参考理解，不要自己实现判定）：

主板（60/000/002/003等）：跌停 -10%，ST -5%
创业板（300/301）：跌停 -20%
科创板（688）：跌停 -20%
北交所（4/8）：跌停 -30%

8.3 通用规则

日K反推：从最新一天向历史回溯，遇到不涨停即停止
secid规则：深市=0.代码，沪市=1.代码，北交所按f13组合
板块排序：fid=f3排序可能不生效，建议在应用层自行排序
涨停池接口：东方财富专用涨停池接口可能返回null，不可作为唯一来源
mootdx 服务器：通达信行情服务器可能变更，定期执行 pip install -U mootdx

name

stock-data-fetcher

description

A股实时行情数据抓取系统

多源聚合数据体系（新浪 + 东方财富 + 腾讯 + mootdx通达信 + 百度 + 同花顺 + 悟道A股），用于全市场短线交易数据的实时采集与分析。

一、数据接口总览

序号	数据源	协议	封IP风险	鉴权	核心用途
1	新浪财经	HTTP	✅ 低	无需	大盘指数、个股实时快照（最稳定兜底）
2	东方财富	HTTP	⚠️ 中	无需	全市场涨幅榜、行业/概念/地区板块排行、个股明细
3	腾讯财经 ⭐	HTTP	✅ 极低	无需	实时价、PE/PB/市值/换手率/涨跌停价/指数/ETF
4	mootdx（通达信） ⭐	TCP:7709	✅ 极低	无需	K线(多周期)+五档盘口+逐笔成交+46字段实时报价
5	百度股市通	HTTP	✅ 极低	无需	日K线自带MA5/MA10/MA20均价
6	同花顺	HTTP	✅ 极低	无需	强势股归类、题材归因、北向资金流向
7	涨停池（东财） ⭐	HTTP	⚠️ 中	无需	涨停股所属行业/概念/5日/10日/20日涨幅/涨停原因
8	昨日涨停BK0815	HTTP	⚠️ 中	无需	连板成功率、涨停溢价、晋级率
9	悟道A股 🔑	HTTP	✅ 低	需API Key	仅涨停梯队ladder可用（数据最丰富，含涨停原因/连板/主营/题材）；龙虎榜等需网页登录JWT不开放
10	akshare 涨停池三件套 ⭐	HTTP	✅ 低	无需	涨停池(含连板数)/炸板池/跌停池 — 替代悟道涨停梯队
11	efinance（东财封装库） ⭐	HTTP	✅ 低	无需	龙虎榜/逐分钟资金流/板块成分股/板块归属 — 替代悟道龙虎榜+资金流

1.1 新浪指数快照（最稳定·兜底）

GET https://hq.sinajs.cn/list={codes}
Header: Referer: https://finance.sina.com.cn

指数编码：

指数	编码
上证指数	`s_sh000001`
深证成指	`s_sz399001`
创业板指	`s_sz399006`
科创50	`s_sh000688`
沪深300	`s_sh000300`
中证1000	`s_sh000852`
北证50	`s_sz899050`

个股编码规则：

沪市：sh{6位代码} → 例：sh600353
深市：sz{6位代码} → 例：sz002141
科创板：sh{6位代码} → 例：sh688598
北交所：bj{6位代码}

批量请求示例：

https://hq.sinajs.cn/list=s_sh000001,s_sz399001,s_sz399006,s_sh000688,sh600353,sz002141,sh688598

返回格式（ISO-8859-1编码，需转UTF-8）：

var hq_str_s_sh000001="上证指数,4100.35,-7.72,-0.19,3628520,85464445";
var hq_str_sz002141="贤丰控股,4.600,4.280,4.710,4.710,4.460,4.710,0.000,52141350,241070243.000,...";

字段含义（指数）：名称, 现价, 涨跌额, 涨跌幅%, 成交量(手), 成交额(元)

字段含义（个股）：名称, 今开, 昨收, 现价, 最高, 最低, 买一价, 卖一价, 成交量(股), 成交额(元), 盘口明细...

1.2 东方财富全市场涨幅榜（核心）

GET https://push2.eastmoney.com/api/qt/clist/get?pn=1&pz=500&po=1&np=1&fltt=2&fid=f3&fs=m:0+t:6,m:0+t:80,m:1+t:2,m:1+t:23,m:0+t:81+s:2048&fields=f12,f13,f14,f2,f3,f4,f5,f6,f8,f15,f16,f17,f18,f20,f21,f62
Header: Referer: https://quote.eastmoney.com

参数说明：

参数	含义
`pn=1`	页码
`pz=500`	每页500条
`po=1`	排序方式（1=升序，0=降序）
`fid=f3`	按涨跌幅排序
`fs=m:0+t:6,m:0+t:80,m:1+t:2,m:1+t:23,m:0+t:81+s:2048`	市场筛选（深主板+创业板+沪主板+科创板+北交所）
`fields=f12,f13,f14,f2,f3,f4,f5,f6,f8,f15,f16,f17,f18,f20,f21,f62`	返回字段

字段含义：

字段	含义
f12	股票代码
f13	市场标识（0=深市，1=沪市）
f14	股票名称
f2	现价
f3	涨跌幅%
f4	涨跌额
f5	成交量(手)
f6	成交额(万)
f8	换手率%
f15	最高价
f16	最低价
f17	今开
f18	昨收
f20	市值
f21	流通市值
f62	量比

1.3 东方财富个股快照

GET https://push2.eastmoney.com/api/qt/stock/get?secid={market}.{code}&fields=f43,f44,f45,f46,f47,f48,f49,f50,f51,f52,f57,f58,f60,f71,f84,f85,f86,f107,f116,f117,f127,f168,f169,f170,f171,f191,f192,f193,f194,f195,f196,f197,f198

secid规则：

市场	secid格式
深市（主板/创业板）	`0.{6位代码}` → 例：`0.002141`
沪市（主板/科创板）	`1.{6位代码}` → 例：`1.600353`
北交所	按接口返回的 `f13.code` 组合

关键字段：

字段	含义
f43	现价
f44	最高
f45	最低
f46	今开
f47	涨停价
f48	跌停价
f57	股票代码
f58	股票名称
f60	昨收
f71	成交量(手)
f84	总市值
f85	流通市值
f86	市盈率
f107	涨跌幅
f116	换手率
f127	涨跌额
f168	换手率(实)
f169	涨跌额
f170	涨跌幅
f171	振幅%

1.4 东方财富日K线（反推连板天数）

GET https://push2his.eastmoney.com/api/qt/stock/kline/get?secid={market}.{code}&fields1=f1,f2,f3,f4,f5,f6&fields2=f51,f52,f53,f54,f55,f56,f57,f58,f59,f60,f61&klt=101&fqt=1&beg=20260601&end=20260618

参数说明：

参数	含义
secid	`{market}.{code}`（同个股快照规则）
fields1	固定为 f1,f2,f3,f4,f5,f6
fields2	f51=日期, f52=开盘, f53=收盘, f54=最高, f55=最低, f56=成交量, f57=成交额, f58=振幅, f59=涨跌幅%, f60=涨跌额, f61=换手率%
klt=101	日K线
fqt=1	前复权
beg/end	起止日期 `YYYYMMDD`

返回格式：

{
  "data": {
    "klines": [
      "2026-06-18,40.55,42.01,42.01,41.50,31050969,1289684694.00,3.82,10.00,3.82,5.46",
      "2026-06-17,35.80,38.19,38.48,35.23,...,...",
      ...
    ]
  }
}

每根K线字段：日期, 开盘, 收盘, 最高, 最低, 成交量, 成交额, 振幅, 涨跌幅%, 涨跌额, 换手率%

反推连板算法：

lines = kline_data.split(';')
board_days = 0
for i, line in enumerate(lines):
    fields = line.split(',')
    chg_pct = float(fields[8])  # 涨跌幅%
    close = float(fields[2])
    if chg_pct >= 9.8:  # 主板涨停标准
        board_days += 1
    elif chg_pct >= 19.5 and secid.startswith('0'):  # 创业板/科创板
        board_days += 1
    else:
        break  # 遇到不涨停的K线就停止计数

1.5 东方财富板块排行（行业·概念·地区）

同一接口，fs 参数区分三种板块类型：

板块类型	`fs` 参数	说明
🗺️ 地区板块（领涨地区）	`m:90+t:1`	各省/直辖市/自治区
🏭 行业板块（领涨板块）	`m:90+t:2`	申万行业分类
💡 概念板块（领涨题材）	`m:90+t:3`	热门概念/题材

请求示例：

# 行业板块（涨跌幅降序，取前20）
GET https://push2.eastmoney.com/api/qt/clist/get?pn=1&pz=20&po=0&np=1&fltt=2&invt=2&fs=m:90+t:2&fields=f2,f3,f4,f8,f12,f14,f20,f21,f62,f104,f105,f128,f136&fid=f3

# 概念板块
GET https://push2.eastmoney.com/api/qt/clist/get?pn=1&pz=20&po=0&np=1&fltt=2&invt=2&fs=m:90+t:3&fields=f2,f3,f4,f8,f12,f14,f20,f21,f62,f104,f105,f128,f136&fid=f3

# 地区板块
GET https://push2.eastmoney.com/api/qt/clist/get?pn=1&pz=20&po=0&np=1&fltt=2&invt=2&fs=m:90+t:1&fields=f2,f3,f4,f8,f12,f14,f20,f21,f62,f104,f105,f128,f136&fid=f3

返回字段含义：

字段	含义
f12	板块代码（如 BK1128）
f14	板块名称
f2	最新价
f3	涨跌幅%
f4	涨跌额
f8	换手率%
f20	总市值
f21	流通市值
f62	量比
f104	上涨家数
f105	下跌家数
f128	领涨股名称
f136	领涨股涨跌幅%

获取板块成分股：拿到板块代码（如 BK1128）后，用以下接口获取成分股：

GET https://push2.eastmoney.com/api/qt/clist/get?pn=1&pz=100&po=0&np=1&fltt=2&fs=b:BK1128&fields=f12,f14,f2,f3,f4,f5,f6,f8,f15,f16,f17,f18,f20,f21&fid=f3

备注：fid=f3 排序可能不生效，建议在应用层按 f3 排序。

1.6 东方财富涨停池接口（备用）

GET https://push2ex.eastmoney.com/getTopicZTPool?ut=7eea3edcaed734bea9cbfc24409ed989&d=20260618&pageindex=0&pagesize=500&sort=fbt:asc

注意：此接口当前返回 data:null，不可靠。改用涨幅榜+日K反推法替代。

1.7 腾讯财经（实时估值·不封IP）⭐

GET https://web.ifzq.gtimg.cn/appstock/app/fqkline/get?param={code},{period},{beg},{end},{limit}

核心端点：

用途	URL
日K线（含MA均线）	`https://web.ifzq.gtimg.cn/appstock/app/fqkline/get?param=sh600519,day,,,10`
实时行情/估值	`https://qt.gtimg.cn/q=sh600519`
批量行情	`https://qt.gtimg.cn/q=sh600519,sz000001,sh600036`

返回格式（批量行情）：

v_sh600519="1
名称,代码,现价,涨跌幅%,涨跌额,成交量(手),成交额(万),总市值,流通市值,PE(TTM),换手率%,最高,最低,今开,昨收,涨停价,跌停价,...

v_sz000001="...

字段含义（按位置索引）：

索引	含义
1	名称
2	代码
3	现价
5	涨跌幅%
6	涨跌额
7	成交量(手)
8	成交额(万)
44	最高
45	最低
46	今开
47	昨收
48	涨停价
49	跌停价
56	换手率%
59	总市值
60	流通市值
62	PE(TTM)

特点：

不封IP，比东方财富更稳定
返回数据包含 PE/PB/市值/换手率（新浪没有的估值数据）
日K线端点返回的数据自带 MA5/MA10/MA20 均线（需解析）
适合作为东方财富的兜底替代

1.8 mootdx 通达信接口（最全K线·盘口·不封IP）⭐

# 安装
pip install 'mootdx[all]'

核心能力：

from mootdx.quotes import Quotes

client = Quotes.factory(market='std')  # 标准通达信行情

# 1. K线数据（多周期）
kline = client.bars(symbol='600519', frequency=9, start=0, count=120)
# frequency: 9=日线, 5=周线, 6=月线, 8=60分钟, 3=30分钟, 2=15分钟, 1=5分钟

# 2. 实时行情（46字段）
quote = client.quotes(symbols=['600519', '000001'])
# 返回：代码、名称、今开、昨收、现价、最高、最低、总手、金额、涨跌、涨幅、换手率、市盈率、市净率、总市值、流通市值...

# 3. 五档盘口
ticks = client.transactions(symbol='600519', start=0, count=100)  # 逐笔成交

# 4. 指数K线
index_kline = client.bars(symbol='000001', frequency=9, start=0, count=120)  # 上证指数

特点：

通达信官方数据通道，极低封IP风险
不需要网页爬取，TCP 协议直连，速度快
K线支持多周期（1/5/15/30/60分钟，日/周/月）
支持五档盘口和逐笔成交（Level-2 级数据）
强烈推荐替代东方财富日K线接口

1.9 百度股市通（K线自带均线）

GET https://gupiao.baidu.com/api/stocks/stockkline?code=sh600519&ktype=day&start_date=20260601&end_date=20260618

特点：

返回直接包含 MA5/MA10/MA20 均价，省去本地计算
极低封IP风险
适合需要均线数据时补充使用

1.10 同花顺热点·北向资金（零鉴权）

北向资金流向：

GET https://data.10jqka.com.cn/funds/ggjj/op=down/globalapi/market/board/north_flow

强势股/题材归类：

GET https://data.10jqka.com.cn/funds/hkgg/field/trade_hf/order/asc/page/1/ajax/1/

特点：

零鉴权，不封IP
数据直接可用，无需解析复杂格式
北向资金适合盘中监控外资动向

1.11 东方财富涨停池（含涨停原因·连板·所属行业）⭐

通过东方财富全市场榜单 + 涨幅筛选，提取涨停池并关联行业/概念/多周期涨幅。

请求地址：同 1.2 全市场涨幅榜，增加以下字段：

字段	含义	用途
f100	所属行业	快速识别涨停股的行业归属
f103	备注（概念标签）	涨停原因/概念归属的关键字段
f109	5日涨跌幅%	中期强度排名
f152	20日涨跌幅%	中期趋势强度
f161	10日涨跌幅%	短期趋势强度

涨停原因获取逻辑：

涨停原因 = 取 f103（备注/概念标签）解析关键词归类
- 如 f103 包含 "AI"、"机器人"、"新能源" 等 → 按对应概念归类
- 结合 f100（所属行业）+ 涨停股所属板块代码交叉验证

简化版涨停池（含连板数据）推荐用 akshare：

import akshare as ak
df = ak.stock_zt_pool_em(date='20260618')
# 返回：代码, 名称, 涨跌幅, 封单金额, 流通市值, 所属行业, 涨停原因, 开板次数, 连板天数

1.12 全市场多周期涨幅排名（5日/10日/20日涨幅）

在东方财富全市场榜单中排序 f109、f161、f152 即可获取多周期涨幅排名：

GET https://push2.eastmoney.com/api/qt/clist/get?pn=1&pz=5000&po=0&np=1&fltt=2&fid=f109&fs=m:0+t:6,m:0+t:80,m:1+t:2,m:1+t:23,m:0+t:81+s:2048&fields=f12,f14,f2,f3,f4,f5,f6,f8,f109,f152,f161,f100,f103

fid=f109&po=0 → 5日涨幅降序（近5日最强）
fid=f152&po=0 → 20日涨幅降序（近1月最强）
fid=f161&po=0 → 10日涨幅降序

1.13 涨跌家数细分统计

通过全市场榜单（pz=5000 拉取全量）在应用层按代码前缀细分统计：

板块	代码前缀	涨/跌判定
沪市主板	60xxxx	f3 > 0 上涨，f3 < 0 下跌
深市主板	00xxxx	同上
创业板	30xxxx	同上
科创板	688xxx	同上
北交所	4xxxxx, 8xxxxx	同上

1.14 昨日涨停今日表现（连板成功率）

GET https://push2.eastmoney.com/api/qt/clist/get?pn=1&pz=500&po=0&np=1&fltt=2&fs=b:BK0815&fields=f12,f14,f2,f3,f4,f5,f6,f8

BK0815 = 东方财富"昨日涨停"板块代码。通过该接口获取昨日涨停股今日的表现，用于计算：

连板成功率 = 今日继续涨停数 / 昨日涨停总数
涨停溢价 = 昨日涨停股今日平均涨幅

1.15 悟道A股 🔑（仅涨停梯队 API 可用·数据最丰富）

⚠️ 2026-06-26 实测真相：悟道官网（stock.quicktiny.cn）注册申请的 lb_ API Key 仅 /api/ladder 一个接口可用。其龙虎榜等接口走 /api/admin/* 路径，需网页登录后的 JWT（cookie+Bearer），不开放给 API Key。本节只保留实测可用的 ladder，原登记的"26 个 API / 龙虎榜 / 竞价 / 资金流向 / 炸板池"等接口路径均不开放给 API Key 调用——这些能力改由本 skill 1.16（akshare 涨停池三件套）和 1.17（efinance）免费覆盖。

获取 API Key：https://stock.quicktiny.cn/developer（注册后在开发者后台拿 lb_ 开头的 Key）

唯一可用接口：涨停梯队

# 涨停梯队（唯一对 API Key 开放的接口，数据极丰富）
curl -s -H "Authorization: Bearer $LB_API_KEY" \
  "https://stock.quicktiny.cn/api/ladder?date=$(date +%Y-%m-%d)"

返回字段（每只涨停股，2MB 量级）：

字段	含义
`continue_num`	连板天数（直接返回，无需反推）
`high_days`	总板数描述（如 `7天6板`）
`limit_up_type`	封板类型（`一字板`/`换手板`等）
`reason_type`	涨停原因（如 `氮化铝+可控核聚变+定增受理`）
`reason_info`	涨停原因详细说明（多段公告摘要）
`primary_theme`	主题材
`industry`	所属行业
`main_business`	主营业务
`business_scope`	经营范围
`first_limit_up_time` / `last_limit_up_time`	首/末次封板时间（Unix 时间戳）
`limitAmount`	封板资金
`tradeAmount`	成交额
`turnover_rate` / `actual_turnover_rate`	换手率（名义/真实）
`kpl_*`	开盘啦系列字段（开盘竞价数据）
`open_num`	开板次数

特点：

✅ ladder 数据质量全 skill 最高——连板天数+涨停原因+主营+题材+封板资金一站式返回，远超 akshare stock_zt_pool_em
✅ 含 kpl_* 开盘啦字段（开盘竞价相关），是其它免费源没有的
⚠️ 仅此一个接口对 API Key 开放；龙虎榜/资金流向/炸板池等需网页登录 JWT，不开放给 API Key
⚠️ Key 有调用频次限制（免费额度）
🔁 龙虎榜需求 → 用 efinance get_daily_billboard（1.17 节，免费）
🔁 资金流向需求 → 用 efinance get_today_bill（1.17 节，免费，逐分钟更细）
🔁 炸板池需求 → 用 akshare stock_zt_pool_zbgc_em（1.16 节，免费）

1.16 akshare 涨停池三件套（免费·替代悟道涨停梯队）⭐

akshare 封装东方财富涨停池专用接口，连板天数/炸板次数/封板资金直接返回，无需自推算、无需 API Key。2026-06-26 实测三接口全部可用。

安装：pip install akshare

import akshare as ak

# 1. 涨停池（含连板数·封板资金·炸板次数·涨停统计·所属行业）
df_zt = ak.stock_zt_pool_em(date='20260625')
# 列：代码, 名称, 涨跌幅, 最新价, 成交额, 流通市值, 总市值, 换手率,
#     封板资金, 首次封板时间, 最后封板时间, 炸板次数, 涨停统计, 连板数, 所属行业
# 例：兴业科技(002674) 连板数=5 涨停统计='5/5' 炸板次数=0 封板资金=4.4亿 所属行业='纺织制造'

# 2. 炸板池（盘中触及涨停但未封住）
df_zb = ak.stock_zt_pool_zbgc_em(date='20260625')
# 列：代码, 名称, 涨跌幅, 最新价, 涨停价, 成交额, 流通市值, 换手率,
#     涨速, 首次封板时间, 炸板次数, 涨停统计, 振幅, 所属行业
# 例：上海港湾(605598) 炸板次数=1 涨停统计='2/1' 振幅=8.51%

# 3. 跌停池（含连续跌停·开板次数·封单资金）
df_dt = ak.stock_zt_pool_dtgc_em(date='20260625')
# 列：代码, 名称, 涨跌幅, 最新价, 成交额, 流通市值, 动态市盈率, 换手率,
#     封单资金, 最后封板时间, 板上成交额, 连续跌停, 开板次数, 所属行业

连板梯队构建（无需自推算）：

df = ak.stock_zt_pool_em(date=YYYYMMDD)
# 直接按"连板数"列分组即得连板梯队
ladder = df.groupby('连板数').apply(
    lambda g: list(zip(g['名称'], g['代码'], g['封板资金'], g['所属行业']))
).to_dict()
# 输出：{5: [('兴业科技','002674',4.4亿,'纺织制造')], 4: [...], 3: [...], ...}

炸板率计算：

zt_n = len(ak.stock_zt_pool_em(date=d))      # 封板数
zb_n = len(ak.stock_zt_pool_zbgc_em(date=d)) # 炸板数
break_rate = zb_n / (zt_n + zb_n) * 100       # 炸板率%

特点：

✅ 连板数直接返回，彻底替代"东财涨幅榜+日K反推"算法
✅ 炸板次数/封板资金直接返回，无需悟道 Key
✅ 涨停统计列格式 '连板天数/封板成功天数'，可识别伪连板
✅ 含所属行业，涨停原因归类一步到位
⚠️ 网络不稳时三个接口可能独立成功/失败，断连时分别重试三个接口，不要因一个失败放弃全部

1.17 efinance 龙虎榜·资金流·板块归属（免费·替代悟道龙虎榜+资金流）⭐

efinance 是基于东方财富爬虫的封装库，API 简洁、零鉴权。2026-06-26 实测龙虎榜/逐分钟资金流/板块归属/板块成分股全部可用。资金流逐分钟返回，比悟道的聚合资金流更细。

安装：pip install efinance

import efinance as ef

# 1. 龙虎榜（当日全部上榜股）— 替代悟道 /dragon-tiger
df_lhb = ef.stock.get_daily_billboard('2026-06-25')
# 列：股票代码, 股票名称, 上榜日期, 解读, 收盘价, 涨跌幅, 换手率,
#     龙虎榜净买额, 龙虎榜买入额, 龙虎榜卖出额, 龙虎榜成交额, 市场总成交额,
#     净买额占总成交比, 成交额占总成交比, 流通市值, 上榜原因
# 例：101行 × 16列；含"上榜原因"和"解读"（如"卖一主卖，成功率50.92%"）

# 2. 逐分钟资金流（主力/超大单/大单/中单/小单）— 替代悟道 /money-flow
df_flow = ef.stock.get_today_bill('600519')
# 列：股票名称, 股票代码, 时间, 主力净流入, 小单净流入, 中单净流入,
#     大单净流入, 超大单净流入
# 例：240行（全天每分钟一行），可计算主力全天累计净流入

# 3. 个股所属全部板块（行业+概念）— 替代东财交叉拼接
df_board = ef.stock.get_belong_board('600519')
# 列：股票名称, 股票代码, 板块代码, 板块名称, 板块涨幅
# 例：29行 × 5列；贵州茅台属于食品饮料、白酒、超级品牌等29个板块

# 4. 板块成分股（按板块名称查）— 替代东财手搓成分股接口
df_mem = ef.stock.get_members('白酒')
# 列：指数代码, 指数名称, 股票代码, 股票名称, 股票权重
# 例：17行 × 5列；含权重，可识别板块龙头

# 5. 最新实时快照（单股，37字段 Series）
snap = ef.stock.get_quote_snapshot('600519')  # pandas Series

# 6. IPO 审核队列（题材打新参考）
df_ipo = ef.stock.get_latest_ipo_info()
# 列：发行人全称, 审核状态, 注册地, 证监会行业, 保荐机构, 会计师事务所,
#     更新日期, 受理日期, 拟上市地点

主力资金全天累计净流入：

df = ef.stock.get_today_bill('600519')
main_net = df['主力净流入'].sum()   # 全天主力净流入（元）
big_net  = df['超大单净流入'].sum() # 超大单累计

龙虎榜净买额排行：

df = ef.stock.get_daily_billboard(date_str)
top_buy = df.sort_values('龙虎榜净买额', ascending=False).head(10)
for _, r in top_buy.iterrows():
    print(f"{r['股票名称']}({r['股票代码']}) 净买{r['龙虎榜净买额']/1e4:.0f}万 原因:{r['上榜原因']}")

特点：

✅ 龙虎榜含上榜原因+解读，比悟道字段更丰富（含"成功率"统计）
✅ 资金流逐分钟返回，可做盘中分时资金流分析（悟道只有聚合值）
✅ 板块归属一键查全量，替代东财"涨幅榜交叉拼接板块代码"的笨办法
✅ 板块成分股按名称查，无需先拿板块代码
✅ IPO 审核队列是当前 skill 完全缺失的数据（打新题材/次新股预热）
⚠️ get_realtime_quotes(全市场批量)和get_quote_history(K线)底层走 push2.eastmoney.com，断连风险同东财原生接口，这两块仍用腾讯/mootdx，efinance 仅用于龙虎榜/资金流/板块

二、涨停筛选规则

市场板块	涨停判定标准
沪市主板(sh60xxxx)	涨幅 >= 9.8%
深市主板(sz00xxxx/sz30xxxx非3开头)	涨幅 >= 9.8%
创业板(sz30xxxx)	涨幅 >= 19.5%
科创板(sh688xxx)	涨幅 >= 19.5%
北交所	涨幅 >= 29%
ST/*ST	涨幅 >= 4.8%

三、数据采集流程

流程1：获取大盘情绪

1. 新浪指数快照 → 获取7大指数实时数据
2. 或：腾讯财经批量行情 → 同步获取指数+估值数据
3. 计算：涨跌家数比、涨停/跌停比
4. 输出：市场情绪温度（冰点/低迷/正常/活跃/高潮）

流程2：获取涨停梯队

方式A（自推算·免费·无需Key）：

1. 东方财富涨幅榜(pz=500) → 全市场涨幅排序
2. 按涨停规则筛选 → 得到当日涨停股列表（含涨幅信息）
3. 对每只涨停股 → mootdx通达信K线(或东财K线兜底) → 反推连续涨停天数
4. 按涨停天数分组 → 输出连板梯队（6板/5板/4板/3板/2板/首板）
5. 统计：严格涨停总数、炸板数（通过涨幅靠近涨停但未封住识别）

方式B（悟道API·需Key·推荐）：

1. 悟道 /ladder → 直接获取连板梯队（含每层个股）
2. 悟道 /break-pool → 获取炸板池（含炸板率）
3. 悟道 /limit-pool → 获取跌停池
4. 合并输出完整情绪数据

流程3：获取板块热点（领涨板块·领涨题材·领涨地区）

方式A（免费·推荐）：

1. 东方财富行业板块排行 t:2 → 🏭 领涨板块 Top 20
2. 东方财富概念板块排行 t:3 → 💡 领涨题材 Top 20
3. 东方财富地区板块排行 t:1 → 🗺️ 领涨地区 Top 10
4. 每板块均含：涨跌幅、上涨/下跌家数、领涨股名称及涨幅
5. 同花顺北向资金 → 监测外资流向
6. 三表交叉验证 → 识别真主线（行业共振+题材配合+地域集中）

方式B（悟道API·需Key）：

1. 悟道 /hot-concept → 最强风口（按涨停聚集度排名）
2. 悟道 /sector-rotation → 板块四象限动量分析
3. 悟道 /concept-constituents → 热点概念成分股

流程4：获取资金流向（新增）

1. 悟道 /money-flow → 个股/板块/大盘资金流向
2. 或：同花顺北向资金接口 → 外资净买入额
3. 识别主力净流入/流出板块

流程5：获取龙虎榜（新增·需悟道Key）

1. 悟道 /dragon-tiger → 当日龙虎榜数据
2. 提取：买入营业部、卖出营业部、净买额
3. 识别：知名游资席位动向（如：中关村、拉萨、深股通等）

流程6：获取竞价数据（新增·需悟道Key）

1. 悟道 /auction → 个股集合竞价成交数据
2. 分析：竞价量能、撮合价格、分歧程度
3. 用于：开盘前的隔夜方向判断

流程7：获取个股详情

轻量版（腾讯·最快·不封IP）：

1. 腾讯 qt.gtimg.cn 批量行情 → PE/PB/市值/换手率/涨停跌停价/五档

标准版（新浪兜底）：

1. 新浪个股快照 → 实时分时数据（稳定兜底）
2. 东方财富个股快照 → 详细指标（市值/换手率/振幅等）

专业版（mootdx·最全）：

1. mootdx quotes() → 46字段实时行情（含盘口深度）
2. mootdx bars() → 多周期K线（替代东财日K）
3. mootdx transactions() → 逐笔成交数据

流程8：涨跌家数细分统计（新增）

1. 全市场涨幅榜(pz=5000) → 拉取全量股票行情
2. 按 f3 涨跌幅统计 → 上涨/下跌/平盘家数
3. 按代码前缀细分 → 沪主板/深主板/创业板/科创板/北交所
4. 累计成交额 → 全市场总成交额(亿)

流程9：多周期涨幅排名（新增）

1. 东方财富全市场榜单 fid=f109 → 5日涨幅降序排名
2. 东方财富全市场榜单 fid=f161 → 10日涨幅降序排名
3. 东方财富全市场榜单 fid=f152 → 20日涨幅降序排名
4. 结合涨停股 → 识别中期强势股

流程10：连板成功率监控（新增）

1. 昨日涨停板块 BK0815 → 获取昨日涨停股今日表现
2. 统计继续涨停数 → 计算连板成功率
3. 统计大阳线数 → 计算溢价率
4. 平均涨幅 → 涨停溢价

四、市场情绪指标体系

4.1 基础情绪指标（免费接口即可获取）

指标	数据来源	说明
涨停数	涨幅榜筛选 / 悟道涨停统计	全市场严格涨停家数
连板数	涨幅榜+日K反推 / 悟道涨停梯队	2板及以上连板股数量
最高板	日K反推 / 悟道涨停梯队	当前最高连板高度
涨停晋级率	昨日首板→今日2板比例	反映接力意愿
跌停数	akshare `stock_zt_pool_dtgc_em(date)`（唯一正确源）	市场亏钱效应
涨跌家数比	涨幅榜	上涨/下跌家数
炸板率	悟道炸板池 / 涨幅榜估算	涨停打开比例
成交额	指数快照 / 腾讯行情	全市场总成交额
涨跌停比	涨停数/跌停数	情绪强度
指数强度	新浪/腾讯指数快照	主要指数涨跌幅
市场温度	综合以上	冰点/低迷/正常/活跃/高潮

4.2 进阶情绪指标（需悟道Key）

指标	数据来源	说明
涨停溢价	悟道涨停溢价	涨停股次日开盘溢价率
封板率	悟道涨跌停统计	封板数/（封板数+炸板数）
最强风口	悟道最强风口	按涨停聚集度排名的板块
封板事件	悟道封板事件流	实时封板/炸板事件，精确到秒
北向资金	悟道资金流向 / 同花顺	外资当日净买入额
主力净流入	悟道资金流向	主力资金流入/流出
板块轮动	悟道板块轮动	板块动量与强度四象限
异动检测	悟道异动检测	个股异常交易行为
龙虎榜	悟道龙虎榜	游资席位动向
竞价数据	悟道竞价数据	集合竞价成交情况

五、输出格式模板

大盘情绪快照输出模板

📊 大盘情绪（YYYY-MM-DD HH:MM）
上证 {点位} {涨跌幅}% | 深证 {点位} {涨跌幅}%
创业板 {点位} {涨跌幅}% | 科创50 {点位} {涨跌幅}%
成交额 {万亿} ｜ 涨停 {N} 只 ｜ 跌停 {N} 只 ｜ 炸板率 {N}%

涨停梯队输出模板

📈 连板梯队
- 4板：{名称}({代码})
- 3板：{名称}({代码})、{名称}({代码})
- 2板：{名称}({代码})、{名称}({代码}) ...
- 首板：共 {N} 只
- 全市场严格涨停：{N} 只

板块排行输出模板

🔥 行业板块涨幅前5
1. {板块名称} {涨幅}% ｜ 领涨：{领涨股}({涨幅}%) ｜ {上涨家数}/{下跌家数}

🔥 概念板块涨幅前5
1. {板块名称} {涨幅}% ｜ 领涨：{领涨股}({涨幅}%) ｜ {上涨家数}/{下跌家数}

🔥 地区板块涨幅前5
1. {省份/直辖市} {涨幅}% ｜ 领涨：{领涨股}({涨幅}%) ｜ {上涨家数}/{下跌家数}

快速调用的 Python 示例

# 一行获取领涨行业
industries = em_board_ranks("t:2", top_n=10)
for b in industries:
    print(f"{b['f14']}: {b['f3']:+.2f}%  领涨:{b['f128']}({b['f136']}%)  {b['f104']}/{b['f105']}家")

# 一行获取领涨题材
concepts = em_board_ranks("t:3", top_n=10)

# 一行获取领涨地区
regions = em_board_ranks("t:1", top_n=10)

龙虎榜输出模板（新增·需悟道Key）

🐅 龙虎榜（YYYY-MM-DD）
{名称}({代码})：净买入 {N} 万
├─ 买一：{营业部} {金额}万
├─ 买二：{营业部} {金额}万
├─ 卖一：{营业部} {金额}万
└─ 卖二：{营业部} {金额}万

资金流向输出模板（新增·需悟道Key）

💰 资金流向
大盘：主力净流入 {N} 亿 ｜ 北向净买入 {N} 亿
板块净流入前3：{板块1}、{板块2}、{板块3}
板块净流出前3：{板块1}、{板块2}、{板块3}

竞价数据输出模板（新增·需悟道Key）

⏰ {名称}({代码}) 集合竞价
竞价量：{N} 万手 ｜ 撮合价：{price}
隔夜方向：{抢筹/分歧/砸盘}

涨跌家数细分模板（新增）

📊 全市场情绪
上涨 {N} 家 ｜ 下跌 {N} 家 ｜ 平盘 {N} 家 ｜ 成交额 {N} 亿
├─ 沪主板: ↑{N} ↓{N}
├─ 深主板: ↑{N} ↓{N}
├─ 创业板: ↑{N} ↓{N}
├─ 科创板: ↑{N} ↓{N}
└─ 北交所: ↑{N} ↓{N}

多周期涨幅排名模板（新增）

📈 5日涨幅 Top 5
1. {名称}({代码}) +{N}% ｜ {所属行业}
2. ...

📈 20日涨幅 Top 5
1. {名称}({代码}) +{N}% ｜ {所属行业}

连板成功率模板（新增）

🎯 连板晋级率
昨日涨停 {N} 只 → 今日继续涨停 {N} 只
晋级率: {N}% ｜ 大阳率(>=7%): {N}% ｜ 平均涨幅: {N}%

六、Python工具函数

import requests, json
from datetime import datetime

# ---------- 新浪接口 ----------
def sina_quote(codes_str: str) -> str:
    """获取新浪实时快照"""
    url = f"https://hq.sinajs.cn/list={codes_str}"
    headers = {"Referer": "https://finance.sina.com.cn"}
    resp = requests.get(url, headers=headers, timeout=10)
    resp.encoding = 'gbk'
    return resp.text

def parse_sina_index(text: str) -> list[dict]:
    """解析新浪指数数据"""
    results = []
    for line in text.strip().split('\n'):
        if not line.startswith('var hq_str_s_'):
            continue
        parts = line.split('="')[1].rstrip('";').split(',')
        name, price, change, pct = parts[0], parts[1], parts[2], parts[3]
        results.append({"name": name, "price": float(price), "change": float(change), "pct": float(pct)})
    return results

def parse_sina_stock(text: str) -> dict:
    """解析新浪个股数据"""
    line = text.strip().split('\n')[0]
    parts = line.split('="')[1].rstrip('";').split(',')
    return {
        "name": parts[0], "open": float(parts[1]), "yclose": float(parts[2]),
        "price": float(parts[3]), "high": float(parts[4]), "low": float(parts[5]),
        "volume": int(parts[8]), "amount": float(parts[9])
    }

# ---------- 东方财富接口 ----------
def em_market_ranks(pz: int = 500) -> list[dict]:
    """获取全市场涨幅榜"""
    url = ("https://push2.eastmoney.com/api/qt/clist/get"
           f"?pn=1&pz={pz}&po=1&np=1&fltt=2&fid=f3"
           "&fs=m:0+t:6,m:0+t:80,m:1+t:2,m:1+t:23,m:0+t:81+s:2048"
           "&fields=f12,f13,f14,f2,f3,f4,f5,f6,f8,f15,f16,f17,f18,f20,f21,f62")
    headers = {"Referer": "https://quote.eastmoney.com"}
    resp = requests.get(url, headers=headers, timeout=15)
    data = resp.json()
    return data.get('data', {}).get('diff', [])

def em_stock_kline(secid: str, beg: str = "20260601", end: str = None) -> list[str]:
    """获取日K线"""
    if end is None:
        end = datetime.now().strftime("%Y%m%d")
    url = (f"https://push2his.eastmoney.com/api/qt/stock/kline/get"
           f"?secid={secid}&fields1=f1,f2,f3,f4,f5,f6"
           f"&fields2=f51,f52,f53,f54,f55,f56,f57,f58,f59,f60,f61"
           f"&klt=101&fqt=1&beg={beg}&end={end}")
    headers = {"Referer": "https://quote.eastmoney.com"}
    resp = requests.get(url, headers=headers, timeout=15)
    data = resp.json()
    return data.get('data', {}).get('klines', [])

def em_board_ranks(board_type: str = "t:2", top_n: int = 20) -> list[dict]:
    """获取板块排行（含重试）
    board_type: 't:1'=地区板块, 't:2'=行业板块, 't:3'=概念板块
    返回字段：板块名称(f14)、涨跌幅(f3)、上涨家数(f104)、下跌家数(f105)、
             领涨股(f128)、领涨股涨幅(f136)、换手率(f8)、总市值(f20)
    """
    import time
    url = (f"https://push2.eastmoney.com/api/qt/clist/get"
           f"?pn=1&pz={top_n}&po=0&np=1&fltt=2&invt=2"
           f"&fs=m:90+{board_type}&fields=f2,f3,f4,f8,f12,f14,f20,f21,f62,f104,f105,f128,f136&fid=f3")
    headers = {"Referer": "https://quote.eastmoney.com"}
    for attempt in range(3):
        try:
            resp = requests.get(url, headers=headers, timeout=15)
            data = resp.json()
            items = data.get('data', {}).get('diff', [])
            return sorted(items, key=lambda x: x.get('f3', 0), reverse=True)
        except Exception:
            if attempt < 2:
                time.sleep(1)
                continue
            return []  # 断连时返回空列表，由调用方决定兜底策略

# ---------- 涨停筛选 ----------
def is_limit_up(item: dict) -> bool:
    """判断是否涨停"""
    pct = float(item.get('f3', 0))
    code = str(item.get('f12', ''))
    if code.startswith(('688', '300')):  # 科创板/创业板
        return pct >= 19.5
    elif code.startswith('4') or code.startswith('8'):  # 北交所
        return pct >= 29.0
    elif item.get('f14', '').startswith(('ST', '*ST')):
        return pct >= 4.8
    else:
        return pct >= 9.8

def calc_board_days(klines: list[str], code: str) -> int:
    """从日K反推连续涨停天数"""
    days = 0
    for kline in klines:
        fields = kline.split(',')
        pct = float(fields[8])  # 涨跌幅%
        if code.startswith(('688', '300')):
            if pct >= 19.5:
                days += 1
            else:
                break
        else:
            if pct >= 9.8:
                days += 1
            else:
                break
    return days

# ---------- 腾讯财经接口（不封IP·最稳定估值） ----------
def tx_quote(codes: str) -> str:
    """获取腾讯批量实时行情"""
    url = f"https://qt.gtimg.cn/q={codes}"
    resp = requests.get(url, timeout=10)
    resp.encoding = 'gbk'
    return resp.text

def parse_tx_quote(text: str) -> list[dict]:
    """解析腾讯行情数据"""
    results = []
    for line in text.strip().split('\n'):
        if not line.startswith('v_'):
            continue
        parts = line.split('="')[1].rstrip('";').split('~')
        results.append({
            "name": parts[1], "code": parts[2], "price": float(parts[3]) if parts[3] else 0,
            "pct": float(parts[32]) if parts[32] else 0, "change": float(parts[31]) if parts[31] else 0,
            "volume": int(parts[6]) if parts[6] else 0, "amount": float(parts[37]) if parts[37] else 0,
            "high": float(parts[33]) if parts[33] else 0, "low": float(parts[34]) if parts[34] else 0,
            "open": float(parts[35]) if parts[35] else 0, "yclose": float(parts[36]) if parts[36] else 0,
            "pe": float(parts[39]) if parts[39] else 0, "turnover": float(parts[38]) if parts[38] else 0,
            "total_mv": float(parts[45]) if parts[45] else 0, "float_mv": float(parts[44]) if parts[44] else 0,
            "high_limit": float(parts[48]) if parts[48] else 0, "low_limit": float(parts[49]) if parts[49] else 0,
        })
    return results

# ---------- mootdx 通达信接口（不封IP·最全K线） ----------
def mootdx_kline(code: str, frequency: int = 9, count: int = 120) -> list:
    """获取mootdx K线数据
    frequency: 9=日线, 5=周线, 6=月线, 8=60分, 3=30分, 2=15分, 1=5分
    """
    try:
        from mootdx.quotes import Quotes
        client = Quotes.factory(market='std')
        return client.bars(symbol=code, frequency=frequency, start=0, count=count)
    except ImportError:
        raise ImportError("请先安装 mootdx: pip install 'mootdx[all]'")

def mootdx_quote(codes: list) -> list:
    """获取mootdx实时行情（46字段）"""
    try:
        from mootdx.quotes import Quotes
        client = Quotes.factory(market='std')
        return client.quotes(symbols=codes)
    except ImportError:
        raise ImportError("请先安装 mootdx: pip install 'mootdx[all]'")

# ---------- 涨跌家数细分统计 ----------
def market_sentiment(pz: int = 5000) -> dict:
    """获取全市场情绪：涨跌家数细分 + 总成交额"""
    items = em_market_ranks(pz=pz)
    result = {
        "total_up": 0, "total_down": 0, "total_flat": 0, "total_amount": 0,
        "sh_main": {"up": 0, "down": 0},         # 沪主板 60xxxx
        "sz_main": {"up": 0, "down": 0},         # 深主板 00xxxx
        "cyb": {"up": 0, "down": 0},             # 创业板 30xxxx
        "kcb": {"up": 0, "down": 0},             # 科创板 688xxx
        "bj": {"up": 0, "down": 0},              # 北交所 4/8xxxx
    }
    for item in items:
        code = str(item.get('f12', ''))
        pct = float(item.get('f3', 0))
        amount = float(item.get('f6', 0))
        result["total_amount"] += amount
        if pct > 0:
            result["total_up"] += 1
        elif pct < 0:
            result["total_down"] += 1
        else:
            result["total_flat"] += 1
        # 按板块细分
        if code.startswith('60'):
            target = result["sh_main"]
        elif code.startswith('00'):
            target = result["sz_main"]
        elif code.startswith('30'):
            target = result["cyb"]
        elif code.startswith('688'):
            target = result["kcb"]
        elif code.startswith(('4', '8')):
            target = result["bj"]
        else:
            continue
        if pct > 0:
            target["up"] += 1
        elif pct < 0:
            target["down"] += 1
    result["total_amount_亿"] = round(result["total_amount"] / 10000, 2)
    return result

# ---------- 多周期涨幅排名 ----------
def multi_day_ranks(period: str = "f109", top_n: int = 20) -> list[dict]:
    """获取多周期涨幅排名
    period: 'f109'=5日, 'f161'=10日, 'f152'=20日
    """
    import time
    url = ("https://push2.eastmoney.com/api/qt/clist/get"
           f"?pn=1&pz={top_n}&po=0&np=1&fltt=2&fid={period}"
           "&fs=m:0+t:6,m:0+t:80,m:1+t:2,m:1+t:23,m:0+t:81+s:2048"
           "&fields=f12,f14,f2,f3,f4,f5,f6,f8,f109,f152,f161,f100,f103")
    headers = {"Referer": "https://quote.eastmoney.com"}
    for attempt in range(3):
        try:
            resp = requests.get(url, headers=headers, timeout=15)
            data = resp.json()
            items = data.get('data', {}).get('diff', [])
            return sorted(items, key=lambda x: x.get(period, 0), reverse=True)
        except Exception:
            if attempt < 2:
                time.sleep(1)
                continue
            return []

# ---------- 昨日涨停今日表现（连板成功率） ----------
def yest_limitup_today() -> list[dict]:
    """获取昨日涨停股今天的表现"""
    url = ("https://push2.eastmoney.com/api/qt/clist/get"
           "?pn=1&pz=500&po=0&np=1&fltt=2"
           "&fs=b:BK0815&fields=f12,f14,f2,f3,f4,f5,f6,f8,f15,f16,f17,f18")
    headers = {"Referer": "https://quote.eastmoney.com"}
    resp = requests.get(url, headers=headers, timeout=15)
    data = resp.json()
    return data.get('data', {}).get('diff', [])

def calc_promotion_rate(items: list[dict]) -> dict:
    """计算连板成功率"""
    total = len(items)
    up2 = sum(1 for i in items if float(i.get('f3', 0)) >= 9.8)
    up7 = sum(1 for i in items if float(i.get('f3', 0)) >= 7)
    avg_pct = sum(float(i.get('f3', 0)) for i in items) / total if total else 0
    return {
        "total": total,
        "continue_limitup": up2,
        "promotion_rate": round(up2/total*100, 1) if total else 0,
        "big_positive_rate": round(up7/total*100, 1) if total else 0,
        "avg_pct": round(avg_pct, 2),
    }

七、完整使用示例

# ==================== 方式一：原始方案（新浪+东财） ====================

# 1. 获取大盘指数（新浪）
text = sina_quote("s_sh000001,s_sz399001,s_sz399006,s_sh000688")
indices = parse_sina_index(text)
for idx in indices:
    print(f"{idx['name']}: {idx['price']}  {idx['pct']:+.2f}%")

# 2. 获取涨停股（东财涨幅榜）
items = em_market_ranks(pz=500)
limit_up_stocks = [i for i in items if is_limit_up(i)]
print(f"涨停总数: {len(limit_up_stocks)}")

# 3. 反推连板天数（东财日K）
for stock in limit_up_stocks[:5]:
    code = stock['f12']
    market = 0 if code.startswith(('00','30')) else 1
    secid = f"{market}.{code}"
    klines = em_stock_kline(secid)
    boards = calc_board_days(klines, code)
    print(f"{stock['f14']}({code}): {boards}连板")


# ==================== 方式二：推荐方案（腾讯+mootdx，不封IP） ====================

# 1. 大盘指数 + 个股估值（腾讯，不封IP）
tx_data = tx_quote("sh000001,sz399001,sz399006,sh000688")
quotes = parse_tx_quote(tx_data)
for q in quotes:
    print(f"{q['name']}: {q['price']}  {q['pct']:+.2f}%  PE={q['pe']}")

# 2. 个股K线（mootdx通达信，不封IP）
kline = mootdx_kline('600519', frequency=9, count=30)
print(kline.tail())  # pandas DataFrame 格式

# 3. 个股实时行情（mootdx，46字段）
quotes = mootdx_quote(['600519', '000001'])
for q in quotes:
    print(f"{q['code']} {q['price']} 涨幅{q['pct']}%")

# ==================== 板块排行（领涨板块·题材·地区） ====================

# 领涨行业板块 Top 10
industries = em_board_ranks("t:2", top_n=10)
print("🏭 领涨行业板块：")
for b in industries:
    print(f"  {b['f14']}: {b['f3']:+.2f}%  领涨:{b.get('f128','')}({b.get('f136',0):+.2f}%)  {b.get('f104',0)}/{b.get('f105',0)}家")

# 领涨概念题材 Top 10
concepts = em_board_ranks("t:3", top_n=10)
print("💡 领涨题材：")
for b in concepts:
    print(f"  {b['f14']}: {b['f3']:+.2f}%  领涨:{b.get('f128','')}({b.get('f136',0):+.2f}%)")

# 领涨地区 Top 10
regions = em_board_ranks("t:1", top_n=10)
print("🗺️ 领涨地区：")
for b in regions:
    print(f"  {b['f14']}: {b['f3']:+.2f}%  领涨:{b.get('f128','')}({b.get('f136',0):+.2f}%)")


# ==================== 涨跌家数细分 ====================

sentiment = market_sentiment(pz=5000)
print(f"📊 全市场: ↑{sentiment['total_up']} / ↓{sentiment['total_down']} / 成交{sentiment['total_amount_亿']}亿")
print(f"  沪主板: ↑{sentiment['sh_main']['up']} / ↓{sentiment['sh_main']['down']}")
print(f"  深主板: ↑{sentiment['sz_main']['up']} / ↓{sentiment['sz_main']['down']}")
print(f"  创业板: ↑{sentiment['cyb']['up']} / ↓{sentiment['cyb']['down']}")
print(f"  科创板: ↑{sentiment['kcb']['up']} / ↓{sentiment['kcb']['down']}")


# ==================== 多周期涨幅排名 ====================

top5 = multi_day_ranks("f109", 5)  # 5日涨幅前5
print("📈 5日涨幅排名：")
for s in top5:
    print(f"  {s['f14']}({s['f12']}): 5日+{s.get('f109',0):.2f}%  所属:{s.get('f100','')}")

top20 = multi_day_ranks("f152", 5)  # 20日涨幅前5
print("📈 20日涨幅排名：")
for s in top20:
    print(f"  {s['f14']}({s['f12']}): 20日+{s.get('f152',0):.2f}%  所属:{s.get('f100','')}")


# ==================== 连板成功率 ====================

items = yest_limitup_today()
rate = calc_promotion_rate(items)
print(f"🎯 连板成功率: {rate['promotion_rate']}% ({rate['continue_limitup']}/{rate['total']})")
print(f"   平均涨幅: {rate['avg_pct']:+.2f}%  | 大阳率(>=7%): {rate['big_positive_rate']}%")


# ==================== 方式三：专业方案（悟道API，需Key） ====================

# import requests
# LB_API_KEY = "your_key_here"
# LB_API_BASE = "https://stock.quicktiny.cn/api"
# headers = {"Authorization": f"Bearer {LB_API_KEY}"}

# # 涨停梯队
# resp = requests.get(f"{LB_API_BASE}/ladder?date=2026-06-18", headers=headers)
# print(resp.json())

# # 龙虎榜
# resp = requests.get(f"{LB_API_BASE}/dragon-tiger?date=2026-06-18", headers=headers)
# print(resp.json())

# # 竞价数据
# resp = requests.get(f"{LB_API_BASE}/auction?code=600519", headers=headers)
# print(resp.json())

八、注意事项

8.1 各数据源注意事项

数据源	注意点
新浪	返回GBK编码，需做 `resp.encoding = 'gbk'` 或 `iconv -f GBK -t UTF-8` 转换
东方财富	`po=1`（升序）从最小涨幅开始排，需结合涨幅筛选使用；偶尔出现 `RemoteDisconnected` 断连。若全市场/板块接口连续返回空或断连，立即用 akshare 兜底：`python3 -m pip install --user -q akshare` 后调用 `stock_zh_a_spot_em()`、`stock_zt_pool_em(date=YYYYMMDD)`、`stock_board_industry_name_em()`、`stock_board_concept_name_em()`；若 `stock_zh_a_spot_em()` 也断连，不要放弃，继续尝试 `stock_zt_pool_em` / `stock_zt_pool_dtgc_em` / `stock_zt_pool_zbgc_em`，涨停池、跌停池、炸板池常可独立成功。
腾讯财经	返回字段较多（60+字段），按位置索引取值，注意空字段保护；不封IP，推荐优先使用
mootdx	首次使用需 `pip install 'mootdx[all]'`；M1/M2 Mac 需用 Rosetta：`arch -x86_64 pip install mootdx`；如连接超时，加 `bestip=True` 参数或手动指定服务器
百度股市通	接口稳定性一般，建议作为辅助数据源
同花顺	接口可能会变化，需定期验证；北向资金接口返回原始数据
悟道A股	需要 API Key（`https://stock.quicktiny.cn/developer` 注册）；免费额度有调用次数限制；MCP 协议配置可选

8.2 数据源选择优先级

场景	首选	兜底
大盘指数	新浪 → 腾讯	东财
涨停股列表	akshare `stock_zt_pool_em`（含连板数）	东财涨幅榜筛选
涨停原因/概念	东财涨停池(f103) / 悟道	akshare `stock_zt_pool_em`（含所属行业）
连板梯队	akshare `stock_zt_pool_em`（连板数列直接分组）	悟道 / 自推算
炸板池/炸板率	akshare `stock_zt_pool_zbgc_em`	悟道炸板池
跌停池	akshare `stock_zt_pool_dtgc_em`（唯一正确源）	⚠️ 禁止用涨幅榜筛选f3<=-9.8%自己算跌停！见下方错误说明

⚠️ 跌停判定错误说明（2026-06-28 修正）

历史错误：自己从全市场行情用涨跌幅阈值判定跌停，导致数据严重偏差。

错误方式	结果	原因
`pct <= -9.8` 判定所有板块跌停	74只（高估2倍+）	把跌超9.8%但未跌停的也算入
688/300开头跌-10%算跌停	多算20+只	科创板/创业板跌停是-20%，跌-10%不是跌停！
新浪API按-10%±0.15%匹配但未区分板块	56只	688/300跌-10%被错误归入主板判定

正确方式：直接调用 ak.stock_zt_pool_dtgc_em(date="YYYYMMDD")，返回东财官方跌停池数据。

import akshare as ak

# ✅ 正确：用跌停池API
df = ak.stock_zt_pool_dtgc_em(date="20260626")
print(f"跌停: {len(df)}只")  # 30只

# ❌ 错误：自己从全市场行情算
# spot = ak.stock_zh_a_spot_em()
# dt = spot[spot['涨跌幅'] <= -9.8]  # 会多算很多非跌停股！

跌停幅度规则（仅作参考理解，不要自己实现判定）：

主板（60/000/002/003等）：跌停 -10%，ST -5%
创业板（300/301）：跌停 -20%
科创板（688）：跌停 -20%
北交所（4/8）：跌停 -30%

8.3 通用规则

日K反推：从最新一天向历史回溯，遇到不涨停即停止
secid规则：深市=0.代码，沪市=1.代码，北交所按f13组合
板块排序：fid=f3排序可能不生效，建议在应用层自行排序
涨停池接口：东方财富专用涨停池接口可能返回null，不可作为唯一来源
mootdx 服务器：通达信行情服务器可能变更，定期执行 pip install -U mootdx

stock-data-fetcher

More from this repository

More from this repository

A股实时行情数据抓取系统

一、数据接口总览

1.1 新浪指数快照（最稳定·兜底）

1.2 东方财富全市场涨幅榜（核心）

1.3 东方财富个股快照

1.4 东方财富日K线（反推连板天数）

1.5 东方财富板块排行（行业·概念·地区）

1.6 东方财富涨停池接口（备用）

1.7 腾讯财经（实时估值·不封IP）⭐

1.8 mootdx 通达信接口（最全K线·盘口·不封IP）⭐

1.9 百度股市通（K线自带均线）

1.10 同花顺热点·北向资金（零鉴权）

1.11 东方财富涨停池（含涨停原因·连板·所属行业）⭐

1.12 全市场多周期涨幅排名（5日/10日/20日涨幅）

1.13 涨跌家数细分统计

1.14 昨日涨停今日表现（连板成功率）

1.15 悟道A股 🔑（仅涨停梯队 API 可用·数据最丰富）

1.16 akshare 涨停池三件套（免费·替代悟道涨停梯队）⭐

1.17 efinance 龙虎榜·资金流·板块归属（免费·替代悟道龙虎榜+资金流）⭐

二、涨停筛选规则

三、数据采集流程

流程1：获取大盘情绪

流程2：获取涨停梯队

流程3：获取板块热点（领涨板块·领涨题材·领涨地区）

流程4：获取资金流向（新增）

流程5：获取龙虎榜（新增·需悟道Key）

流程6：获取竞价数据（新增·需悟道Key）

流程7：获取个股详情

流程8：涨跌家数细分统计（新增）

流程9：多周期涨幅排名（新增）

流程10：连板成功率监控（新增）

四、市场情绪指标体系

4.1 基础情绪指标（免费接口即可获取）

4.2 进阶情绪指标（需悟道Key）

五、输出格式模板

大盘情绪快照输出模板

涨停梯队输出模板

板块排行输出模板

快速调用的 Python 示例

龙虎榜输出模板（新增·需悟道Key）

资金流向输出模板（新增·需悟道Key）

竞价数据输出模板（新增·需悟道Key）

涨跌家数细分模板（新增）

多周期涨幅排名模板（新增）

连板成功率模板（新增）

六、Python工具函数

七、完整使用示例

八、注意事项

8.1 各数据源注意事项

8.2 数据源选择优先级

⚠️ 跌停判定错误说明（2026-06-28 修正）

8.3 通用规则

A股实时行情数据抓取系统

一、数据接口总览

1.1 新浪指数快照（最稳定·兜底）

1.2 东方财富全市场涨幅榜（核心）

1.3 东方财富个股快照

1.4 东方财富日K线（反推连板天数）

1.5 东方财富板块排行（行业·概念·地区）

1.6 东方财富涨停池接口（备用）

1.7 腾讯财经（实时估值·不封IP）⭐

1.8 mootdx 通达信接口（最全K线·盘口·不封IP）⭐

1.9 百度股市通（K线自带均线）

1.10 同花顺热点·北向资金（零鉴权）

1.11 东方财富涨停池（含涨停原因·连板·所属行业）⭐

1.12 全市场多周期涨幅排名（5日/10日/20日涨幅）

1.13 涨跌家数细分统计

1.14 昨日涨停今日表现（连板成功率）

1.15 悟道A股 🔑（仅涨停梯队 API 可用·数据最丰富）

1.16 akshare 涨停池三件套（免费·替代悟道涨停梯队）⭐

1.17 efinance 龙虎榜·资金流·板块归属（免费·替代悟道龙虎榜+资金流）⭐

二、涨停筛选规则

三、数据采集流程

流程1：获取大盘情绪

流程2：获取涨停梯队

流程3：获取板块热点（领涨板块·领涨题材·领涨地区）

流程4：获取资金流向（新增）