money_flow
Analyze capital flow data for stocks, markets, and sectors to track fund movements by investor type and size.
Instructions
获取个股、大盘和板块资金流向数据，包括主力资金、超大单、大单、中单、小单的净流入净额和净占比数据
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| query_type | No | 查询类型：stock=个股，market=大盘，sector=板块。默认根据ts_code自动判断 | |
| ts_code | No | 股票代码或板块代码。个股如'000001.SZ'，板块如'BK0447'(东财板块代码)。不填写则查询大盘资金流向 | |
| start_date | Yes | 起始日期，格式为YYYYMMDD，如'20240901' | |
| end_date | Yes | 结束日期，格式为YYYYMMDD，如'20240930' | |
| content_type | No | 板块资金类型，仅在查询板块时有效。可选：行业、概念、地域 | |
| trade_date | No | 单独查询某个交易日的数据，格式为YYYYMMDD。如填写则忽略start_date和end_date |
Implementation Reference
- src/tools/moneyFlow.ts:36-128 (handler)Core handler function that executes the money_flow tool. Parses arguments, determines query type (stock/market/sector), fetches data from Tushare API using specialized functions, processes and formats the data into a markdown report with statistics, tables, and trends.async run(args: { query_type?: string; ts_code?: string; start_date: string; end_date: string; content_type?: string; trade_date?: string; }) { try { console.log('资金流向数据查询参数:', args); const TUSHARE_API_KEY = TUSHARE_CONFIG.API_TOKEN; const TUSHARE_API_URL = TUSHARE_CONFIG.API_URL; if (!TUSHARE_API_KEY) { throw new Error('请配置TUSHARE_TOKEN环境变量'); } // 判断查询类型 let queryType = args.query_type; if (!queryType) { // 自动判断：没有ts_code=大盘，有BK开头=板块，否则=个股 if (!args.ts_code || args.ts_code.trim() === '') { queryType = 'market'; } else if (args.ts_code.startsWith('BK')) { queryType = 'sector'; } else { queryType = 'stock'; } } let result; let targetName = ''; if (queryType === 'market') { // 查询大盘资金流向 targetName = '大盘'; result = await fetchMarketMoneyFlow( args.trade_date || args.start_date, args.trade_date || args.end_date, TUSHARE_API_KEY, TUSHARE_API_URL ); } else if (queryType === 'sector') { // 查询板块资金流向 targetName = `板块${args.ts_code || ''}`; result = await fetchSectorMoneyFlow( args.ts_code, args.trade_date, args.start_date, args.end_date, args.content_type, TUSHARE_API_KEY, TUSHARE_API_URL ); } else { // 查询个股资金流向 targetName = `股票${args.ts_code}`; result = await fetchStockMoneyFlow( args.ts_code!, args.trade_date || args.start_date, args.trade_date || args.end_date, TUSHARE_API_KEY, TUSHARE_API_URL ); } if (!result.data || result.data.length === 0) { throw new Error(`未找到${targetName}在指定时间范围内的资金流向数据`); } // 格式化输出 const formattedOutput = formatMoneyFlowData( result.data, result.fields, queryType, args.ts_code ); return { content: [{ type: "text", text: formattedOutput }] }; } catch (error) { console.error('资金流向数据查询错误:', error); return { content: [{ type: "text", text: `查询资金流向数据时发生错误: ${error instanceof Error ? error.message : '未知错误'}` }] }; } }
- src/tools/moneyFlow.ts:6-35 (schema)JSON Schema defining the input parameters for the money_flow tool, including query_type, ts_code, date ranges, etc.parameters: { type: "object", properties: { query_type: { type: "string", description: "查询类型：stock=个股，market=大盘，sector=板块。默认根据ts_code自动判断" }, ts_code: { type: "string", description: "股票代码或板块代码。个股如'000001.SZ'，板块如'BK0447'(东财板块代码)。不填写则查询大盘资金流向" }, start_date: { type: "string", description: "起始日期，格式为YYYYMMDD，如'20240901'" }, end_date: { type: "string", description: "结束日期，格式为YYYYMMDD，如'20240930'" }, content_type: { type: "string", description: "板块资金类型，仅在查询板块时有效。可选：行业、概念、地域" }, trade_date: { type: "string", description: "单独查询某个交易日的数据，格式为YYYYMMDD。如填写则忽略start_date和end_date" } }, required: ["start_date", "end_date"] },
- src/index.ts:225-227 (registration)Tool registration in the MCP server's ListToolsRequestSchema handler, adding money_flow to the list of available tools.name: moneyFlow.name, description: moneyFlow.description, inputSchema: moneyFlow.parameters
- src/index.ts:350-357 (registration)Dispatch logic in the MCP server's CallToolRequestSchema handler, parsing arguments and invoking the moneyFlow.run method.case "money_flow": { const query_type = request.params.arguments?.query_type ? String(request.params.arguments.query_type) : undefined; const ts_code = request.params.arguments?.ts_code ? String(request.params.arguments.ts_code) : undefined; const start_date = String(request.params.arguments?.start_date); const end_date = String(request.params.arguments?.end_date); const content_type = request.params.arguments?.content_type ? String(request.params.arguments.content_type) : undefined; const trade_date = request.params.arguments?.trade_date ? String(request.params.arguments.trade_date) : undefined; return normalizeResult(await moneyFlow.run({ query_type, ts_code, start_date, end_date, content_type, trade_date }));
- src/tools/moneyFlow.ts:208-260 (helper)Helper utility that makes authenticated POST requests to Tushare Pro API, handles timeouts, converts response data from arrays to keyed objects, and includes logging.async function callTushareAPI(params: any, apiUrl: string) { const controller = new AbortController(); const timeoutId = setTimeout(() => controller.abort(), TUSHARE_CONFIG.TIMEOUT); try { console.log(`请求Tushare API: ${params.api_name}，参数:`, params.params); const response = await fetch(apiUrl, { method: "POST", headers: { "Content-Type": "application/json" }, body: JSON.stringify(params), signal: controller.signal }); if (!response.ok) { throw new Error(`Tushare API请求失败: ${response.status}`); } const data = await response.json(); if (data.code !== 0) { throw new Error(`Tushare API错误: ${data.msg}`); } if (!data.data || !data.data.items) { throw new Error(`未找到资金流向数据`); } // 获取字段名 const fields = data.data.fields; // 将数据转换为对象数组 const convertedData = data.data.items.map((item: any) => { const result: Record<string, any> = {}; fields.forEach((field: string, index: number) => { result[field] = item[index]; }); return result; }); console.log(`成功获取到${convertedData.length}条资金流向数据记录`); return { data: convertedData, fields: fields }; } finally { clearTimeout(timeoutId); } }