task_fundPerformance.dos 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270
  1. module fundit::task_fundPerformance
  2. use fundit::sqlUtilities;
  3. use fundit::operationDataPuller;
  4. use fundit::performanceDataPuller;
  5. use fundit::dataSaver;
  6. use fundit::returnCalculator;
  7. use fundit::indicatorCalculator;
  8. use fundit::ms_dataPuller;
  9. /*
  10. * [定时任务]:最新净值触发的业绩指标计算
  11. *
  12. * @param entityType <STRING>: 'MF', 'HF'...
  13. * @param date <DATETIME>: 净值更新时间, 为空时缺省为当前时间-1天;为1989.01.01或更早日期时代表初始化,指标会被存入本地数据库
  14. *
  15. * NOTE: 与Java不同的是当月indicator计算每日触发,不必等到Month-end production
  16. *
  17. * Example: calFundPerformanceTask('MF', 2024.10.28);
  18. * calFundPerformanceTask('MI', 2024.10.28);
  19. * calFundPerformanceTask('FI', 2024.10.28);
  20. * calFundPerformanceTask('MF', get_ini_data_const()['date']); -- 【初始化数据专用】(70min)
  21. */
  22. def calFundPerformanceTask(entityType, date) {
  23. rt = '';
  24. if(!(entityType IN ['MF', 'HF', 'MI', 'FI'])) return null;
  25. if(date.isNothing() || date.isNull())
  26. end_day = temporalAdd(now(), -1d);
  27. else
  28. end_day = date;
  29. // 取有最新净值变动的基金列表 (1s)
  30. tb_cal_funds = get_entity_list_by_nav_updatetime(entityType, NULL, end_day, true);
  31. if(tb_cal_funds.isVoid() || tb_cal_funds.size() == 0 ) return;
  32. // 按照 MySQL 建好各表
  33. tb_fund_performance = create_entity_performance();
  34. tb_fund_indicator = create_entity_indicator();
  35. tb_fund_risk_stats = create_entity_risk_stats();
  36. tb_fund_riskadjret_stats = create_entity_riskadjret_stats();
  37. tb_fund_style_stats = create_entity_style_stats();
  38. tb_fund_performance_weekly = create_entity_performance_weekly();
  39. tb_fund_latest_performance = create_entity_latest_performance();
  40. // 分批跑
  41. i = 0;
  42. batch_size = 1000;
  43. do {
  44. funds = tb_cal_funds[i : min(tb_cal_funds.size(), i+batch_size)];
  45. if(funds.isVoid() || funds.size() == 0) break;
  46. // 200ms
  47. fund_info = SELECT entity_id, price_date, inception_date, benchmark_id, ini_value
  48. FROM ej(funds, get_entity_info(entityType, funds.entity_id), 'entity_id');
  49. // 计算月收益 (12s)
  50. rets = mix_monthly_returns(entityType, fund_info);
  51. if(!rets.isVoid() && rets.size() > 0) {
  52. // 计算月度指标 (56s)
  53. rets.rename!('cumulative_nav', 'nav');
  54. indicators = cal_monthly_indicators(entityType, 'PBI', rets);
  55. // 仿照MySQL的表结构准备好记录 (1s)
  56. generate_entity_performance(fund_info, indicators, true, tb_fund_performance);
  57. generate_entity_indicator(fund_info, indicators, true, tb_fund_indicator);
  58. generate_entity_risk_stats(fund_info, indicators, true, tb_fund_risk_stats);
  59. generate_entity_riskadjret_stats(fund_info, indicators, true, tb_fund_riskadjret_stats);
  60. generate_entity_style_stats(fund_info, indicators, true, tb_fund_style_stats);
  61. }
  62. // 计算周收益 (8s)
  63. rets_w = cal_weekly_returns(entityType, fund_info);
  64. if(! rets_w.isVoid() && rets_w.size() > 0) {
  65. generate_entity_performance_weekly(fund_info, rets_w, true, tb_fund_performance_weekly);
  66. }
  67. // 计算最新收益 (69s)
  68. perf_latest = cal_latest_performance(entityType, fund_info, true);
  69. if(! perf_latest.isVoid() && perf_latest.size() > 0) {
  70. generate_entity_latest_performance(fund_info, perf_latest, true, tb_fund_latest_performance);
  71. }
  72. i += batch_size;
  73. // } while (i < batch_size);
  74. } while (i <= tb_cal_funds.size());
  75. if(! tb_fund_performance.isVoid() && tb_fund_performance.size() > 0) {
  76. // save data to MySQL (13s)
  77. try {
  78. chg_columns_for_mysql(tb_fund_performance, 'fund_id');
  79. save_and_sync(tb_fund_performance, 'raw_db.fund_performance', 'raw_db.fund_performance');
  80. chg_columns_for_mysql(tb_fund_indicator, 'fund_id');
  81. save_and_sync(tb_fund_indicator, 'raw_db.fund_indicator', 'raw_db.fund_indicator');
  82. chg_columns_for_mysql(tb_fund_risk_stats, 'fund_id');
  83. // mfdb.fund_performance 表中 maxdrawdown_6m & maxdrawdown_ytd 是虚拟列,这里用数据列顺序强行写入真实列 6m_maxdrawdown & ytd_maxdrawdown (DolphinDB 不允许字段名以数字开头)
  84. save_and_sync(tb_fund_risk_stats, 'raw_db.fund_risk_stats', 'raw_db.fund_risk_stats');
  85. chg_columns_for_mysql(tb_fund_riskadjret_stats, 'fund_id');
  86. save_and_sync(tb_fund_riskadjret_stats, 'raw_db.fund_riskadjret_stats', 'raw_db.fund_riskadjret_stats');
  87. chg_columns_for_mysql(tb_fund_style_stats, 'fund_id');
  88. save_and_sync(tb_fund_style_stats, 'raw_db.fund_style_stats', 'raw_db.fund_style_stats');
  89. save_and_sync(tb_fund_performance_weekly, 'raw_db.fund_performance_weekly', 'raw_db.fund_performance_weekly');
  90. save_and_sync(tb_fund_latest_performance, 'raw_db.fund_latest_performance', 'raw_db.fund_latest_nav_performance');
  91. // 数据初始化时将指标存入本地
  92. if(end_day <= get_ini_data_const['date']) {
  93. save_table(tb_fund_performance, 'mfdb.fund_performance', false);
  94. save_table(tb_fund_indicator, 'mfdb.fund_indicator', false);
  95. save_table(tb_fund_risk_stats, 'mfdb.fund_risk_stats', false);
  96. save_table(tb_fund_riskadjret_stats, 'mfdb.fund_riskadjret_stats', false);
  97. save_table(tb_fund_style_stats, 'mfdb.fund_style_stats', false);
  98. save_table(tb_fund_performance_weekly, 'mfdb.fund_performance_weekly', false);
  99. save_table(tb_fund_latest_performance, 'mfdb.fund_latest_performance', false);
  100. }
  101. } catch(ex) {
  102. //TODO: Log errors
  103. rt = ex;
  104. }
  105. }
  106. return rt;
  107. }
  108. /*
  109. * 【临时】用于数据初始化:只计算收益
  110. *
  111. * @param entityType <STRING>: 'MF', 'HF'...
  112. * @param date <DATETIME>: 净值更新时间
  113. *
  114. */
  115. def ms_calFundReturns() {
  116. rt = '';
  117. very_old_date = 1990.01.01;
  118. // 取基金列表 (27s)
  119. tb_cal_funds = ms_get_fund_list_by_nav_updatetime(NULL, very_old_date);
  120. if(tb_cal_funds.isVoid() || tb_cal_funds.size() == 0 ) return;
  121. tb_fund_performance = create_entity_performance();
  122. tb_fund_indicator = create_entity_indicator();
  123. tb_fund_risk_stats = create_entity_risk_stats();
  124. tb_fund_riskadjret_stats = create_entity_riskadjret_stats();
  125. tb_fund_style_stats = create_entity_style_stats();
  126. tb_fund_performance_weekly = create_entity_performance_weekly();
  127. tb_fund_latest_performance = create_entity_latest_performance();
  128. // 分批跑
  129. i = 0;
  130. batch_size = 1000;
  131. do {
  132. funds = tb_cal_funds[i : min(tb_cal_funds.size(), i+batch_size)];
  133. if(funds.isVoid() || funds.size() == 0) break;
  134. // 200ms
  135. fund_info = SELECT entity_id, price_date, inception_date, benchmark_id, ini_value
  136. FROM ej(funds, ms_get_fund_info(funds.entity_id), 'entity_id', 'fund_id');
  137. // 计算月收益 (19s)
  138. tb_nav = ms_get_fund_monthly_nav(fund_info.entity_id);
  139. rets = cal_monthly_returns_by_nav(fund_info, tb_nav);
  140. if(!rets.isVoid() && rets.size() > 0) {
  141. // 计算月度指标 (67s)
  142. rets.rename!('cumulative_nav', 'nav');
  143. indicators = cal_monthly_indicators('MF', 'PBI', rets);
  144. // 仿照MySQL的表结构准备好记录 (1s)
  145. generate_entity_performance(fund_info, indicators, true, tb_fund_performance);
  146. generate_entity_indicator(fund_info, indicators, true, tb_fund_indicator);
  147. generate_entity_risk_stats(fund_info, indicators, true, tb_fund_risk_stats);
  148. generate_entity_riskadjret_stats(fund_info, indicators, true, tb_fund_riskadjret_stats);
  149. generate_entity_style_stats(fund_info, indicators, true, tb_fund_style_stats);
  150. }
  151. // 计算周收益 (49s)
  152. rets_w = cal_weekly_returns('MF', fund_info);
  153. if(! rets_w.isVoid() && rets_w.size() > 0) {
  154. generate_entity_performance_weekly(fund_info, rets_w, true, tb_fund_performance_weekly);
  155. }
  156. // 计算最新收益 (23s)
  157. perf_latest = cal_latest_performance('MF', fund_info, true);
  158. if(! perf_latest.isVoid() && perf_latest.size() > 0) {
  159. generate_entity_latest_performance(fund_info, perf_latest, true, tb_fund_latest_performance);
  160. }
  161. i += batch_size;
  162. // } while (i < batch_size);
  163. } while (i <= tb_cal_funds.size());
  164. if(! tb_fund_performance.isVoid() && tb_fund_performance.size() > 0) {
  165. // save data to MySQL (26m)
  166. try {
  167. chg_columns_for_mysql(tb_fund_performance, 'fund_id');
  168. save_and_sync(tb_fund_performance, 'raw_db.fund_performance', 'raw_db.fund_performance');
  169. chg_columns_for_mysql(tb_fund_indicator, 'fund_id');
  170. save_and_sync(tb_fund_indicator, 'raw_db.fund_indicator', 'raw_db.fund_indicator');
  171. chg_columns_for_mysql(tb_fund_risk_stats, 'fund_id');
  172. // mfdb.fund_performance 表中 maxdrawdown_6m & maxdrawdown_ytd 是虚拟列,这里用数据列顺序强行写入真实列 6m_maxdrawdown & ytd_maxdrawdown (DolphinDB 不允许字段名以数字开头)
  173. save_and_sync(tb_fund_risk_stats, 'raw_db.fund_risk_stats', 'raw_db.fund_risk_stats');
  174. chg_columns_for_mysql(tb_fund_riskadjret_stats, 'fund_id');
  175. save_and_sync(tb_fund_riskadjret_stats, 'raw_db.fund_riskadjret_stats', 'raw_db.fund_riskadjret_stats');
  176. chg_columns_for_mysql(tb_fund_style_stats, 'fund_id');
  177. save_and_sync(tb_fund_style_stats, 'raw_db.fund_style_stats', 'raw_db.fund_style_stats');
  178. save_and_sync(tb_fund_performance_weekly, 'raw_db.fund_performance_weekly', 'raw_db.fund_performance_weekly');
  179. save_and_sync(tb_fund_latest_performance, 'raw_db.fund_latest_performance', 'raw_db.fund_latest_nav_performance');
  180. } catch(ex) {
  181. //TODO: Log errors
  182. rt = ex;
  183. }
  184. }
  185. return rt;
  186. }