src/EventListener/InvoiceBatchSubscriber.php line 108

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use App\Entity\InvoiceBatch;
  6. use App\Event\InvoiceBatchEvent;
  7. use App\Model\InvoiceBatchFactory;
  8. use App\Model\InvoiceFactory;
  9. use App\Model\InvoiceProcessor;
  10. use App\Service\SupplierConnectionService;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class InvoiceBatchSubscriber implements EventSubscriberInterface
  16. {
  17.     /**
  18.      * @var InvoiceFactory
  19.      */
  20.     private $invoiceFactory;
  22.     private $invoiceBatchFactory;
  24.     private $invoiceProcessor;
  26.     /** @var EventDispatcherInterface $eventDispatcher */
  27.     private $eventDispatcher;
  29.     /**
  30.      * @var EntityManagerInterface
  31.      */
  32.     private $entityManager;
  34.     /**
  35.      * @var SupplierConnectionService
  36.      */
  37.     private $supplierConnectionService;
  39.     public function __construct(
  40.         InvoiceFactory $invoiceFactory,
  41.         InvoiceBatchFactory $invoiceBatchFactory,
  42.         EntityManagerInterface $entityManager,
  43.         EventDispatcherInterface $eventDispatcher,
  44.         InvoiceProcessor $invoiceProcessor,
  45.         SupplierConnectionService $supplierConnectionService
  46.     ) {
  47.         $this->invoiceFactory = $invoiceFactory;
  48.         $this->invoiceBatchFactory = $invoiceBatchFactory;
  49.         $this->entityManager = $entityManager;
  50.         $this->eventDispatcher = $eventDispatcher;
  51.         $this->invoiceProcessor = $invoiceProcessor;
  52.         $this->supplierConnectionService = $supplierConnectionService;
  53.     }
  55.     public static function getSubscribedEvents(): array
  56.     {
  57.         return [
  58.             InvoiceBatchEvent::STATUS_REFRESH_EVENT => [ 'onInvoiceBatchStatusRefresh' ],
  59.             InvoiceBatchEvent::PROCESS_EVENT => [ 'onInvoiceBatchProcess' ]
  60.         ];
  61.     }
  63.     public function onInvoiceBatchStatusRefresh(InvoiceBatchEvent $event)
  64.     {
  65.         $invoiceBatchEntity = $event->getInvoiceBatch();
  66.         $cptPending = 0;
  67.         $cptProcessing = 0;
  68.         $cptProcessed = 0;
  69.         $invoiceEntities = $invoiceBatchEntity->getInvoices();
  70.         if ($invoiceEntities) {
  71.             foreach ($invoiceEntities as $invoiceEntity) {
  73.                 $invoice = $this->invoiceFactory->createModel($invoiceEntity);
  75.                 if ($invoice->isPending()) {
  76.                     $cptPending++;
  77.                 } elseif ($invoice->isProcessing()) {
  78.                     $cptProcessing++;
  79.                 } else {
  80.                     $cptProcessed++;
  81.                 }
  82.             }
  84.             if ($cptPending + $cptProcessing == 0) {
  85.                 $newStatus = InvoiceBatch::STATUS_PROCESSED;
  86.             } elseif ($cptPending === $invoiceBatchEntity->getInvoices()->count()) {
  87.                 $newStatus = InvoiceBatch::STATUS_PENDING;
  88.             } else {
  89.                 $newStatus = InvoiceBatch::STATUS_PROCESSING;
  90.             }
  92.             $invoiceBatchEntity->setStatus($newStatus);
  93.             $this->entityManager->flush();
  95.             $invoiceBatch = $this->invoiceBatchFactory->createModel($invoiceBatchEntity);
  96.             if ($invoiceBatch->isProcessed()) {
  98.                 $invoiceBatchEvent = new InvoiceBatchEvent($invoiceBatchEntity);
  99.                 $this->eventDispatcher->dispatch(
  100.                     $invoiceBatchEvent,
  101.                     InvoiceBatchEvent::PROCESS_EVENT
  102.                 );
  104.             }
  105.         }
  106.     }
  108.     public function onInvoiceBatchProcess(InvoiceBatchEvent $event)
  109.     {
  111.         $invoiceBatchEntity = $event->getInvoiceBatch();
  113.         foreach ($invoiceBatchEntity->getInvoices() as $invoiceEntity) {
  115.             $invoice = $this->invoiceFactory->createModel($invoiceEntity);
  117.             // On ne prend pas en compte les rejetées
  118.             if ($invoice->isProcessed()) {
  120.                 $this->invoiceProcessor->setInvoice($invoiceEntity);
  122.                 $supplierCustomer = $this->invoiceProcessor->getSupplierCustomer();
  123.                 $supplierCustomerNoTP = $this->supplierConnectionService->getSupplierCustomerNoTP();
  125.                 if (is_null($supplierCustomer->getId())) {
  126.                     $this->entityManager->persist($supplierCustomer);
  127.                 }
  129.                 if (! is_null($supplierCustomerNoTP)) {
  130.                     $this->entityManager->persist($supplierCustomerNoTP);
  131.                 }
  133.                 $this->entityManager->flush();
  134.             }
  136.             // Enable the products
  137.             if ($products = $invoiceEntity->getProducts()) {
  138.                 foreach ($products as $product) {
  140.                     $product->setEnabled(true);
  142.                     $this->entityManager->flush();
  143.                 }
  144.             }
  145.         }
  147.     }
  148. }