v2026-07-21: 实战教训汇总 (push 11 文件)

新增 8 reference:
  - dividend-stability-score: A 股 5 维评分 (派息年数/CAGR/波动/最近/连续) → 0-100 分 + 5 星
  - dividend-yield-rate-sort: 按股息率% 倒序 (用户偏好 2026-07-13)
  - longport-http-module: longport_http.py 公共模块 (替代 SDK WSS)
  - leverage-pass-through-bug: process_signal.py 丢失 leverage 字段 (5x 实际 10x)
  - follow-trading-iron-laws: 跟单铁律 (用户原话 5+ 次 2026-07-21)
  - forced-skill-entry-okx-trade: okx_trade.sh 强制入口 (替代 ccxt 裸调)
  - mihomo-clash-node-supplier-dns: Clash 节点供应商 DNS 失败处理
  - mihomo-ssl-reconnect-pattern: mihomo 反复 SSL/Timeout 模式
  - v4.5.44-mu-add-to-75pct-cap: MU 加仓 75% 单币种 cap 标准流程

改 2 SKILL.md:
  - dividend-investing: 加 5 维评分 + 长桥 http 模块
  - longbridge-cli: 标注 '不要写 openapi.QuoteContext' + 迁移说明
This commit is contained in:
2026-07-22 13:22:45 +08:00
parent e23f8d38c0
commit b660debd06
11 changed files with 907 additions and 244 deletions
@@ -0,0 +1,154 @@
---
name: dividend-stability-score
description: "5 维综合分红稳定性评分 0-100 (派息年数/CAGR/波动/最近/连续) + 5 星等级. 用于 A 股 — 港美股可扩展 (占位)"
version: 1.0.0
type: reference
---
# 分红稳定性评分 (Stability Score)
**用户原话** (2026-07-22): 推送要加**分红稳定性**,综合评分。
## 设计 (5 维, 100 分总分)
| 维度 | 分值 | 说明 |
|------|------|------|
| **派息年数** | 30 | 派过 15 年满分 |
| **派息 CAGR** | 20 | 最新/最早比, 复合年增长 ≥10% 满分 |
| **波动率**(CV) | 25 | 派息标准差/均值, ≤0.2 满分 |
| **最近 ≥ 上次** | 15 | `latest_div >= prev_div` |
| **连续性** | 10 | 最近 3 年都派 |
## 等级 (0-100 → 1-5 星)
| 分数 | 等级 | 标签 |
|------|------|------|
| 80-100 | 5★ | 长期稳定 |
| 60-79 | 4★ | 基本稳定 |
| 40-59 | 3★ | 不稳定 |
| 20-39 | 2★ | 风险大 |
| 0-19 | 1★ | 不推荐 |
## 实现 (`dividend_alert.py` 已部署)
```python
def score_dividend_stability(symbol: str, market: str) -> dict:
"""返回: {"score": 75, "level": 4, "label": "基本稳定", "years": 10, "cagr": 5.2, "cv": 0.3, "latest_div": 3.5}"""
try:
if market != "CN":
return None # 暂时只 A 股 (akshare)
import akshare as ak
code = symbol.replace(".SH", "").replace(".SZ", "").replace(".BJ", "")
df = ak.stock_history_dividend_detail(symbol=code, indicator="分红")
if df is None or len(df) < 3:
return None
df = df[df["进度"] == "实施"].copy()
df["派息"] = pd.to_numeric(df["派息"], errors="coerce")
df = df.dropna(subset=["派息"])
df = df[df["派息"] > 0]
if len(df) < 3:
return None
df["年份"] = pd.to_datetime(df["公告日期"]).dt.year
df = df.sort_values("年份", ascending=False).reset_index(drop=True)
years_count = df["年份"].nunique()
latest_div = df["派息"].iloc[0]
oldest_div = df["派息"].iloc[-1]
years_score = min(30, years_count * 2) # 15 年满分
if years_count >= 2 and oldest_div > 0:
cagr = (latest_div / oldest_div) ** (1 / (years_count - 1)) - 1
if cagr >= 0.10: cagr_score = 20
elif cagr >= 0.05: cagr_score = 15
elif cagr >= 0.02: cagr_score = 10
elif cagr >= 0: cagr_score = 5
else: cagr_score = 0
else:
cagr = 0
cagr_score = 0
if len(df) >= 3:
mean_div = df["派息"].mean()
std_div = df["派息"].std()
cv = std_div / mean_div if mean_div > 0 else 1
if cv <= 0.2: vol_score = 25
elif cv <= 0.4: vol_score = 20
elif cv <= 0.6: vol_score = 15
elif cv <= 0.8: vol_score = 10
else: vol_score = 5
else:
cv = 1
vol_score = 5
recent_score = 15 if (len(df) >= 2 and df["派息"].iloc[0] >= df["派息"].iloc[1]) else 5
consecutive_score = 10 if (years_count >= 3 and len(df["年份"].head(3).unique()) >= 3) else 0
total = years_score + cagr_score + vol_score + recent_score + consecutive_score
if total >= 80: level, label = 5, "长期稳定"
elif total >= 60: level, label = 4, "基本稳定"
elif total >= 40: level, label = 3, "不稳定"
elif total >= 20: level, label = 2, "风险大"
else: level, label = 1, "不推荐"
return {"score": total, "level": level, "label": label, "years": years_count, "cagr": cagr * 100, "cv": cv, "latest_div": latest_div}
except Exception as e:
print(f" [WARN] score_dividend_stability {symbol} failed: {e}", file=sys.stderr)
return None
```
## 推送格式
集成到 `dividend_alert.py` fmt():
```
600033 福建高速 [3★不稳定 25年CAGR-2%]
💰每10股派0.71元 | 📊3.53 | 股息率 2.01%
```
格式: `[<level>★<label> <years>年CAGR<cagr:+int>%]` 在股票名后, 派息行前。
## 缓存 (避免重复 akshare 调用)
```python
_stability_cache = {}
def score_dividend_stability(symbol, market):
cache_key = f"{market}:{symbol}"
if cache_key in _stability_cache:
return _stability_cache[cache_key]
...
_stability_cache[cache_key] = result
return result
```
**为什么**:dividend_alert.py 跑 1 次 12 只 A 股, 每次 23 秒。AKShare 历史派息 API 1 只 1-2 秒。**12 只 × 1.5s = 18 秒纯 akshare 调用**。用 cache 减少到 0 (单次 cron 内重复)。
## 限制
- **A 股只**(akshare 历史数据完整, HK/US 缺)
- **要 ≥ 3 年派息** 才评分 (样本不足跳过, 显示没标签)
- **CAGR 受疫情/异常影响大**(2020+ 多数公司派息都降, CAGR 全负)。**以后经济恢复, 这部分会变好**。
## 实际效果 (2026-07-22 测试)
| 股票 | 分数 | 等级 | 年数 | CAGR |
|------|------|------|------|------|
| 河钢股份 | 4★ | 基本稳定 | 22年 | -12% |
| 福建高速 | 3★ | 不稳定 | 25年 | -2% |
| 南玻 A | 3★ | 不稳定 | 31年 | -4% |
**注意**:CAGR 全负是因为疫情后多数公司派息下降——**4★ 河钢 22 年 CAGR -12% 还是"基本稳定"**, 当前阈值偏松。等经济恢复后再调严。
## 调参选项
如果觉得阈值不对:
- **调严** 改分数区间(比如 `total >= 90 → 5★`)
- **调 CAGR 权重** 改 `cagr >= 0.10` 等条件
- **加新维度**: 派息比率(payout ratio)= `派息/净利润`, 现金流覆盖 = `经营现金流/派息`
如果要扩到港美股, 需要单独 API:
- **港股**: AKShare 没历史, 用 `ccxt``yfinance` 替代
- **美股**: `yfinance``.dividends` 列 (但只含过去 5 年)
@@ -0,0 +1,90 @@
---
name: dividend-yield-rate-sort
description: "分红扫描按股息率% 倒序(用户偏好 2026-07-13),不按派息金额"
version: 1.0.0
type: reference
---
# 分红扫描: 按股息率% 排序(用户明确偏好)
## 用户原话
> "这种任务推送的结果, 按股息率排个序, 倒序" (2026-07-13)
## 错误做法 ❌
`dividend_alert.py` 原版按 **`div` 字段排序**(派息金额绝对值 USD):
```python
us_h = sorted(us_r, key=lambda x: -x['div']) # 错!
```
**问题**: 派息 USD 0.54(NEWTH)排第一,但股息率 8.49%;派息 USD 0.14(CPZ)股息率 **12.74%** 被挤后面。**用户买的是收益率,不是绝对金额**。
## 正确做法 ✅
**年化股息率 % = (年化派息 / 当前价) × 100** 倒序排序:
- 美股: `yield = annual_div / price × 100`
- A 股: `yield = (每 10 股派 / 10) / price × 100`
- 港股: 同 A 股(每 10 股派多少 HKD)
### 代码模板(2026-07-13 已部署 dividend_alert.py)
```python
# 4.5. 重排序 - 按股息率% 倒序
def _yr_a(r):
price = (a_p.get(r['code'] + '.SH') or a_p.get(r['code'] + '.SZ') or a_p.get(r['code'] + '.BJ') or 0)
if price <= 0: return 0
return (r.get('div', 0) / 10) / price * 100
def _yr_hk(r):
price = (hk_p.get(r['code'] + '.HK') or 0)
if price <= 0: return 0
return (r.get('div', 0) / 10) / price * 100
def _yr_us(r):
price = (us_p.get(r['code'] + '.US') or 0)
if price <= 0: return 0
# 关键: fetch_us() 字段名是 'ann' (不是 'ann_div')
# 原代码用 'ann_div' 拿不到 → fallback 到 'div' 单次派息
# → 算出的 yield 是当次收益率,不是年化 (SATA 年化 12.54% 被算成 0.05%)
ann = r.get('ann', 0) or r.get('div', 0)
return ann / price * 100
if a_p: a_h = sorted(a_h, key=lambda x: -_yr_a(x))
if hk_p: hk_h = sorted(hk_h, key=lambda x: -_yr_hk(x))
if us_p: us_h = sorted(us_h, key=lambda x: -_yr_us(x))
```
## 排序 vs 价格的依赖
**重要**:**必须先 `batch_quote()` 拿价格**,再排序。如果先按 div 排序再去重价格,排行榜就是错的(代码顺序:`先 div 排序 → 批量拿价 → 按 yield 重排序`)。
## 实际效果对比(2026-07-13 美股清单)
| 排名 | 按派息金额 (旧) | 按股息率% (新) |
|------|-----------------|----------------|
| 1 | NEWTH $0.54 (8.49%) | **NEWTH 8.49%** |
| 2 | APOG $0.27 (2.78%) | **CPZ 12.74%** ⭐ |
| 3 | CCD $0.20 (9.03%) | CCD 9.03% |
| 4 | CPZ $0.14 (12.74%) | CHY 8.73% |
| 5 | CSQ $0.14 (7.07%) | CHI 8.49% |
| 6 | CHY $0.10 (8.73%) | CHW 6.80% ⭐(新发现) |
| 7 | CHI $0.10 (8.49%) | CGO 7.09% |
**CPZ 12.74% 从第 4 → 第 2**(用户买到的高息标的从筛子漏出)。
## 关联文件
- `~/.hermes/scripts/dividend_alert.py` — 已部署 `dividend_alert.py --market {cn_hk|us|all}` 两种模式
- `~/.hermes/scripts/dividend_alert_cn_hk.sh` — wrapper (cron `789a7710b1cf`)
- `~/.hermes/scripts/dividend_alert_us.sh` — wrapper (cron `366934c1474c`)
- SKILL.md `dividend-investing` (若存在) 或 `cron-job-management` — cron 调度
## 其他可应用的场景
任何"收益率 / 性价比"扫描(类似 dividend alert)都该用相同排序:
- 财报收益率
- 套息年化收益率
- bond yield
- staking APY
永远 **先拿价格 → 再按收益率排序**(不是按绝对金额)。