OroCRM\Bundle\MagentoBundle\ImportExport\Writer\NewsletterSubscriberInitialWriter::write()

Complexity

Conditions	5
Paths	4

Size

Total Lines	21
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function write(array $items)
    {
        parent::write($items);

        $count = count($items);
        if (!$count) {
            return;
        }
        // Save minimum originId received by initial sync for further filtering in case of failure
        $lastSubscriber = $items[$count - 1];
        $transport = $lastSubscriber->getChannel()->getTransport();
        if ($transport instanceof MagentoSoapTransport) {
            /** @var MagentoSoapTransport $transport */
            $transport = $this->databaseHelper->getEntityReference($transport);
            $syncedToId = $transport->getNewsletterSubscriberSyncedToId();
            if (!$syncedToId || $syncedToId > $lastSubscriber->getOriginId()) {
                $transport->setNewsletterSubscriberSyncedToId($lastSubscriber->getOriginId());
                $this->writer->write([$transport]);
            }
        }
    }
}