feat: add market data sync, Tushare driver, and market desk research UX.

Integrate local market-data sync with settings UI and Tushare priority sourcing, and expand the right panel with discover screening, watchlist radar, and decision cards.

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: Travisun

apps/server/src/index.ts

@@ -13,6 +13,7 @@ const PORT = Number(process.env.STOCK_RESEARCH_PORT ?? 8711)
 const HOST = process.env.STOCK_RESEARCH_HOST ?? '127.0.0.1'
 
 const hub = new ResearchHub()
+hub.initMarketDataAutoResume()
 let cfg = loadConfig()
 
 function syncAgentProviders() {
@@ -51,6 +52,51 @@ app.post<{ Body: { feature: string; params?: Record<string, unknown> } }>(
   },
 )
 
+app.get('/api/market-data/status', async () => {
+  const result = await hub.dispatch('market_db_status', {})
+  return { success: result.success, data: result.data, message: result.message }
+})
+
+app.get('/api/market-data/sync-state', async () => {
+  const result = await hub.dispatch('market_db_sync_state', {})
+  return { success: result.success, data: result.data, message: result.message }
+})
+
+app.post<{ Body: { mode?: string; max_stocks?: number; jobs?: string[]; background?: boolean; force?: boolean; profile?: string } }>(
+  '/api/market-data/sync',
+  async (req) => {
+    const body = req.body ?? {}
+    const result = await hub.dispatch('market_db_sync', {
+      mode: body.mode,
+      max_stocks: body.max_stocks,
+      jobs: body.jobs,
+      background: body.background,
+      force: body.force,
+      profile: body.profile,
+    })
+    return { success: result.success, data: result.data, message: result.message, elapsed: result.elapsed }
+  },
+)
+
+app.get('/api/tushare/config', async () => {
+  const r = await hub.dispatch('tushare_config', {})
+  return { success: r.success, data: r.data, message: r.message }
+})
+
+app.post<{ Body: { enabled?: boolean; token?: string } }>('/api/tushare/config', async (req) => {
+  const body = req.body ?? {}
+  const r = await hub.dispatch('tushare_config_save', {
+    enabled: body.enabled,
+    token: body.token,
+  })
+  return { success: r.success, data: r.data, message: r.message }
+})
+
+app.post<{ Body: { token?: string } }>('/api/tushare/test', async (req) => {
+  const r = await hub.dispatch('tushare_test', { token: req.body?.token })
+  return { success: r.success, data: r.data, message: r.message }
+})
+
 app.get('/api/config', async () => publicConfig(cfg))
 
 app.patch<{ Body: { default_scorecard?: string; default_top_n?: number; default_model?: string } }>(

client-ui/src/api/client.ts

@@ -7,13 +7,22 @@ const REQUEST_TIMEOUT = 10000 // 10s timeout for all API requests
 
 async function fetchWithTimeout(path: string, init?: RequestInit, timeoutMs = REQUEST_TIMEOUT): Promise<Response> {
   const controller = new AbortController()
-  const timer = setTimeout(() => controller.abort(), timeoutMs)
+  let timedOut = false
+  const timer = setTimeout(() => {
+    timedOut = true
+    controller.abort()
+  }, timeoutMs)
   const external = init?.signal
   const onExternalAbort = () => controller.abort()
   external?.addEventListener('abort', onExternalAbort)
   try {
     const { signal: _ignored, ...rest } = init ?? {}
     return await fetch(path, { ...rest, signal: controller.signal })
+  } catch (e) {
+    if (timedOut && e instanceof Error && e.name === 'AbortError') {
+      throw new Error('请求超时')
+    }
+    throw e
   } finally {
     clearTimeout(timer)
     external?.removeEventListener('abort', onExternalAbort)
@@ -33,13 +42,14 @@ export async function apiCall<T>(
   feature: string,
   params: Record<string, any> = {},
   init?: RequestInit,
+  timeoutMs = REQUEST_TIMEOUT,
 ): Promise<ApiResponse<T>> {
   const resp = await fetchWithTimeout(`${API_BASE}/research`, {
     method: 'POST',
     headers: { 'Content-Type': 'application/json' },
     body: JSON.stringify({ feature, params }),
     ...init,
-  })
+  }, timeoutMs)
   if (!resp.ok) throw new Error(`API error: ${resp.status}`)
   return resp.json()
 }
@@ -56,14 +66,25 @@ export const research = {
   diagnose:      (code: string) =>
     apiCall<StockDiagnosisData>('stock_diagnosis', { code }),
 
-  institutionRating: (code: string, groups?: string[]) =>
-    apiCall<InstitutionRatingData>('institution_rating', { code, groups }),
+  institutionRating: (code: string, groups?: string[], signal?: AbortSignal) =>
+    apiCall<InstitutionRatingData>('institution_rating', { code, groups }, { signal }, 20000),
+
+  screen: (conditions: any[], scorecard = '综合评估', topN = 20, signal?: AbortSignal) =>
+    apiCall<ScreeningData>('screening', { conditions, scorecard, top_n: topN }, { signal }, 120000),
 
-  screen: (conditions: any[], scorecard = '综合评估', topN = 20) =>
-    apiCall<ScreeningData>('screening', { conditions, scorecard, top_n: topN }),
+  marketDbStatus: () =>
+    apiCall<import('../types/market').MarketDbStatusData>('market_db_status'),
+
+  marketDbSync: (mode: 'full' | 'incremental' | 'resume' = 'full', background = true, force = false) =>
+    apiCall<{ started: boolean; running: boolean; mode: string }>(
+      'market_db_sync',
+      { mode, background, force },
+      undefined,
+      background ? 15000 : 600000,
+    ),
 
-  strategySignals: (code: string) =>
-    apiCall<StrategySignalData>('strategy_signal', { code }),
+  strategySignals: (code: string, signal?: AbortSignal) =>
+    apiCall<StrategySignalData>('strategy_signal', { code }, { signal }, 30000),
 
   strategyVerify: (code: string, checkpoints = 30, forwardDays = 5) =>
     apiCall<StrategyVerifyData>('strategy_verify', { code, checkpoints, forward_days: forwardDays }),
@@ -83,6 +104,9 @@ export const research = {
   stockQuotes: (codes: string[]) =>
     apiCall<import('../types/market').StockQuotesData>('stock_quotes', { codes }),
 
+  watchlistRadar: (codes: string[], signal?: AbortSignal) =>
+    apiCall<import('../types/schemas').WatchlistRadarData>('watchlist_radar', { codes }, { signal }, 15000),
+
   stockKline: (code: string, count = 90) =>
     apiCall<import('../types/market').StockKlineData>('stock_kline', { code, count }),
 
@@ -100,10 +124,12 @@ export const research = {
       { signal },
     ),
 
-  stockCyq: (code: string) =>
+  stockCyq: (code: string, signal?: AbortSignal) =>
     apiCall<{ code: string; rows: import('../types/market').ChipDistributionPoint[]; latest: import('../types/market').ChipDistributionPoint }>(
       'stock_cyq',
       { code },
+      { signal },
+      15000,
     ),
 
   stockDetail: (code: string) =>
@@ -112,8 +138,8 @@ export const research = {
   backtest: (codes: string[], scorecard = '综合评估', periods = 5) =>
     apiCall<BacktestResultData>('backtest', { codes, scorecard, periods }),
 
-  latestEval: (code: string) =>
-    apiCall<LatestEvalData>('latest_evaluation', { code }),
+  latestEval: (code: string, signal?: AbortSignal) =>
+    apiCall<LatestEvalData>('latest_evaluation', { code }, { signal }, 30000),
 
   strategyReport: (code: string) =>
     apiCall<ReportTextData>('strategy_report', { code }),
@@ -134,6 +160,61 @@ export const research = {
     apiCall<import('../types/schemas').PortfolioSummaryData>('portfolio_summary', {}),
 }
 
+export async function getMarketDataSyncState() {
+  const resp = await jsonFetch<{ success: boolean; data: import('../types/market').MarketDataSyncState }>(
+    '/market-data/sync-state',
+  )
+  if (!resp.data) throw new Error('无法获取同步状态')
+  return resp.data
+}
+
+export async function startMarketDataSync(
+  mode: 'full' | 'incremental' | 'resume' = 'full',
+  options: { force?: boolean; jobs?: string[]; profile?: string } = {},
+) {
+  return jsonFetch<{ success: boolean; message?: string }>('/market-data/sync', {
+    method: 'POST',
+    headers: { 'Content-Type': 'application/json' },
+    body: JSON.stringify({
+      mode,
+      background: true,
+      force: options.force ?? false,
+      jobs: options.jobs,
+      profile: options.profile,
+    }),
+  })
+}
+
+export interface TusharePublicConfig {
+  enabled: boolean
+  token: string
+  token_configured: boolean
+  token_preview: string
+  config_path: string
+}
+
+export async function getTushareConfig() {
+  const resp = await jsonFetch<{ success: boolean; data: TusharePublicConfig }>('/tushare/config')
+  if (!resp.data) throw new Error('无法读取 Tushare 配置')
+  return resp.data
+}
+
+export async function saveTushareConfig(payload: { enabled: boolean; token?: string }) {
+  return jsonFetch<{ success: boolean; data: TusharePublicConfig; message?: string }>('/tushare/config', {
+    method: 'POST',
+    headers: { 'Content-Type': 'application/json' },
+    body: JSON.stringify(payload),
+  })
+}
+
+export async function testTushareConfig(token?: string) {
+  return jsonFetch<{ success: boolean; data: { ok: boolean; message: string }; message?: string }>('/tushare/test', {
+    method: 'POST',
+    headers: { 'Content-Type': 'application/json' },
+    body: JSON.stringify(token ? { token } : {}),
+  })
+}
+
 export async function writerTypes() {
   const resp = await fetchWithTimeout(`${API_BASE}/writer/types`)
   if (!resp.ok) throw new Error('writer types failed')

client-ui/src/chat/ChatApp.tsx

@@ -4,6 +4,7 @@ import SessionSidebar from './SessionSidebar'
 import ChatView from './ChatView'
 import SettingsPage from '../pages/SettingsPage'
 import RightPanel from './RightPanel'
+import type { StockDiscussPayload } from '../market/StockDecisionCard'
 import WorkspaceSplitDivider from './WorkspaceSplitDivider'
 import {
   listSessions, createSession, getSession, deleteSession, forkSession, clearSessionContext,
@@ -427,6 +428,35 @@ export default function ChatApp() {
     }
   }
 
+  const handleStockDiscuss = useCallback(async (payload: StockDiscussPayload) => {
+    if (!activeId) {
+      setError('请先新建或选择一个对话')
+      return
+    }
+    try {
+      const at = new Date().toISOString()
+      const nextRef: SessionSelectionContextRef = {
+        kind: 'selection',
+        selectedText: payload.contextText,
+        sourceMessageIndex: 0,
+        sourceRole: 'user',
+        anchorAt: at,
+        preview: `${payload.topic === 'buy' ? '研讨买入' : '研讨卖出'} · ${payload.name}`,
+        turns: [{
+          role: 'user',
+          content: payload.contextText,
+          at,
+        }],
+      }
+      const data = await setSessionContext(activeId, nextRef)
+      setContextRef(data.contextRef ?? nextRef)
+      setInput(payload.prompt)
+      setError('')
+    } catch (e) {
+      setError(e instanceof Error ? e.message : '设置研讨上下文失败')
+    }
+  }, [activeId])
+
   const handleEphemeralAsk = useCallback(async (
     message: string,
     selection: MessageSelection,
@@ -621,6 +651,7 @@ export default function ChatApp() {
                 chromeToolbarReserve={chromeToolbarReserve}
                 onToggleRightPanel={handleToggleRightPanel}
                 onToggleChatColumn={canToggleChatColumn ? handleToggleChatColumn : undefined}
+                onDiscussInChat={handleStockDiscuss}
               />
             )}
           </div>

client-ui/src/chat/RightPanel.tsx

@@ -6,6 +6,7 @@ import {
   WORKSPACE_RIGHT_PANEL_DEFAULT_WIDTH,
 } from '../desktop/constants'
 import RightMarketPanel from '../market/RightMarketPanel'
+import type { StockDiscussPayload } from '../market/StockDecisionCard'
 
 const useStyles = makeStyles({
   panelShell: {
@@ -51,6 +52,7 @@ interface Props {
   chromeToolbarReserve?: number
   onToggleRightPanel?: () => void
   onToggleChatColumn?: () => void
+  onDiscussInChat?: (payload: StockDiscussPayload) => void
 }
 
 export default function RightPanel({
@@ -63,6 +65,7 @@ export default function RightPanel({
   chromeToolbarReserve = 0,
   onToggleRightPanel,
   onToggleChatColumn,
+  onDiscussInChat,
 }: Props) {
   const s = useStyles()
 
@@ -95,6 +98,7 @@ export default function RightPanel({
           chromeToolbarReserve={chromeToolbarReserve}
           onToggleRightPanel={visible ? onToggleRightPanel : undefined}
           onToggleChatColumn={visible ? onToggleChatColumn : undefined}
+          onDiscussInChat={visible ? onDiscussInChat : undefined}
         />
       </aside>
     </div>