feat: add custom module with loader, crypto, MiniMax patch, ensemble reports, bot extensions

Author: dministrator

.env.example

@@ -783,15 +783,6 @@ ADMIN_AUTH_ENABLED=false
 # YFINANCE_PRIORITY=0
 # EFINANCE_PRIORITY=99
 
-# ===========================================
-# Crypto Data Source (CCXT)
-# ===========================================
-# CCXTCryptoFetcher 仅在分析加密货币标的（如 BTC-USD、ETH-USD）时启用。
-# 需要 `pip install ccxt`；未安装时该数据源自动跳过，不影响现有股票分析。
-# 默认优先级为 0，crypto 代码首选 CCXT 直连交易所，失败时回退 YFinance。
-# CCXT_EXCHANGE=kraken     # CCXT 交易所 ID（支持 100+ 交易所，见 https://github.com/ccxt/ccxt）
-# CCXT_PRIORITY=0          # CCXTCryptoFetcher 优先级，默认 0
-
 # ===========================================
 # 实时行情数据源优先级配置
 # ===========================================
@@ -840,115 +831,3 @@ ADMIN_AUTH_ENABLED=false
 # 东财接口补丁：东财/Efinance/Akshare 东方财富接口频繁失败（RemoteDisconnected、连接被关闭）时建议开启
 # 开启后会注入 NID 令牌与随机 User-Agent，降低被东财限流概率
 # ENABLE_EASTMONEY_PATCH=false
-
-# 专家战绩数据库路径（默认：workspace/analyst_performance.db，只读容器可指向 /tmp 等可写路径）
-# ANALYST_PERF_DB=workspace/analyst_performance.db
-
-# ===========================================
-# TQQQ 自动交易机器人配置（可选）
-# ===========================================
-# 以下环境变量可覆盖 config/trading.yaml 中的同名配置
-# 详细配置请参考 config/trading.yaml.example
-#
-# Tiger Brokers 环境：PAPER（模拟盘）/ LIVE（实盘）
-# TRADING_TIGER_ENV=PAPER
-# Tiger OpenAPI 配置文件路径
-# TRADING_TIGER_CONFIG_PATH=tiger_openapi_config.properties
-#
-# 交易标的
-# TRADING_SYMBOL=TQQQ
-# 是否开启自动交易（false = 仅发送通知不下单）
-# TRADING_AUTO_TRADE=false
-# 交易模式（SANDBOX/PAPER/PROD）
-# TRADING_MODE=SANDBOX
-# 是否启用交易模块
-# ENABLE_TRADING=false
-# 是否启用 MCP Server（Model Context Protocol）
-# ENABLE_MCP_SERVER=false
-
-# 决策信号桥接轮询间隔（秒）
-# BRIDGE_POLL_INTERVAL_SEC=300
-
-# 买入触发价
-# TRADING_ENTRY_PRICE=74.61
-# 买入数量（股）
-# TRADING_ENTRY_QTY=35
-# 止盈百分比（0.04 = 4%）
-# TRADING_TP_PCT=0.04
-# 止损百分比（0.032 = 3.2%）
-# TRADING_SL_PCT=0.032
-#
-# 交易通知 Webhook URL（飞书/钉钉/企业微信）
-# TRADING_WEBHOOK_URL=
-# Webhook 签名密钥（可选）
-# TRADING_WEBHOOK_SECRET=
-# 日志级别
-# TRADING_LOG_LEVEL=INFO
-
-# ===================================
-# QuantWeasel - AI 量化交易系统配置
-# ===================================
-# 复制此部分到 .env 并填入真实配置
-# ！！！禁止将 .env 提交到 git ！！！
-
-# ── Tiger Brokers OpenAPI 凭据 ──────────────────────────────
-# 从 tiger_openapi_config.properties 迁移而来
-TIGER_PRIVATE_KEY=
-# RSA 私钥内容（PKCS#1 格式，对应 private_key_pk1 字段）
-# 注意：如果包含多行，请用引号包裹并用 \n 替换换行符
-
-TIGER_TIGER_ID=
-# 老虎证券开发者 ID
-
-TIGER_ACCOUNT=
-# 交易账户号
-
-TIGER_TOKEN=
-# API Token（base64 编码的认证字符串）
-
-TIGER_LICENSE=
-# License
-
-TIGER_ENV=SANDBOX
-# 环境: SANDBOX（模拟盘）/ PROD（实盘）
-# Phase 1 强制使用 SANDBOX
-
-# ── 交易策略默认参数 ────────────────────────────────────────
-TRADING_SYMBOL=TQQQ
-# 默认交易标的
-
-TRADING_AUTO_TRADE=false
-# 是否自动交易（Phase 1 始终为 false）
-
-# ── 飞书通知 ────────────────────────────────────────────────
-LARK_WEBHOOK_URL=
-# 飞书机器人 Webhook URL
-
-LARK_WEBHOOK_SECRET=
-# 飞书 Webhook 签名密钥
-
-LARK_APP_ID=
-# 飞书应用 ID（Stream Bot 模式）
-
-LARK_APP_SECRET=
-# 飞书应用 Secret（Stream Bot 模式）
-
-LARK_DEFAULT_CHAT_ID=
-# 飞书 Stream Bot 默认推送会话 ID（未指定 chat_id 时使用）
-
-# ── 风控参数 ────────────────────────────────────────────────
-RISK_MAX_POSITION_PCT=5.0
-# 单标的最大仓位占比（%）
-
-RISK_MAX_DAILY_LOSS_PCT=8.0
-# 每日最大亏损占比（%）
-
-RISK_SIGNAL_TTL_MINUTES=30
-# 信号有效期（分钟），过期自动失效
-
-# ── 运行模式 ────────────────────────────────────────────────
-QUANT_DRY_RUN=true
-# 是否为 dry-run 模式（不下真实订单）
-
-LOG_LEVEL=INFO
-# 日志级别: DEBUG / INFO / WARNING / ERROR

api/v1/endpoints/agent.py

@@ -92,18 +92,6 @@ class AgentModelsResponse(BaseModel):
     models: List[AgentModelDeployment]
 
 
-class ExpertPerformanceItem(BaseModel):
-    id: str
-    name: str
-    total_predictions: int
-    win_rate: float
-    win_count: int
-    settled_count: int
-
-class ExpertPerformanceResponse(BaseModel):
-    performance: List[ExpertPerformanceItem]
-
-
 @router.get("/models", response_model=AgentModelsResponse)
 async def get_agent_models():
     """Get configured Agent model deployments for frontend selection."""
@@ -113,17 +101,6 @@ async def get_agent_models():
     )
 
 
-@router.get("/experts/performance", response_model=ExpertPerformanceResponse)
-async def get_expert_performance():
-    """
-    获取专家（大师）的战绩统计和胜率榜单。
-    """
-    from src.services.performance_tracker import PerformanceTracker
-    tracker = PerformanceTracker()
-    performance = tracker.get_analyst_performance()
-    return ExpertPerformanceResponse(performance=performance)
-
-
 def _build_skills_response(config) -> SkillsResponse:
     from src.agent.factory import get_skill_manager
     from src.agent.skills.defaults import get_primary_default_skill_id

api/v1/endpoints/history.py

@@ -464,28 +464,6 @@ def get_history_detail(
             fallback_fundamental_payload=fallback_fundamental,
         )
 
-        raw_result_dict = result.get("raw_result")
-        ensemble_reports = None
-        radar_data = None
-        if isinstance(raw_result_dict, dict):
-            dashboard = raw_result_dict.get("dashboard") or {}
-            ensemble_reports = dashboard.get("ensemble_reports") or None
-            try:
-                from src.analyzer import AnalysisResult
-                _partial = AnalysisResult(
-                    code=result.get("stock_code", ""),
-                    name=result.get("stock_name", ""),
-                    sentiment_score=int(raw_result_dict.get("sentiment_score") or 50),
-                    trend_prediction=raw_result_dict.get("trend_prediction", ""),
-                    operation_advice=raw_result_dict.get("operation_advice", ""),
-                    dashboard=raw_result_dict.get("dashboard"),
-                    risk_warning=raw_result_dict.get("risk_warning", ""),
-                    fundamental_analysis=raw_result_dict.get("fundamental_analysis", ""),
-                )
-                radar_data = _partial.get_radar_data()
-            except Exception:
-                pass
-
         details = ReportDetails(
             news_content=result.get("news_content"),
             raw_result=result.get("raw_result"),
@@ -495,8 +473,6 @@ def get_history_detail(
             dividend_metrics=extracted_fundamental.get("dividend_metrics"),
             belong_boards=extracted_boards.get("belong_boards"),
             sector_rankings=extracted_boards.get("sector_rankings"),
-            ensemble_reports=ensemble_reports,
-            radar_data=radar_data,
         )
 
         return AnalysisReport(

api/v1/router.py

@@ -24,7 +24,6 @@
     portfolio,
     stocks,
     system_config,
-    trading,
     usage,
 )
 
@@ -108,9 +107,3 @@
     health.router,
     tags=["Health"]
 )
-
-router.include_router(
-    trading.router,
-    prefix="/trading",
-    tags=["Trading"]
-)

bot/__init__.py

@@ -12,7 +12,6 @@
 - dispatcher.py: 命令分发器
 - commands/: 命令处理器
 - platforms/: 平台适配器
-  - lark_interactive.py: 飞书互动卡片 Bot（Stream 模式骨架）
 - handler.py: Webhook 处理器
 
 使用方式：
@@ -30,10 +29,6 @@
 - /batch              - 批量分析自选股
 - /help               - 显示帮助
 - /status             - 系统状态
-
-飞书互动卡片（platforms/lark_interactive.py）：
-- LarkCardBuilder: 构建信号确认、执行结果、风控拦截、信号过期卡片
-- LarkInteractiveBot: Stream 模式骨架，支持确认/拒绝回调注册
 """
 
 from bot.models import BotMessage, BotResponse, ChatType, WebhookResponse

bot/models.py

@@ -85,11 +85,6 @@ def get_command_and_args(self, prefix: str = "/") -> tuple:
                 '批量': 'batch',
                 '帮助': 'help',
                 '状态': 'status',
-                '自选股': 'watchlist',
-                '股票列表': 'watchlist',
-                '我的自选': 'watchlist',
-                '添加': 'watchlist',
-                '删除': 'watchlist',
             }
             for cn_cmd, en_cmd in chinese_commands.items():
                 if text.startswith(cn_cmd):

bot/platforms/__init__.py

@@ -53,16 +53,6 @@
     get_feishu_stream_client = lambda: None
     start_feishu_stream_background = lambda: False
 
-# 飞书互动卡片 Bot（无额外依赖，始终可用）
-from bot.platforms.lark_interactive import (
-    LarkCardBuilder,
-    LarkInteractiveBot,
-    CARD_SIGNAL_CONFIRM,
-    CARD_EXECUTION_RESULT,
-    CARD_RISK_INTERCEPT,
-    CARD_SIGNAL_EXPIRED,
-)
-
 __all__ = [
     'BotPlatform',
     'DingtalkPlatform',
@@ -80,11 +70,4 @@
     'get_feishu_stream_client',
     'start_feishu_stream_background',
     'FEISHU_SDK_AVAILABLE',
-    # 飞书互动卡片
-    'LarkCardBuilder',
-    'LarkInteractiveBot',
-    'CARD_SIGNAL_CONFIRM',
-    'CARD_EXECUTION_RESULT',
-    'CARD_RISK_INTERCEPT',
-    'CARD_SIGNAL_EXPIRED',
 ]