累积净值处理方式

app/service/data_service_v2_1.py

@@ -420,8 +420,8 @@ class UserCustomerDataAdaptor:
 
             # 根据确认净值日查看是否含有累积净值的数据，如果没有按照前后差值推算当天累积净值
             if pd.isnull(p_nav_df.loc[confirm_share_date, cur_fund_id]):
-                last_nav_data = p_nav_df[p_nav_df.index > confirm_share_date][cur_fund_id].dropna().head(1)
-                last_cnav_data = p_cnav_df[p_cnav_df.index > confirm_share_date][cur_fund_id].dropna().head(1)
+                last_nav_data = p_nav_df[p_nav_df.index < confirm_share_date][cur_fund_id].dropna().tail(1)
+                last_cnav_data = p_cnav_df[p_cnav_df.index < confirm_share_date][cur_fund_id].dropna().tail(1)
                 # 判断上个净值日和当前确认日之中是否存在分红日
                 """need add judge"""
 
@@ -583,8 +583,8 @@ class UserCustomerDataAdaptor:
 
             # 根据确认净值日查看是否含有累积净值的数据，如果没有按照前后差值推算当天累积净值
             if pd.isnull(p_nav_df.loc[confirm_share_date, cur_fund_id]):
-                last_nav_data = p_nav_df[p_nav_df.index > confirm_share_date][cur_fund_id].dropna().head(1)
-                last_cnav_data = p_cnav_df[p_cnav_df.index > confirm_share_date][cur_fund_id].dropna().head(1)
+                last_nav_data = p_nav_df[p_nav_df.index < confirm_share_date][cur_fund_id].dropna().tail(1)
+                last_cnav_data = p_cnav_df[p_cnav_df.index < confirm_share_date][cur_fund_id].dropna().tail(1)
                 # 判断上个净值日和当前确认日之中是否存在分红日
                 """need add judge"""