app/Plugin/MailMagazine42/Event/MailMagazineHistoryFilePaginationSubscriber.php line 37

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of EC-CUBE
  5.  *
  6.  * Copyright(c) EC-CUBE CO.,LTD. All Rights Reserved.
  7.  *
  8.  * http://www.ec-cube.co.jp/
  9.  *
  10.  * For the full copyright and license information, please view the LICENSE
  11.  * file that was distributed with this source code.
  12.  */
  14. namespace Plugin\MailMagazine42\Event;
  16. use Knp\Component\Pager\Event\ItemsEvent;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Plugin\MailMagazine42\Service\MailMagazineService;
  20. class MailMagazineHistoryFilePaginationSubscriber implements EventSubscriberInterface
  21. {
  22.     /**
  23.      * @var MailMagazineService
  24.      */
  25.     protected MailMagazineService $mailMagazineService;
  27.     /**
  28.      * MailMagazineHistoryFilePaginationSubscriber constructor.
  29.      *
  30.      * @param MailMagazineService $mailMagazineService
  31.      */
  32.     public function __construct(MailMagazineService $mailMagazineService)
  33.     {
  34.         $this->mailMagazineService = $mailMagazineService;
  35.     }
  37.     public function items(ItemsEvent $event)
  38.     {
  39.         $mailMagazineDir = $this->mailMagazineService->getMailMagazineDir();
  40.         if (!is_string($event->target) || strpos($event->target, $mailMagazineDir) !== 0) {
  41.             return;
  42.         }
  44.         $event->stopPropagation();
  45.         $file = $event->target;
  46.         if (!file_exists($file)) {
  47.             $event->count = 0;
  48.             $event->items = [];
  50.             return;
  51.         }
  53.         $skip = $event->getOffset();
  54.         $fp = fopen($file, 'r');
  55.         $count = $event->getLimit();
  56.         $total = 0;
  58.         $event->items = [];
  59.         while ($line = fgets($fp)) {
  60.             $total++;
  61.             if ($skip-- > 0) {
  62.                 continue;
  63.             }
  64.             if ($count > 0) {
  65.                 list($status, $customerId, $email, $name) = explode(',', str_replace(PHP_EOL, '', $line), 4);
  66.                 $event->items[] = [
  67.                     'status' => $status,
  68.                     'customerId' => $customerId,
  69.                     'email' => $email,
  70.                     'name' => $name,
  71.                 ];
  72.             }
  73.             --$count;
  74.         }
  75.         $event->count = $total;
  76.     }
  78.     public static function getSubscribedEvents()
  79.     {
  80.         return [
  81.             'knp_pager.items' => ['items', 1],
  82.         ];
  83.     }
  84. }