From 111f2b8ae6b20faa009dd41308587372bb603ede Mon Sep 17 00:00:00 2001 From: Sean Date: Tue, 15 Apr 2025 21:11:04 -0400 Subject: [PATCH] Adding the monthly jobs --- MarketData/MarketData/Services/MainService.cs | 58 +++++++++++++++++++ README.md | 13 ++++- 2 files changed, 70 insertions(+), 1 deletion(-) diff --git a/MarketData/MarketData/Services/MainService.cs b/MarketData/MarketData/Services/MainService.cs index 3f1dbda..467a161 100755 --- a/MarketData/MarketData/Services/MainService.cs +++ b/MarketData/MarketData/Services/MainService.cs @@ -33,6 +33,9 @@ namespace MarketData.Services MDTrace.WriteLine(LogLevel.DEBUG,"UPDATECOMPANYPROFILES"); MDTrace.WriteLine(LogLevel.DEBUG,"UPDATEGDPPERCAPITA"); MDTrace.WriteLine(LogLevel.DEBUG,"UPDATEETFHOLDINGS"); + MDTrace.WriteLine(LogLevel.DEBUG,"UPDATEFINANCIALSTATEMENTS"); + MDTrace.WriteLine(LogLevel.DEBUG,"UPDATEFUNDAMENTALS"); + MDTrace.WriteLine(LogLevel.DEBUG,"UPDATEHISTORICAL"); MDTrace.WriteLine(LogLevel.DEBUG,"ECHO {param1} {param2} {param(n)"); MDTrace.WriteLine(LogLevel.DEBUG,"MGSHSESSION /SESSIONFILE:"); MDTrace.WriteLine(LogLevel.DEBUG,"MGSHRUNBACKTEST /USEHEDGING: /HEDGEINITIALCASH: /USESTOPLIMITS: /KEEPSLOTPOSITIONS: /STARTDATE: /MAXPOSITIONS: /INITIALCASH: /HOLDINGPERIOD: /{ENDDATE}: /SESSIONFILE: "); @@ -63,6 +66,9 @@ namespace MarketData.Services tasks.Add("UPDATECOMPANYPROFILES",TaskUpdateCompanyProfiles); tasks.Add("UPDATEGDPPERCAPITA",TaskUpdateGDPPerCapita); tasks.Add("UPDATEETFHOLDINGS",TaskUpdateETFHoldings); + tasks.Add("UPDATEFINANCIALSTATEMENTS",TaskUpdateFinancialStatements); + tasks.Add("UPDATEFUNDAMENTALS",TaskUpdateFundamentals); + tasks.Add("UPDATEHISTORICAL",TaskUpdateHistorical); tasks.Add("MGSHSESSION",TaskMGSHSession); tasks.Add("MGSHRUNBACKTEST",TaskMGSHRunBacktest); tasks.Add("MGSHRUNDAILY",TaskMGSHRunDaily); @@ -123,6 +129,33 @@ namespace MarketData.Services // ********************************************************************************************************************************************************** // ********************************************************* T A S K S ************************************************************************************* // ********************************************************************************************************************************************************** + public async Task TaskUpdateHistorical(CommandArgs commandArgs) + { + UpdateHistorical(); + await Task.FromResult(true); + } + + + public async Task TaskUpdateFundamentals(CommandArgs commandArgs) + { + UpdateFundamentalsFinViz(); + UpdateFundamentalsFinViz(); + UpdateFundamentalsFinViz(); + UpdateFundamentals(); + UpdateFundamentals(); + UpdateFundamentals(); + await Task.FromResult(true); + } + + public async Task TaskUpdateFinancialStatements(CommandArgs commandArgs) + { + UpdateFinancialStatements(); + UpdateFinancialStatements(); + UpdateFinancialStatements(); + UpdateFinancialStatements(); + await Task.FromResult(true); + } + public async Task TaskUpdateETFHoldings(CommandArgs commandArgs) { GetETFHoldings(); @@ -1025,6 +1058,31 @@ namespace MarketData.Services } } + public static void UpdateHistorical() + { + HistoricalMarketDataHelper historicalMarketDataHelper=new HistoricalMarketDataHelper(); + historicalMarketDataHelper.LoadHistorical(); + } + + public static void UpdateFundamentalsFinViz() + { + FundamentalMarketDataHelper fundamentalMarketDataHelper=new FundamentalMarketDataHelper(); + fundamentalMarketDataHelper.LoadFundamentalsFinViz(); + } + + public static void UpdateFundamentals() + { + FundamentalMarketDataHelper fundamentalMarketDataHelper=new FundamentalMarketDataHelper(); + fundamentalMarketDataHelper.LoadFundamentals(); + } + + public static void UpdateFinancialStatements() + { + FinancialStatementsMarketDataHelper financialStatementsMarketDataHelper=new FinancialStatementsMarketDataHelper(); + financialStatementsMarketDataHelper.LoadFinancialStatements(); + } + +// ******************************************************************************************************************************** public static bool CheckRunCriteria() { DateGenerator dateGenerator = new DateGenerator(); diff --git a/README.md b/README.md index 3e49916..a2f8cf2 100644 --- a/README.md +++ b/README.md @@ -94,7 +94,6 @@ CRON_DIR=/opt/MarketData/MarketData */30 9-16 * * 1-5 cd $CRON_DIR ; /opt/MarketData/MarketData/mk UPDATELATESTANALYSTRATINGS > /dev/null 2>&1 0 19 * * 1-5 cd $CRON_DIR ; /opt/MarketData/MarketData/mk UPDATEDAILY2 /DATE:$(date -d"-0 days" +\%m-\%d-\%Y) > /dev/null 2>&1 -Here is the latest crontab # m h dom mon dow command # sudo service cron reload , sudo service cron restart # cron helper app here -> https://cron.help/#*/5_9-17_*_*_1-5 @@ -107,3 +106,15 @@ CRON_DIR=/opt/MarketData/MarketData 0 19 * * 1-5 cd $CRON_DIR ; /opt/MarketData/MarketData/mk UPDATEDAILY2 /DATE:$(date -d"-0 days" +\%m-\%d-\%Y) > /dev/null 2>&1 +Here is the latest crontab. Adding the monthly jobs to run on the 17th + +DOTNET_ROOT=/opt/dotnet +CRON_DIR=/opt/MarketData/MarketData +*/15 6-16 * * 1-5 cd $CRON_DIR ; /opt/MarketData/MarketData/mk LOADHEADLINESWATCHLIST /WATCHLIST:Valuations > /dev/null 2>&1 +*/5 5-16 * * 1-5 cd $CRON_DIR ; /opt/MarketData/MarketData/mk LOADPREMARKETDATA > /dev/null 2>&1 +*/5 9-16 * * 1-5 cd $CRON_DIR ; /opt/MarketData/MarketData/mk UPDATEINTRADAYPRICING > /dev/null 2>&1 +*/30 9-16 * * 1-5 cd $CRON_DIR ; /opt/MarketData/MarketData/mk UPDATELATESTANALYSTRATINGS > /dev/null 2>&1 +0 19 * * 1-5 cd $CRON_DIR ; /opt/MarketData/MarketData/mk UPDATEDAILY2 /DATE:$(date -d"-0 days" +\%m-\%d-\%Y) > /dev/null 2>&1 +0 0 17 * * cd $CRON_DIR ; /opt/MarketData/MarketData/mk UPDATEFINANCIALSTATEMENTS > /dev/null 2>&1 +0 0 17 * * cd $CRON_DIR ; /opt/MarketData/MarketData/mk UPDATEFUNDAMENTALS > /dev/null 2>&1 +0 0 17 * * cd $CRON_DIR ; /opt/MarketData/MarketData/mk UPDATEHISTORICAL > /dev/null 2>&1