当前位置：首页 > news >正文

实时估值服务

news 2026/3/26 21:08:56

一、盈米且慢 MCP 平台方案（推荐）

1.1 平台介绍与优势

盈米且慢 MCP 是目前唯一仍提供实时估值服务的合规平台，它提供了 78 个专业金融工具接口，包括 46 个金融数据接口、11 个投研服务接口等。作为证监会首批持牌基金投顾平台，盈米且慢 MCP 的实时估值基于基金公司披露的持仓及第三方合规数据源，模型经投顾团队优化，估值偏差率低于 0.12%

。

更重要的是，盈米且慢 MCP 还提供了个人持仓查询功能

，你可以通过 API 接口获取个人在各平台的基金持仓信息，真正实现 "一站式" 数据查询。

1.2 技术架构设计

基于盈米且慢 MCP 的技术方案包含以下核心模块：

数据获取层：

通过 MCP API 获取个人基金持仓数据

获取单只或多只基金的实时估值数据

支持批量查询，提高效率

数据处理层：

计算实时涨幅：(实时估值 - 上日净值)/ 上日净值 ×100%

计算持仓市值和浮动盈亏

数据格式化和异常处理

展示层：

终端实时显示基金信息

支持定时刷新（默认 3 分钟）

清晰展示核心数据指标
1.3 完整代码实现
首先需要申请 MCP API Key。访问盈米且慢 MCP 官网免费申请 API Key
28
，申请通过后即可开始使用。

  1 import requests
  2 import json
  3 import time
  4 import pandas as pd
  5 from datetime import datetime
  6 
  7 # 配置区
  8 API_KEY = "your_api_key_here"  # 替换为你的API Key
  9 MCP_SERVER_URL = "https://api.yingmi.cn/mcp"  # MCP服务器地址
 10 
 11 def get_portfolio_data(user_id):
 12     """获取个人持仓数据"""
 13     endpoint = f"{MCP_SERVER_URL}/user/portfolio"
 14     headers = {"Authorization": f"Bearer {API_KEY}"}
 15     params = {"user_id": user_id}
 16     
 17     try:
 18         response = requests.get(endpoint, headers=headers, params=params, timeout=10)
 19         response.raise_for_status()
 20         return response.json()
 21     except requests.exceptions.RequestException as e:
 22         print(f"获取持仓数据失败: {e}")
 23         return None
 24 
 25 def get_fund_realtime_valuation(fund_code):
 26     """获取单只基金的实时估值数据"""
 27     endpoint = f"{MCP_SERVER_URL}/fund/valuation"
 28     headers = {"Authorization": f"Bearer {API_KEY}"}
 29     params = {"fund_code": fund_code}
 30     
 31     try:
 32         response = requests.get(endpoint, headers=headers, params=params, timeout=10)
 33         response.raise_for_status()
 34         return response.json()
 35     except requests.exceptions.RequestException as e:
 36         print(f"获取基金{fund_code}实时估值失败: {e}")
 37         return None
 38 
 39 def batch_get_fund_values(fund_codes):
 40     """批量获取多只基金的实时估值数据"""
 41     results = []
 42     for code in fund_codes:
 43         data = get_fund_realtime_valuation(code)
 44         if data:
 45             results.append({
 46                 "基金代码": code,
 47                 "基金名称": data.get("fund_name", "未知"),
 48                 "上日净值": data.get("yesterday_nav", 0),
 49                 "实时估值": data.get("current_nav", 0),
 50                 "更新时间": data.get("update_time", "N/A")
 51             })
 52     return pd.DataFrame(results)
 53 
 54 def calculate_gains(df):
 55     """计算实时涨幅和持仓价值"""
 56     df['实时涨幅(%)'] = ((df['实时估值'] - df['上日净值']) / df['上日净值'] * 100).round(2)
 57     return df
 58 
 59 def main():
 60     # 假设你的用户ID是123456，需要替换为真实的用户ID
 61     user_id = "123456"
 62     
 63     # 获取个人持仓
 64     portfolio = get_portfolio_data(user_id)
 65     if not portfolio:
 66         print("无法获取个人持仓数据")
 67         return
 68     
 69     # 提取基金代码列表
 70     fund_codes = [item["fund_code"] for item in portfolio["positions"]]
 71     
 72     while True:
 73         # 批量获取实时估值
 74         fund_values = batch_get_fund_values(fund_codes)
 75         
 76         if not fund_values.empty:
 77             # 计算涨幅
 78             fund_values = calculate_gains(fund_values)
 79             
 80             # 打印结果
 81             print("=" * 80)
 82             print(f"个人基金实时估值查询结果 - {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
 83             print("=" * 80)
 84             
 85             # 按涨幅排序
 86             fund_values_sorted = fund_values.sort_values('实时涨幅(%)', ascending=False)
 87             
 88             for _, fund in fund_values_sorted.iterrows():
 89                 status = "📈 盈利" if fund['实时涨幅(%)'] > 0 else "📉 亏损"
 90                 print(f"\n基金代码: {fund['基金代码']}")
 91                 print(f"基金名称: {fund['基金名称']}")
 92                 print(f"上日净值: {fund['上日净值']:.4f}")
 93                 print(f"实时估值: {fund['实时估值']:.4f}")
 94                 print(f"实时涨幅: {fund['实时涨幅(%)']:+.2f}% ({status})")
 95                 print(f"更新时间: {fund['更新时间']}")
 96             
 97             # 计算总体情况
 98             total_gain = fund_values['实时涨幅(%)'].mean()
 99             print(f"\n平均涨幅: {total_gain:+.2f}%")
100         
101         # 每3分钟刷新一次
102         print("\n" + "=" * 80)
103         print("等待3分钟后刷新...")
104         time.sleep(180)
105 
106 if __name__ == "__main__":
107     main()