fix repo methods

Author: michalkaczmarek-bitbag

src/Entity/MollieSubscription.php

@@ -130,9 +130,18 @@ public function getMigratedAt(): ?\DateTime
         return $this->migratedAt;
     }
 
-    public function setMigratedAt(?\DateTime $migratedAt): void
+    public function setMigratedAt(?\DateTimeInterface $migratedAt): void
     {
-        $this->migratedAt = $migratedAt;
+        if ($migratedAt instanceof \DateTimeImmutable) {
+            $this->migratedAt = \DateTime::createFromImmutable($migratedAt);
+        } else {
+            $this->migratedAt = $migratedAt;
+        }
+    }
+
+    public function isMigrated(): bool
+    {
+        return null !== $this->migratedAt;
     }
 
     public function getLastOrder(): ?SyliusOrder

src/Entity/MollieSubscriptionInterface.php

@@ -84,7 +84,9 @@ public function setStartedAt(?\DateTime $startedAt = null): void;
 
     public function getMigratedAt(): ?\DateTime;
 
-    public function setMigratedAt(?\DateTime $migratedAt): void;
+    public function setMigratedAt(?\DateTimeInterface $migratedAt): void;
+
+    public function isMigrated(): bool;
 
     /** @return Collection<int, MollieSubscriptionScheduleInterface> */
     public function getSchedules(): Collection;

src/Repository/MollieSubscriptionRepository.php

@@ -71,6 +71,19 @@ public function findScheduledSubscriptions(): array
         return $qb->getQuery()->getResult();
     }
 
+    public function findScheduledSubscriptionsForMigration(): array
+    {
+        $qb = $this->createQueryBuilder('q');
+        $qb->andWhere('q.state IN (:states)');
+        $qb->setParameter('states', [MollieSubscriptionInterface::STATE_ACTIVE, MollieSubscriptionInterface::STATE_PROCESSING]);
+        $qb->leftJoin('q.schedules', 's');
+        $qb->andWhere('s.scheduledDate < :date');
+        $qb->setParameter('date', new \DateTime());
+        $qb->andWhere('s.fulfilledDate IS NULL');
+
+        return $qb->getQuery()->getResult();
+    }
+
     public function findProcessableSubscriptions(): array
     {
         $qb = $this->createQueryBuilder('q');
@@ -86,6 +99,8 @@ public function iterateToMigrate(int $batchSize): iterable
     {
         $qb = $this->createQueryBuilder('q');
         $qb->andWhere('q.migratedAt IS NULL');
+        $qb->andWhere('q.state != :paused');
+        $qb->setParameter('paused', MollieSubscriptionInterface::STATE_PAUSED);
         $qb->setMaxResults($batchSize);
 
         return $qb->getQuery()->toIterable();

src/Repository/MollieSubscriptionRepositoryInterface.php

@@ -30,6 +30,9 @@ public function findByPayment(PaymentInterface $payment): array;
     /** @return MollieSubscriptionInterface[] */
     public function findScheduledSubscriptions(): array;
 
+    /** @return MollieSubscriptionInterface[] */
+    public function findScheduledSubscriptionsForMigration(): array;
+
     /** @return MollieSubscriptionInterface[] */
     public function findProcessableSubscriptions(): array;