DolphinDB/codes/CalculationJobs.dos

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');