Yimaru/Yimaru-BackEnd
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

-

Browse Source
This commit is contained in:
Samuel Tariku 2025-10-15 16:57:22 +03:00
parent f8878cd8b3
commit 0875298792
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
internal/web_server/cron.go
View File

@ -80,23 +80,23 @@ func StartDataFetchingCrons(eventService eventsvc.Service, oddsService oddssvc.S
} }
}, },
}, },
{ // {
spec: "0 0 0 * * 1", // Every Monday // spec: "0 0 0 * * 1", // Every Monday
task: func() { // task: func() {
mongoLogger.Info("Began Send weekly result notification cron task") // mongoLogger.Info("Began Send weekly result notification cron task")
if err := resultService.CheckAndSendResultNotifications(context.Background(), time.Now().Add(-7*24*time.Hour)); err != nil { // if err := resultService.CheckAndSendResultNotifications(context.Background(), time.Now().Add(-7*24*time.Hour)); err != nil {
mongoLogger.Error("Failed to process result", // mongoLogger.Error("Failed to process result",
zap.Error(err), // zap.Error(err),
) // )
} else { // } else {
mongoLogger.Info("Completed sending weekly result notification without errors") // mongoLogger.Info("Completed sending weekly result notification without errors")
} // }
}, // },
}, // },
} }
for _, job := range schedule { for _, job := range schedule {
// job.task() job.task()
if _, err := c.AddFunc(job.spec, job.task); err != nil { if _, err := c.AddFunc(job.spec, job.task); err != nil {
mongoLogger.Error("Failed to schedule data fetching cron job", mongoLogger.Error("Failed to schedule data fetching cron job",
zap.Error(err), zap.Error(err),