diff --git a/lib/Cron/Workers/SubscribersEngagementScore.php b/lib/Cron/Workers/SubscribersEngagementScore.php index 2898c83094..f65dce05ef 100644 --- a/lib/Cron/Workers/SubscribersEngagementScore.php +++ b/lib/Cron/Workers/SubscribersEngagementScore.php @@ -59,7 +59,7 @@ class SubscribersEngagementScore extends SimpleWorker { } private function recalculateSegments(): int { - $segments = $this->segmentsRepository->findByUpdatedScoreNotInLastMonth(self::BATCH_SIZE); + $segments = $this->segmentsRepository->findByUpdatedScoreNotInLastDay(self::BATCH_SIZE); foreach ($segments as $segment) { $this->statisticsOpensRepository->recalculateSegmentScore($segment); } diff --git a/lib/Segments/SegmentsRepository.php b/lib/Segments/SegmentsRepository.php index 19697ae67d..c8f6bfff21 100644 --- a/lib/Segments/SegmentsRepository.php +++ b/lib/Segments/SegmentsRepository.php @@ -185,8 +185,8 @@ class SegmentsRepository extends Repository { return $rows; } - public function findByUpdatedScoreNotInLastMonth(int $limit): array { - $dateTime = (new Carbon())->subMonths(1); + public function findByUpdatedScoreNotInLastDay(int $limit): array { + $dateTime = (new Carbon())->subDay(); return $this->entityManager->createQueryBuilder() ->select('s') ->from(SegmentEntity::class, 's')