src/EventListener/StripeTransferListener.php line 25

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use App\Services\Functions;
  6. use Pimcore\Event\Model\ElementEventInterface;
  7. use Pimcore\Event\Model\DataObjectEvent;
  8. use Pimcore\Log\ApplicationLogger;
  9. use Symfony\Component\Messenger\MessageBusInterface;
  10. use Carbon\Carbon;
  11. use Exception;
  12. use Pimcore\Model\DataObject;
  13. use Pimcore\Model\DataObject\StripeTransfer;
  14. use Stripe;
  16. class StripeTransferListener
  17. {
  19.     private $logger;
  20.     public function __construct(ApplicationLogger $logger)
  21.     {
  22.         $this->logger = $logger;
  23.     }
  25.     public function onPreUpdate(ElementEventInterface $e)
  26.     {
  28.         if ($e instanceof DataObjectEvent) {
  29.             $object = $e->getObject();
  32.             if ($object instanceof StripeTransfer) {
  33.                 if ($object->getPublished() && empty($object->getTransferId()) && $object->getAmount() > 0) {
  35.                     $stripe = new \Stripe\StripeClient($_ENV["STRIPE_SECRET"]);
  37.                     try {
  38.                         $result = $stripe->transfers->create([
  39.                             'amount' => $object->getAmount() * 100,
  40.                             'currency' => 'eur',
  41.                             'destination' => $object->getAccount()
  42.                         ]);
  43.                         $object->setKey($result->id);
  44.                         $object->setTransferId($result->id);
  45.                         $object->setTransferDate(Carbon::createFromTimestamp($result->created));
  46.                     } catch (Exception $e) {
  47.                         $this->logger->info($e->getMessage());
  48.                     }
  49.                 }
  50.             }
  51.         }
  52.     }
  53. }