diff --git a/internal/services/odds/service.go b/internal/services/odds/service.go index 53629c7..fcbabb3 100644 --- a/internal/services/odds/service.go +++ b/internal/services/odds/service.go @@ -80,7 +80,7 @@ func (s *ServiceImpl) FetchNonLiveOdds(ctx context.Context) error { func (s *ServiceImpl) ProcessBet365Odds(ctx context.Context) error { eventIDs, _, err := s.eventSvc.GetAllEvents(ctx, domain.EventFilter{ - FirstStartTime: domain.ValidTime{ + LastStartTime: domain.ValidTime{ Value: time.Now(), Valid: true, }, diff --git a/internal/services/result/service.go b/internal/services/result/service.go index 4f53a19..e92adc6 100644 --- a/internal/services/result/service.go +++ b/internal/services/result/service.go @@ -228,7 +228,7 @@ func (s *Service) FetchB365ResultAndUpdateBets(ctx context.Context) error { // TODO: Optimize this because there could be many bet outcomes for the same odd // Take market id and match result as param and update all the bet outcomes at the same time events, _, err := s.repo.GetAllEvents(ctx, domain.EventFilter{ - FirstStartTime: domain.ValidTime{ + LastStartTime: domain.ValidTime{ Value: time.Now(), Valid: true, }, @@ -725,7 +725,7 @@ func (s *Service) SendAdminResultStatusErrorNotification( func (s *Service) CheckAndUpdateExpiredB365Events(ctx context.Context) (int64, error) { events, _, err := s.repo.GetAllEvents(ctx, domain.EventFilter{ - FirstStartTime: domain.ValidTime{ + LastStartTime: domain.ValidTime{ Value: time.Now(), Valid: true, },