|
|
@@ -0,0 +1,31 @@
|
|
|
+login(`admin, `123456);
|
|
|
+
|
|
|
+use fundit::task_fundPerformance;
|
|
|
+use fundit::task_portfolioPerformance;
|
|
|
+
|
|
|
+
|
|
|
+/*
|
|
|
+ * 定时任务
|
|
|
+ *
|
|
|
+ * 查询任务运行； getRecentJobs()；
|
|
|
+ * 查询任务列表：getScheduledJobs('daily_%');
|
|
|
+ * 删除任务：deleteScheduledJob('daily_portfolio_bfi');
|
|
|
+ *
|
|
|
+ */
|
|
|
+
|
|
|
+// index and factor calculations go first
|
|
|
+scheduleJob('daily_market_index_performance', "Market Index return and indicator calculation", calFundPerformanceTask{'MI', now().temporalAdd(-3d)}, 22:00m, today(), today()+30, 'D');
|
|
|
+scheduleJob('daily_factor_performance', "Factor nav, return and indicator calculation", CalFactorPerformanceTask{now().temporalAdd(-3d)}, 23:00m, today(), today()+30, 'D');
|
|
|
+
|
|
|
+// standard return and indicator calculation
|
|
|
+scheduleJob('daily_fund_performance', "Mutual fund return and indicator calculation", calFundPerformanceTask{'MF', now().temporalAdd(-3d)}, 00:00m, today(), today()+30, 'D');
|
|
|
+scheduleJob('daily_portfolio_performance', "Portfolio nav, return and indicator calculation", CalPortfolioPerformanceTask{now().temporalAdd(-3d)}, 01:00m, today(), today()+30, 'D');
|
|
|
+
|
|
|
+// BFI MATCHING HERE
|
|
|
+scheduleJob('daily_BFI_fund_matching', "Mutual fund bfi matching", MatchEntityBFITask{'MF', now().temporalAdd(-3d)}, 01:30m, today(), today()+30, 'D');
|
|
|
+scheduleJob('daily_BFI_portfolio_matching', "Portfolio bfi matching", MatchEntityBFITask{'PF', now().temporalAdd(-3d)}, 06:00m, today(), today()+30, 'D');
|
|
|
+
|
|
|
+// BFI indicator calculation
|
|
|
+scheduleJob('daily_fund_bfi_indicator', "Mutual fund BFI indicator calculation", calEntityBfiIndicatorTask{'MF', now().temporalAdd(-3d)}, 07:00m, today(), today()+30, 'D');
|
|
|
+scheduleJob('daily_portfolio_bfi', "Portfolio BFI indicator calculation", calEntityBfiIndicatorTask{'PF', now().temporalAdd(-3d)}, 08:00m, today(), today()+30, 'D');
|
|
|
+
|
