feat(mx): 集成东方财富妙想API并新增AI选股功能

- 新增MiaoXiangSearchProvider实现东方财富妙想资讯搜索支持
- 配置文件增加MX_APIKEY环境变量支持多个妙想API Key
- 新增AI选股API端点，支持自然语言条件智能选股
- WebUI添加AI选股页面及相关路由和侧边栏入口
- 实现前端调用AI选股API并展示选股结果和提交深度分析功能
- 调整核心配置管理以支持妙想API Key的加载和校验
- 更新.gitignore和配置示例以支持妙想API相关文件和文档
- 日志、错误处理和消息提示完善AI选股功能用户体验

Author: DengGuiXing

.codex

@@ -237,7 +237,7 @@ GEMINI_API_KEY=
 # LLM_OPENROUTER_MODELS=~anthropic/claude-sonnet-latest,~openai/gpt-latest
 # LITELLM_MODEL=openai/~anthropic/claude-sonnet-latest
 
-# 高级：模型路由 YAML 配置（可选，参考 litellm_config.example.yaml）
+# 高级：模型路由 YAML 配置（可选，参考 docs/examples/litellm_config.example.yaml）
 # LITELLM_CONFIG=./litellm_config.yaml
 
 # ===================================
@@ -462,6 +462,10 @@ AGENT_SKILLS=
 # 注册Server酱3账号并获取SendKey https://sc3.ft07.com/
 # SERVERCHAN3_SENDKEY=
 #
+# 【方式十一】AstrBot 配置
+# ASTRBOT_URL=
+# ASTRBOT_TOKEN=  # 可选，用于需要 Bearer Token 的 AstrBot Webhook
+#
 # 【高级配置】消息长度限制（字节）
 # 超过限制会自动分批发送，一般无需修改
 # FEISHU_MAX_BYTES=20000    # 飞书限制约 20KB，默认 20000 字节

.env.example

@@ -270,6 +270,8 @@ jobs:
 
           # 方式二：飞书 Webhook
           FEISHU_WEBHOOK_URL: ${{ secrets.FEISHU_WEBHOOK_URL }}
+          FEISHU_WEBHOOK_SECRET: ${{ secrets.FEISHU_WEBHOOK_SECRET }}
+          FEISHU_WEBHOOK_KEYWORD: ${{ vars.FEISHU_WEBHOOK_KEYWORD || secrets.FEISHU_WEBHOOK_KEYWORD }}
 
           # 方式三：Telegram
           TELEGRAM_BOT_TOKEN: ${{ secrets.TELEGRAM_BOT_TOKEN }}
@@ -288,10 +290,13 @@ jobs:
 
           # 方式六：PushPlus ⬅️ 新增！
           PUSHPLUS_TOKEN: ${{ secrets.PUSHPLUS_TOKEN }}
+          PUSHPLUS_TOPIC: ${{ vars.PUSHPLUS_TOPIC || secrets.PUSHPLUS_TOPIC }}
 
           # 方式七：自定义 Webhook（钉钉、Bark、自建服务等）
           CUSTOM_WEBHOOK_URLS: ${{ secrets.CUSTOM_WEBHOOK_URLS }}
           CUSTOM_WEBHOOK_BEARER_TOKEN: ${{ secrets.CUSTOM_WEBHOOK_BEARER_TOKEN }}
+          CUSTOM_WEBHOOK_BODY_TEMPLATE: ${{ vars.CUSTOM_WEBHOOK_BODY_TEMPLATE || secrets.CUSTOM_WEBHOOK_BODY_TEMPLATE }}
+          WEBHOOK_VERIFY_SSL: ${{ vars.WEBHOOK_VERIFY_SSL || secrets.WEBHOOK_VERIFY_SSL || 'true' }}
 
           # 方式八：Discord
           DISCORD_WEBHOOK_URL: ${{ secrets.DISCORD_WEBHOOK_URL }}

.github/workflows/daily_analysis.yml

@@ -40,7 +40,7 @@ jobs:
         continue-on-error: true
         run: |
           set -o pipefail
-          ./test.sh quick --no-notify | tee quick-smoke.log
+          ./scripts/test.sh quick --no-notify | tee quick-smoke.log
 
       - name: 📤 Upload smoke logs
         if: always()

.github/workflows/network-smoke.yml

@@ -8,7 +8,13 @@
 # 测试文件（可能包含敏感配置）
 # 仅忽略仓库根目录下的临时 test_*.py 脚本；tests/ 目录下的单元测试需要纳入版本控制。
 /test_*.py
-!test_env.py
+/test.sh
+
+# 本地评审与高级路由配置（可能包含敏感信息或临时分析产物）
+/.codex
+/review.md
+/litellm_config.yaml
+/litellm_config.*.yaml
 
 # Python
 __pycache__/
@@ -78,5 +84,3 @@ verify_*.py
 static/
 /apps/dsa-desktop/dist/
 /apps/dsa-desktop/node_modules/
-
-.codex

.gitignore

@@ -138,7 +138,7 @@ gh run view <run_id> --log-failed
 | `backend-gate` | `.github/workflows/ci.yml` | 执行 `./scripts/ci_gate.sh` | 是 |
 | `docker-build` | `.github/workflows/ci.yml` | Docker 构建与关键模块导入 smoke | 是 |
 | `web-gate` | `.github/workflows/ci.yml` | 前端改动时执行 `npm run lint` + `npm run build` | 是（触发时） |
-| `network-smoke` | `.github/workflows/network-smoke.yml` | `pytest -m network` + `test.sh quick` | 否，观测项 |
+| `network-smoke` | `.github/workflows/network-smoke.yml` | `pytest -m network` + `scripts/test.sh quick` | 否，观测项 |
 | `pr-review` | `.github/workflows/pr-review.yml` | PR 静态检查 + AI 审查 + 自动标签 | 否，辅助项 |
 
 若 PR 上已有对应 CI 结果，可直接引用 CI 结论；若 CI 未覆盖改动面，或本地与 CI 环境差异较大，需要补充说明本地验证与缺口。

AGENTS.md

@@ -22,6 +22,8 @@
     SystemConfigValidationErrorResponse,
     TestLLMChannelRequest,
     TestLLMChannelResponse,
+    TestNotificationChannelRequest,
+    TestNotificationChannelResponse,
     UpdateSystemConfigRequest,
     UpdateSystemConfigResponse,
     ValidateSystemConfigRequest,
@@ -346,6 +348,50 @@ def test_llm_channel(
         )
 
 
+@router.post(
+    "/config/notification/test-channel",
+    response_model=TestNotificationChannelResponse,
+    responses={
+        200: {"description": "Notification channel test completed"},
+        500: {"description": "Internal server error", "model": ErrorResponse},
+    },
+    summary="Test one notification channel",
+    description="Send a short test notification using unsaved or saved notification configuration.",
+)
+def test_notification_channel(
+    request: TestNotificationChannelRequest,
+    service: SystemConfigService = Depends(get_system_config_service),
+) -> TestNotificationChannelResponse:
+    """Validate and test one notification channel without writing `.env`."""
+    try:
+        payload = service.test_notification_channel(
+            channel=request.channel,
+            items=[item.model_dump() for item in request.items],
+            mask_token=request.mask_token,
+            title=request.title,
+            content=request.content,
+            timeout_seconds=request.timeout_seconds,
+        )
+        return TestNotificationChannelResponse.model_validate(payload)
+    except (ValueError, TypeError) as exc:
+        raise HTTPException(
+            status_code=422,
+            detail={
+                "error": "validation_error",
+                "message": str(exc),
+            },
+        )
+    except Exception as exc:
+        logger.error("Failed to test notification channel: %s", exc, exc_info=True)
+        raise HTTPException(
+            status_code=500,
+            detail={
+                "error": "internal_error",
+                "message": "Failed to test notification channel",
+            },
+        )
+
+
 @router.post(
     "/config/llm/discover-models",
     response_model=DiscoverLLMChannelModelsResponse,

api/v1/endpoints/system_config.py

@@ -8,6 +8,19 @@
 from pydantic import BaseModel, ConfigDict, Field
 
 LLMCapabilityCheck = Literal["json", "tools", "vision", "stream"]
+NotificationTestChannel = Literal[
+    "wechat",
+    "feishu",
+    "telegram",
+    "email",
+    "pushover",
+    "pushplus",
+    "serverchan3",
+    "custom",
+    "discord",
+    "slack",
+    "astrbot",
+]
 
 
 class SystemConfigOption(BaseModel):
@@ -204,6 +217,43 @@ class TestLLMChannelResponse(BaseModel):
     capability_results: Dict[str, LLMCapabilityCheckResult] = Field(default_factory=dict)
 
 
+class NotificationTestAttempt(BaseModel):
+    """One notification delivery attempt result."""
+
+    channel: NotificationTestChannel
+    success: bool
+    message: str
+    target: Optional[str] = None
+    error_code: Optional[str] = None
+    stage: str = "notification_send"
+    retryable: bool = False
+    latency_ms: Optional[int] = None
+    http_status: Optional[int] = None
+
+
+class TestNotificationChannelRequest(BaseModel):
+    """Request payload for testing one notification channel."""
+
+    channel: NotificationTestChannel
+    items: List[SystemConfigUpdateItem] = Field(default_factory=list)
+    mask_token: str = "******"
+    title: str = Field(default="DSA 通知测试", min_length=1, max_length=80)
+    content: str = Field(default="这是一条来自 DSA Web 设置页的通知测试消息。", min_length=1, max_length=1000)
+    timeout_seconds: float = Field(default=20.0, ge=1.0, le=120.0)
+
+
+class TestNotificationChannelResponse(BaseModel):
+    """Response payload for one notification channel connectivity test."""
+
+    success: bool
+    message: str
+    error_code: Optional[str] = None
+    stage: Optional[str] = None
+    retryable: bool = False
+    latency_ms: Optional[int] = None
+    attempts: List[NotificationTestAttempt] = Field(default_factory=list)
+
+
 class DiscoverLLMChannelModelsRequest(BaseModel):
     """Request payload for discovering models from one LLM channel."""
 

api/v1/schemas/system_config.py

@@ -61,4 +61,54 @@ describe('systemConfigApi', () => {
       expect.objectContaining({ capability_checks: ['json', 'stream'] }),
     );
   });
+
+  it('sends notification channel test payloads with snake_case fields', async () => {
+    post.mockResolvedValueOnce({
+      data: {
+        success: true,
+        message: 'ok',
+        error_code: null,
+        stage: 'notification_send',
+        retryable: false,
+        latency_ms: 15,
+        attempts: [
+          {
+            channel: 'custom',
+            success: true,
+            message: 'sent',
+            target: 'https://example.com/hook?token=***',
+            error_code: null,
+            stage: 'notification_send',
+            retryable: false,
+            latency_ms: 15,
+            http_status: 200,
+          },
+        ],
+      },
+    });
+
+    const result = await systemConfigApi.testNotificationChannel({
+      channel: 'custom',
+      items: [{ key: 'CUSTOM_WEBHOOK_URLS', value: 'https://example.com/hook?token=secret' }],
+      maskToken: '******',
+      title: 'hello',
+      content: 'world',
+      timeoutSeconds: 7,
+    });
+
+    expect(post).toHaveBeenCalledWith(
+      '/api/v1/system/config/notification/test-channel',
+      {
+        channel: 'custom',
+        items: [{ key: 'CUSTOM_WEBHOOK_URLS', value: 'https://example.com/hook?token=secret' }],
+        mask_token: '******',
+        title: 'hello',
+        content: 'world',
+        timeout_seconds: 7,
+      },
+    );
+    expect(result.latencyMs).toBe(15);
+    expect(result.attempts[0].errorCode).toBeNull();
+    expect(result.attempts[0].httpStatus).toBe(200);
+  });
 });

apps/dsa-web/src/api/__tests__/systemConfig.test.ts

@@ -12,6 +12,8 @@ import type {
   SystemConfigValidationErrorResponse,
   TestLLMChannelRequest,
   TestLLMChannelResponse,
+  TestNotificationChannelRequest,
+  TestNotificationChannelResponse,
   UpdateSystemConfigRequest,
   UpdateSystemConfigResponse,
   ValidateSystemConfigRequest,
@@ -99,6 +101,20 @@ function toSnakeTestChannelPayload(payload: TestLLMChannelRequest): Record<strin
   return request;
 }
 
+function toSnakeNotificationTestPayload(payload: TestNotificationChannelRequest): Record<string, unknown> {
+  return {
+    channel: payload.channel,
+    items: (payload.items || []).map((item) => ({
+      key: item.key,
+      value: item.value,
+    })),
+    mask_token: payload.maskToken ?? '******',
+    title: payload.title ?? 'DSA 通知测试',
+    content: payload.content ?? '这是一条来自 DSA Web 设置页的通知测试消息。',
+    timeout_seconds: payload.timeoutSeconds ?? 20,
+  };
+}
+
 function toSnakeDiscoverModelsPayload(payload: DiscoverLLMChannelModelsRequest): Record<string, unknown> {
   return {
     name: payload.name,
@@ -152,6 +168,14 @@ export const systemConfigApi = {
     return toCamelCase<TestLLMChannelResponse>(response.data);
   },
 
+  async testNotificationChannel(payload: TestNotificationChannelRequest): Promise<TestNotificationChannelResponse> {
+    const response = await apiClient.post<Record<string, unknown>>(
+      '/api/v1/system/config/notification/test-channel',
+      toSnakeNotificationTestPayload(payload),
+    );
+    return toCamelCase<TestNotificationChannelResponse>(response.data);
+  },
+
   async discoverLLMChannelModels(
     payload: DiscoverLLMChannelModelsRequest,
   ): Promise<DiscoverLLMChannelModelsResponse> {