+
-
- {pendingCount}
-
- 等待中
+ {pendingCount}
+ 等待中
-
- {runningCount}
-
- 分析中
+ {runningCount}
+ 分析中
-
- {completedCount}
-
- 已完成
+ {completedCount}
+ 已完成
-
- {failedCount}
-
- 失败
+ {failedCount}
+ 失败
- {/* Settings */}
-
-
- 最大并发数:
- setMaxConcurrent(val)}
- style={{ width: 80 }}
- />
-
- 同时运行的分析任务数量
-
-
-
-
{/* Tasks Table */}
- {loading ? (
-
- ) : error ? (
+ {loading && tasks.length === 0 ? (
+
+ ) : error && tasks.length === 0 ? (
{
- fetchTasks()
- }}
- aria-label="重试"
- >
+
}
/>
) : tasks.length === 0 ? (
-
-
-
-
-
-
- }
- />
+
+
+
暂无批量任务
+
+ 在股票筛选页面提交分析任务
+
+
+
diff --git a/web_dashboard/frontend/src/pages/PortfolioPanel.jsx b/web_dashboard/frontend/src/pages/PortfolioPanel.jsx
new file mode 100644
index 00000000..def6a728
--- /dev/null
+++ b/web_dashboard/frontend/src/pages/PortfolioPanel.jsx
@@ -0,0 +1,467 @@
+import { useState, useEffect, useCallback, useRef } from 'react'
+import {
+ Table, Button, Input, Select, Space, Row, Col, Card, Progress, Result,
+ message, Popconfirm, Modal, Tabs, Tag, Tooltip, Upload, Form, Typography,
+} from 'antd'
+import {
+ PlusOutlined, DeleteOutlined, PlayCircleOutlined, UploadOutlined,
+ DownloadOutlined, SyncOutlined, CheckCircleOutlined, CloseCircleOutlined,
+ AccountBookOutlined,
+} from '@ant-design/icons'
+import { portfolioApi } from '../services/portfolioApi'
+
+const { Text } = Typography
+
+// ============== Helpers ==============
+
+const formatMoney = (v) =>
+ v == null ? '—' : `¥${v.toFixed(2)}`;
+
+const formatPct = (v) =>
+ v == null ? '—' : `${v >= 0 ? '+' : ''}${v.toFixed(2)}%`;
+
+const DecisionBadge = ({ decision }) => {
+ if (!decision) return null
+ const cls = decision === 'BUY' ? 'badge-buy' : decision === 'SELL' ? 'badge-sell' : 'badge-hold'
+ return
{decision}
+}
+
+// ============== Tab 1: Watchlist ==============
+
+function WatchlistTab() {
+ const [data, setData] = useState([])
+ const [loading, setLoading] = useState(true)
+ const [addOpen, setAddOpen] = useState(false)
+ const [form] = Form.useForm()
+
+ const fetch_ = useCallback(async () => {
+ setLoading(true)
+ try {
+ const res = await portfolioApi.getWatchlist()
+ setData(res.watchlist || [])
+ } catch {
+ message.error('加载失败')
+ } finally {
+ setLoading(false)
+ }
+ }, [])
+
+ useEffect(() => { fetch_() }, [fetch_])
+
+ const handleAdd = async (vals) => {
+ try {
+ await portfolioApi.addToWatchlist(vals.ticker, vals.name || vals.ticker)
+ message.success('已添加')
+ setAddOpen(false)
+ form.resetFields()
+ fetch_()
+ } catch (e) {
+ message.error(e.message)
+ }
+ }
+
+ const handleDelete = async (ticker) => {
+ try {
+ await portfolioApi.removeFromWatchlist(ticker)
+ message.success('已移除')
+ fetch_()
+ } catch (e) {
+ message.error(e.message)
+ }
+ }
+
+ const columns = [
+ { title: '代码', dataIndex: 'ticker', key: 'ticker', width: 120,
+ render: t =>
{t} },
+ { title: '名称', dataIndex: 'name', key: 'name', render: t =>
{t} },
+ { title: '添加日期', dataIndex: 'added_at', key: 'added_at', width: 120 },
+ {
+ title: '操作', key: 'action', width: 100,
+ render: (_, r) => (
+
handleDelete(r.ticker)} okText="确认" cancelText="取消">
+ }>移除
+
+ ),
+ },
+ ]
+
+ return (
+
+
+
+
自选股列表
+
+ } type="primary" onClick={() => setAddOpen(true)}>添加
+ } onClick={fetch_} loading={loading}>刷新
+
+
+
+
+
+
+ {data.length === 0 && !loading && (
+
+
+
暂无自选股
+
点击上方"添加"将股票加入自选
+
+ )}
+
+
+
{ setAddOpen(false); form.resetFields() }} footer={null}>
+
+
+
+ )
+}
+
+// ============== Tab 2: Positions ==============
+
+function PositionsTab() {
+ const [data, setData] = useState([])
+ const [accounts, setAccounts] = useState(['默认账户'])
+ const [account, setAccount] = useState(null)
+ const [loading, setLoading] = useState(true)
+ const [addOpen, setAddOpen] = useState(false)
+ const [form] = Form.useForm()
+
+ const fetchPositions = useCallback(async () => {
+ setLoading(true)
+ try {
+ const [posRes, accRes] = await Promise.all([
+ portfolioApi.getPositions(account),
+ portfolioApi.getAccounts(),
+ ])
+ setData(posRes.positions || [])
+ setAccounts(accRes.accounts || ['默认账户'])
+ } catch {
+ message.error('加载失败')
+ } finally {
+ setLoading(false)
+ }
+ }, [account])
+
+ useEffect(() => { fetchPositions() }, [fetchPositions])
+
+ const handleAdd = async (vals) => {
+ try {
+ await portfolioApi.addPosition({ ...vals, account: account || '默认账户' })
+ message.success('已添加')
+ setAddOpen(false)
+ form.resetFields()
+ fetchPositions()
+ } catch (e) {
+ message.error(e.message)
+ }
+ }
+
+ const handleDelete = async (ticker, positionId) => {
+ try {
+ await portfolioApi.removePosition(ticker, positionId, account)
+ message.success('已移除')
+ fetchPositions()
+ } catch (e) {
+ message.error(e.message)
+ }
+ }
+
+ const handleExport = async () => {
+ try {
+ const blob = await portfolioApi.exportPositions(account)
+ const url = URL.createObjectURL(blob)
+ const a = document.createElement('a')
+ a.href = url; a.download = 'positions.csv'; a.click()
+ URL.revokeObjectURL(url)
+ } catch (e) {
+ message.error(e.message)
+ }
+ }
+
+ const totalPnl = data.reduce((s, p) => s + (p.unrealized_pnl || 0), 0)
+
+ const columns = [
+ { title: '代码', dataIndex: 'ticker', key: 'ticker', width: 110,
+ render: t =>
{t} },
+ { title: '账户', dataIndex: 'account', key: 'account', width: 100 },
+ { title: '数量', dataIndex: 'shares', key: 'shares', align: 'right', width: 80,
+ render: v =>
{v} },
+ { title: '成本价', dataIndex: 'cost_price', key: 'cost_price', align: 'right', width: 90,
+ render: v =>
{formatMoney(v)} },
+ { title: '现价', dataIndex: 'current_price', key: 'current_price', align: 'right', width: 90,
+ render: v =>
{formatMoney(v)} },
+ {
+ title: '浮亏浮盈',
+ key: 'pnl',
+ align: 'right',
+ width: 110,
+ render: (_, r) => {
+ const pnl = r.unrealized_pnl
+ const pct = r.unrealized_pnl_pct
+ const color = pnl == null ? undefined : pnl >= 0 ? 'var(--color-buy)' : 'var(--color-sell)'
+ return (
+
+ {pnl == null ? '—' : `${pnl >= 0 ? '+' : ''}${formatMoney(pnl)}`}
+
+ {pct == null ? '' : formatPct(pct)}
+
+ )
+ },
+ },
+ {
+ title: '买入日期',
+ dataIndex: 'purchase_date',
+ key: 'purchase_date',
+ width: 100,
+ },
+ {
+ title: '操作', key: 'action', width: 80,
+ render: (_, r) => (
+
handleDelete(r.ticker, r.position_id)} okText="确认" cancelText="取消">
+ }>平仓
+
+ ),
+ },
+ ]
+
+ return (
+
+
+
+
+
账户
+
+
总浮亏浮盈
+
= 0 ? 'var(--color-buy)' : 'var(--color-sell)' }}>
+ {formatMoney(totalPnl)}
+
+
+
+
+
+
持仓记录
+
+ } onClick={handleExport}>导出
+ } type="primary" onClick={() => setAddOpen(true)}>添加持仓
+ } onClick={fetchPositions} loading={loading}>刷新
+
+
+
+
+
+
+ {data.length === 0 && !loading && (
+
+
+
暂无持仓
+
点击"添加持仓"录入您的股票仓位
+
+ )}
+
+
+
{ setAddOpen(false); form.resetFields() }} footer={null}>
+
+
+
+ )
+}
+
+// ============== Tab 3: Recommendations ==============
+
+function RecommendationsTab() {
+ const [data, setData] = useState([])
+ const [loading, setLoading] = useState(true)
+ const [analyzing, setAnalyzing] = useState(false)
+ const [taskId, setTaskId] = useState(null)
+ const [wsConnected, setWsConnected] = useState(false)
+ const [progress, setProgress] = useState(null)
+ const [selectedDate, setSelectedDate] = useState(null)
+ const [dates, setDates] = useState([])
+ const wsRef = useRef(null)
+
+ const fetchRecs = useCallback(async (date) => {
+ setLoading(true)
+ try {
+ const res = await portfolioApi.getRecommendations(date)
+ setData(res.recommendations || [])
+ if (!date) {
+ const d = [...new Set((res.recommendations || []).map(r => r.analysis_date))].sort().reverse()
+ setDates(d)
+ }
+ } catch {
+ message.error('加载失败')
+ } finally {
+ setLoading(false)
+ }
+ }, [])
+
+ useEffect(() => { fetchRecs(selectedDate) }, [fetchRecs, selectedDate])
+
+ const connectWs = useCallback((tid) => {
+ if (wsRef.current) wsRef.current.close()
+ const protocol = window.location.protocol === 'https:' ? 'wss:' : 'ws:'
+ const host = window.location.host
+ const ws = new WebSocket(`${protocol}//${host}/ws/analysis/${tid}`)
+ ws.onopen = () => setWsConnected(true)
+ ws.onmessage = (e) => {
+ const d = JSON.parse(e.data)
+ if (d.type === 'progress') setProgress(d)
+ }
+ ws.onclose = () => setWsConnected(false)
+ wsRef.current = ws
+ }, [])
+
+ const handleAnalyze = async () => {
+ try {
+ const res = await portfolioApi.startAnalysis()
+ setTaskId(res.task_id)
+ setAnalyzing(true)
+ setProgress({ completed: 0, total: res.total, status: 'running' })
+ connectWs(res.task_id)
+ message.info('开始批量分析...')
+ } catch (e) {
+ message.error(e.message)
+ }
+ }
+
+ useEffect(() => {
+ if (progress?.status === 'completed' || progress?.status === 'failed') {
+ setAnalyzing(false)
+ setTaskId(null)
+ setProgress(null)
+ fetchRecs(selectedDate)
+ }
+ }, [progress?.status])
+
+ useEffect(() => () => { if (wsRef.current) wsRef.current.close() }, [])
+
+ const columns = [
+ { title: '代码', dataIndex: 'ticker', key: 'ticker', width: 110,
+ render: t =>
{t} },
+ { title: '名称', dataIndex: 'name', key: 'name', render: t =>
{t} },
+ {
+ title: '决策', dataIndex: 'decision', key: 'decision', width: 80,
+ render: d =>
,
+ },
+ { title: '分析日期', dataIndex: 'analysis_date', key: 'analysis_date', width: 120 },
+ ]
+
+ return (
+
+ {/* Analysis card */}
+
+
+
今日建议
+
+ {analyzing && progress && (
+
+ {wsConnected ? '🟢' : '🔴'}
+ {progress.completed || 0} / {progress.total || 0}
+
+ )}
+ }
+ onClick={handleAnalyze}
+ loading={analyzing}
+ disabled={analyzing}
+ >
+ {analyzing ? '分析中...' : '生成今日建议'}
+
+
+
+ {analyzing && progress && (
+
+ )}
+
+
+ {/* Date filter */}
+
+
+
+ {/* Recommendations list */}
+
+
+ {data.length === 0 && !loading && (
+
+
+
暂无建议
+
点击上方"生成今日建议"开始批量分析
+
+ )}
+
+
+ )
+}
+
+// ============== Main ==============
+
+export default function PortfolioPanel() {
+ const [activeTab, setActiveTab] = useState('watchlist')
+
+ const items = [
+ { key: 'watchlist', label: '自选股', children:
},
+ { key: 'positions', label: '持仓', children:
},
+ { key: 'recommendations', label: '今日建议', children:
},
+ ]
+
+ return (
+
+ )
+}
diff --git a/web_dashboard/frontend/src/pages/ReportsViewer.jsx b/web_dashboard/frontend/src/pages/ReportsViewer.jsx
new file mode 100644
index 00000000..4e17196b
--- /dev/null
+++ b/web_dashboard/frontend/src/pages/ReportsViewer.jsx
@@ -0,0 +1,225 @@
+import { useState, useEffect } from 'react'
+import { Table, Input, Modal, Skeleton, Button, Space, message } from 'antd'
+import { FileTextOutlined, SearchOutlined, CloseOutlined, DownloadOutlined } from '@ant-design/icons'
+import ReactMarkdown from 'react-markdown'
+
+const { Search } = Input
+
+export default function ReportsViewer() {
+ const [loading, setLoading] = useState(true)
+ const [reports, setReports] = useState([])
+ const [selectedReport, setSelectedReport] = useState(null)
+ const [reportContent, setReportContent] = useState(null)
+ const [loadingContent, setLoadingContent] = useState(false)
+ const [searchText, setSearchText] = useState('')
+
+ useEffect(() => {
+ fetchReports()
+ }, [])
+
+ const fetchReports = async () => {
+ setLoading(true)
+ try {
+ const res = await fetch('/api/reports/list')
+ if (!res.ok) throw new Error(`请求失败: ${res.status}`)
+ const data = await res.json()
+ setReports(data)
+ } catch {
+ setReports([])
+ } finally {
+ setLoading(false)
+ }
+ }
+
+ const handleExportCsv = async () => {
+ try {
+ const res = await fetch('/api/reports/export')
+ if (!res.ok) throw new Error('导出失败')
+ const blob = await res.blob()
+ const url = URL.createObjectURL(blob)
+ const a = document.createElement('a')
+ a.href = url; a.download = 'tradingagents_reports.csv'; a.click()
+ URL.revokeObjectURL(url)
+ } catch (e) {
+ message.error(e.message)
+ }
+ }
+
+ const handleExportPdf = async (ticker, date) => {
+ try {
+ const res = await fetch(`/api/reports/${ticker}/${date}/pdf`)
+ if (!res.ok) throw new Error('导出失败')
+ const blob = await res.blob()
+ const url = URL.createObjectURL(blob)
+ const a = document.createElement('a')
+ a.href = url; a.download = `${ticker}_${date}_report.pdf`; a.click()
+ URL.revokeObjectURL(url)
+ } catch (e) {
+ message.error(e.message)
+ }
+ }
+
+ const handleViewReport = async (record) => {
+ setSelectedReport(record)
+ setLoadingContent(true)
+ try {
+ const res = await fetch(`/api/reports/${record.ticker}/${record.date}`)
+ if (!res.ok) throw new Error(`加载失败: ${res.status}`)
+ const data = await res.json()
+ setReportContent(data)
+ } catch (err) {
+ setReportContent({ report: `# 加载失败\n\n无法加载报告: ${err.message}` })
+ } finally {
+ setLoadingContent(false)
+ }
+ }
+
+ const filteredReports = reports.filter(
+ (r) =>
+ r.ticker.toLowerCase().includes(searchText.toLowerCase()) ||
+ r.date.includes(searchText)
+ )
+
+ const columns = [
+ {
+ title: '代码',
+ dataIndex: 'ticker',
+ key: 'ticker',
+ width: 120,
+ render: (text) => (
+
{text}
+ ),
+ },
+ {
+ title: '日期',
+ dataIndex: 'date',
+ key: 'date',
+ width: 120,
+ render: (text) => (
+
{text}
+ ),
+ },
+ {
+ title: '操作',
+ key: 'action',
+ width: 100,
+ render: (_, record) => (
+
}
+ size="small"
+ onClick={() => handleViewReport(record)}
+ >
+ 查看
+
+ ),
+ },
+ ]
+
+ return (
+
+ {/* Search + Export */}
+
+
+ setSearchText(e.target.value)}
+ prefix={}
+ size="large"
+ style={{ flex: 1 }}
+ />
+ } onClick={handleExportCsv} disabled={reports.length === 0}>
+ 导出CSV
+
+
+
+
+ {/* Reports Table */}
+
+ {loading ? (
+
+
+
+ ) : filteredReports.length === 0 ? (
+
+
+
暂无历史报告
+
+ 在股票筛选页面提交分析任务后，报告将显示在这里
+
+
+ ) : (
+
`${r.ticker}-${r.date}`}
+ pagination={{ pageSize: 10 }}
+ size="middle"
+ />
+ )}
+
+
+ {/* Report Modal */}
+
+
+ {selectedReport.ticker}
+
+ {selectedReport.date}
+
+ ) : null
+ }
+ open={!!selectedReport}
+ onCancel={() => {
+ setSelectedReport(null)
+ setReportContent(null)
+ }}
+ footer={
+ selectedReport ? (
+
+ }
+ onClick={() => handleExportPdf(selectedReport.ticker, selectedReport.date)}
+ >
+ 导出PDF
+
+
+
+ ) : null
+ }
+ width={800}
+ closeIcon={}
+ styles={{
+ wrapper: { maxWidth: '95vw' },
+ body: { maxHeight: '70vh', overflow: 'auto', padding: 'var(--space-6)' },
+ header: { padding: 'var(--space-4) var(--space-6)', borderBottom: '1px solid rgba(0,0,0,0.08)' },
+ }}
+ >
+ {loadingContent ? (
+
+
+
+ ) : reportContent ? (
+
+ {reportContent.report || 'No content'}
+
+ ) : null}
+
+
+ )
+}
diff --git a/web_dashboard/frontend/src/pages/ScreeningPanel.jsx b/web_dashboard/frontend/src/pages/ScreeningPanel.jsx
index 108009ef..5de31a39 100644
--- a/web_dashboard/frontend/src/pages/ScreeningPanel.jsx
+++ b/web_dashboard/frontend/src/pages/ScreeningPanel.jsx
@@ -1,6 +1,6 @@
import { useState, useEffect } from 'react'
import { useNavigate } from 'react-router-dom'
-import { Table, Button, Select, Input, Space, Statistic, Row, Col, Skeleton, Result, message, Popconfirm, Tooltip } from 'antd'
+import { Table, Button, Select, Space, Row, Col, Skeleton, Result, message, Popconfirm, Tooltip } from 'antd'
import { PlayCircleOutlined, ReloadOutlined, QuestionCircleOutlined } from '@ant-design/icons'
const SCREEN_MODES = [
@@ -15,7 +15,6 @@ export default function ScreeningPanel() {
const navigate = useNavigate()
const [mode, setMode] = useState('china_strict')
const [loading, setLoading] = useState(true)
- const [screening, setScreening] = useState(false)
const [results, setResults] = useState([])
const [stats, setStats] = useState({ total: 0, passed: 0 })
const [error, setError] = useState(null)
@@ -41,6 +40,22 @@ export default function ScreeningPanel() {
fetchResults()
}, [mode])
+ const handleStartAnalysis = async (stock) => {
+ try {
+ const res = await fetch('/api/analysis/start', {
+ method: 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body: JSON.stringify({ ticker: stock.ticker }),
+ })
+ if (!res.ok) throw new Error('启动分析失败')
+ const data = await res.json()
+ message.success(`已提交分析任务: ${stock.name} (${stock.ticker})`)
+ navigate(`/monitor?task_id=${data.task_id}`)
+ } catch (err) {
+ message.error(err.message)
+ }
+ }
+
const columns = [
{
title: '代码',
@@ -48,7 +63,7 @@ export default function ScreeningPanel() {
key: 'ticker',
width: 120,
render: (text) => (
- {text}
+ {text}
),
},
{
@@ -56,18 +71,24 @@ export default function ScreeningPanel() {
dataIndex: 'name',
key: 'name',
width: 120,
+ render: (text) => (
+ {text}
+ ),
},
{
title: (
- 营收增速
+
+ 营收增速
+
),
dataIndex: 'revenue_growth',
key: 'revenue_growth',
align: 'right',
+ width: 100,
render: (val) => (
-
+ 0 ? 'var(--color-buy)' : 'var(--color-sell)' }}>
{val?.toFixed(1)}%
),
@@ -75,14 +96,17 @@ export default function ScreeningPanel() {
{
title: (
- 利润增速
+
+ 利润增速
+
),
dataIndex: 'profit_growth',
key: 'profit_growth',
align: 'right',
+ width: 100,
render: (val) => (
-
+ 0 ? 'var(--color-buy)' : 'var(--color-sell)' }}>
{val?.toFixed(1)}%
),
@@ -90,16 +114,17 @@ export default function ScreeningPanel() {
{
title: (
- ROE
+
+ ROE
+
),
dataIndex: 'roe',
key: 'roe',
align: 'right',
+ width: 80,
render: (val) => (
-
- {val?.toFixed(1)}%
-
+ {val?.toFixed(1)}%
),
},
{
@@ -107,31 +132,31 @@ export default function ScreeningPanel() {
dataIndex: 'current_price',
key: 'current_price',
align: 'right',
+ width: 100,
render: (val) => (
-
- ¥{val?.toFixed(2)}
-
+ ¥{val?.toFixed(2)}
),
},
{
title: (
- Vol比
+
+ Vol比
+
),
dataIndex: 'vol_ratio',
key: 'vol_ratio',
align: 'right',
+ width: 80,
render: (val) => (
-
- {val?.toFixed(2)}x
-
+ {val?.toFixed(2)}x
),
},
{
title: '操作',
key: 'action',
- width: 140,
+ width: 100,
render: (_, record) => (
{
- try {
- const res = await fetch('/api/analysis/start', {
- method: 'POST',
- headers: { 'Content-Type': 'application/json' },
- body: JSON.stringify({ ticker: stock.ticker }),
- })
- if (!res.ok) throw new Error('启动分析失败')
- const data = await res.json()
- message.success(`已提交分析任务: ${stock.name} (${stock.ticker})`)
- navigate(`/monitor?task_id=${data.task_id}`)
- } catch (err) {
- message.error(err.message)
- }
- }
-
return (
- {/* Stats Row */}
+ {/* Stats Row - Apple style */}
-
m.value === mode)?.label}
- />
+ 筛选模式
+
+ {SCREEN_MODES.find(m => m.value === mode)?.label}
+
-
+
通过数量
+
{stats.passed}
@@ -213,6 +213,7 @@ export default function ScreeningPanel() {
onChange={setMode}
options={SCREEN_MODES}
style={{ width: 200 }}
+ popupMatchSelectWidth={false}
/>
}
@@ -239,12 +240,10 @@ export default function ScreeningPanel() {
type="primary"
icon={
}
onClick={fetchResults}
- aria-label="重试"
>
重试
}
- style={{ border: '1px solid var(--color-sell)', borderRadius: 'var(--radius-md)' }}
/>
) : results.length === 0 ? (
@@ -265,6 +264,7 @@ export default function ScreeningPanel() {
rowKey="ticker"
pagination={{ pageSize: 10 }}
size="middle"
+ scroll={{ x: 700 }}
/>
)}
diff --git a/web_dashboard/frontend/src/services/portfolioApi.js b/web_dashboard/frontend/src/services/portfolioApi.js
new file mode 100644
index 00000000..2ee67b4c
--- /dev/null
+++ b/web_dashboard/frontend/src/services/portfolioApi.js
@@ -0,0 +1,66 @@
+const BASE = '/api/portfolio';
+const FETCH_TIMEOUT_MS = 15000; // 15s timeout per request
+
+async function req(method, path, body) {
+ const controller = new AbortController();
+ const timeout = setTimeout(() => controller.abort(), FETCH_TIMEOUT_MS);
+ const opts = {
+ method,
+ headers: { 'Content-Type': 'application/json' },
+ signal: controller.signal,
+ };
+ if (body !== undefined) opts.body = JSON.stringify(body);
+ try {
+ const res = await fetch(`${BASE}${path}`, opts);
+ clearTimeout(timeout);
+ if (!res.ok) {
+ const err = await res.json().catch(() => ({}));
+ throw new Error(err.detail || `请求失败: ${res.status}`);
+ }
+ if (res.status === 204) return null;
+ return res.json();
+ } catch (e) {
+ clearTimeout(timeout);
+ if (e.name === 'AbortError') throw new Error('请求超时，请检查网络连接');
+ throw e;
+ }
+}
+
+export const portfolioApi = {
+ // Watchlist
+ getWatchlist: () => req('GET', '/watchlist'),
+ addToWatchlist: (ticker, name) => req('POST', '/watchlist', { ticker, name }),
+ removeFromWatchlist: (ticker) => req('DELETE', `/watchlist/${ticker}`),
+
+ // Accounts
+ getAccounts: () => req('GET', '/accounts'),
+ createAccount: (name) => req('POST', '/accounts', { account_name: name }),
+ deleteAccount: (name) => req('DELETE', `/accounts/${name}`),
+
+ // Positions
+ getPositions: (account) => req('GET', `/positions${account ? `?account=${encodeURIComponent(account)}` : ''}`),
+ addPosition: (data) => req('POST', '/positions', data),
+ removePosition: (ticker, positionId, account) => {
+ const params = new URLSearchParams({ ticker });
+ if (positionId) params.set('position_id', positionId);
+ if (account) params.set('account', account);
+ return req('DELETE', `/positions/${ticker}?${params}`);
+ },
+ exportPositions: (account) => {
+ const controller = new AbortController();
+ const timeout = setTimeout(() => controller.abort(), FETCH_TIMEOUT_MS);
+ const url = `${BASE}/positions/export${account ? `?account=${encodeURIComponent(account)}` : ''}`;
+ return fetch(url, { signal: controller.signal })
+ .then(r => { clearTimeout(timeout); return r; })
+ .then(r => { if (!r.ok) throw new Error(`导出失败: ${r.status}`); return r.blob(); })
+ .catch(e => { clearTimeout(timeout); if (e.name === 'AbortError') throw new Error('请求超时'); throw e; });
+ },
+
+ // Recommendations
+ getRecommendations: (date) =>
+ req('GET', `/recommendations${date ? `?date=${date}` : ''}`),
+ getRecommendation: (date, ticker) => req('GET', `/recommendations/${date}/${ticker}`),
+
+ // Batch analysis
+ startAnalysis: () => req('POST', '/analyze'),
+};