|
@@ -178,7 +178,7 @@ def calFundPerformanceTask(entityType, date) {
|
|
|
|
|
|
save_and_sync(tb_fund_performance_weekly, 'raw_db.fund_performance_weekly', 'raw_db.fund_performance_weekly', 'fund_id', 'year_week');
|
|
save_and_sync(tb_fund_performance_weekly, 'raw_db.fund_performance_weekly', 'raw_db.fund_performance_weekly', 'fund_id', 'year_week');
|
|
|
|
|
|
- save_and_sync(tb_fund_latest_performance, 'raw_db.fund_latest_performance', 'raw_db.fund_latest_nav_performance', 'fund_id', 'price_date');
|
|
|
|
|
|
+ save_and_sync(tb_fund_latest_performance, 'raw_db.fund_latest_performance', 'raw_db.fund_latest_nav_performance', 'fund_id', 'end_date');
|
|
|
|
|
|
// 数据初始化时将指标存入本地
|
|
// 数据初始化时将指标存入本地
|
|
if(end_day <= get_ini_data_const()['date']) {
|
|
if(end_day <= get_ini_data_const()['date']) {
|
|
@@ -378,7 +378,7 @@ def ms_calFundReturns() {
|
|
|
|
|
|
save_and_sync(tb_fund_performance_weekly, 'raw_db.fund_performance_weekly', 'raw_db.fund_performance_weekly', 'fund_id', 'year_week');
|
|
save_and_sync(tb_fund_performance_weekly, 'raw_db.fund_performance_weekly', 'raw_db.fund_performance_weekly', 'fund_id', 'year_week');
|
|
|
|
|
|
- save_and_sync(tb_fund_latest_performance, 'raw_db.fund_latest_performance', 'raw_db.fund_latest_nav_performance', 'fund_id', 'price_date');
|
|
|
|
|
|
+ save_and_sync(tb_fund_latest_performance, 'raw_db.fund_latest_performance', 'raw_db.fund_latest_nav_performance', 'fund_id', 'end_date');
|
|
|
|
|
|
} catch(ex) {
|
|
} catch(ex) {
|
|
|
|
|