1#!/usr/bin/env python3
2# -*- coding: utf-8 -*-
3 
4from datetime import date, datetime
5from typing import Any
6import json
7 
8 
9MAX_LEN = 1000
10 
11 
12INTENT_EMOJI = {
13    "INDEX_REALTIME": "📈",
14    "KLINE_ANALYSIS": "🕯️",
15    "KLINE_CHART": "📊",
16    "INTRADAY_ANALYSIS": "⏱️",
17    "VOLUME_ANALYSIS": "📊",
18    "LIMIT_STATS": "🚦",
19    "MONEY_FLOW": "💰",
20    "FUNDAMENTAL": "📊",
21    "STOCK_OVERVIEW": "📌",
22    "MARGIN_LHB": "🏦",
23    "SECTOR_ANALYSIS": "🧩",
24    "DERIVATIVES": "📉",
25    "FUND_BOND": "🏛️",
26    "HK_US_MARKET": "🌍",
27    "NEWS": "📰",
28    "RESEARCH_REPORT": "📰",
29    "STOCK_PICK": "🏆",
30}
31 
32 
33def _to_text(data: Any) -> str:
34    if data is None:
35        return "无数据"
36 
37    if isinstance(data, str):
38        return data
39 
40    if isinstance(data, (dict, list, tuple)):
41        import datetime as dt
42 
43        def convert(obj):
44            if isinstance(obj, dt.date):
45                return obj.isoformat()
46            if isinstance(obj, (dict, list, tuple)):
47                if isinstance(obj, dict):
48                    return {k: convert(v) for k, v in obj.items()}
49                return [convert(i) for i in obj]
50            return obj
51 
52        data = convert(data)
53        return json.dumps(data, ensure_ascii=False, indent=2)
54 
55    if hasattr(data, "to_dict"):
56        try:
57            as_dict = data.to_dict(orient="records")
58            return json.dumps(as_dict, ensure_ascii=False, indent=2)
59        except Exception:
60            pass
61 
62    return str(data)
63 
64 
65def _truncate(text: str, limit: int = MAX_LEN) -> str:
66    if len(text) <= limit:
67        return text
68    suffix = "\n...\n(内容过长，已截断)"
69    keep = max(0, limit - len(suffix))
70    return text[:keep] + suffix
71 
72 
73def _safe_float(value: Any) -> Any:
74    if value is None:
75        return None
76    if isinstance(value, str):
77        value = value.replace(",", "").replace("%", "").strip()
78    try:
79        return float(value)
80    except Exception:
81        return None
82 
83 
84def _fmt_price(value: Any) -> str:
85    num = _safe_float(value)
86    if num is None:
87        return str(value) if value is not None else "?"
88    return f"{num:.2f}"
89 
90 
91def _fmt_pct(value: Any) -> str:
92    num = _safe_float(value)
93    if num is None:
94        return "?"
95    return f"{num:+.2f}%"
96 
97 
98def _fmt_amount(value: Any) -> str:
99    num = _safe_float(value)
100    if num is None:
101        return str(value) if value is not None else "?"
102    abs_num = abs(num)
103    if abs_num >= 1e8:
104        return f"{num / 1e8:.2f}亿"
105    if abs_num >= 1e4:
106        return f"{num / 1e4:.2f}万"
107    return f"{num:.0f}"
108 
109 
110def _fmt_ratio(value: Any) -> str:
111    num = _safe_float(value)
112    if num is None:
113        return "?"
114    return f"{num:.2f}%"
115 
116 
117def _fmt_date(value: Any) -> str:
118    if value is None:
119        return "未知"
120    if isinstance(value, datetime):
121        return value.strftime("%Y-%m-%d %H:%M")
122    if isinstance(value, date):
123        return value.strftime("%Y-%m-%d")
124    if hasattr(value, "strftime"):
125        try:
126            return value.strftime("%Y-%m-%d %H:%M")
127        except Exception:
128            pass
129    text = str(value)
130    if len(text) == 8 and text.isdigit():
131        return f"{text[:4]}-{text[4:6]}-{text[6:]}"
132    return text
133 
134 
135def _pick(item: dict, keys: list[str], default: Any = None) -> Any:
136    for key in keys:
137        if key in item and item.get(key) not in (None, ""):
138            return item.get(key)
139    return default
140 
141 
142def _fmt_clock(value: Any) -> str:
143    text = _fmt_date(value)
144    if len(text) >= 16 and text[10] == " ":
145        return text[11:16]
146    if ":" in text and len(text) >= 5:
147        return text[-5:]
148    return text
149 
150 
151def _market_sentiment(changes: list[float]) -> str:
152    if not changes:
153        return "市场情绪：数据不足，偏中性。"
154 
155    pos = sum(1 for c in changes if c > 0)
156    neg = sum(1 for c in changes if c < 0)
157    avg_change = sum(changes) / len(changes)
158    spread = max(changes) - min(changes)
159 
160    if avg_change >= 0.8 and pos >= 4:
161        return "市场情绪：整体偏强，风险偏好回升。"
162    if avg_change <= -0.8 and neg >= 4:
163        return "市场情绪：整体偏弱，防御情绪升温。"
164    if spread >= 1.0 and 2 <= pos <= 3:
165        return "市场情绪：板块分化明显，结构性机会为主。"
166    return "市场情绪：震荡整理，资金观望为主。"
167 
168 
169def render_output(intent_obj, result, platform: str = "qq") -> str:
170    _ = platform
171    ts = datetime.now().strftime("%Y-%m-%d %H:%M")
172    emoji = INTENT_EMOJI.get(getattr(intent_obj, "intent", ""), "📌")
173    intent = getattr(intent_obj, "intent", "")
174 
175    # 使用说明
176    if intent == "HELP" and result.get("ok") and result.get("source") == "help":
177        return result.get("text", "")
178 
179    # 持仓管理
180    if intent == "PORTFOLIO" and result.get("source") == "portfolio":
181        return result.get("text", "")
182 
183    if intent == "INDEX_REALTIME" and result.get("ok"):
184        items = result.get("data", {}).get("items", [])
185        index_targets = [
186            ("上证指数", ["上证指数", "上证综指", "沪指"]),
187            ("深证成指", ["深证成指", "深证指数"]),
188            ("创业板指", ["创业板指"]),
189            ("沪深300", ["沪深300"]),
190            ("上证50", ["上证50"]),
191        ]
192 
193        selected = []
194        for label, aliases in index_targets:
195            matched = None
196            for item in items:
197                name = str(item.get("名称", ""))
198                if any(alias in name for alias in aliases):
199                    matched = item
200                    break
201            if matched:
202                selected.append((label, matched))
203 
204        if not selected:
205            selected = [(str(item.get("名称", "?")), item) for item in items[:5]]
206 
207        lines = [f"📊 A股实时大盘 · {ts}", ""]
208        changes = []
209        for label, item in selected:
210            price = _pick(item, ["最新价", "最新点位", "收盘"])
211            change = _pick(item, ["涨跌幅", "涨跌幅%", "涨跌"])
212            amount = _pick(item, ["成交额", "成交金额", "成交额(元)", "总成交额"])
213 
214            change_num = _safe_float(change)
215            if change_num is not None:
216                changes.append(change_num)
217            direction = "📈" if (change_num or 0) >= 0 else "📉"
218            lines.append(
219                f"{direction} {label}: {_fmt_price(price)} ({_fmt_pct(change)}) | 成交额 {_fmt_amount(amount)}"
220            )
221 
222        lines.extend(["", f"💡 {_market_sentiment(changes)}", "", "数据源: akshare"])
223        return _truncate("\n".join(lines), MAX_LEN)
224 
225    if intent == "KLINE_ANALYSIS":
226        if not result.get("ok"):
227            return "\n".join([f"{emoji} A股分析 · {ts}", f"\n⚠️ 错误: {result.get('error', '未知')}"])
228 
229        data = result.get("data", {})
230        items = data.get("items", [])
231        symbol = data.get("symbol") or getattr(intent_obj, "symbol", None) or ""
232        stock_name = data.get("name") or data.get("名称")
233        if not stock_name:
234            query = getattr(intent_obj, "query", "")
235            if query:
236                try:
237                    from router import STOCK_NAME_MAP
238 
239                    for name in sorted(STOCK_NAME_MAP, key=len, reverse=True):
240                        if name in query:
241                            stock_name = name
242                            break
243                except Exception:
244                    stock_name = None
245        if not stock_name:
246            stock_name = symbol or "未知"
247 
248        display_name = f"{stock_name}({symbol})" if symbol else stock_name
249        ts_date = datetime.now().strftime("%Y-%m-%d")
250        count = getattr(intent_obj, "top_n", None) or len(items) or 0
251        sections = [
252            f"{emoji} {display_name} 近{count}日K线 · {ts_date}",
253            "",
254        ]
255 
256        show_items = items[:5]
257        for item in show_items:
258            if not isinstance(item, dict):
259                sections.append(str(item))
260                continue
261            date_text = _fmt_date(_pick(item, ["日期", "date", "时间"]))
262            open_price = _fmt_price(_pick(item, ["开盘", "open"]))
263            close_price = _fmt_price(_pick(item, ["收盘", "close"]))
264            change = _pick(item, ["涨跌幅", "pct_change", "涨跌幅%"])
265            change_value = _safe_float(change)
266            direction = "📈" if (change_value or 0) >= 0 else "📉"
267            change_text = f" {direction} ({_fmt_pct(change)})" if change_value is not None else ""
268            sections.append(f"📅 {date_text}: 开盘 {open_price} 收盘 {close_price}{change_text}")
269 
270        if len(items) > len(show_items):
271            sections.append("...")
272 
273        sections.append("\n数据源: akshare")
274        return _truncate("\n".join(sections), MAX_LEN)
275 
276    if intent == "KLINE_CHART":
277        if not result.get("ok"):
278            return "\n".join([f"{emoji} K线图 · {ts}", f"\n⚠️ 错误: {result.get('error', '未知')}"])
279 
280        data = result.get("data", {})
281        symbol = data.get("symbol", "")
282        name = data.get("name", symbol)
283        filepath = data.get("filepath", "")
284        
285        if filepath:
286            # 直接返回图片标签，让 QQ 自动发送（不换行，避免路径前多了空格）
287            return f"📊 {name}({symbol}) 近期股价走势图<qqimg>{filepath}</qqimg>"
288        return f"📊 {name}({symbol}) 走势图生成失败"
289 
290    if intent == "INTRADAY_ANALYSIS":
291        if not result.get("ok"):
292            return "\n".join([f"{emoji} 分时分析 · {ts}", f"\n⚠️ 错误: {result.get('error', '未知')}"])
293 
294        data = result.get("data", {})
295        items = data.get("items", [])
296        symbol = data.get("symbol") or getattr(intent_obj, "symbol", "?") or "?"
297        period = data.get("period") or getattr(intent_obj, "period", None) or "1"
298 
299        lines = [f"⏱️ {symbol} 分时({period}m) · {ts}", ""]
300        if not items:
301            lines.extend(["暂无分时数据", "", "数据源: akshare"])
302            return "\n".join(lines)
303 
304        latest = items[0] if isinstance(items[0], dict) else {}
305        latest_price = _pick(latest, ["收盘", "close", "最新价", "成交价", "价格"])
306        high_price = _pick(latest, ["最高", "high"])
307        low_price = _pick(latest, ["最低", "low"])
308        volume = _pick(latest, ["成交量", "volume", "手数"])
309        latest_time = _pick(latest, ["时间", "day", "datetime"])
310 
311        lines.append(
312            f"最新 {_fmt_date(latest_time)} | 价 {_fmt_price(latest_price)} | 高 {_fmt_price(high_price)} | 低 {_fmt_price(low_price)} | 量 {_fmt_amount(volume)}"
313        )
314        lines.append("")
315        lines.append("最近成交:")
316 
317        for item in items[:8]:
318            if not isinstance(item, dict):
319                lines.append(str(item))
320                continue
321            t = _fmt_date(_pick(item, ["时间", "day", "datetime"]))
322            p = _fmt_price(_pick(item, ["收盘", "close", "成交价", "价格"]))
323            v = _fmt_amount(_pick(item, ["成交量", "volume", "手数"]))
324            direction = _pick(item, ["买卖盘性质", "性质"], "")
325            tag = f" {direction}" if direction else ""
326            lines.append(f"- {t}: {p} | 量 {v}{tag}")
327 
328        lines.extend(["", "数据源: akshare"])
329        return _truncate("\n".join(lines), MAX_LEN)
330 
331    if intent == "VOLUME_ANALYSIS":
332        # 分时量能分析结果直接返回
333        if not result.get("ok"):
334            return "\n".join([f"{emoji} 分时量能分析 · {ts}", f"\n⚠️ 错误: {result.get('error', '未知')}"])
335 
336        # 直接返回脚本输出
337        text = result.get("text", "")
338        return _truncate(f"📊 分时量能分析\n{text}", MAX_LEN)
339 
340    if intent == "LIMIT_STATS":
341        if not result.get("ok"):
342            return "\n".join([f"{emoji} 涨跌停统计 · {ts}", f"\n⚠️ 错误: {result.get('error', '未知')}"])
343 
344        data = result.get("data", {})
345        date = _fmt_date(data.get("date") or getattr(intent_obj, "date", ""))
346        up_items = data.get("up_items") or data.get("items") or []
347        down_items = data.get("down_items") or []
348        up_count = data.get("up_count")
349        down_count = data.get("down_count")
350 
351        if up_count is None:
352            up_count = len(up_items)
353        if down_count is None:
354            down_count = len(down_items)
355 
356        lines = [f"🚦 涨跌停统计 · {date}", "", f"涨停: {up_count} 家 | 跌停: {down_count} 家", "", "涨停前10:"]
357 
358        for idx, item in enumerate(up_items[:10], start=1):
359            if not isinstance(item, dict):
360                lines.append(f"{idx}. {item}")
361                continue
362            name = _pick(item, ["名称", "股票简称", "简称"], "?")
363            code = _pick(item, ["代码", "股票代码", "symbol"], "?")
364            pct = _pick(item, ["涨跌幅", "涨跌幅%"], None)
365            board = _pick(item, ["连板数", "连板", "几天几板"], None)
366            board_text = f" | 连板 {board}" if board not in (None, "") else ""
367            pct_text = f" | {_fmt_pct(pct)}" if pct is not None else ""
368            lines.append(f"{idx}. {name}({code}){pct_text}{board_text}")
369 
370        lines.extend(["", "数据源: akshare"])
371        return _truncate("\n".join(lines), MAX_LEN)
372 
373    if intent == "STOCK_PICK":
374        if not result.get("ok"):
375            return "\n".join([
376                f"🏆 今日股票推荐 · {datetime.now().strftime('%Y-%m-%d')}",
377                f"\n⚠️ 错误: {result.get('error', '未知')}",
378            ])
379 
380        data = result.get("data", {})
381        items = data.get("items", [])
382        today = datetime.now().strftime("%Y-%m-%d")
383 
384        lines = [f"🏆 今日股票推荐 · {today}", ""]
385        if not items:
386            lines.extend(["暂无满足条件的推荐标的", "", "数据源: akshare"])
387            return _truncate("\n".join(lines), MAX_LEN)
388 
389        for idx, item in enumerate(items[:5], start=1):
390            if not isinstance(item, dict):
391                continue
392            name = item.get("name") or "未知"
393            code = item.get("code") or "?"
394            pct = item.get("pct", 0)
395            stars = "⭐⭐⭐"
396            
397            lines.append(f"{idx}. {name}({code}) {stars}")
398            lines.append(f"   📈 近期涨幅: {_fmt_pct(pct)}")
399            
400            if item.get("report_rating"):
401                lines.append(f"   📰 研报: [{item.get('report_org', '机构')}] {item.get('report_rating')}")
402            lines.append("")
403 
404        lines.append("数据源: akshare")
405        return _truncate("\n".join(lines), MAX_LEN)
406 
407    if intent == "STOCK_OVERVIEW":
408        if not result.get("ok"):
409            return "\n".join([f"{emoji} 个股综合信息 · {ts}", f"\n⚠️ 错误: {result.get('error', '未知')}"])
410 
411        data = result.get("data", {})
412        symbol = data.get("symbol") or getattr(intent_obj, "symbol", "?") or "?"
413 
414        stock_name = symbol
415        query = getattr(intent_obj, "query", "")
416        if query:
417            try:
418                from router import STOCK_NAME_MAP
419 
420                for name in sorted(STOCK_NAME_MAP, key=len, reverse=True):
421                    if name in query:
422                        stock_name = name
423                        break
424            except Exception:
425                pass
426 
427        realtime = data.get("realtime") if isinstance(data.get("realtime"), dict) else {}
428        money_flow = data.get("money_flow") if isinstance(data.get("money_flow"), dict) else {}
429        fundamental = data.get("fundamental") if isinstance(data.get("fundamental"), dict) else {}
430        limit_stats = data.get("limit_stats") if isinstance(data.get("limit_stats"), dict) else {}
431 
432        rt_latest = realtime.get("latest") if isinstance(realtime.get("latest"), dict) else {}
433        flow_latest = money_flow.get("latest") if isinstance(money_flow.get("latest"), dict) else {}
434        fund_latest = fundamental.get("latest") if isinstance(fundamental.get("latest"), dict) else {}
435 
436        price = _pick(rt_latest, ["收盘", "close", "最新价", "成交价", "价格"])
437        if price is None:
438            price = _pick(flow_latest, ["收盘价", "收盘", "close", "最新价"])
439        pct = _pick(rt_latest, ["涨跌幅", "涨跌幅%", "pct_change"])
440        if pct is None:
441            pct = _pick(flow_latest, ["涨跌幅", "涨跌幅%"])
442 
443        main_inflow = _pick(flow_latest, ["主力净流入-净额", "主力净流入", "主力净额", "主力净流入额"])
444        main_ratio = _pick(flow_latest, ["主力净流入-净占比", "主力净占比", "主力净流入占比"])
445 
446        period = _pick(fund_latest, ["报告期", "日期", "报告日期", "公告日期"], "最新")
447        roe = _pick(fund_latest, ["净资产收益率", "净资产收益率-摊薄", "ROE", "净资产收益率(%)"])
448        gross_margin = _pick(fund_latest, ["销售毛利率", "毛利率", "毛利率(%)"])
449        net_margin = _pick(fund_latest, ["销售净利率", "净利率", "净利率(%)", "净利润率"])
450        debt_ratio = _pick(fund_latest, ["资产负债率", "资产负债率(%)"])
451 
452        up_count = limit_stats.get("up_count")
453        down_count = limit_stats.get("down_count")
454        days = limit_stats.get("days") or 10
455 
456        title_name = f"{stock_name}({symbol})" if stock_name != symbol else symbol
457        lines = [f"📌 个股综合信息 | {title_name}", ""]
458 
459        if realtime.get("ok") or price is not None or pct is not None:
460            lines.append(f"💹 实时: {_fmt_price(price)} ({_fmt_pct(pct)})")
461        else:
462            lines.append("💹 实时: 暂无")
463 
464        if money_flow.get("ok"):
465            lines.append(f"💰 主力净流入: {_fmt_amount(main_inflow)} (净占比 {_fmt_pct(main_ratio)})")
466        else:
467            lines.append("💰 主力净流入: 暂无")
468 
469        if fundamental.get("ok"):
470            lines.append("")
471            lines.append(f"📊 基本面({_fmt_date(period)}):")
472            lines.append(f"ROE {_fmt_ratio(roe)} | 毛利率 {_fmt_ratio(gross_margin)}")
473            lines.append(f"净利率 {_fmt_ratio(net_margin)} | 资产负债率 {_fmt_ratio(debt_ratio)}")
474        else:
475            lines.append("")
476            lines.append("📊 基本面: 暂无")
477 
478        if isinstance(up_count, int) and isinstance(down_count, int):
479            lines.append("")
480            lines.append(f"🚦 近{days}日涨跌停: 涨停{up_count}次 / 跌停{down_count}次")
481        else:
482            lines.append("")
483            lines.append("🚦 近10日涨跌停: 暂无")
484 
485        # 研报
486        research_report = data.get("research_report") if isinstance(data.get("research_report"), dict) else {}
487        report_items = research_report.get("items", [])
488        if report_items:
489            lines.append("")
490            lines.append("📰 研报:")
491            for item in report_items[:2]:
492                if not isinstance(item, dict):
493                    continue
494                org = _pick(item, ["机构", "东财评级"], "?")
495                rating = _pick(item, ["东财评级", "评级"], "?")
496                pe = _pick(item, ["2025-盈利预测-市盈率", "2026-盈利预测-市盈率"], None)
497                date = _pick(item, ["日期", "报告日期"])
498                title = _pick(item, ["报告名称", "标题", "研报名称"], "(无标题)")
499                # 截取标题前25字
500                title = title[:25] + "..." if len(title) > 25 else title
501                pe_text = f" | PE {pe}x" if pe else ""
502                lines.append(f"• [{org}] {title}")
503                lines.append(f"  评级: {rating}{pe_text}")
504        elif research_report.get("ok") is False:
505            lines.append("")
506            lines.append("📰 研报: 暂无")
507 
508        return _truncate("\n".join(lines), MAX_LEN)
509 
510    if intent == "NEWS":
511        if not result.get("ok"):
512            return "\n".join([f"📰 财经要闻 · {datetime.now().strftime('%Y-%m-%d')}", f"\n⚠️ 错误: {result.get('error', '未知')}"])
513 
514        data = result.get("data", {})
515        items = data.get("items", [])
516        today = datetime.now().strftime("%Y-%m-%d")
517        lines = [f"📰 财经要闻 · {today}", ""]
518 
519        if not items:
520            lines.extend(["暂无新闻数据", "", "数据源: akshare"])
521            return _truncate("\n".join(lines), MAX_LEN)
522 
523        for idx, item in enumerate(items[:10], start=1):
524            if not isinstance(item, dict):
525                lines.append(f"{idx}. {item}")
526                continue
527 
528            source = _pick(item, ["文章来源", "新闻来源", "来源", "source"], "未知来源")
529            title = _pick(item, ["新闻标题", "标题", "title", "内容"], "(无标题)")
530            publish_time = _pick(item, ["发布时间", "时间", "date", "发布日期"])
531            url = _pick(item, ["新闻链接", "链接", "url", "link"], "")
532            
533            # 使用 markdown 格式（QQ支持可点击链接）
534            if url:
535                lines.append(f"{idx}. [{title}]({url})")
536 
537        lines.extend(["", "数据源: eastmoney(agent-browser)"])
538        # 财经新闻需要更多字符显示链接
539        return _truncate("\n".join(lines), 3000)
540 
541    if intent == "RESEARCH_REPORT":
542        if not result.get("ok"):
543            return "\n".join([f"📰 个股研报 · {datetime.now().strftime('%Y-%m-%d')}", f"\n⚠️ 错误: {result.get('error', '未知')}"])
544 
545        data = result.get("data", {})
546        items = data.get("items", [])
547        symbol = data.get("symbol") or getattr(intent_obj, "symbol", "") or ""
548 
549        stock_name = symbol
550        query = getattr(intent_obj, "query", "")
551        if query:
552            try:
553                from router import STOCK_NAME_MAP
554 
555                for name in sorted(STOCK_NAME_MAP, key=len, reverse=True):
556                    if name in query:
557                        stock_name = name
558                        break
559            except Exception:
560                pass
561 
562        title_name = stock_name if stock_name else (symbol or "个股")
563        today = datetime.now().strftime("%Y-%m-%d")
564        lines = [f"📰 {title_name}研报 · {today}", ""]
565 
566        if not items:
567            lines.extend(["暂无研报数据", "", "数据源: akshare"])
568            return _truncate("\n".join(lines), MAX_LEN)
569 
570        for idx, item in enumerate(items[:10], start=1):
571            if not isinstance(item, dict):
572                lines.append(f"{idx}. {item}")
573                continue
574 
575            org = _pick(item, ["研究机构", "机构", "机构名称", "评级机构"], "未知机构")
576            stock_short = _pick(item, ["股票简称", "简称", "股票名称", "名称"], title_name)
577            report_name = _pick(item, ["报告名称", "研报标题", "标题", "报告标题"], "(无标题)")
578            rating = _pick(item, ["东财评级", "最新评级", "评级", "投资评级"], "未知")
579            date = _pick(item, ["日期", "报告日期", "发布时间", "发布日期"])
580            pe_2025 = _pick(item, ["2025-盈利预测-市盈率", "2025预测市盈率", "2025年PE"]) 
581            pe_2026 = _pick(item, ["2026-盈利预测-市盈率"]) 
582            eps_2025 = _pick(item, ["2025-盈利预测-收益", "2025每股收益", "预测EPS"]) 
583 
584            if pe_2025 is not None:
585                profit = f"2025年PE {pe_2025}"
586            elif pe_2026 is not None:
587                profit = f"2026年PE {pe_2026}"
588            elif eps_2025 is not None:
589                profit = f"2025年EPS {eps_2025}"
590            else:
591                profit = _pick(item, ["预测市盈率", "盈利预测"], None)
592 
593            lines.append(f"{idx}. [{org}] {stock_short} - {report_name}")
594            if profit is not None:
595                profit_text = str(profit)
596                if "x" not in profit_text.lower() and "倍" not in profit_text:
597                    profit_text = f"{profit_text}x"
598                lines.append(f"   评级: {rating} | 盈利预测: {profit_text}")
599            else:
600                lines.append(f"   评级: {rating}")
601            if date is not None:
602                lines.append(f"   日期: {_fmt_date(date)}")
603 
604        lines.extend(["", "数据源: akshare"])
605        return _truncate("\n".join(lines), MAX_LEN)
606 
607    if intent == "MONEY_FLOW":
608        if not result.get("ok"):
609            return "\n".join([f"{emoji} 资金流向 · {ts}", f"\n⚠️ 错误: {result.get('error', '未知')}"])
610 
611        data = result.get("data", {})
612        scope = data.get("scope") or "individual"
613        items = data.get("items", [])
614 
615        if scope == "market":
616            lines = [f"💰 市场资金流向 · {ts}", ""]
617            if not items:
618                lines.extend(["暂无市场资金流数据", "", "数据源: akshare"])
619                return "\n".join(lines)
620 
621            latest = items[0] if isinstance(items[0], dict) else {}
622            d = _fmt_date(_pick(latest, ["日期", "交易日期", "date", "时间"]))
623            
624            # 尝试获取主力净流入等字段
625            main_flow = _pick(latest, ["主力净流入-净额", "主力净流入", "净额"])
626            super_flow = _pick(latest, ["超大单净流入-净额", "超大单净流入"])
627            
628            lines.append(f"最新({d})")
629            if main_flow is not None:
630                lines.append(f"- 主力净流入: {_fmt_amount(main_flow)}")
631            if super_flow is not None:
632                lines.append(f"- 超大单净流入: {_fmt_amount(super_flow)}")
633 
634            lines.append("")
635            lines.append("近5日主力资金:")
636            for item in items[:5]:
637                if not isinstance(item, dict):
638                    lines.append(f"- {item}")
639                    continue
640                day = _fmt_date(_pick(item, ["日期", "交易日期", "date", "时间"]))
641                val = _pick(item, ["主力净流入-净额", "主力净流入", "净额", "净流入"])
642                if val is not None:
643                    lines.append(f"- {day}: {_fmt_amount(val)}")
644 
645            lines.extend(["", "数据源: akshare"])
646            return _truncate("\n".join(lines), MAX_LEN)
647 
648        if scope == "sector":
649            lines = [f"💰 行业资金流向 · {ts}", ""]
650            if not items:
651                lines.extend(["暂无行业资金流数据", "", "数据源: akshare"])
652                return "\n".join(lines)
653 
654            lines.append("净流入前10行业:")
655            for idx, item in enumerate(items[:10], start=1):
656                if not isinstance(item, dict):
657                    lines.append(f"{idx}. {item}")
658                    continue
659                name = _pick(item, ["名称", "行业", "板块名称", "行业名称"], "?")
660                inflow = _pick(item, ["今日主力净流入-净额", "主力净流入", "今日净流入", "净流入", "主力净额", "今日主力净流入"])
661                pct = _pick(item, ["今日涨跌幅", "涨跌幅", "涨跌幅%"])
662                pct_text = f" | {_fmt_pct(pct)}" if pct is not None else ""
663                if inflow is not None:
664                    lines.append(f"{idx}. {name}: {_fmt_amount(inflow)}{pct_text}")
665                else:
666                    lines.append(f"{idx}. {name}{pct_text}")
667 
668            lines.extend(["", "数据源: akshare"])
669            return _truncate("\n".join(lines), MAX_LEN)
670 
671        symbol = data.get("symbol") or getattr(intent_obj, "symbol", "?") or "?"
672        lines = [f"💰 {symbol} 资金流向 · {ts}", ""]
673        if not items:
674            lines.extend(["暂无资金流数据", "", "数据源: akshare"])
675            return "\n".join(lines)
676 
677        latest = items[0] if isinstance(items[0], dict) else {}
678        d = _fmt_date(_pick(latest, ["日期", "交易日期", "date"]))
679        main_inflow = _pick(latest, ["主力净流入-净额", "主力净流入", "主力净额", "主力净流入额"])
680        main_ratio = _pick(latest, ["主力净流入-净占比", "主力净占比", "主力净流入占比"])
681        close_price = _pick(latest, ["收盘价", "收盘", "close"])
682        pct = _pick(latest, ["涨跌幅", "涨跌幅%"])
683 
684        lines.append(
685            f"最新({d}): 收盘 {_fmt_price(close_price)} ({_fmt_pct(pct)}) | 主力净流入 {_fmt_amount(main_inflow)} ({_fmt_pct(main_ratio)})"
686        )
687        lines.append("")
688        lines.append("近5日主力净流入:")
689 
690        for item in items[:5]:
691            if not isinstance(item, dict):
692                lines.append(str(item))
693                continue
694            day = _fmt_date(_pick(item, ["日期", "交易日期", "date"]))
695            inflow = _pick(item, ["主力净流入-净额", "主力净流入", "主力净额", "主力净流入额"])
696            ratio = _pick(item, ["主力净流入-净占比", "主力净占比", "主力净流入占比"])
697            lines.append(f"- {day}: {_fmt_amount(inflow)} ({_fmt_pct(ratio)})")
698 
699        lines.extend(["", "数据源: akshare"])
700        return _truncate("\n".join(lines), MAX_LEN)
701 
702    if intent == "FUNDAMENTAL":
703        if not result.get("ok"):
704            return "\n".join([f"{emoji} 基本面分析 · {ts}", f"\n⚠️ 错误: {result.get('error', '未知')}"])
705 
706        data = result.get("data", {})
707        symbol = data.get("symbol") or getattr(intent_obj, "symbol", "?") or "?"
708        latest = data.get("latest") if isinstance(data.get("latest"), dict) else {}
709        items = data.get("items", [])
710 
711        if not latest and isinstance(items, list):
712            first_item = items[0] if items else None
713            if isinstance(first_item, dict):
714                latest = first_item
715 
716        lines = [f"📊 {symbol} 基本面摘要 · {ts}", ""]
717        if not latest:
718            lines.extend(["暂无基本面数据", "", "数据源: akshare"])
719            return _truncate("\n".join(lines), MAX_LEN)
720 
721        period = _pick(latest, ["报告期", "日期", "报告日期", "公告日期"], "最新")
722        roe = _pick(latest, ["净资产收益率", "净资产收益率-摊薄", "ROE", "净资产收益率(%)"])
723        gross_margin = _pick(latest, ["销售毛利率", "毛利率", "毛利率(%)"])
724        net_margin = _pick(latest, ["销售净利率", "净利率", "净利率(%)", "净利润率"])
725        debt_ratio = _pick(latest, ["资产负债率", "资产负债率(%)"])
726        rev_yoy = _pick(latest, ["营业总收入同比增长率", "营业收入同比增长率", "营收同比"])
727        np_yoy = _pick(latest, ["净利润同比增长率", "归母净利润同比增长率", "净利润同比"])
728 
729        # 更多指标
730        eps = _pick(latest, ["基本每股收益", "每股收益"])
731        bvps = _pick(latest, ["每股净资产", "每股净资产(元)"])
732        op_cashflow = _pick(latest, ["每股经营现金流", "每股经营现金流量"])
733        inv_turnover = _pick(latest, ["存货周转率", "存货周转次数"])
734        ar_turnover = _pick(latest, ["应收账款周转天数", "应收账款周转率"])
735 
736        lines.append(f"报告期: {_fmt_date(period)}")
737        
738        if eps is not None and str(eps) not in ('False', ''):
739            lines.append(f"- 每股收益: {eps}")
740        if bvps is not None and str(bvps) not in ('False', ''):
741            lines.append(f"- 每股净资产: {bvps}")
742        if roe is not None:
743            lines.append(f"- ROE: {_fmt_ratio(roe)}")
744        if gross_margin is not None:
745            lines.append(f"- 毛利率: {_fmt_ratio(gross_margin)}")
746        if net_margin is not None:
747            lines.append(f"- 净利率: {_fmt_ratio(net_margin)}")
748        if debt_ratio is not None:
749            lines.append(f"- 资产负债率: {_fmt_ratio(debt_ratio)}")
750        if rev_yoy is not None:
751            lines.append(f"- 营收同比: {_fmt_pct(rev_yoy)}")
752        if np_yoy is not None:
753            lines.append(f"- 净利润同比: {_fmt_pct(np_yoy)}")
754        
755        # 第二行：更多指标
756        if op_cashflow is not None and str(op_cashflow) not in ('False', ''):
757            lines.append(f"- 每股经营现金流: {op_cashflow}")
758        if inv_turnover is not None and str(inv_turnover) not in ('False', ''):
759            lines.append(f"- 存货周转率: {inv_turnover}")
760        if ar_turnover is not None and str(ar_turnover) not in ('False', ''):
761            lines.append(f"- 应收账款周转天数: {ar_turnover}")
762 
763        lines.extend(["", "数据源: akshare"])
764        return _truncate("\n".join(lines), MAX_LEN)
765 
766    if intent == "MARGIN_LHB":
767        if not result.get("ok"):
768            return "\n".join([f"{emoji} 两融/龙虎榜 · {ts}", f"\n⚠️ 错误: {result.get('error', '未知')}"])
769 
770        data = result.get("data", {})
771        symbol = data.get("symbol") or getattr(intent_obj, "symbol", "") or ""
772        title = f"🏦 {symbol} 两融/龙虎榜 · {ts}" if symbol else f"🏦 两融/龙虎榜 · {ts}"
773 
774        margin_items = data.get("margin_items", [])
775        lhb_items = data.get("lhb_items", [])
776 
777        lines = [title, ""]
778 
779        if margin_items:
780            latest_margin = margin_items[0] if isinstance(margin_items[0], dict) else {}
781            m_date = _fmt_date(_pick(latest_margin, ["日期", "交易日期", "截止日期", "date"]))
782            rzye = _pick(latest_margin, ["融资余额", "融资余额(元)", "融资余额(万元)"])
783            rzmr = _pick(latest_margin, ["融资买入额", "融资买入", "融资买入额(元)"])
784            rzjme = _pick(latest_margin, ["融资净买入", "融资净买入额", "融资净偿还"])
785            rqye = _pick(latest_margin, ["融券余额", "融券余额(元)", "融券余额(万元)"])
786            lines.append(f"融资融券({m_date}):")
787            if rzye is not None:
788                lines.append(f"- 融资余额: {_fmt_amount(rzye)}")
789            if rzmr is not None:
790                lines.append(f"- 融资买入额: {_fmt_amount(rzmr)}")
791            if rzjme is not None:
792                lines.append(f"- 融资净买入: {_fmt_amount(rzjme)}")
793            if rqye is not None:
794                lines.append(f"- 融券余额: {_fmt_amount(rqye)}")
795            lines.append("")
796        else:
797            lines.append("融资融券: 暂无数据")
798            lines.append("")
799 
800        lines.append("龙虎榜前5:")
801        if lhb_items:
802            for idx, item in enumerate(lhb_items[:5], start=1):
803                if not isinstance(item, dict):
804                    lines.append(f"{idx}. {item}")
805                    continue
806                name = _pick(item, ["名称", "股票简称", "证券简称"], "?")
807                code = _pick(item, ["代码", "股票代码", "证券代码"], "?")
808                reason = _pick(item, ["上榜原因", "解读", "原因"], "")
809                net_buy = _pick(item, ["龙虎榜净买额", "净买额", "买卖净额"])
810                net_text = f" | 净买 {_fmt_amount(net_buy)}" if net_buy is not None else ""
811                reason_text = f" | {reason}" if reason else ""
812                lines.append(f"{idx}. {name}({code}){net_text}{reason_text}")
813        else:
814            lines.append("暂无龙虎榜数据")
815 
816        lines.extend(["", "数据源: akshare"])
817        return _truncate("\n".join(lines), MAX_LEN)
818 
819    if intent == "SECTOR_ANALYSIS":
820        if not result.get("ok"):
821            return "\n".join([f"{emoji} 板块分析 · {ts}", f"\n⚠️ 错误: {result.get('error', '未知')}"])
822 
823        data = result.get("data", {})
824        sector_type = data.get("sector_type", "industry")
825        top_gain = data.get("top_gain") or data.get("items") or []
826        top_drop = data.get("top_drop") or []
827        label = "概念板块" if sector_type == "concept" else "行业板块"
828 
829        lines = [f"🧩 {label}涨跌排行 · {ts}", "", "涨幅前5:"]
830        for idx, item in enumerate(top_gain[:5], start=1):
831            if not isinstance(item, dict):
832                lines.append(f"{idx}. {item}")
833                continue
834            name = _pick(item, ["板块", "板块名称", "名称", "行业", "概念名称", "symbol"], "?")
835            pct = _pick(item, ["涨跌幅", "今日涨跌幅", "涨跌幅%", "涨跌"])
836            lines.append(f"{idx}. {name}: {_fmt_pct(pct)}")
837 
838        lines.append("")
839        lines.append("跌幅前5:")
840        for idx, item in enumerate(top_drop[:5], start=1):
841            if not isinstance(item, dict):
842                lines.append(f"{idx}. {item}")
843                continue
844            name = _pick(item, ["板块", "板块名称", "名称", "行业", "概念名称", "symbol"], "?")
845            pct = _pick(item, ["涨跌幅", "今日涨跌幅", "涨跌幅%", "涨跌"])
846            lines.append(f"{idx}. {name}: {_fmt_pct(pct)}")
847 
848        lines.extend(["", "数据源: akshare"])
849        return _truncate("\n".join(lines), MAX_LEN)
850 
851    if intent == "FUND_BOND":
852        if not result.get("ok"):
853            return "\n".join([f"{emoji} 基金/可转债 · {ts}", f"\n⚠️ 错误: {result.get('error', '未知')}"])
854 
855        data = result.get("data", {})
856        scope = data.get("scope", "fund")
857        items = data.get("items", [])
858 
859        if scope == "bond":
860            lines = [f"🏛️ 可转债行情 · {ts}", ""]
861            if not items:
862                lines.extend(["暂无可转债数据", "", "数据源: akshare"])
863                return _truncate("\n".join(lines), MAX_LEN)
864 
865            for idx, item in enumerate(items[:8], start=1):
866                if not isinstance(item, dict):
867                    lines.append(f"{idx}. {item}")
868                    continue
869                name = _pick(item, ["name", "债券简称", "名称", "转债名称"], "?")
870                code = _pick(item, ["symbol", "code", "代码", "债券代码", "转债代码"], "?")
871                price = _pick(item, ["trade", "最新价", "现价", "收盘", "price"])
872                pct = _pick(item, ["changepercent", "涨跌幅", "涨跌幅%", "涨跌"])
873                lines.append(f"{idx}. {name}({code}): {_fmt_price(price)} {_fmt_pct(pct)}")
874 
875            lines.extend(["", "数据源: akshare"])
876            return _truncate("\n".join(lines), MAX_LEN)
877 
878        lines = [f"🏛️ 基金净值/行情 · {ts}", ""]
879        if not items:
880            lines.extend(["暂无基金数据", "", "数据源: akshare"])
881            return _truncate("\n".join(lines), MAX_LEN)
882 
883        for idx, item in enumerate(items[:8], start=1):
884            if not isinstance(item, dict):
885                lines.append(f"{idx}. {item}")
886                continue
887            name = _pick(item, ["基金简称", "名称", "基金名称", "symbol"], "?")
888            code = _pick(item, ["基金代码", "代码", "证券代码"], "?")
889            nav = _pick(item, ["单位净值", "净值", "最新价", "收盘", "close"])
890            pct = _pick(item, ["日增长率", "涨跌幅", "涨跌幅%", "涨跌"])
891            date = _pick(item, ["日期", "净值日期", "date"])
892            label = name if name != "?" else (code if code != "?" else "基金")
893            if date:
894                lines.append(f"{idx}. {_fmt_date(date)} {label}: {_fmt_price(nav)} {_fmt_pct(pct)}")
895            elif pct is not None:
896                lines.append(f"{idx}. {label}: {_fmt_price(nav)} {_fmt_pct(pct)}")
897            else:
898                lines.append(f"{idx}. {label}: {_fmt_price(nav)}")
899 
900        lines.extend(["", "数据源: akshare"])
901        return _truncate("\n".join(lines), MAX_LEN)
902 
903    if intent == "HK_US_MARKET":
904        if not result.get("ok"):
905            return "\n".join([f"{emoji} 港美股行情 · {ts}", f"\n⚠️ 错误: {result.get('error', '未知')}"])
906 
907        data = result.get("data", {})
908        market = data.get("market", "hk")
909        items = data.get("items", [])
910        title = "🌍 美股行情" if market == "us" else "🌍 港股行情"
911 
912        lines = [f"{title} · {ts}", ""]
913        if not items:
914            lines.extend(["暂无跨市场数据", "", "数据源: akshare"])
915            return _truncate("\n".join(lines), MAX_LEN)
916 
917        for idx, item in enumerate(items[:8], start=1):
918            if not isinstance(item, dict):
919                lines.append(f"{idx}. {item}")
920                continue
921            name = _pick(item, ["名称", "股票名称", "英文名称", "name", "代码", "symbol"], "?")
922            code = _pick(item, ["代码", "股票代码", "证券代码", "symbol"], "?")
923            price = _pick(item, ["最新价", "现价", "收盘", "close", "price", "最新价(美元)", "最新"])
924            pct = _pick(item, ["涨跌幅", "涨跌幅%", "涨跌", "changepercent"])
925            lines.append(f"{idx}. {name}({code}): {_fmt_price(price)} {_fmt_pct(pct)}")
926 
927        lines.extend(["", "数据源: akshare"])
928        return _truncate("\n".join(lines), MAX_LEN)
929 
930    if intent == "DERIVATIVES":
931        if not result.get("ok"):
932            return "\n".join([f"{emoji} 期货/期权 · {ts}", f"\n⚠️ 错误: {result.get('error', '未知')}"])
933 
934        data = result.get("data", {})
935        scope = data.get("scope", "futures")
936        items = data.get("items", [])
937        title = "📉 期权数据" if scope == "options" else "📉 期货主力合约"
938 
939        lines = [f"{title} · {ts}", ""]
940        if not items:
941            lines.extend(["暂无衍生品数据", "", "数据源: akshare"])
942            return _truncate("\n".join(lines), MAX_LEN)
943 
944        for idx, item in enumerate(items[:8], start=1):
945            if not isinstance(item, dict):
946                lines.append(f"{idx}. {item}")
947                continue
948            name = _pick(item, ["名称", "合约", "品种", "主力合约", "symbol", "代码"], "?")
949            code = _pick(item, ["代码", "合约", "symbol", "合约代码"], "?")
950            price = _pick(item, ["最新价", "现价", "收盘", "close", "price", "结算价", "最新"])
951            pct = _pick(item, ["涨跌幅", "涨跌幅%", "涨跌", "changepercent"])
952            lines.append(f"{idx}. {name}({code}): {_fmt_price(price)} {_fmt_pct(pct)}")
953 
954        lines.extend(["", "数据源: akshare"])
955        return _truncate("\n".join(lines), MAX_LEN)
956 
957    sections = [
958        f"{emoji} A股分析 · {ts}",
959    ]
960 
961    params = []
962    for key in ["symbol", "date", "period", "top_n"]:
963        value = getattr(intent_obj, key, None)
964        if value is not None:
965            params.append(f"{key}={value}")
966 
967    if params:
968        sections.append(f"参数: {' | '.join(params)}")
969 
970    if not result.get("ok"):
971        sections.append(f"\n⚠️ 错误: {result.get('error', '未知')}")
972        return "\n".join(sections)
973 
974    data = result.get("data", {})
975    items = data.get("items", [])
976    if items:
977        for item in items[:5]:
978            if isinstance(item, dict):
979                name = item.get("名称") or item.get("股票代码") or "未知"
980                price = item.get("最新价") or item.get("收盘")
981                change = item.get("涨跌幅")
982                if price is not None:
983                    direction = "📈" if (_safe_float(change) or 0) >= 0 else "📉"
984                    change_str = f" ({_fmt_pct(change)})" if change is not None else ""
985                    sections.append(f"{direction} {name}: {price}{change_str}")
986 
987    if len(items) > 5:
988        sections.append(f"... 还有 {len(items)-5} 条")
989 
990    sections.append("\n数据源: akshare")
991    final = "\n".join(sections)
992    return _truncate(final, MAX_LEN)
993