feat: stock-to-email group routing (Fix ZhuLinsen#268) (ZhuLinsen#313)

- Add STOCK_GROUP_N + EMAIL_GROUP_N config for routing reports to different emails
- Market review sends to all configured email receivers
- Minimal changes: optional params on send_to_email and send(), new helpers

Author: massif-01

.env.example

@@ -93,6 +93,13 @@ BRAVE_API_KEYS=your_brave_key_here
 # EMAIL_PASSWORD=your_email_auth_code
 # EMAIL_RECEIVERS=receiver@example.com  # 可选，留空则发给自己
 #
+# 【方式四扩展】股票分组发往不同邮箱（Issue #268，可选）
+# 配置后，不同股票组的报告发送到对应邮箱；大盘复盘发往所有配置邮箱
+# STOCK_GROUP_1=600519,300750
+# EMAIL_GROUP_1=user1@example.com
+# STOCK_GROUP_2=002594,AAPL
+# EMAIL_GROUP_2=user2@example.com
+#
 # 【方式五】自定义 Webhook（支持多个，逗号分隔）
 # 适用于：钉钉、Discord、Slack、Bark、自建服务等任意支持 POST JSON 的 Webhook
 # 系统会自动识别常见服务并使用对应格式

README.md

@@ -96,6 +96,7 @@
 | `EMAIL_PASSWORD` | 邮箱授权码（非登录密码） | 可选 |
 | `EMAIL_RECEIVERS` | 收件人邮箱（多个用逗号分隔，留空则发给自己） | 可选 |
 | `EMAIL_SENDER_NAME` | 邮件发件人显示名称（默认：daily_stock_analysis股票分析助手） | 可选 |
+| `STOCK_GROUP_N` / `EMAIL_GROUP_N` | 股票分组发往不同邮箱（如 `STOCK_GROUP_1=600519,300750` `EMAIL_GROUP_1=user1@example.com`） | 可选 |
 | `PUSHPLUS_TOKEN` | PushPlus Token（[获取地址](https://www.pushplus.plus)，国内推送服务） | 可选 |
 | `SERVERCHAN3_SENDKEY` | Server酱³ Sendkey（[获取地址](https://sc3.ft07.com/)，手机APP推送服务） | 可选 |
 | `CUSTOM_WEBHOOK_URLS` | 自定义 Webhook（支持钉钉等，多个用逗号分隔） | 可选 |

bot/commands/market.py

@@ -107,7 +107,7 @@ def _run_market_review(self, message: BotMessage) -> None:
             if review_report:
                 # 推送结果
                 report_content = f"🎯 **大盘复盘**\n\n{review_report}"
-                notifier.send(report_content)
+                notifier.send(report_content, email_send_to_all=True)
                 logger.info("[MarketCommand] 大盘复盘完成并已推送")
             else:
                 logger.warning("[MarketCommand] 大盘复盘返回空结果")

docs/CHANGELOG.md

@@ -5,6 +5,13 @@
 格式基于 [Keep a Changelog](https://keepachangelog.com/zh-CN/1.0.0/)，
 版本号遵循 [Semantic Versioning](https://semver.org/lang/zh-CN/)。
 
+## [Unreleased]
+
+### 新增
+- 📧 **股票分组发往不同邮箱** (Issue #268)
+  - 支持 `STOCK_GROUP_N` + `EMAIL_GROUP_N` 配置，不同股票组报告发送到对应邮箱
+  - 大盘复盘发往所有配置的邮箱
+
 ## [3.0.5] - 2026-02-08
 
 ### 修复

docs/full-guide.md

@@ -168,6 +168,7 @@ daily_stock_analysis/
 | `EMAIL_PASSWORD` | 邮箱授权码（非登录密码） | 可选 |
 | `EMAIL_RECEIVERS` | 收件人邮箱（逗号分隔，留空发给自己） | 可选 |
 | `EMAIL_SENDER_NAME` | 发件人显示名称 | 可选 |
+| `STOCK_GROUP_N` / `EMAIL_GROUP_N` | 股票分组发往不同邮箱（Issue #268），如 `STOCK_GROUP_1=600519,300750` 与 `EMAIL_GROUP_1=user1@example.com` 配对 | 可选 |
 | `CUSTOM_WEBHOOK_URLS` | 自定义 Webhook（逗号分隔） | 可选 |
 | `CUSTOM_WEBHOOK_BEARER_TOKEN` | 自定义 Webhook Bearer Token | 可选 |
 | `PUSHOVER_USER_KEY` | Pushover 用户 Key | 可选 |
@@ -414,6 +415,16 @@ crontab -e
 - 163 邮箱：smtp.163.com:465
 - Gmail：smtp.gmail.com:587
 
+**股票分组发往不同邮箱**（Issue #268，可选）：
+配置 `STOCK_GROUP_N` 与 `EMAIL_GROUP_N` 可实现不同股票组的报告发送到不同邮箱，例如多人共享分析时互不干扰。大盘复盘会发往所有配置的邮箱。
+
+```bash
+STOCK_GROUP_1=600519,300750
+EMAIL_GROUP_1=user1@example.com
+STOCK_GROUP_2=002594,AAPL
+EMAIL_GROUP_2=user2@example.com
+```
+
 ### 自定义 Webhook
 
 支持任意 POST JSON 的 Webhook，包括：

src/config.py

@@ -11,8 +11,9 @@
 """
 
 import os
+import re
 from pathlib import Path
-from typing import List, Optional
+from typing import List, Optional, Tuple
 from dotenv import load_dotenv, dotenv_values
 from dataclasses import dataclass, field
 
@@ -99,7 +100,11 @@ class Config:
     email_sender_name: str = "daily_stock_analysis股票分析助手"  # 发件人显示名称
     email_password: Optional[str] = None  # 邮箱密码/授权码
     email_receivers: List[str] = field(default_factory=list)  # 收件人列表（留空则发给自己）
-    
+
+    # Stock-to-email group routing (Issue #268): STOCK_GROUP_N + EMAIL_GROUP_N
+    # When configured, each group's report is sent to that group's emails only.
+    stock_email_groups: List[Tuple[List[str], List[str]]] = field(default_factory=list)
+
     # Pushover 配置（手机/桌面推送通知）
     pushover_user_key: Optional[str] = None  # 用户 Key（https://pushover.net 获取）
     pushover_api_token: Optional[str] = None  # 应用 API Token
@@ -370,6 +375,7 @@ def _load_from_env(cls) -> 'Config':
             email_sender_name=os.getenv('EMAIL_SENDER_NAME', 'daily_stock_analysis股票分析助手'),
             email_password=os.getenv('EMAIL_PASSWORD'),
             email_receivers=[r.strip() for r in os.getenv('EMAIL_RECEIVERS', '').split(',') if r.strip()],
+            stock_email_groups=cls._parse_stock_email_groups(),
             pushover_user_key=os.getenv('PUSHOVER_USER_KEY'),
             pushover_api_token=os.getenv('PUSHOVER_API_TOKEN'),
             pushplus_token=os.getenv('PUSHPLUS_TOKEN'),
@@ -442,6 +448,33 @@ def _load_from_env(cls) -> 'Config':
             circuit_breaker_cooldown=int(os.getenv('CIRCUIT_BREAKER_COOLDOWN', '300'))
         )
 
+    @classmethod
+    def _parse_stock_email_groups(cls) -> List[Tuple[List[str], List[str]]]:
+        """
+        Parse STOCK_GROUP_N and EMAIL_GROUP_N from environment.
+        Returns [(stocks, emails), ...] ordered by group index.
+        """
+        groups: dict = {}
+        stock_re = re.compile(r'^STOCK_GROUP_(\d+)$', re.IGNORECASE)
+        email_re = re.compile(r'^EMAIL_GROUP_(\d+)$', re.IGNORECASE)
+        for key in os.environ:
+            m = stock_re.match(key)
+            if m:
+                idx = int(m.group(1))
+                val = os.environ[key].strip()
+                groups.setdefault(idx, {})['stocks'] = [c.strip() for c in val.split(',') if c.strip()]
+            m = email_re.match(key)
+            if m:
+                idx = int(m.group(1))
+                val = os.environ[key].strip()
+                groups.setdefault(idx, {})['emails'] = [e.strip() for e in val.split(',') if e.strip()]
+        result = []
+        for idx in sorted(groups.keys()):
+            g = groups[idx]
+            if 'stocks' in g and 'emails' in g and g['stocks'] and g['emails']:
+                result.append((g['stocks'], g['emails']))
+        return result
+
     @classmethod
     def _resolve_realtime_source_priority(cls) -> str:
         """

src/core/market_review.py

@@ -67,7 +67,7 @@ def run_market_review(
                 # 添加标题
                 report_content = f"🎯 大盘复盘\n\n{review_report}"
 
-                success = notifier.send(report_content)
+                success = notifier.send(report_content, email_send_to_all=True)
                 if success:
                     logger.info("大盘复盘推送成功")
                 else:

src/core/pipeline.py

@@ -14,6 +14,7 @@
 import logging
 import time
 import uuid
+from collections import defaultdict
 from concurrent.futures import ThreadPoolExecutor, as_completed
 from datetime import date
 from typing import List, Dict, Any, Optional, Tuple
@@ -568,7 +569,7 @@ def process_single_stock(
                             report_content = self.notifier.generate_single_stock_report(result)
                             logger.info(f"[{code}] 使用精简报告格式")
 
-                        if self.notifier.send(report_content):
+                        if self.notifier.send(report_content, email_stock_codes=[code]):
                             logger.info(f"[{code}] 单股推送成功")
                         else:
                             logger.warning(f"[{code}] 单股推送失败")
@@ -736,6 +737,7 @@ def _send_notifications(self, results: List[AnalysisResult], skip_push: bool = F
 
                 # 其他渠道：发完整报告（避免自定义 Webhook 被 wechat 截断逻辑污染）
                 non_wechat_success = False
+                stock_email_groups = getattr(self.config, 'stock_email_groups', []) or []
                 for channel in channels:
                     if channel == NotificationChannel.WECHAT:
                         continue
@@ -744,7 +746,31 @@ def _send_notifications(self, results: List[AnalysisResult], skip_push: bool = F
                     elif channel == NotificationChannel.TELEGRAM:
                         non_wechat_success = self.notifier.send_to_telegram(report) or non_wechat_success
                     elif channel == NotificationChannel.EMAIL:
-                        non_wechat_success = self.notifier.send_to_email(report) or non_wechat_success
+                        if stock_email_groups:
+                            code_to_emails: Dict[str, Optional[List[str]]] = {}
+                            for r in results:
+                                if r.code not in code_to_emails:
+                                    emails = []
+                                    for stocks, emails_list in stock_email_groups:
+                                        if r.code in stocks:
+                                            emails.extend(emails_list)
+                                    code_to_emails[r.code] = list(dict.fromkeys(emails)) if emails else None
+                            emails_to_results: Dict[Optional[Tuple], List] = defaultdict(list)
+                            for r in results:
+                                recs = code_to_emails.get(r.code)
+                                key = tuple(recs) if recs else None
+                                emails_to_results[key].append(r)
+                            for key, group_results in emails_to_results.items():
+                                grp_report = self.notifier.generate_dashboard_report(group_results)
+                                if key is None:
+                                    non_wechat_success = self.notifier.send_to_email(grp_report) or non_wechat_success
+                                else:
+                                    non_wechat_success = (
+                                        self.notifier.send_to_email(grp_report, receivers=list(key))
+                                        or non_wechat_success
+                                    )
+                        else:
+                            non_wechat_success = self.notifier.send_to_email(report) or non_wechat_success
                     elif channel == NotificationChannel.CUSTOM:
                         non_wechat_success = self.notifier.send_to_custom(report) or non_wechat_success
                     elif channel == NotificationChannel.PUSHPLUS:

src/notification.py

@@ -160,7 +160,9 @@ def __init__(self, source_message: Optional[BotMessage] = None):
             'password': config.email_password,
             'receivers': config.email_receivers or ([config.email_sender] if config.email_sender else []),
         }
-        
+        # Stock-to-email group routing (Issue #268)
+        self._stock_email_groups = getattr(config, 'stock_email_groups', None) or []
+
         # Pushover 配置
         self._pushover_config = {
             'user_key': getattr(config, 'pushover_user_key', None),
@@ -274,6 +276,43 @@ def _is_astrbot_configured(self) -> bool:
     def _is_email_configured(self) -> bool:
         """检查邮件配置是否完整（只需邮箱和授权码）"""
         return bool(self._email_config['sender'] and self._email_config['password'])
+
+    def get_receivers_for_stocks(self, stock_codes: List[str]) -> List[str]:
+        """
+        Look up email receivers for given stock codes based on stock_email_groups.
+        Returns union of receivers for all matching groups; falls back to default if none match.
+        """
+        if not stock_codes or not self._stock_email_groups:
+            return self._email_config['receivers']
+        seen: set = set()
+        result: List[str] = []
+        for stocks, emails in self._stock_email_groups:
+            for code in stock_codes:
+                if code in stocks:
+                    for e in emails:
+                        if e not in seen:
+                            seen.add(e)
+                            result.append(e)
+                    break
+        return result if result else self._email_config['receivers']
+
+    def get_all_email_receivers(self) -> List[str]:
+        """
+        Return union of all configured email receivers (all groups + default).
+        Used for market review which should go to everyone.
+        """
+        seen: set = set()
+        result: List[str] = []
+        for _, emails in self._stock_email_groups:
+            for e in emails:
+                if e not in seen:
+                    seen.add(e)
+                    result.append(e)
+        for e in self._email_config['receivers']:
+            if e not in seen:
+                seen.add(e)
+                result.append(e)
+        return result
 
     def _is_pushover_configured(self) -> bool:
         """检查 Pushover 配置是否完整"""
@@ -1782,13 +1821,16 @@ def _post_payload(payload: Dict[str, Any]) -> bool:
 
         return _post_payload(text_payload)
 
-    def send_to_email(self, content: str, subject: Optional[str] = None) -> bool:
+    def send_to_email(
+        self, content: str, subject: Optional[str] = None, receivers: Optional[List[str]] = None
+    ) -> bool:
         """
         通过 SMTP 发送邮件（自动识别 SMTP 服务器）
         
         Args:
             content: 邮件内容（支持 Markdown，会转换为 HTML）
             subject: 邮件主题（可选，默认自动生成）
+            receivers: 收件人列表（可选，默认使用配置的 receivers）
             
         Returns:
             是否发送成功
@@ -1799,7 +1841,7 @@ def send_to_email(self, content: str, subject: Optional[str] = None) -> bool:
 
         sender = self._email_config['sender']
         password = self._email_config['password']
-        receivers = self._email_config['receivers']
+        receivers = receivers or self._email_config['receivers']
 
         try:
             # 生成主题
@@ -3063,14 +3105,21 @@ def _send_astrbot(self, content: str) -> bool:
             logger.error(f"AstrBot 发送异常: {e}")
             return False
 
-    def send(self, content: str) -> bool:
+    def send(
+        self,
+        content: str,
+        email_stock_codes: Optional[List[str]] = None,
+        email_send_to_all: bool = False
+    ) -> bool:
         """
         统一发送接口 - 向所有已配置的渠道发送
         
         遍历所有已配置的渠道，逐一发送消息
         
         Args:
             content: 消息内容（Markdown 格式）
+            email_stock_codes: 股票代码列表（可选，用于邮件渠道路由到对应分组邮箱，Issue #268）
+            email_send_to_all: 邮件是否发往所有配置邮箱（用于大盘复盘等无股票归属的内容）
             
         Returns:
             是否至少有一个渠道发送成功
@@ -3100,7 +3149,12 @@ def send(self, content: str) -> bool:
                 elif channel == NotificationChannel.TELEGRAM:
                     result = self.send_to_telegram(content)
                 elif channel == NotificationChannel.EMAIL:
-                    result = self.send_to_email(content)
+                    receivers = None
+                    if email_send_to_all and self._stock_email_groups:
+                        receivers = self.get_all_email_receivers()
+                    elif email_stock_codes and self._stock_email_groups:
+                        receivers = self.get_receivers_for_stocks(email_stock_codes)
+                    result = self.send_to_email(content, receivers=receivers)
                 elif channel == NotificationChannel.PUSHOVER:
                     result = self.send_to_pushover(content)
                 elif channel == NotificationChannel.PUSHPLUS: