custom/plugins/IdeaBooks/src/Storefront/Subscriber/ProductSubscriber.php line 52

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace IdeaBooks\Storefront\Subscriber;
  5. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Shopware\Core\Framework\Struct\ArrayEntity;
  9. use \Mysqli;
  10. use GeoIp2\WebService\Client as GeoIp2Client;
  12. class ProductSubscriber implements EventSubscriberInterface
  13. {
  15.     public static function getSubscribedEvents(): array
  16.     {
  17.         return [
  18.           ProductPageLoadedEvent::class => 'addBuyFrom'
  19.         ];
  20.     }
  22.     private function OpenCon()
  23.      {
  24.         //DATABASE_URL="mysql://ideabooks.nl:i9cIbFBadWuxdwgb@localhost:3306/ideabooks_albertvanderveen_nl"
  25.         $databaseUrl = getenv('DATABASE_URL');
  26.         $databaseUrlParts = explode(':', $databaseUrl);
  28.         $dbuser = trim($databaseUrlParts[1],'/');
  29.         $dbpass = explode('@', $databaseUrlParts[2])[0];
  30.         $dbhost = explode('@', $databaseUrlParts[2])[1];
  31.         $db = explode('/', $databaseUrlParts[3])[1];
  33.          /*
  34.          $dbhost = "localhost";
  35.          $dbuser = "app";
  36.          $dbpass = "SAg8XKmloD8cjS2dCvneYFMnH70onxgr";
  37.          $db = "ideanew2";
  38.          */
  41.          $mysqli = new mysqli($dbhost, $dbuser, $dbpass,$db) or die("Connect failed: %s\n". $conn -> error);
  44.          return $mysqli;
  45.      }
  46.      
  47.     private function CloseCon($mysqli)
  48.      {
  49.          $mysqli -> close();
  50.      }
  52.      public function addBuyFrom(ProductPageLoadedEvent $event): void
  53.     {
  55.         /*
  56.         $request = $event->getRequest();
  57.         $contextToken = $request->headers->get(PlatformRequest::HEADER_CONTEXT_TOKEN);
  59.         if ($contextToken) {
  61.             $persistedParams = $this->contextPersister->load($contextToken);
  62.             $persistedCountryId = $persistedParams[SalesChannelContextService::COUNTRY_ID] ?? null;
  64.             dump($persistedCountryId);
  65.         }
  66.         */
  68.         //$country = $event->getPage()->getHeader()->activeShippingLocation->getCountry();
  69.         //dump($country);
  71.         //$isocode2 = $country->get('iso');
  72.         //$isocode2 = $_SERVER['GEOIP_CITY_COUNTRY_CODE'];
  74.         $mysqli = $this->OpenCon();
  76.         $ip = $_SERVER['REMOTE_ADDR'];
  78.         $query = "SELECT isocode2 FROM idea_ip WHERE ip = '".$ip."'";
  79.         if ($result = $mysqli->query($query)) {
  80.             if ($result->num_rows == 1){
  81.                 $row = mysqli_fetch_assoc($result);
  82.                 $isocode2 = $row['isocode2'];
  83.                 file_put_contents(getenv('APP_DIR') . '/var/log/ProductSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'isocode2 uit lokale tabel gehaald'.PHP_EOL, FILE_APPEND);
  84.             }
  85.             else {
  86.                 $client = new GeoIp2Client(448110, 'HnTnKEMimEMUwKN3');
  87.                 $record = $client->country($ip);
  88.                 $isocode2 = $record->country->isoCode;
  89.                 file_put_contents(getenv('APP_DIR') . '/var/log/ProductSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'isocode2 via GeoIp2Client'.PHP_EOL, FILE_APPEND);
  90.                 $query = "INSERT INTO idea_ip VALUES('" . $ip . "','" . $isocode2 . "')";
  91.                 file_put_contents(getenv('APP_DIR') . '/var/log/ProductSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'insert query ip/isocode2: '.$query.PHP_EOL, FILE_APPEND);
  92.                 if ($result = $mysqli->query($query)) {
  93.                     file_put_contents(getenv('APP_DIR') . '/var/log/ProductSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'ip/isocode2 toegevoegd aan lokale tabel'.PHP_EOL, FILE_APPEND);
  94.                 }
  95.             }
  96.         }
  97.         else $isocode2 = 'NL';//default als er iets misgaat
  100.         file_put_contents(getenv('APP_DIR') . '/var/log/ProductSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'ip: '.$_SERVER['REMOTE_ADDR'].PHP_EOL, FILE_APPEND);
  101.         file_put_contents(getenv('APP_DIR') . '/var/log/ProductSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'isocode2: '.$isocode2.PHP_EOL, FILE_APPEND);
  103.         $product = $event->getPage()->getProduct();
  104.         $titelnummer = trim($product->get('productNumber'), 'idea');//strip 'idea'
  105.         file_put_contents(getenv('APP_DIR') . '/var/log/ProductSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'titelnummer: idea'.$titelnummer.PHP_EOL, FILE_APPEND);
  106.         $isSaleable = $product->get('stock') > 0 && $product->get('available');
  107.         $addtocartUrl = '';
  109.         //dump($titelnummer);
  110.        //dump($isSaleable);
  112.         //idearegio ophalen
  113.         $idearegio = null;
  114.         $query = "SELECT idearegio FROM idea_land WHERE isocode2 = '".$isocode2."'";
  115.         file_put_contents(getenv('APP_DIR') . '/var/log/ProductSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'query idearegio: '.$query.PHP_EOL, FILE_APPEND);
  116.         if ($result = $mysqli->query($query)) {
  117.             //printf("Select returned %d rows.\n", $result->num_rows);
  118.             $row = mysqli_fetch_all($result, MYSQLI_ASSOC);
  119.             $idearegio = $row[0]['idearegio'];
  120.         }
  121.         file_put_contents(getenv('APP_DIR') . '/var/log/ProductSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'idearegio: '.$idearegio.PHP_EOL, FILE_APPEND);
  122.         //dump($idearegio);
  124.         //eerst in het land zelf zoeken:
  125.         //$titelboekhandelurl_collection_land = Mage::getModel('ideabooks/titelboekhandelurl')->getCollection()
  126.         //->addFieldToFilter('titelnummer', $titelnummer)->addFieldToFilter('isocode2', $isocode2);
  128.         $boekhandels = array();
  129.         $query = "SELECT url, naam, isocode3 FROM idea_titelboekhandelurl WHERE titelnummer = '".$titelnummer."' AND isocode2 = '".$isocode2."' LIMIT 30";
  130.         file_put_contents(getenv('APP_DIR') . '/var/log/ProductSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'query idea_titelboekhandelurl: '.$query.PHP_EOL, FILE_APPEND);
  131.         if ($result = $mysqli->query($query)) {
  132.             //printf("Select returned %d rows.\n", $result->num_rows);
  133.             //dump($result->num_rows);
  134.             $boekhandels = mysqli_fetch_all($result, MYSQLI_ASSOC);
  135.             //file_put_contents(getenv('APP_DIR') . '/var/log/ProductSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'boekhandels:'.print_r($boekhandels, true).PHP_EOL, FILE_APPEND);
  136.         }
  138.         //vervolgens in idearegio, maar met uitzondering van het land zelf (dat is immers al verwerkt)
  139.         /*
  140.         $titelboekhandelurl_collection_regio = Mage::getModel('ideabooks/titelboekhandelurl')->getCollection()
  141.         ->addFieldToFilter('titelnummer', $titelnummer)
  142.         ->addFieldToFilter('idearegio', $idearegio)
  143.         ->addFieldToFilter('isocode2', array('neq' => $isocode2));
  144.         */
  146.         if ($idearegio){
  147.             $query = "SELECT url, naam, isocode3 FROM idea_titelboekhandelurl WHERE titelnummer = '".$titelnummer."' AND isocode2 != '".$isocode2."' AND idearegio='".$idearegio."'";
  148.             if ($result = $mysqli->query($query)) {
  149.                 //printf("Select returned %d rows.\n", $result->num_rows);
  150.                 //$boekhandels = mysqli_fetch_all($result, MYSQLI_ASSOC);
  151.                 //dump($result->num_rows);
  152.                 $boekhandels = array_merge($boekhandels, mysqli_fetch_all($result, MYSQLI_ASSOC));
  153.                 //file_put_contents(getenv('APP_DIR') . '/var/log/ProductSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'boekhandels na merge:'.print_r($boekhandels, true).PHP_EOL, FILE_APPEND);
  154.             }
  155.         }
  157.         file_put_contents(getenv('APP_DIR') . '/var/log/ProductSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'boekhandels: '.print_r($boekhandels, true).PHP_EOL, FILE_APPEND);
  159.         $this->CloseCon($mysqli);
  161.         //dump($boekhandels);
  164.         $saleOptionAvailable = false;
  165.         $buyFrom = '';
  166.         //limiet nu anders oplossen: break uit foreach na 10 loops
  167.         $count = 0;
  168.         foreach ($boekhandels as $boekhandel) {
  169.             $saleOptionAvailable = true;
  170.             $boekhandelUrl = $boekhandel['url'];
  171.             if (stristr($boekhandelUrl, 'http') === false) $boekhandelUrl = 'http://'.$boekhandelUrl;
  172.             $buyFrom .= '<a href="'.$boekhandelUrl.'" onClick="ga(\'send\', \'event\', {
  173.   \'eventCategory\': \'Boekhandel links\',
  174.   \'eventAction\': \'click\',
  175.   \'eventLabel\': \''.$boekhandelUrl.'\',
  176.   \'hitCallback\': function() {
  177.     //alert(\'hit sent\');
  178.     //window.open(\''.$boekhandelUrl.'\',\'_blank\')
  179.     window.location.href = \''.$boekhandelUrl.'\'
  180.   }
  181. }); return false;">'.ucwords(strtolower($boekhandel['naam'])).'</a> ('.$boekhandel['isocode3'].')<br />';
  182.             $count++;
  183.             if ($count == 30) break;
  184.         }
  185.         //direct via Ideabooks - niet toevoegen, in template
  186.         /*if ($isSaleable){
  187.             $saleOptionAvailable = true;
  188.             $buyFrom .= '<a href="'.$addtocartUrl.'">Idea Books Direct</a>';
  189.         }*/
  190.         //if (!$saleOptionAvailable) $buyFrom .= '';
  191.         //$buyFrom = '<h3>Buy this title from:</h3>'.$buyFrom;
  193.         //dump($buyFrom);
  195.         /* debug van $event->getPage() geeft o.a. deze key:
  196.             #extensions: array:1 [▼
  197.                 "product_buyfrom" => Shopware\Core\Framework\Struct\ArrayEntity {#264113 ▼
  198.                     #data: array:1 [▼
  199.                         0 => "test.html"
  200.                     ]
  202.             de array data daarin is direct te benaderen, dus bijv via page.extensions.product_buyfrom.0: geeft string(9) "test.html"
  203.         */
  205.         $buyFromStruct = new ArrayEntity();
  206.         $buyFromStruct->set(0,$buyFrom);
  208.         $event->getPage()->addExtension('product_buyfrom', $buyFromStruct);
  210.         //dump($event);
  212.     }
  213. }