股票分析器

本技能基于当前仓库的 canonical 分析流水线，提供分析股票和整体市场的功能。

输出结构 (AnalysisResult)

分析函数返回一个 AnalysisResult 对象（或其列表），该对象具有丰富的结构。以下是其关键组件的简要概述，并附有真实的输出示例：

dashboard 属性包含核心分析，分为四个主要部分：

1. core_conclusion: 一句话总结、信号类型和仓位建议。
2. data_perspective: 技术数据，包括趋势状态、价格位置、量能分析和筹码结构。
3. intelligence: 定性信息，如新闻、风险警报和积极催化剂。
4. battle_plan: 可操作的策略，包括狙击点（买/卖目标）、仓位策略和风险控制清单。

配置 (Config)

所有分析函数都可以接受一个可选的 config 对象。该对象包含应用程序的所有配置，例如 API 密钥、通知设置和分析参数。

如果未提供 config 对象，函数将自动使用从 .env 文件加载的全局单例实例。

参考: `Config`

函数

1. 分析单只股票

描述: 分析单只股票并返回分析结果。

何时使用: 当用户要求分析特定股票时。

输入:

• stock_code (str): 要分析的股票代码。
• config (Config, 可选): 配置对象。默认为 get_config()。
• report_type (ReportType, 可选): 报告类型。默认为 ReportType.SIMPLE。

输出: Optional[AnalysisResult]
一个包含分析结果的 AnalysisResult 对象，如果分析失败则为 None。

示例:

from src.config import get_config
from src.core.pipeline import StockAnalysisPipeline
from src.enums import ReportType

# 直接使用核心流水线获取 AnalysisResult
pipeline = StockAnalysisPipeline(config=get_config(), query_source="cli")
result = pipeline.process_single_stock(
    code="600989",
    report_type=ReportType.SIMPLE,
    single_stock_notify=False,
)
if result:
    print(f"股票: {result.name} ({result.code})")
    print(f"情绪得分: {result.sentiment_score}")
    print(f"操作建议: {result.operation_advice}")

参考: `StockAnalysisPipeline.process_single_stock`

2. 分析多只股票

描述: 分析一个股票列表并返回分析结果列表。

何时使用: 当用户想要一次分析多只股票时。

输入:

• stock_codes (List[str]): 要分析的股票代码列表。
• config (Config, 可选): 配置对象。默认为 get_config()。
• send_notification (bool, 可选): 是否发送通知。默认为 False。

输出: List[AnalysisResult]
一个 AnalysisResult 对象列表。

示例:

from src.config import get_config
from src.core.pipeline import StockAnalysisPipeline

# 批量运行当前 canonical 分析流水线
pipeline = StockAnalysisPipeline(config=get_config(), query_source="cli")
results = pipeline.run(["600989", "000001"], send_notification=False)
for result in results:
    print(f"股票: {result.name}, 操作建议: {result.operation_advice}")

参考: `StockAnalysisPipeline.run`

3. 执行大盘复盘

描述: 对整体市场进行复盘并返回一份报告。

何时使用: 当用户要求市场概览、摘要或复盘时。

输入:

• CLI: python3 main.py --market-review
• 代码入口: run_market_review(notifier=NotificationService())

输出: Optional[str]
一个包含市场复盘报告的字符串，如果失败则为 None。

示例:

from src.core.market_review import run_market_review
from src.notification import NotificationService

# 直接调用当前的大盘复盘入口
report = run_market_review(notifier=NotificationService())
if report:
    print(report)

参考: `run_market_review`