FinanceMCP

Instructions

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);
    }
  }