custom/plugins/IdeaBooks/src/Storefront/Subscriber/ExportSubscriber.php line 53

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace IdeaBooks\Storefront\Subscriber;
  5. use Shopware\Core\Content\ImportExport\Event\ImportExportBeforeExportRecordEvent;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Shopware\Core\Framework\Struct\ArrayEntity;
  9. use \Mysqli;
  11. class ExportSubscriber implements EventSubscriberInterface
  12. {
  14.     public static function getSubscribedEvents(): array
  15.     {
  16.         return [
  17.           ImportExportBeforeExportRecordEvent::class => 'convertTags'
  18.         ];
  19.     }
  23.     private function OpenCon()
  24.      {
  25.         //DATABASE_URL="mysql://ideabooks.nl:i9cIbFBadWuxdwgb@localhost:3306/ideabooks_albertvanderveen_nl"
  26.         $databaseUrl = getenv('DATABASE_URL');
  27.         $databaseUrlParts = explode(':', $databaseUrl);
  29.         $dbuser = trim($databaseUrlParts[1],'/');
  30.         $dbpass = explode('@', $databaseUrlParts[2])[0];
  31.         $dbhost = explode('@', $databaseUrlParts[2])[1];
  32.         $db = explode('/', $databaseUrlParts[3])[1];
  34.          /*
  35.          $dbhost = "localhost";
  36.          $dbuser = "app";
  37.          $dbpass = "SAg8XKmloD8cjS2dCvneYFMnH70onxgr";
  38.          $db = "ideanew2";
  39.          */
  42.          $mysqli = new mysqli($dbhost, $dbuser, $dbpass,$db) or die("Connect failed: %s\n". $conn -> error);
  45.          return $mysqli;
  46.      }
  47.      
  48.     private function CloseCon($mysqli)
  49.      {
  50.          $mysqli -> close();
  51.      }
  53.      public function convertTags(ImportExportBeforeExportRecordEvent $event): void
  54.     {
  56.         $record = $event->getRecord();
  58.         if ($record['status'] == 'notSet'){
  59.             $record = [];//in dit geval record niet exporteren, want niet bevestigde aanmelding
  60.         }
  61.         else {
  62.             //$record['tags'] = 'test';
  63.             $tags = explode(',', str_replace('|', ',', $record['tags']));
  64.             $tags = substr_replace($tags, '0x', 0, 0);//voeg '0x' toe aan ieder tag-id (is UUID)
  66.             $mysqli = $this->OpenCon();
  67.             $query = "SELECT name FROM tag WHERE id IN (" . implode(',', $tags) . ")";
  68.             file_put_contents(getenv('APP_DIR') . '/var/log/ExportSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'query tags: '.$query.PHP_EOL, FILE_APPEND);            
  69.             if ($result = $mysqli->query($query)) {
  70.                 $rows = mysqli_fetch_all($result, MYSQLI_ASSOC);
  71.                 file_put_contents(getenv('APP_DIR') . '/var/log/ExportSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'rows: '.print_r($rows, true).PHP_EOL, FILE_APPEND);
  72.                 $tagsConvertedArr = [];
  73.                 $country = '';
  74.                 foreach ($rows as $key => $row) {
  75.                     if (in_array($row['name'], ['Art', 'Photography', 'Design', 'Architecture'])) $tagsConvertedArr[] = $row['name'];
  76.                     else $country = $row['name'];
  77.                 }
  78.                 $record['country'] = $country;
  79.                 $record['newsletterCategories'] = implode('|', $tagsConvertedArr);
  80.             }
  81.             else {
  82.                 $record['country'] = '';//deze twee altijd setten, zodat de col in shopware/core/Content/ImportExport/Processing/Writer/CsvFileWriter.php wordt geset in de header, als $index === 0
  83.                 $record['newsletterCategories'] = '';
  84.             }
  86.             unset($record['tags']);//unsetten, want verspreid over $record['country'] en $record['newsletterCategories']
  87.             //deze ook unsetten, want niet van belang:
  88.             unset($record['id']);
  89.             unset($record['salutation']);
  90.             unset($record['title']);
  91.             unset($record['hash']);
  92.             unset($record['sales_channel_id']);
  93.             unset($record['salesChannelId']);
  95.             $this->CloseCon($mysqli);
  96.         }
  98.         $event->setRecord($record);
  99.         file_put_contents(getenv('APP_DIR') . '/var/log/ExportSubscriber.log', PHP_EOL.date("Y-m-d H:i:s").chr(9).'record: '.print_r($record, true).PHP_EOL, FILE_APPEND);
  101.     }
  102. }