# -*- coding: utf-8 -*-
"""生成单页离线 HTML 市场情绪日报（暗色盘面复盘风，全内联）"""
import json
import re
import sys
from collections import Counter, defaultdict
from datetime import datetime
from html import escape
from pathlib import Path
TRADE_DATE = sys.argv[1] if len(sys.argv) > 1 else datetime.now().strftime("%Y-%m-%d")
MODE = sys.argv[2] if len(sys.argv) > 2 else "full" # full | intraday
SHOW_LHB = MODE != "intraday"
BASE = Path(__file__).parent
DATA = BASE / (sys.argv[3] if len(sys.argv) > 3 else "data")
OUTFILE = BASE / (f"A股实时情绪_盘中_{TRADE_DATE}.html"
if MODE == "intraday" else f"A股市场情绪日报_{TRADE_DATE}.html")
UP = "#f6465d" # 涨 红
DOWN = "#0ecb81" # 跌 绿
FLAT = "#8b949e"
# ---------------- 载入数据 ----------------
lhb_raw = json.loads((DATA / "lhb.json").read_text(encoding="utf-8")) if SHOW_LHB else []
hot = json.loads((DATA / "ths_hot.json").read_text(encoding="utf-8"))
ind_raw = json.loads((DATA / "industry_raw.json").read_text(encoding="utf-8"))
idx = json.loads((DATA / "index.json").read_text(encoding="utf-8"))
try:
ind_detail = json.loads((DATA / "industry_detail.json").read_text(encoding="utf-8"))
except Exception:
ind_detail = {}
# ---------------- 龙虎榜聚合（按个股去重）----------------
grp = defaultdict(list)
for r in lhb_raw:
grp[r["code"]].append(r)
lhb = []
for code, rows in grp.items():
main = max(rows, key=lambda x: abs(x["net_buy"]))
reasons = []
for x in rows:
if x["reason"] and x["reason"] not in reasons:
reasons.append(x["reason"])
lhb.append({
"code": code, "name": main["name"], "close": main["close"],
"change_pct": main["change_pct"], "net_buy": main["net_buy"],
"buy_amt": max(x["buy_amt"] for x in rows),
"sell_amt": max(x["sell_amt"] for x in rows),
"turnover_pct": max(x["turnover_pct"] for x in rows),
"accum_amount": main["accum_amount"],
"free_mcap": main["free_mcap"],
"reasons": reasons, "n_rec": len(rows),
})
lhb.sort(key=lambda x: x["net_buy"], reverse=True)
net_total = sum(x["net_buy"] for x in lhb)
buy_total = sum(x["buy_amt"] for x in lhb)
sell_total = sum(x["sell_amt"] for x in lhb)
n_netbuy = sum(1 for x in lhb if x["net_buy"] > 0)
n_netsell = sum(1 for x in lhb if x["net_buy"] < 0)
n_up = sum(1 for x in lhb if x["change_pct"] > 0)
n_down = sum(1 for x in lhb if x["change_pct"] < 0)
n_limitup = sum(1 for x in lhb if x["change_pct"] >= 9.8)
# ---------------- 题材词频 ----------------
tag_stocks = defaultdict(list)
for h in hot:
for t in re.split(r"[+＋]", str(h.get("reason") or "")):
t = t.strip()
if t:
tag_stocks[t].append(h)
tag_cnt = Counter({k: len(v) for k, v in tag_stocks.items()})
top_tags = tag_cnt.most_common(15)
multi_tags = [(t, c) for t, c in tag_cnt.items() if c >= 2]
multi_tags.sort(key=lambda x: -x[1])
hot_up = [float(h["change_pct"]) for h in hot if h.get("change_pct") not in (None, "")]
# ---------------- 行业 ----------------
inds = [i for i in ind_raw if i.get("kline")]
for i in inds:
i["chg"] = i["kline"]["change_pct"]
i["amount"] = i["kline"]["amount"]
i["turnover"] = i["kline"]["turnover"]
d = ind_detail.get(i["code"]) or {}
i["up"] = d.get("up")
i["down"] = d.get("down")
i["flat"] = d.get("flat")
i["members"] = d.get("sampled")
i["leader"] = d.get("leader")
i["laggard"] = d.get("laggard")
inds.sort(key=lambda x: x["chg"], reverse=True)
ind_top = inds[:15]
ind_bottom = list(reversed(inds[-15:]))
n_ind_up = sum(1 for i in inds if i["chg"] > 0)
n_ind_down = sum(1 for i in inds if i["chg"] < 0)
# ---------------- 工具 ----------------
def money(v, unit="元"):
"""元 -> ¥x.xx亿 / ¥x万"""
a = abs(v)
s = "-" if v < 0 else ""
if a >= 1e8:
return f"{s}¥{a/1e8:.2f}亿"
if a >= 1e4:
return f"{s}¥{a/1e4:.0f}万"
return f"{s}¥{a:.0f}"
def pct(v, plus=True):
return f"{'+' if (plus and v > 0) else ''}{v:.2f}%"
def color(v):
return UP if v > 0 else (DOWN if v < 0 else FLAT)
def esc(s):
return escape(str(s), quote=True)
# ---------------- SVG 1: 题材热度 ----------------
def svg_themes():
rows = top_tags
if not rows:
return "
无数据
"
W, rowh, pad_l, pad_r, top = 1000, 30, 210, 70, 34
H = top + rowh * len(rows) + 18
maxv = max(c for _, c in rows)
bw = W - pad_l - pad_r
p = [f'")
return "".join(p)
# ---------------- SVG 2: 行业涨跌 ----------------
def svg_industry():
if not inds:
return ('')
rows = ind_top[:12] + ind_bottom[:12]
rows = sorted({r["code"]: r for r in rows}.values(), key=lambda r: r["chg"], reverse=True)
# 列：0-150 行业名 | 155-245 涨跌家数 | 轴心 cx=420，正负各 160px 条 | 640+ 领涨股
W, rowh, top = 1000, 28, 46
cx, half = 420, 150
H = top + rowh * len(rows) + 12
maxa = max(abs(r["chg"]) for r in rows) or 1
p = [f'")
return "".join(p)
# ---------------- SVG 3: 龙虎榜净买入排名 ----------------
def svg_lhb():
if not lhb:
return ('')
tops = lhb[:15]
bots = [x for x in lhb if x["net_buy"] < 0][-10:]
rows = tops + list(reversed(bots))
# 列：0-150 名称 | 155-215 代码 | 225-275 涨跌幅 | 轴心 cx=460，正 430 / 负 180
W, rowh, top = 1000, 28, 46
cx, halfp, halfn = 460, 430, 150
H = top + rowh * len(rows) + 12
maxa = max(abs(r["net_buy"]) for r in rows) or 1
p = [f'")
return "".join(p)
# ---------------- 表格 ----------------
def table_lhb():
if not lhb:
return '
龙虎榜尚未公布（盘后 16:00 后自动补充）
'
tr = []
for i, r in enumerate(lhb, 1):
tr.append(
f'
{i}
{esc(r["code"])}
'
f'
{esc(r["name"])}
'
f'
{r["close"]:.2f}
'
f'
{r["change_pct"]:+.2f}%
'
f'
=0 else DOWN}">{money(r["net_buy"])}
'
f'
{money(r["buy_amt"])}
'
f'
{money(r["sell_amt"])}
'
f'
{r["turnover_pct"]:.2f}%
'
f'
{money(r["accum_amount"])}
'
f'
{esc(" / ".join(r["reasons"]))}
')
return "".join(tr)
def card_lhb():
"""龙虎榜明细：横滑卡片行（每个股一张卡），移动端友好。"""
if not lhb:
return '
龙虎榜尚未公布（交易所盘后 16:00 后发布，届时自动补充）
'
cards = []
for r in lhb:
nc = UP if r["net_buy"] >= 0 else DOWN
cards.append(
'
'
)
return "".join(cards)
def table_industry(rows):
tr = []
for i, r in enumerate(rows, 1):
ld = r.get("leader")
lead = (f'{esc(ld["name"])} {ld["change_pct"]:+.2f}%'
if ld else '—')
ud = (f'{r["up"]} / {r["down"]}'
f' / {r["flat"]}' if r.get("up") is not None else '—')
tr.append(
f'
{i}
{esc(r["name"])}
'
f'
{r["chg"]:+.2f}%
'
f'
{ud}
'
f'
{money(r["amount"])}
'
f'
{r["turnover"]:.2f}%
'
f'
{lead}
')
return "".join(tr)
def fchg(s):
try:
return float(s)
except (TypeError, ValueError):
return 0.0
def table_themes():
tr = []
for i, (tag, c) in enumerate(multi_tags[:20], 1):
sts = tag_stocks[tag]
chips = " ".join(
f''
f'{esc(s["name"])}{fchg(s["change_pct"]):+.1f}%'
for s in sorted(sts, key=lambda x: -fchg(x["change_pct"])))
tr.append(f'
{i}
{esc(tag)}
'
f'
{c}
{chips}
')
return "".join(tr)
def index_cards():
out = []
for nm, d in idx.items():
out.append(f'
"""
# ---------------- 页脚来源（按模式） ----------------
if SHOW_LHB:
src_html = (f"① 龙虎榜 — 东方财富数据中心 每日龙虎榜详情（datacenter-web.eastmoney.com，reportName=RPT_DAILYBILLBOARD_DETAILSNEW）； "
f"② 题材热点 — 同花顺当日强势股题材归因（zx.10jqka.com.cn/event/api/getharden，reason 字段按「+」拆分词频）； "
f"③ 行业板块 — 东方财富行业板块列表（push2 clist，m:90+t:2）+ 各板块 {TRADE_DATE} 历史日K（push2his kline）； "
f"④ 行业成分股涨跌家数与领涨股 — 东方财富板块成分（clist b:BKxxxx）+ 腾讯财经历史日K（不复权收盘价计算当日涨跌幅）； "
f"⑤ 指数行情 — 腾讯财经历史日K。")
gen_note = "数据为该日盘后最终值"
caveat = (f"龙虎榜金额为交易所公布的营业部席位买卖金额，非个股全天资金流；行业涨跌家数基于东财板块成分股名单与腾讯历史收盘价计算，"
f"成分股名单为最新快照，可能与 {TRADE_DATE} 当日成分略有出入；")
else:
src_html = ("① 龙虎榜 — 交易所盘后数据，本实时版不含（盘后完整日报自动补充）； "
"② 题材热点 — 同花顺当日强势股题材归因（zx.10jqka.com.cn/event/api/getharden，reason 字段按「+」拆词频）； "
"③ 行业板块 — 东方财富行业板块实时行情（push2 clist 实时，m:90+t:1 一级行业），直接含涨跌幅 / 涨跌家数 / 领涨股； "
"⑤ 指数行情 — 东方财富实时行情（push2 stock/get）。")
gen_note = "数据为盘中实时快照"
caveat = ("行业涨跌家数与领涨股来自东财板块实时接口（f104/f105/f128），盘中随行情变动；本版不含龙虎榜（盘后数据）；")
# 自动刷新 JS（每60s 强制 reload + 保持滚动位置）。meta refresh 作兜底，JS 主导更可靠。
n_ind_red = round(n_ind_up / len(inds) * 100, 1) if inds else 0
theme_chips = " ".join(f'{esc(t)} {c}' for t, c in top_tags[:8])
TAB_JS = """
var TABS = ['overview','theme','industry','lhb','watch'];
window.currentTab = 'overview';
function switchTab(t){
window.currentTab = t;
document.querySelectorAll('.tab').forEach(function(x){ x.classList.toggle('active', x.getAttribute('data-tab')===t); });
document.querySelectorAll('.tabpane').forEach(function(p){ p.classList.toggle('active', p.getAttribute('data-tab')===t); });
var sc = document.getElementById('screen'); if (sc) sc.scrollTop = 0;
try{ localStorage.setItem('sl_tab', t); }catch(e){}
}
document.querySelectorAll('.tab').forEach(function(b){
b.addEventListener('click', function(){ switchTab(b.getAttribute('data-tab')); });
});
// 左右滑动切换 Tab
var _sx=0,_sy=0,_st=null;
var _screen=document.getElementById('screen');
if(_screen){
_screen.addEventListener('touchstart',function(e){var t=e.changedTouches[0];_sx=t.clientX;_sy=t.clientY;_st=Date.now();},{passive:true});
_screen.addEventListener('touchend',function(e){
var t=e.changedTouches[0];var dx=t.clientX-_sx,dy=t.clientY-_sy;
if(Date.now()-_st<600 && Math.abs(dx)>50 && Math.abs(dx)>Math.abs(dy)*1.5){
var cur=TABS.findIndex(function(x){return document.querySelector('.tabpane.active')&&document.querySelector('.tabpane.active').getAttribute('data-tab')===x;});
if(cur<0)cur=0;
var nx = dx<0 ? Math.min(cur+1,TABS.length-1) : Math.max(cur-1,0);
switchTab(TABS[nx]);
}
},{passive:true});
}
// 恢复上次停留的 Tab（避免 60s 整页刷新把用户弹回概览）
try{
var _t = localStorage.getItem('sl_tab');
if(_t && TABS.indexOf(_t) >= 0){ switchTab(_t); }
}catch(e){}
"""
WATCH_JS = """
function initWatch(){
var listEl=document.getElementById('wlList');
var input=document.getElementById('wlInput');
var addBtn=document.getElementById('wlAddBtn');
if(!listEl) return;
// 轻量设备令牌：首次访问自动生成 64-hex 身份并存入 localStorage，后续所有请求携带
var UID=localStorage.getItem('sl_uid');
if(!UID||!/^[0-9a-f]{32,64}$/.test(UID)){
var _b=new Uint8Array(32); (window.crypto||window.msCrypto).getRandomValues(_b);
UID=Array.prototype.map.call(_b,function(x){return x.toString(16).padStart(2,'0');}).join('');
localStorage.setItem('sl_uid',UID);
}
function api(path,opts){
opts=opts||{}; opts.headers=opts.headers||{}; opts.headers['Authorization']='Bearer '+UID;
return fetch(path,opts).then(function(r){ if(r.status===401){alert('身份无效，请刷新页面重新获取');throw new Error('AUTH');} return r; });
}
var wlCodes=[];
function esc(s){return (s==null?'':String(s)).replace(/[&<>]/g,function(c){return {'&':'&','<':'<','>':'>'}[c];});}
function fmt(n){return (n==null||isNaN(n))?'':Number(n).toFixed(2);}
function col(v){return v>0?'var(--up)':(v<0?'var(--down)':'var(--dim)');}
function load(){
api('/api/watchlist').then(function(r){return r.json();}).then(function(wl){
var codes=wl.codes||[]; wlCodes=codes;
if(!codes.length){listEl.innerHTML='
暂无自选股，添加一只开始跟踪
';return;}
fetch('/api/quote?codes='+codes.join(',')).then(function(r){return r.json();}).then(function(qs){
var map={}; qs.forEach(function(q){map[q.code]=q;});
var html='';
codes.forEach(function(code){
var q=map[code]||{code:code,name:'—',price:0,change_pct:0};
var cp=q.change_pct||0;
html+='