custom/plugins/SteincoProducts/src/Subscriber/CustomerEventsSubscriber.php line 65

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Schoettler\SteincoProducts\Subscriber;
  5. use Schoettler\SteincoProducts\SharedFunctions;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Shopware\Core\Checkout\Customer\Event\CustomerRegisterEvent;
  8. use Shopware\Core\Checkout\Customer\CustomerEvents;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  11. use Shopware\Core\System\SystemConfig\SystemConfigService;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityPreWriteEvent;
  17. class CustomerEventsSubscriber implements EventSubscriberInterface
  18. {
  19.     public static function getSubscribedEvents(): array
  20.     {
  21.         // Return the events to listen to as array like this:  <event to listen to> => <method to execute>
  22.         return [
  23.             CustomerEvents::CUSTOMER_REGISTER_EVENT => 'onCustomerRegistered',
  24.             CustomerEvents::CUSTOMER_WRITTEN_EVENT => 'onCustomerWritten',
  25.             CustomerEvents::CUSTOMER_DELETED_EVENT => 'onCustomerDeleted'
  26.             /* 
  27.             CustomerEvents::CUSTOMER_ADDRESS_WRITTEN_EVENT => 'onCustomerAddressWritten',
  28.             CustomerEvents::CUSTOMER_ADDRESS_DELETED_EVENT => 'onCustomerAddressDeleted',
  29.             */
  30.         ];
  31.     }
  33.     private $systemConfigService;
  34.     private $customerRepository;
  35.     private $addressRepository;
  36.     private $countryRepository;
  37.     private $stateRepository;
  38.     private $languageRepository;
  41.     public function __construct(
  42.         SystemConfigService $systemConfigService,
  43.         EntityRepository $customerRepository,
  44.         EntityRepository $addressRepository,
  45.         EntityRepository $countryRepository,
  46.         EntityRepository $stateRepository,
  47.         EntityRepository $languageRepository
  48.     )
  49.     {
  50.         $this->systemConfigService = $systemConfigService;
  51.         $this->customerRepository = $customerRepository;
  52.         $this->addressRepository = $addressRepository;
  53.         $this->countryRepository = $countryRepository;
  54.         $this->stateRepository = $stateRepository;
  55.         $this->languageRepository = $languageRepository;
  56.     }
  58.     public function onCustomerRegistered(CustomerRegisterEvent $event): void
  59.     {
  60.         $customerId = $event->getPayLoads()[0]['id'];
  61.         $this->registerInExternalDatabase($customerId, 0);
  62.         $this->adjustSalesChannel($customerId);
  63.     }
  65.     public function onCustomerWritten(EntityWrittenEvent $event): void
  66.     {
  67.         SharedFunctions::dumpToLog("onCustomerWritten()");
  68.         $payload = $event->getPayLoads()[0];
  69.         if ($payload && array_key_exists('id', $payload)) {
  70.             $customerId = $event->getPayLoads()[0]['id'];
  71.         } else {
  72.             // we need to get the id from the writeResult
  73.             $writeResult = $event->getWriteResults()[0];
  74.             $customerId = $writeResult->getPrimaryKey();
  75.         }
  76.         if ($customerId) {
  77.             $this->registerInExternalDatabase($customerId, 1);
  78.             $this->adjustSalesChannel($customerId);
  79.         }
  80.     }
  82.     public function onCustomerDeleted(EntityDeletedEvent $event): void
  83.     {
  84.         $customerId = $event->getPayLoads()[0]['id'];
  85.         $this->registerInExternalDatabase($customerId, 2);
  86.     }
  88.     public function onCustomerAddressWritten(EntityWrittenEvent $event): void
  89.     {
  90.         $writeResults = $event->getWriteResults();
  91.         $writeResult = reset($writeResults);
  92.         $customerId = $writeResult->getPayload()['customerId'];
  93.         $this->registerInExternalDatabase($customerId, 1);
  94.     }
  96.     public function onCustomerAddressDeleted(EntityDeletedEvent $event): void
  97.     {
  98.         //dump($event); die();
  99.         $this->registerInExternalDatabase(1);
  100.     }
  102.     private function registerInExternalDatabase($customerId, $created_or_changed_or_deleted)
  103.     {
  104.         // create a connection to the external database
  105.         SharedFunctions::dumpToLog("registerInExternalDatabase()");
  107.         $dbHost = $this->systemConfigService->get('SteincoProductsController.config.externalDatabaseHost');
  108.         $dbUser = $this->systemConfigService->get('SteincoProductsController.config.externalDatabaseUser');
  109.         $dbPass = $this->systemConfigService->get('SteincoProductsController.config.externalDatabasePassword');
  110.         $dbName = $this->systemConfigService->get('SteincoProductsController.config.externalDatabaseName');
  111.         $mySql = new \mysqli($dbHost, $dbUser, $dbPass, $dbName);
  112.         if ($mySql->connect_errno) {
  113.             // Log the error somehow
  114.             //dump($mysqli->connect_errno);
  115.         }
  117.         // get the user or set dummy data
  118.         $customerSearchResult = $this->customerRepository->search(
  119.             (new Criteria([]))->addAssociation('salutation')->addAssociation('title')->addFilter(new EqualsFilter('id', $customerId)),
  120.             \Shopware\Core\Framework\Context::createDefaultContext()
  121.         );
  123.         $elements = $customerSearchResult->getEntities()->getElements();
  125.         $customer = reset($elements);
  127.         // Sprache des Kunden mit Locale-Assoziation abrufen
  128.         $languageSearchResult = $this->languageRepository->search(
  129.             (new Criteria([]))
  130.                 ->addFilter(new EqualsFilter('id', $customer->getLanguageId()))
  131.                 ->addAssociation('locale'),
  132.             \Shopware\Core\Framework\Context::createDefaultContext()
  133.         );
  135.         $language = $languageSearchResult->first();
  136.         if ($language && $language->getLocale()) {
  137.             $language_name = $language->getName();
  138.             // Extrahiere den Ländercode nach dem Bindestrich
  139.             $locale_parts = explode('-', $language->getLocale()->getCode());
  140.             $language_locale = end($locale_parts); // Nimmt den letzten Teil nach dem Bindestrich
  141.         } else {
  142.             // Fallback-Werte setzen
  143.             $language_name = 'Deutsch';
  144.             $language_locale = 'DE';
  145.         }
  147.         // we need to get some data from the db:
  148.         $customer_group = null; // no customergroups yet, will be from $customer->groupId
  149.         // Salutation
  150.         $salutation = $customer->getSalutation();
  152.         // address-data from the billing address
  153.         $addressId = $customer->getDefaultBillingAddressId();
  155.         $address_searchresult = $this->addressRepository->search(
  156.             (new Criteria([]))->addAssociation('countryState')->addFilter(new EqualsFilter('id', $addressId)),
  157.             \Shopware\Core\Framework\Context::createDefaultContext());
  158.         $address_elements = $address_searchresult->getEntities()->getElements();
  159.         $address = reset($address_elements);
  161.         $department = $address->getDepartment(); // part of address
  162.         $iso_3 = null;
  163.         // search for countryId
  164.         $country_searchresult = $this->countryRepository->search(
  165.             (new Criteria([]))->addFilter(new EqualsFilter('id', $address->getCountryId())),
  166.             \Shopware\Core\Framework\Context::createDefaultContext());
  167.         $country_elements = $country_searchresult->getEntities()->getElements();
  168.         $country_element = reset($country_elements);
  169.         if ($country_element) {
  170.             $country = $country_element->getName(); //part of address
  171.             $iso_3 = $country_element->getIso3();
  172.         } else {
  173.             $country = "";
  174.         }
  175.         // search for countryStateId
  176.         if ($address->getCountryState()) {
  177.             $state = $address->getCountryState()->getName(); // bundesland, part of address
  178.         } else {
  179.             $state = "";
  180.         }
  182.         if ($address->getCountryStateId()) {
  183.             $state_searchresult = $this->stateRepository->search(
  184.                 (new Criteria([]))->addFilter(new EqualsFilter('id', $address->getCountryStateId())),
  185.                 \Shopware\Core\Framework\Context::createDefaultContext());
  186.             $state_elements = $state_searchresult->getEntities()->getElements();
  187.             $state_element = reset($state_elements);
  188.             $state_element->getName();
  189.         }
  190.         $street = $address->getStreet(); // part of address
  191.         $postal_code = $address->getZipcode(); // part of address
  192.         $city = $address->getCity(); // part of address
  193.         $address_addition_1 = $address->getAdditionalAddressLine1(); // part of address
  194.         $address_addition_2 = $address->getAdditionalAddressLine2();  // part of address
  195.         $phone_number = $address->getPhoneNumber();  // part of address
  196.         $webpage = null; // ???
  199.         $id = '0x0';
  200.         $transaktions_id = null; // auto-increment
  201.         $art = $created_or_changed_or_deleted;
  202.         $kundengruppe = $customer_group;
  203.         $sprache_name = $language_name;
  204.         $sprache_gebietsschema = $language_locale;
  205.         $kundennummer = $customer->getCustomerNumber();
  206.         $titel = $customer->getTitle();
  207.         $anrede = $salutation->getDisplayName();
  208.         $vorname = $customer->getFirstName();
  209.         $nachname = $customer->getLastName();
  210.         $firma = $customer->getCompany();
  211.         if (empty($firma))
  212.             $firma = $address->getCompany();
  213.         $abteilung = $address->getDepartment(); // part of address
  214.         $USt_id = $customer->getVatIds()[0] ?? "";
  215.         $land = $country;
  216.         $bundesland = $state;
  217.         $strasse = $street;
  218.         $postleitzahl = $postal_code;
  219.         $ort = $city;
  220.         $adresse_Zusatz_Zeile1 = $address_addition_1;
  221.         $adresse_Zusatz_Zeile2 = $address_addition_2;
  222.         $email = $customer->getEmail();
  223.         $telefon = $phone_number;
  224.         $geburtstag = $customer->getBirthday();
  225.         $aktiv = $customer->getActive();
  226.         $werbezusage = $customer->getNewsletter() ? 1 : 0;
  227.         $IP_Adresse = $customer->getRemoteAddress(); // $customer->getNewsletter() ? 'TODO' : null;//ip only if werbezusage
  228.         /* The function gets the remote IP which is stored by nginx in
  229.          * the headers send to Apache.
  230.          */
  231.         $IP_Adresse = SharedFunctions::getRemoteIP();
  232.         $email_alt = null;//should be done by a trigger in db
  233.         $webseite = $webpage;
  234.         $zu_uebertragen = 0; //(always 0 for us)
  235.         $gast = $customer->getGuest() ? 1 : 0;
  236.         $erste_Anmeldung = $customer->getFirstLogin();
  237.         $letzte_Anmeldung = $customer->getLastLogin();
  238.         $erstellt_am = $customer->getCreatedAt();
  239.         $geaendert_am = $customer->getUpdatedAt();
  241.         $gesperrt = 0;
  242.         if (isset($customer->getCustomFields()['custom_customer_blocked'])) {
  243.             $gesperrt = $customer->getCustomFields()['custom_customer_blocked'];
  244.         }
  245.         if ($firma) {
  246.             $firma = substr($firma, 0, 40); // Firma darf maximal 40 Zeichen lang sein
  247.             $firma = str_replace('"', "'", $firma); // Damit die D.3 Schnittstelle funktioniert
  248.         }
  249.         // if geaendert_am is null this is the registration of the customer
  250.         if ($geaendert_am == null) {
  251.             $art = 0;
  252.         }
  254.         // avoid double entries
  255.         $last_entry_sql = 'SELECT NOT EXISTS( SELECT `geaendert_am` FROM `Kundendaten_Shop` WHERE `Email` = ' . $this->valueString($email)
  256.             . ' AND `geaendert_am` BETWEEN '
  257.             . $this->dateString($geaendert_am) . ' - INTERVAL 2 SECOND AND '
  258.             . $this->dateString($geaendert_am) . ' ) AS `lastEntry`';
  259.         if ($result = $mySql->query($last_entry_sql)) {
  260.             // $result indicates that no entry for the customer with that name exists which is less than 2 seconds old
  261.             // so we can insert the data
  262.             $row = mysqli_fetch_array($result);
  263.             $no_entry_exists = $row['lastEntry'];
  265.             $result->close();
  266.             // create the query and send it to the external database
  267.             // no need for a prepared statement
  268.             if ($no_entry_exists == "1") {
  269.                 $sql = 'INSERT INTO `Kundendaten_Shop` (`id`, `Transaktions_Id`, `Art`, `Kundengruppe`,'
  270.                     . ' `Sprache_Name`, `Sprache_Gebietsschema`, `Kundennummer`, `Titel`,'
  271.                     . ' `Anrede`, `Vorname`, `Nachname`, `Firma`, `Abteilung`, `USt_id`,'
  272.                     . ' `Land`, `Bundesland`, `Strasse`, `Postleitzahl`, `Ort`, `Adresse_Zusatz_Zeile1`,'
  273.                     . ' `Adresse_Zusatz_Zeile2`, `Email`, `Telefon`, `Geburtstag`, `aktiv`, `gesperrt`,'
  274.                     . ' `Werbezusage`, `IP_Adresse`, `Email_alt`, `Webseite`, `zu_uebertragen`,'
  275.                     . ' `Gast`, `erste_Anmeldung`, `letzte_Anmeldung`, `erstellt_am`, `geaendert_am`, `Land_ISO_3`)'
  276.                     . ' VALUES (' . $id . ', ' . $this->valueString($transaktions_id) . ', ' . $art . ', ' . $this->valueString($kundengruppe) . ', '
  277.                     . $this->valueString($sprache_name) . ',' . $this->valueString($sprache_gebietsschema) . ', '
  278.                     . $this->valueString($kundennummer) . ', ' . $this->valueString($titel) . ', ' . $this->valueString($anrede)
  279.                     . ', ' . $this->valueString($vorname) . ', ' . $this->valueString($nachname) . ', '
  280.                     . $this->valueString($firma, 40) . ', ' . $this->valueString($abteilung, 35) . ', '
  281.                     . $this->valueString($USt_id) . ' ,' . $this->valueString($land) . ', '
  282.                     . $this->valueString($bundesland) . ', ' . $this->valueString($strasse) . ', '
  283.                     . $this->valueString($postleitzahl) . ', ' . $this->valueString($ort) . ', '
  284.                     . $this->valueString($adresse_Zusatz_Zeile1) . ', ' . $this->valueString($adresse_Zusatz_Zeile2) . ', '
  285.                     . $this->valueString($email) . ', ' . $this->valueString($telefon) . ', ' . $this->dateString($geburtstag) . ', '
  286.                     . $this->booleanString($aktiv) . ', ' . $this->booleanString($gesperrt) . ', ' . $werbezusage . ', ' . $this->valueString($IP_Adresse) . ', '
  287.                     . $this->valueString($email_alt) . ', ' . $this->valueString($webseite) . ', 0, '
  288.                     . $gast . ', ' . $this->dateString($erste_Anmeldung) . ', '
  289.                     . $this->dateString($letzte_Anmeldung) . ', ' . $this->dateString($erstellt_am)
  290.                     . ', ' . $this->dateString($geaendert_am)
  291.                     . ', ' . $this->valueString($iso_3) . ')';
  292.                 if (!$mySql->query($sql)) {
  293.                     //query did not succeed, log this somehow
  294.                     //dump(mysqli_error($mysqli), $sql, $customer);
  295.                 }
  296.             }
  297.         } else {
  298.             // either there is an entry for the customer or there was an error
  299.             // dump(mysqli_error($mysqli));
  300.         }
  301.     }
  303.     private function adjustSalesChannel($customerId)
  304.     {
  305.         /* Hier wird der Standard-Saleschannel für den Kunden korrigiert.
  306.             Es muss sich immer um den Shop-channel handeln, da für den Kunden sonst
  307.             keine manuellen Bestellungen erzeugt werden können. Leider ist dieser
  308.             Eintrag im Backend nicht bearbeitbar und wird bei Anlage des Kunden auf
  309.             den in diesem Moment aktuellen Channel gesetzt.
  310.         */
  311.         SharedFunctions::dumpToLog("adjustSalesChannel()");
  313.         $dbHost = $this->systemConfigService->get('SteincoProductsController.config.externalDatabaseHost');
  314.         $dbUser = $this->systemConfigService->get('SteincoProductsController.config.externalDatabaseUser');
  315.         $dbPass = $this->systemConfigService->get('SteincoProductsController.config.externalDatabasePassword');
  316.         $dbName = $this->systemConfigService->get('SteincoProductsController.config.shopDatabaseName');
  317.         $mySql = new \mysqli($dbHost, $dbUser, $dbPass, $dbName);
  318.         if ($mySql->connect_errno) {
  319.             SharedFunctions::dumpToLog('Could not connect to MySQL: ' . $mySql->connect_error);
  320.             return;
  321.         }
  322.         $salesChannelId = $this->systemConfigService->get('SteincoProductsController.config.scShopUUID');
  323.         SharedFunctions::dumpToLog($salesChannelId);
  325.         try {
  326.             // Vorher prüfen, ob ein Update notwendig ist
  327.             $checkSql = "SELECT HEX(sales_channel_id) AS sales_channel_id FROM `customer` WHERE id = UNHEX('" . $customerId . "')";
  328.             $result = $mySql->query($checkSql);
  330.             if ($result) {
  331.                 $row = $result->fetch_assoc();
  332.                 if ($row && $row['sales_channel_id'] !== strtoupper($salesChannelId)) {
  333.                     // Update durchführen, wenn der neue Wert unterschiedlich ist
  334.                     $updateSql = "UPDATE `customer` SET sales_channel_id = UNHEX('" . $salesChannelId . "') WHERE id = UNHEX('" . $customerId . "')";
  335.                     if (!$mySql->query($updateSql)) {
  336.                         // Query did not succeed, log this somehow
  337.                         SharedFunctions::dumpToLog('Error executing: ' . $updateSql);
  338.                         SharedFunctions::dumpToLog('SQL-Error: ' . $mySql->error);
  339.                     } else {
  340.                         SharedFunctions::dumpToLog('Aktualisierung des SalesChannels erfolgt. ' . $mySql->affected_rows . ' Zeile(n).');
  341.                     }
  342.                     SharedFunctions::dumpToLog($updateSql);
  343.                 } else {
  344.                     SharedFunctions::dumpToLog('Kein Update notwendig. SalesChannelId ist bereits gesetzt.');
  345.                 }
  346.             } else {
  347.                 SharedFunctions::dumpToLog('Error executing: ' . $checkSql);
  348.                 SharedFunctions::dumpToLog('SQL-Error: ' . $mySql->error);
  349.             }
  350.         } catch (\Exception $e) {
  351.             // Logge die Fehlermeldung in eine Datei oder verarbeite den Fehler entsprechend
  352.             SharedFunctions::dumpToLog('Aktualisierung des SalesChannels fehlgeschlagen.');
  353.             SharedFunctions::dumpToLog($e->getMessage());
  354.         }
  355.     }
  357.     private function valueString($value, $maxLength = null)
  358.     {
  359.         $result = 'NULL';
  360.         if ($value) {
  361.             $valueString = '"' . $value . '" ';
  362.             if (is_null($maxLength)) {
  363.                 $result = $valueString;
  364.             } else {
  365.                 // Beschränke die Länge des Ergebnisses auf $maxLength Zeichen
  366.                 $result = substr($valueString, 0, $maxLength);
  367.             }
  368.         }
  369.         return $result;
  370.     }
  372.     private function dateString($date)
  373.     {
  374.         $result = 'NULL';
  375.         if ($date) {
  376.             $result = '"' . $date->format('Y-m-d H:i:s') . '" ';
  377.         }
  378.         return $result;
  379.     }
  381.     private function booleanString($a_boolean)
  382.     {
  383.         if ($a_boolean) {
  384.             return '1';
  385.         }
  386.         return '0';
  387.     }
  388. }