src/EventSubscriber/Finance/Bill/TransportBillDrafter.php line 27

  1. <?php
  3. namespace App\EventSubscriber\Finance\Bill;
  5. use App\Doctrine\Type\Expediting\ShipmentType;
  6. use App\Doctrine\Type\Finance\BillType;
  7. use App\Doctrine\Type\Finance\PayableStatus;
  8. use App\Event\Expediting\ShipmentStatusUpdateEvent;
  9. use DateTime;
  10. use Doctrine\DBAL\Exception;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. readonly class TransportBillDrafter implements EventSubscriberInterface
  15. {
  16.     public function __construct(
  17.         private EntityManagerInterface $entityManager,
  18.     ) {}
  20.     public static function getSubscribedEvents(): array
  21.     {
  22.         return [
  23.             ShipmentStatusUpdateEvent::IDENTIFIER => ['process', -100],
  24.         ];
  25.     }
  27.     public function process(ShipmentStatusUpdateEvent $event): void
  28.     {
  29.         $segment = $event->getShippingSegment();
  30.         $shippingPlan = $segment->getShippingPlan();
  31.         $workOrder = $shippingPlan->getWorkOrder();
  32.         if (null === $workOrder || !in_array(ShipmentType::PICKUP, $segment->getTypes())) {
  33.             return;
  34.         }
  36.         $quotation = null;
  37.         $quotations = $shippingPlan->getQuotations();
  38.         foreach ($quotations as $entity) {
  39.             if (PayableStatus::ACCEPTED !== $entity->getStatus()) {
  40.                 continue;
  41.             }
  43.             $quotation = $entity;
  44.         }
  46.         if (null === $quotation) {
  47.             return;
  48.         }
  50.         try {
  51.             $this->entityManager->getConnection()->executeStatement(
  52.                 'UPDATE finance_bill SET type = :type WHERE payable_to = :agentId AND shipping_plan_id = :planId',
  53.                 [
  54.                     'type' => BillType::BILL->value,
  55.                     'planId' => $shippingPlan->getId(),
  56.                     'agentId' => $quotation->getPayableTo()->getId(),
  57.                 ],
  58.             );
  60.             $quotation->setDueOn(new DateTime());
  61.             $quotation->setStatus(PayableStatus::QUOTED);
  62.             $this->entityManager->persist($quotation);
  63.             $this->entityManager->flush();
  64.             $this->entityManager->clear();
  66.         } catch (Exception $e) {
  67.             dd($e->$e->getMessage());
  68.         }
  69.     }
  70. }