bundles/Jabber/GenericBundle/EventListener/PriceChangesLive.php line 29

Open in your IDE?
  1. <?php 
  3. namespace Jabber\GenericBundle\EventListener;
  5. use Jabber\GenericBundle\Messenger\TestMessenger;
  6. use Pimcore\Db;
  7. use Pimcore\Event\Model\ElementEventInterface;
  8. use Pimcore\Event\Model\DataObjectEvent;
  9. use Pimcore\Model\DataObject\Product;
  10. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  11. use Symfony\Component\Messenger\MessageBusInterface;
  13. class PriceChangesLive {
  15.     private $syncCompanyOne = false;
  17.     private $syncCompanyTwo = false;
  19.     /**
  20.      *
  21.      * @var ParameterBagInterface
  22.      */
  23.     private $params = null;
  25.     public function __construct(ParameterBagInterface $params, private MessageBusInterface $bus) {
  26.         $this->params = $params;
  27.     }
  29.     public function OnPostSave(ElementEventInterface $e) {
  30.         if (!$e->hasArgument('isAutoSave')) {
  31.             if ($e instanceof DataObjectEvent) {
  32.                 $dataObject = $e->getObject();
  33.                 if ($dataObject instanceof Product) {
  34.                     // if (!$this->IgnoredUser($dataObject->getUserModification())) {
  35.                         if ($dataObject->getProductLevel() == 'STYLE') {
  36.                             $this->checkForChanges($dataObject);
  38.                             if ($this->syncCompanyOne == true) {
  39.                                 $this->bus->dispatch(new TestMessenger($dataObject->getId(), 58));
  40.                             }
  41.                             if ($this->syncCompanyTwo == true) {
  42.                                 $this->bus->dispatch(new TestMessenger($dataObject->getId(), 65));
  43.                             }
  44.                         }
  45.                     // }
  46.                 }
  47.             }
  48.         }
  49.     }
  51.     private function checkForChanges(Product $dataObject) {
  52.         $storedRetail = Db::getConnection()->fetchAssociative('SELECT RetailPriceGBP, RetailPriceUSD FROM object_store_Product WHERE oo_id = ?', [$dataObject->getId()]);
  53.         $storedWebGb = Db::getConnection()->fetchAssociative('SELECT WebSellingPrice FROM object_localized_query_Product_en_GB WHERE ooo_id = ?', [$dataObject->getId()]);
  54.         $storedWebUs = Db::getConnection()->fetchAssociative('SELECT WebSellingPrice FROM object_localized_query_Product_en_US WHERE ooo_id = ?', [$dataObject->getId()]);
  55.         if ($storedRetail['RetailPriceGBP'] != $dataObject->getRetailPriceGBP()) {
  56.             $this->syncCompanyOne = true;
  57.         }
  58.         if ($storedRetail['RetailPriceUSD'] != $dataObject->getRetailPriceUSD()) {
  59.             $this->syncCompanyTwo = true;
  60.         }
  61.         if ($storedWebGb['WebSellingPrice'] != $dataObject->getWebSellingPrice('en_GB')) {
  62.             $this->syncCompanyOne = true;
  63.         }
  64.         if ($storedWebUs['WebSellingPrice'] != $dataObject->getWebSellingPrice('en_US')) {
  65.             $this->syncCompanyTwo = true;
  66.         }
  67.     }
  71.     // /**
  72.     //  * Is user in ignore list for price changes
  73.     //  *
  74.     //  * @param int $userId
  75.     //  * @return bool
  76.     //  */
  77.     // private function IgnoredUser($userId) {
  78.     //     $ignoredUsers = null;
  79.     //     $priceBundleParams = $this->params->get('jabber_price_bundle');
  80.     //     if (isset($priceBundleParams['ignored_users'])) {
  81.     //         $ignoredUsers = $priceBundleParams['ignored_users'];
  82.     //     }
  83.     //     if (is_array($ignoredUsers)) {
  84.     //         if (isset($ignoredUsers[$userId])) {
  85.     //             return true;
  86.     //         }
  87.     //     }
  88.     //     return false;
  89.     // }
  91.     
  92. }