Commit 54e1004c authored by 赵杰's avatar 赵杰

修复数据库净值数据重复的bug,并添加去除不是交易日数据机制

parent e1a145c7
...@@ -120,7 +120,9 @@ class UserCustomerDataAdaptor: ...@@ -120,7 +120,9 @@ class UserCustomerDataAdaptor:
self.all_fund_performance[cur_fund_id] = cur_fund_performance_df self.all_fund_performance[cur_fund_id] = cur_fund_performance_df
cur_fund_nav_df["price_date"] = pd.to_datetime(cur_fund_nav_df["price_date"]) cur_fund_nav_df["price_date"] = pd.to_datetime(cur_fund_nav_df["price_date"])
cur_fund_nav_df.drop_duplicates(subset="price_date", keep='first', inplace=True)
cur_fund_nav_df.set_index("price_date", inplace=True) cur_fund_nav_df.set_index("price_date", inplace=True)
cur_fund_nav_df = cur_fund_nav_df[cur_fund_nav_df.index.isin(all_fund_nav.index & cur_fund_nav_df.index)]
all_fund_nav[cur_fund_id] = cur_fund_nav_df["nav"] all_fund_nav[cur_fund_id] = cur_fund_nav_df["nav"]
all_fund_cnav[cur_fund_id] = cur_fund_nav_df["cnav"] all_fund_cnav[cur_fund_id] = cur_fund_nav_df["cnav"]
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment