bundles/ExportBundle/EventListener/TboneListener.php line 44

Open in your IDE?
  1. <?php 
  3. namespace ExportBundle\EventListener;
  5. use ExportBundle\Util\XML\TboneBuilder;
  6. use GuzzleHttp\Client;
  7. use Pimcore\Event\Model\DataObjectEvent;
  8. use Pimcore\Event\Model\ElementEventInterface;
  9. use Pimcore\Model\DataObject\Product;
  10. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  12. class TboneListener {
  14.     /**
  15.      * Symfony parameters
  16.      *
  17.      * @var ParameterBagInterface
  18.      */
  19.     private $params;
  21.     public function __construct(ParameterBagInterface $params) {
  22.         $this->params = $params;
  23.     }
  25.     private function ServiceEnabled() {
  26.         if ($this->params->get('tbone')['save_event'] ?? false) {
  27.             return true;
  28.         }
  29.         return false;
  30.     }
  32.     private function isTboneObject($dataObject) {
  33.         if (isset($this->params->get('tbone')['object_id'])) {
  34.             foreach ($dataObject->getListingRelation() as $listingRelation) {
  35.                 if ($listingRelation->getId() == $this->params->get('tbone')['object_id']) {
  36.                     return true;
  37.                 }
  38.             }
  39.         }
  40.         return false;
  41.     }
  42.     
  44.     public function onObjectSave(ElementEventInterface $e) {
  45.         if ($this->ServiceEnabled()) {
  46.             if($e instanceof DataObjectEvent) {
  47.                 
  48.                 if (!$e->hasArgument('isAutoSave')) {
  49.                     $dataObject = $e->getObject();
  50.                     if ($dataObject instanceof Product) {
  51.                         $exportObject = false;
  52.                         switch ($dataObject->getProductLevel()) {
  53.                             case 'CHILD': 
  54.                                 $dataObject = $dataObject->getParent();
  55.                             case 'STYLE': 
  56.                                 $exportObject = $this->isTboneObject($dataObject);
  57.                                 $dataObject = $dataObject->getParent();
  58.                                 break;
  59.                             default: 
  60.                                 $exportObject = $this->isTboneObject($dataObject);
  61.                         }
  62.                         if ($exportObject == true) {
  63.                             $builder = new TboneBuilder($this->params->get('tbone')['object_id']);
  64.                             $xml = $builder->CreateXML([$dataObject]);
  65.                             $this->SendFile($xml);
  66.                         }
  67.                     }
  68.                 }
  69.             }
  70.         }
  71.     }
  73.     private function SendFile($data) {
  74.         $client = new Client([
  75.             'base_uri'=>$this->params->get('tbone')['api']['uri']
  76.         ]);
  77.         
  78.         $response = $client->request(
  79.             'POST',
  80.             $this->params->get('tbone')['merchant_id'] . "/sync/in/TBCAT_" . date("YmdHis") . ".xml",
  81.             [
  82.                 'auth' => [
  83.                     $this->params->get('tbone')['api']['user'], 
  84.                     $this->params->get('tbone')['api']['password']
  85.                 ],
  86.                 'body'=>$data
  87.             ]
  88.         );
  89.     }
  91. }