含外部现金流的复利收益计算及Python实现咨询

阿华AIGC实验室

2026-4-28

计算含外部现金流的时间序列累计价值（Python实现）

问题背景

你需要计算基金在存在外部现金流（申购/赎回）情况下的累计价值，核心逻辑是每一期的累计价值基于上期结果、当期现金流和月度回报率计算，示例数据集和期望输出已经明确了计算规则。

核心计算逻辑

先明确规则细节：

第一期无历史累计价值，直接计算：Desired Output = 当期cashflow × (1 + mtd_return)
后续每一期：Desired Output = (上期Desired Output + 当期cashflow) × (1 + mtd_return)
注：如果当期无现金流（示例中为空值），则cashflow按0处理

你提供的示例数据完全符合这个逻辑，比如第一期：15687713 × (1 - 0.0086) = 15552798.98，和期望输出一致；再比如2019年5月（第7行）：15954482.84 + 1000000 = 16954482.84，乘以(1+0.0006)得到16964655.53，和期望输出匹配。

Python实现方案

用pandas处理表格数据是最便捷的方式，下面是完整的实现代码，包含数据加载、计算和结果验证：

import pandas as pd

# 构建示例数据集（你也可以用pd.read_csv读取本地文件）
data = {
    "reportdate": ["30/11/2018", "31/12/2018", "31/01/2019", "28/02/2019", "31/03/2019",
                   "30/04/2019", "31/05/2019", "30/06/2019", "31/07/2019", "31/08/2019",
                   "30/09/2019", "31/10/2019", "30/11/2019", "31/12/2019", "31/01/2020",
                   "29/02/2020", "31/03/2020", "30/04/2020", "31/05/2020", "30/06/2020",
                   "31/07/2020", "31/08/2020", "30/09/2020", "31/10/2020", "30/11/2020",
                   "31/12/2020"],
    "fund": ["Fund X"]*26,
    "mtd_return": [-0.0086, -0.009, 0.0092, 0.0063, 0.007, 0.0122, 0.0006, 0.0057, 0.0045,
                   0.0021, 0.0053, 0.002, 0.0043, 0.0066, 0.0107, -0.0051, -0.107, 0.0274,
                   0.0218, 0.0227, 0.0112, 0.0126, 0.0075, 0.0041, 0.0279, 0.0123],
    "cashflow": [15687713, None, None, None, None, None, 1000000, 1200000, None, None,
                 None, None, None, None, None, None, None, 3400000, 2000000, None, None,
                 None, None, -8110576, None, None],
    "Desired Output": [15552798.98, 15412823.78, 15554621.76, 15652615.88, 15762184.19,
                       15954482.84, 16964655.53, 18268194.07, 18350400.94, 18388936.78,
                       18486398.15, 18523370.94, 18603021.44, 18725801.38, 18926167.45,
                       18829644.00, 16814872.09, 20768759.59, 23265118.55, 23793236.74,
                       24059720.99, 24362873.47, 24545595.02, 16502402.68, 16962819.72,
                       17171462.40]
}

df = pd.DataFrame(data)

# 处理空的现金流，替换为0
df["cashflow"] = df["cashflow"].fillna(0)

# 初始化计算列
df["calculated_output"] = 0.0
# 第一行单独计算（无历史数据）
df.loc[0, "calculated_output"] = df.loc[0, "cashflow"] * (1 + df.loc[0, "mtd_return"])

# 循环计算后续每一期的累计价值
for i in range(1, len(df)):
    prev_value = df.loc[i-1, "calculated_output"]
    current_cash = df.loc[i, "cashflow"]
    current_return = df.loc[i, "mtd_return"]
    df.loc[i, "calculated_output"] = (prev_value + current_cash) * (1 + current_return)

# 验证计算结果与期望输出的匹配度（保留两位小数后对比）
df["is_match"] = round(df["calculated_output"], 2) == round(df["Desired Output"], 2)

print("计算结果与期望输出对比：")
print(df[["reportdate", "calculated_output", "Desired Output", "is_match"]])