custom/plugins/imnxxNWBUserLogin/src/Subscriber/MySubscriber.php line 981

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace imnxxNWBUserLogin\Subscriber;
  5. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  6. use Shopware\Storefront\Page\GenericPageLoadedEvent;
  7. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  9. use Shopware\Storefront\Page\Checkout\Register\CheckoutRegisterPageLoadedEvent;
  10. use Shopware\Storefront\Page\Checkout\Confirm\CheckoutConfirmPageLoadedEvent;
  11. use Shopware\Storefront\Page\Checkout\Finish\CheckoutFinishPageLoadedEvent;
  12. use Shopware\Storefront\Page\Checkout\Cart\CheckoutCartPageLoadedEvent;
  13. use Shopware\Storefront\Page\Checkout\Offcanvas\OffcanvasCartPageLoadedEvent;
  15. use Shopware\Storefront\Page\Address\Listing\AddressListingPageLoadedEvent;
  16. use Shopware\Storefront\Page\Address\Detail\AddressDetailPageLoadedEvent;
  18. use Shopware\Storefront\Page\Account\Overview\AccountOverviewPageLoadedEvent;
  20. use Shopware\Core\Checkout\Customer\Event\CustomerRegisterEvent;
  21. use Shopware\Core\Checkout\Cart\Event\LineItemAddedEvent;
  23. use Shopware\Storefront\Page\Search\SearchPageLoadedEvent;
  25. use Symfony\Component\HttpFoundation\Session\Session;
  26. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  28. use Shopware\Core\Checkout\Cart\SalesChannel\CartService;
  29. use Doctrine\DBAL\Connection;
  30. use PDO;
  31. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemEntity;
  33. class MySubscriber implements EventSubscriberInterface {
  34.     private CartService $cartService;
  35.     private Connection $connection;
  37.     public function __construct(CartService $cartService, Connection $connection) {
  38.         $this->cartService = $cartService;
  39.         $this->connection = $connection;
  40.     }
  41.     public static function getSubscribedEvents(): array {
  42.         return [
  43.             SearchPageLoadedEvent::class => 'onSearchPageLoaded',
  45.             GenericPageLoadedEvent::class => 'onPageLoaded',
  46.             ProductPageLoadedEvent::class => 'onProductPageLoaded',
  48.             CheckoutRegisterPageLoadedEvent::class => 'onCheckoutRegisterPageLoaded',
  49.             CheckoutConfirmPageLoadedEvent::class => 'onCheckoutConfirmPageLoaded',
  50.             CheckoutFinishPageLoadedEvent::class => 'onCheckoutFinishPageLoaded',
  51.             CheckoutCartPageLoadedEvent::class => 'onCheckoutCartPageLoaded',
  52.             OffcanvasCartPageLoadedEvent::class => 'onOffcanvasCartPageLoaded',
  54.             AddressListingPageLoadedEvent::class => 'onAddressListingPageLoaded',
  55.             AddressDetailPageLoadedEvent::class => 'onAddressDetailPageLoaded',
  57.             AccountOverviewPageLoadedEvent::class => 'onAccountOverviewPageLoaded',
  59.             CustomerRegisterEvent::class => 'onCustomerRegisterEvent',
  61.             LineItemAddedEvent::class => 'onLineItemAdded',
  62.             CheckoutOrderPlacedEvent::class => 'onOrderPlaced',
  63.         ];
  64.     }
  66.     public function onCustomerRegisterEvent(CustomerRegisterEvent $event) {
  67.         if ($_POST['nwb_user_account']) {
  68.             $data = json_decode($_POST['nwb_user_account']);
  69.             // update user data - AccountID and SessionID
  70.             $url = 'https://' . $_SERVER['SERVER_NAME'] . '/login_api/imn_nwb_set_customer_account_id.php';
  72.             $curl = curl_init($url);
  73.             curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  74.             curl_setopt($curl, CURLOPT_POST, true);
  75.             curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
  76.             $response = curl_exec($curl);
  77.             unset($_SESSION['nwb_user_account']);
  78.             unset($_SESSION['test']);
  79.         }
  80.     }
  81.     public function onSearchPageLoaded(SearchPageLoadedEvent $event) {
  82.     }
  83.     public function onPageLoaded(GenericPageLoadedEvent $event) {
  84.         $nwbService = $event
  85.             ->getSalesChannelContext()
  86.             ->getSalesChannel()
  87.             ->getCustomFields()['bis_url'];
  88.         $cookieBisNameUser = $event
  89.             ->getSalesChannelContext()
  90.             ->getSalesChannel()
  91.             ->getCustomFields()['cookie_bis'];
  93.         if (isset($_GET['DokumentenId']) && $_GET['DokumentenId'] != '') {
  94.             if (!file_exists(dirname(__FILE__) . '/../document_logs/' . date('Y') . '/' . date('Y-m'))) {
  95.                 mkdir(dirname(__FILE__) . '/../document_logs/' . date('Y') . '/' . date('Y-m'), 0777, true);
  96.             }
  98.             $t = microtime(true);
  99.             $micro = sprintf('%06d', ($t - floor($t)) * 1000000);
  100.             $documentIdLogName =
  101.                 dirname(__FILE__) .
  102.                 '/../document_logs/' .
  103.                 date('Y') .
  104.                 '/' .
  105.                 date('Y-m') .
  106.                 '/document_id_log_' .
  107.                 date('Y-m-d') .
  108.                 '.txt';
  109.             $documentLogContent =
  110.                 "\n\n" .
  111.                 '----------------------------------------+----------------------------------------+----------------------------------------' .
  112.                 "\n";
  114.             $documentLogContent =
  115.                 $documentLogContent .
  116.                 "\n" .
  117.                 date('Y-m-d H:i:s.', time()) .
  118.                 $micro .
  119.                 "\n" .
  120.                 'Request documentid: ' .
  121.                 $_GET['DokumentenId'] .
  122.                 "\n";
  124.             if (
  125.                 isset($_SESSION['_sf2_attributes']['sw-context-token']) &&
  126.                 $_SESSION['_sf2_attributes']['sw-context-token'] != ''
  127.             ) {
  128.                 $this->cartService->deleteCart($event->getSalesChannelContext());
  129.             }
  131.             $url =
  132.                 'https://' .
  133.                 $nwbService .
  134.                 '/customercare/api/order/getbestellinformationen?bisDocumentId=' .
  135.                 $_GET['DokumentenId'];
  136.             $curl = curl_init($url);
  137.             curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  138.             $response = curl_exec($curl);
  139.             curl_close($curl);
  140.             $json = json_decode($response);
  143.             if ($json->Success) {
  144.                 $json->Bestellinformationen->DokumentenId = $_GET['DokumentenId'];
  145.                 $_SESSION['bestellinformationen'] = $json->Bestellinformationen;
  146.                 $_SESSION['DokumentenId'] = $_GET['DokumentenId'];
  147.                 setcookie('DokumentenId_productnumber_for_login', $_GET['DokumentenId']);
  148.                 $add_product['nwb_add_product'] = [
  149.                     'nwb_product_number' => $json->Bestellinformationen->Bestellnummer,
  150.                 ];
  151.                 $event->getPage()->assign($add_product);
  152.                 $_SESSION['nwb_add_product_next_url'] = '/checkout/confirm';
  154.                 $documentLogContent =
  155.                     $documentLogContent .
  156.                     'After request DocumentId: ' .
  157.                     $json->Bestellinformationen->DokumentenId .
  158.                     "\n";
  159.                 $logHandle = fopen($documentIdLogName, 'a+');
  160.                 fwrite($logHandle, $documentLogContent);
  161.                 fclose($logHandle);
  162.                 unset($documentLogContent);
  164.                 return true;
  165.             }
  166.             $documentLogContent =
  167.                 $documentLogContent . 'After request DocumentId: ' . 'NO REQUEST MADE' . "\n";
  169.             $logHandle = fopen($documentIdLogName, 'a+');
  170.             fwrite($logHandle, $documentLogContent);
  171.             fclose($logHandle);
  172.             unset($documentLogContent);
  173.         }
  174.         if (
  175.             (!isset($_SESSION['GET_ADDRESSES']) ||
  176.                 (!str_contains($_SERVER['REQUEST_URI'], '/checkout/') &&
  177.                     !str_contains($_SERVER['REQUEST_URI'], '/account/'))) &&
  178.             !(isset($_SESSION['login_timestamp']) && $_SESSION['login_timestamp'] + 10 >= time())
  179.         ) {
  180.             if (isset($_GET['test']) && $_GET['test'] == 'session') {
  181.                 echo '<pre>$_SESSION<br>';
  182.                 var_dump($_SESSION);
  183.                 echo '</pre>';
  184.                 die();
  185.             }
  186.             if (isset($_GET['url_test']) && $_GET['url_test'] == 'url_test') {
  187.                 echo '<pre>$_SERVER<br>';
  188.                 var_dump($_SERVER);
  189.                 echo '</pre>';
  190.                 die();
  191.             }
  192.             if (isset($_GET['logout']) && $_GET['logout'] == 'logout') {
  193.                 $customer = $event->getSalesChannelContext()->getCustomer();
  194.                 if ($customer != null) {
  195.                     // Clear cart
  196.                     $this->cartService->deleteCart($event->getSalesChannelContext());
  197.                 }
  198.                 if (isset($_SESSION['stay_on_confirm'])) {
  199.                     unset($_SESSION['stay_on_confirm']);
  200.                 }
  201.                 header('Location: https://' . $_SERVER['SERVER_NAME'] . '/account/logout');
  202.                 exit();
  203.             }
  205.             $customer = $event->getSalesChannelContext()->getCustomer();
  207.             // send partnerkonto back to confirm page - musste ausgeklammert werden wegen fehlern
  208.             //        if( isset($_GET['test']) && $_GET['test'] == 'session') {
  209.             //            echo('<pre>stay_on_confirm<br>');var_dump($_SESSION);echo('</pre>');
  210.             //        }
  211.             //        if( isset($_GET['test']) && $_GET['test'] == 'server') {
  212.             //            echo('<pre>REQUEST_URI<br>');var_dump($_SERVER["REQUEST_URI"]);echo('</pre>');
  213.             //            if(
  214.             //                isset($_SESSION['stay_on_confirm']) &&
  215.             //                $_SESSION['stay_on_confirm'] == 'true' &&
  216.             //                !str_contains($_SERVER["REQUEST_URI"], '/checkout/confirm') &&
  217.             //                !str_contains($_SERVER["REQUEST_URI"], '/checkout/finish') &&
  218.             //                $customer != null
  219.             //            ) {
  220.             //                echo('thats true!');
  221.             //            }
  222.             //            echo('is it true?');
  223.             //        }
  224.             //            if(
  225.             //                isset($_SESSION['stay_on_confirm']) &&
  226.             //                $_SESSION['stay_on_confirm'] == 'true' &&
  227.             //                !str_contains($_SERVER["REQUEST_URI"], '/checkout/confirm') &&
  228.             //                !str_contains($_SERVER["REQUEST_URI"], '/checkout/finish') &&
  229.             //                $customer != null
  230.             //            ) {
  231.             //                header('Location: https://shop.nwb.de/checkout/confirm/');
  232.             //                exit;
  233.             //            }
  235.             //        if(
  236.             //            isset($_SESSION['stay_on_confirm']) &&
  237.             //            $_SESSION['stay_on_confirm'] == 'true' &&
  238.             //            $_SERVER["REQUEST_URI"] != "/checkout/finish" &&
  239.             //            $customer != null
  240.             //        ) {
  241.             //            header('Location: https://shop.nwb.de/checkout/confirm/');
  242.             //            exit;
  243.             //Test
  244.             //        }
  246.             if (!is_null($event->getPage()->getHeader())) {
  247.                 $active_category = $event
  248.                     ->getPage()
  249.                     ->getHeader()
  250.                     ->getNavigation()
  251.                     ->getActive();
  252.                 if (isset($active_category->getCustomFields()['hide_lp_header'])) {
  253.                     $hide_lp_header['hide_lp_header'] = $active_category->getCustomFields()['hide_lp_header'];
  254.                     $event->getPage()->assign($hide_lp_header);
  255.                 }
  256.                 if (isset($active_category->getCustomFields()['navi_entry_point'])) {
  257.                     $navi_entry_point['navi_entry_point'] = $active_category->getCustomFields()[
  258.                         'navi_entry_point'
  259.                     ];
  260.                     $event->getPage()->assign($navi_entry_point);
  261.                 }
  262.             }
  264.             if (isset($_GET['send']) && $_GET['send'] == 'success') {
  265.                 $landingpage_form_send['landingpage_form_send'] = 'success';
  266.                 $event->getPage()->assign($landingpage_form_send);
  267.             }
  269.             $recently_ordered['recently_ordered'] = false;
  270.             if (isset($_SESSION['checkout_finish_timestamp'])) {
  271.                 if (time() < $_SESSION['checkout_finish_timestamp'] + 3 * 60) {
  272.                     $recently_ordered['recently_ordered'] = true;
  273.                 } else {
  274.                     unset($_SESSION['checkout_finish_timestamp']);
  275.                 }
  276.             }
  277.             $event->getPage()->assign($recently_ordered);
  279.             $old_browser['old_browser'] = 0;
  280.             if (
  281.                 strpos($_SERVER['HTTP_USER_AGENT'], 'Edge') !== false ||
  282.                 strpos($_SERVER['HTTP_USER_AGENT'], 'Trident') !== false
  283.             ) {
  284.                 $old_browser['old_browser'] = 1;
  285.             }
  286.             $event->getPage()->assign($old_browser);
  288.             if (isset($_GET['et_sub']) && $_GET['et_sub'] != '') {
  289.                 $_SESSION['moorl-order-notice.order_target_group_number'] = $_GET['et_sub'];
  290.                 $session = new Session();
  291.                 $session->set('moorl-order-notice.order_target_group_number', $_GET['et_sub']);
  292.             }
  294.             if (
  295.                 isset($_SESSION['moorl-order-notice.order_target_group_number']) &&
  296.                 $_SESSION['moorl-order-notice.order_target_group_number'] != ''
  297.             ) {
  298.                 $et_sub['et_sub'] = $_SESSION['moorl-order-notice.order_target_group_number'];
  299.                 $event->getPage()->assign($et_sub);
  300.                 if (
  301.                     (!isset($_GET['et_sub']) || $_GET['et_sub'] == '') &&
  302.                     !str_contains($_SERVER['REQUEST_URI'], '/checkout/confirm') &&
  303.                     !str_contains($_SERVER['REQUEST_URI'], '/checkout/finish') &&
  304.                     !str_contains($_SERVER['REQUEST_URI'], '/suggest') &&
  305.                     !str_contains($_SERVER['REQUEST_URI'], '/widget')
  306.                 ) {
  307.                     $header_location = 'https://'.$_SERVER['SERVER_NAME'].$_SERVER['REQUEST_URI'];
  308.                     if( str_contains($_SERVER['REQUEST_URI'],'?') ) {
  309.                         $request_url_parts = explode('?', $_SERVER['REQUEST_URI'], 2);
  310.                         if($request_url_parts[1]!='') {
  311.                             $header_location = $header_location . '&et_sub=' . $et_sub['et_sub'];
  312.                         } else {
  313.                             $header_location = $header_location . 'et_sub=' . $et_sub['et_sub'];
  314.                         }
  315.                     } else {
  316.                         $header_location = $header_location . '?et_sub=' . $et_sub['et_sub'];
  317.                     }
  318.                     header('Location: ' . $header_location );
  319.                     die();
  320.                 }
  321.             }
  323.             if (isset($_GET['product_to_cart']) && $_GET['product_to_cart'] != '') {
  324.                 $add_product['nwb_add_product'] = [
  325.                     'nwb_product_number' => $_GET['product_to_cart'],
  326.                 ];
  327.                 $event->getPage()->assign($add_product);
  328.             }
  330.             if (isset($_SESSION['logout_redirect']) && $_SESSION['logout_redirect'] != '') {
  331.                 $logout_redirect = $_SESSION['logout_redirect'];
  332.                 unset($_SESSION['logout_redirect']);
  333.                 unset($_SESSION['login_timestamp']);
  334.                 header('Location: ' . $logout_redirect);
  335.                 exit();
  336.             }
  337.             if (
  338.                 !isset($_COOKIE[$cookieBisNameUser]) &&
  339.                 isset($_COOKIE['sw-states']) &&
  340.                 preg_match('/logged-in/i', $_COOKIE['sw-states']) &&
  341.                 $customer !== null &&
  342.                 !$customer->getGuest()
  343.             ) {
  344.                 $_SESSION['logout_redirect'] = $_SERVER['SCRIPT_URI'];
  345.                 header('Location: https://' . $_SERVER['SERVER_NAME'] . '/account/logout');
  346.                 exit();
  347.             }
  348.         }
  349.     }
  351.     public function onProductPageLoaded(ProductPageLoadedEvent $event) {
  352.         $page = $event->getPage();
  353.         $product = $page->getProduct();
  354.         if (isset($_GET['testen']) && $_GET['testen'] == 'testen') {
  355.             $cross_selling_elements = $page->getCrossSellings()->getElements();
  356.             foreach ($cross_selling_elements as $cross_selling_element) {
  357.                 echo '<pre>$cross_selling_element<br>';
  358.                 print_r($cross_selling_element->getCrossSelling());
  359.                 echo '</pre>';
  360.             }
  361.             //            echo('<pre>product<br>');print_r($product);echo('</pre>');
  362.         }
  363.         $custom_fields = $product->getCustomFields();
  364.         // todo: get varianten price
  365.         //        echo('<pre>');print_r($_SERVER);echo('</pre>');
  366.         //        echo('<pre>');print_r($product->getParentId());echo('</pre>');
  367.         //        if( $product->getParentId() != '' ) {
  368.         //            $url = '/product_api/get_products_by_parent_id.php';
  369.         //            $curl = curl_init($url);
  370.         //            curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  371.         //            $response = curl_exec($curl);
  372.         //            echo('<pre>response');var_dump($response);echo('</pre>');
  373.         //        }
  375.         $education_proof['need_education_proof'] = false;
  376.         foreach ($product->getOptions()->getElements() as $option) {
  377.             if ($option->getGroup()->getName() == 'Preisart') {
  378.                 if ($option->getName() == 'Ausbildungspreis') {
  379.                     $education_proof['need_education_proof'] = $option->getName();
  380.                 }
  381.             }
  382.         }
  384.         $event->getPage()->assign($education_proof);
  386.         //wurde ausgelagert ins authorProductList Plugin
  387.         if (
  388.             isset($custom_fields['custom_product_attributs_autor_ids']) &&
  389.             $custom_fields['custom_product_attributs_autor_ids'] != ''
  390.         ) {
  391.             $result = $this->connection->executeQuery(
  392.                 'SELECT *, HEX(cbax_lexicon_entry.id) as author_sw_id ' .
  393.                     'From cbax_lexicon_entry_translation ' .
  394.                     'INNER JOIN cbax_lexicon_entry ON cbax_lexicon_entry_translation.cbax_lexicon_entry_id=cbax_lexicon_entry.id ' .
  395.                     'WHERE cbax_lexicon_entry_translation.attribute6 IN (' .
  396.                     $custom_fields['custom_product_attributs_autor_ids'] .
  397.                     ')',
  398.             );
  400.             $unsorted_authors = [];
  401.             $authors['authors'] = [];
  402.             while ($row = $result->fetch(PDO::FETCH_ASSOC)) {
  403.                 $unsorted_authors[$row['attribute6']] = $row;
  404.             }
  405.             $author_ids = explode(',', $custom_fields['custom_product_attributs_autor_ids']);
  406.             foreach ($author_ids as $author_id) {
  407.                 if(isset($unsorted_authors[$author_id]))
  408.                 $authors['authors'][$author_id] = $unsorted_authors[$author_id];
  409.             }
  410.             if (isset($_GET['test']) && $_GET['test'] == 'author') {
  411.                 echo '<pre>$authors<br>';
  412.                 print_r($authors);
  413.                 echo '</pre>';
  414.             }
  415.             $event->getPage()->assign($authors);
  416.         }
  417.     }
  419.     public function onCheckoutRegisterPageLoaded(CheckoutRegisterPageLoadedEvent $event) {
  420.         $page = $event->getPage();
  421.         $cart = $page->getCart();
  423.         $lineitems = $cart->getLineItems()->getFlat();
  424.         $cart_price = $cart->getPrice();
  425.         $this->changeCartPriceForAboProducts($cart_price, $lineitems);
  426.     }
  428.     public function onCheckoutConfirmPageLoaded(CheckoutConfirmPageLoadedEvent $event) {
  429.         $cookieBisNameUser = $event
  430.             ->getSalesChannelContext()
  431.             ->getSalesChannel()
  432.             ->getCustomFields()['cookie_bis'];
  433.         $cookieBisNameToBis = $event
  434.             ->getSalesChannelContext()
  435.             ->getSalesChannel()
  436.             ->getCustomFields()['cookie_bis_sending'];
  437.         $nwbService = $event
  438.             ->getSalesChannelContext()
  439.             ->getSalesChannel()
  440.             ->getCustomFields()['bis_url'];
  442.         if (isset($_COOKIE[$cookieBisNameUser]) && $_COOKIE[$cookieBisNameUser] != '') {
  443.             $url = 'https://' . $nwbService . '/customercare/api/accounts/info';
  444.             $curl = curl_init($url);
  445.             curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  446.             curl_setopt($curl, CURLOPT_COOKIE, $cookieBisNameToBis . '=' . $_COOKIE[$cookieBisNameUser]);
  447.             $response = curl_exec($curl);
  449.             // Close cURL session
  450.             curl_close($curl);
  451.             $user_data = json_decode($response);
  452.             if (isset($_SESSION['dokument_kauf']) && isset($user_data->Partnerkonto)) {
  453.                 if ($user_data->Partnerkonto && $_SESSION['dokument_kauf'] == 'true') {
  454.                     $_SESSION['stay_on_confirm'] = 'true';
  455.                     unset($_SESSION['dokument_kauf']);
  456.                 }
  457.             }
  458.         }
  460.         $page = $event->getPage();
  461.         $cart = $page->getCart();
  463.         //musste ebenfalls ausgeklammert werden wegen fehler
  464.         //        if( isset($_SESSION['stay_on_confirm']) && $_SESSION['stay_on_confirm'] == 'true' ) {
  465.         //            $event->getPage()->assign( ['stay_on_confirm' => true] );
  466.         //        }
  467.         //
  468.         //        if( isset($_GET['stay_on_confirm']) && $_GET['stay_on_confirm'] == 'true' ) {
  469.         //            $event->getPage()->assign( ['stay_on_confirm' => true] );
  470.         //        }
  472.         $lineitems = $cart->getLineItems()->getFlat();
  473.         $cart_price = $cart->getPrice();
  474.         $this->changeCartPriceForAboProducts($cart_price, $lineitems);
  476.         $crossselling_return = get_cross_selling_items($lineitems);
  478.         $education_proof['need_education_proof'] = false;
  479.         $download_products = [];
  480.         $hasDocumentIdProductInCart = false;
  481.         $libreka_download_links = '';
  482.         foreach ($lineitems as $lineitem) {
  483.             if (
  484.                 isset($lineitem->getPayload()['customFields']['custom_product_attributs_dokumenten_id']) &&
  485.                 $lineitem->getPayload()['customFields']['custom_product_attributs_dokumenten_id'] != ''
  486.             ) {
  487.                 $hasDocumentIdProductInCart = true;
  488.             }
  489.             if (
  490.                 isset($lineitem->getPayload()['customFields']['custom_product_attributs_email_gruppe']) &&
  491.                 $lineitem->getPayload()['customFields']['custom_product_attributs_email_gruppe'] ==
  492.                     'E-Book-Email-Gruppe'
  493.             ) {
  494.                 if (
  495.                     $lineitem->getPayload()['customFields'][
  496.                         'custom_product_attributs_libreka_download_format'
  497.                     ] == 'EPUB'
  498.                 ) {
  499.                     $librekaDownloadFormat = '029';
  500.                 } elseif (
  501.                     $lineitem->getPayload()['customFields'][
  502.                         'custom_product_attributs_libreka_download_format'
  503.                     ] == 'PDF'
  504.                 ) {
  505.                     $librekaDownloadFormat = '002';
  506.                 }
  508.                 $url =
  509.                     'https://' .
  510.                     $nwbService .
  511.                     '/customercare/api/order/GetLibrekaDownloadLink/?accountId=' .
  512.                     $user_data->AccountID .
  513.                     '&isbn=' .
  514.                     $lineitem->getPayload()['customFields']['custom_product_attributs_isbn'] .
  515.                     '&librekaDownloadFormat=' .
  516.                     $librekaDownloadFormat .
  517.                     '&idBestellposition=11';
  518.                 $curl = curl_init($url);
  519.                 curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  520.                 $response = curl_exec($curl);
  521.                 curl_close($curl);
  522.                 if ($libreka_download_links != '') {
  523.                     $libreka_download_links = $libreka_download_links . '|';
  524.                 }
  525.                 $libreka_download_links =
  526.                     $libreka_download_links .
  527.                     $lineitem->getPayload()['productNumber'] .
  528.                     '=>' .
  529.                     json_decode($response)->Url;
  530.             }
  531.             foreach ($lineitem->getPayload()['options'] as $option) {
  532.                 if ($option['group'] == 'Preisart') {
  533.                     if ($option['option'] == 'Ausbildungspreis') {
  534.                         $education_proof['need_education_proof'] = $option['option'];
  535.                     }
  536.                 }
  537.             }
  538.         }
  539.         $_SESSION['prevent_order_export'] = false;
  540.         $session = new Session();
  541.         $session->set('moorl-order-notice.libreka_download_links', $libreka_download_links);
  543.         $advertising_permission['advertising_permission'] = $session->get(
  544.             'moorl-order-notice.advertising_permission',
  545.         );
  546.         if (is_null($advertising_permission['advertising_permission'])) {
  547.             $advertising_permission['advertising_permission'] = false;
  548.         }
  549.         $event->getPage()->assign($advertising_permission);
  551.         $event->getPage()->assign($education_proof);
  552.         $event->getPage()->assign($crossselling_return);
  554.         // if(!$hasDocumentIdProductInCart && isset($_SESSION['bestellinformationen'])) {
  555.         //     unset($_SESSION['bestellinformationen']);
  556.         // }
  558.         if (isset($_SESSION['bestellinformationen'])) {
  559.             $bestellinformationen['bestellinformationen'] = $_SESSION['bestellinformationen'];
  560.             $event->getPage()->assign($bestellinformationen);
  562.             $session = new Session();
  563.             $session->set('moorl-order-notice.bestellinformationen', $_SESSION['bestellinformationen']);
  564.         }
  565.     }
  567.     public function onCheckoutFinishPageLoaded(CheckoutFinishPageLoadedEvent $event) {
  568.         if (isset($_SESSION['bestellinformationen'])) {
  569.             $orderProducts = $event
  570.                 ->getPage()
  571.                 ->getOrder()
  572.                 ->getLineItems();
  573.             $documentProductInOrder = false;
  575.             /**
  576.              * @var OrderLineItemEntity $product
  577.              */
  578.             foreach ($orderProducts as $product) {
  579.                 if (
  580.                     $_SESSION['bestellinformationen']->Bestellnummer ==
  581.                     $product->getPayload()['productNumber']
  582.                 ) {
  583.                     $documentProductInOrder = true;
  584.                     break;
  585.                 }
  586.             }
  588.             if (!$documentProductInOrder) {
  589.                 unset($_SESSION['bestellinformationen']);
  590.             }
  591.         }
  592.         // session setzen zum logout link ausblenden
  593.         $_SESSION['checkout_finish_timestamp'] = time();
  595.         $page = $event->getPage();
  596.         $order = $page->getOrder();
  597.         $customer = $order->getOrderCustomer();
  598.         $order_price = $order->getPrice();
  599.         $lineItems = $order->getLineItems()->getElements();
  600.         $this->changeCartPriceForAboProducts($order_price, $lineItems);
  602.         $crossselling_return = get_cross_selling_items($lineItems, true);
  604.         if (isset($_GET['test']) && $_GET['test'] == 'additem') {
  605.             echo '<pre>$crossselling_return<br>';
  606.             var_dump($crossselling_return);
  607.             echo '</pre>';
  608.             die();
  609.         }
  611.         $checkout_finish_page_url = '';
  612.         $education_proof['need_education_proof'] = false;
  613.         foreach ($lineItems as $lineItem) {
  614.             if (
  615.                 isset($lineItem->getPayload()['customFields']['imn_checkout_finish_page_url']) &&
  616.                 $lineItem->getPayload()['customFields']['imn_checkout_finish_page_url'] != ''
  617.             ) {
  618.                 $checkout_finish_page_url =
  619.                     'https://' . $_SERVER['HTTP_HOST'] . 
  620.                     $lineItem->getPayload()['customFields']['imn_checkout_finish_page_url'];
  621.                 if ( ($_GET['et_sub'] ?? false) != '' ) {
  622.                     $checkout_finish_page_url = $checkout_finish_page_url . '?et_sub=' . $_GET['et_sub'];
  623.                 } elseif ( ($_SESSION['moorl-order-notice.order_target_group_number'] ?? false) != '' ) {
  624.                     $checkout_finish_page_url = $checkout_finish_page_url . '?et_sub=' . $_SESSION['moorl-order-notice.order_target_group_number'];
  625.                 }
  626.             }
  627.             if (
  628.                 isset($lineItem->getPayload()['customFields']['finish_page_parameter']) &&
  629.                 $lineItem->getPayload()['customFields']['finish_page_parameter'] != ''
  630.             ) {
  631.                 if (
  632.                     isset($_SERVER['QUERY_STRING']) &&
  633.                     $_SERVER['QUERY_STRING'] != '' &&
  634.                     !str_contains(
  635.                         $_SERVER['QUERY_STRING'],
  636.                         $lineItem->getPayload()['customFields']['finish_page_parameter'],
  637.                     )
  638.                 ) {
  639.                     $new_url =
  640.                         'finish?' .
  641.                         $_SERVER['QUERY_STRING'] .
  642.                         '&' .
  643.                         $lineItem->getPayload()['customFields']['finish_page_parameter'];
  644.                 } elseif ($_SERVER['QUERY_STRING'] == '') {
  645.                     $new_url = 'finish?' . $lineItem->getPayload()['customFields']['finish_page_parameter'];
  646.                 }
  647.                 if (isset($new_url)) {
  648.                     header('Location:' . $new_url);
  649.                     exit();
  650.                 }
  651.             }
  652.             foreach ($lineItem->getPayload()['options'] as $option) {
  653.                 if ($option['group'] == 'Preisart') {
  654.                     if ($option['option'] == 'Ausbildungspreis') {
  655.                         $education_proof['need_education_proof'] = $option['option'];
  656.                     }
  657.                 }
  658.             }
  659.         }
  661.         $assign_arr['checkout_finish_page_url'] = $checkout_finish_page_url;
  662.         $event->getPage()->assign($assign_arr);
  664.         $event->getPage()->assign($education_proof);
  665.         $event->getPage()->assign($crossselling_return);
  667.         if (isset($order->getCustomFields()['order_notice_notice'])) {
  668.             $components['components'] = $order->getCustomFields()['order_notice_notice'];
  669.             $event->getPage()->assign($components);
  670.         }
  672.         $data = ['customer_id' => $customer->getCustomerId()];
  674.         // curl für Gastflag
  675.         $url =
  676.             'https://' . $_SERVER['SERVER_NAME'] . '/customer_data_api/imn_nwb_get_customer_guest_flag.php';
  677.         $curl = curl_init($url);
  678.         curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  679.         curl_setopt($curl, CURLOPT_POST, true);
  680.         curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
  681.         $guest_flag['guest'] = curl_exec($curl);
  682.         curl_close($curl);
  684.         // curl zum absenden der Order an nwb
  685.         //        $url = 'https://shop.nwb.de/_api/order_export.php';
  686.         //        $curl = curl_init($url);
  687.         //        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  688.         //        $result = curl_exec($curl);
  689.         //        curl_close($curl);
  691.         $event
  692.             ->getPage()
  693.             ->getOrder()
  694.             ->getOrderCustomer()
  695.             ->assign($guest_flag);
  696.         if (isset($_SESSION['bestellinformationen'])) {
  697.             $NextUrl['NextUrl'] = $_SESSION['bestellinformationen']->NextUrl;
  698.             $event->getPage()->assign($NextUrl);
  699.         }
  700.         $bestellinformationen['db_order_getter'] = '';
  701.         if (isset($_SESSION['bestellinformationen'])) {
  702.             $bestellinformationen['bestellinformationen'] = $_SESSION['bestellinformationen'];
  703.             $bestellinformationen['db_order_getter'] =
  704.                 '&titel=' .
  705.                 $_SESSION['bestellinformationen']->Titel .
  706.                 '&product_nr=' .
  707.                 $_SESSION['bestellinformationen']->Bestellnummer .
  708.                 '&next_url=' .
  709.                 $_SESSION['bestellinformationen']->NextUrl .
  710.                 '&document_id=' .
  711.                 $_SESSION['bestellinformationen']->DokumentenId;
  713.             if (isset($_GET['test']) && $_GET['test'] == 'doc') {
  714.                 echo '<pre>$bestellinformationen<br>';
  715.                 var_dump($bestellinformationen);
  716.                 echo '</pre>';
  717.             }
  718.             $event->getPage()->assign($bestellinformationen);
  719.         }
  721.         if (isset($_GET['test']) && $_GET['test'] == 'doc') {
  722.             $bestellinformationen['bestellinformationen'] = $_SESSION['bestellinformationen'];
  723.             echo '<pre>$bestellinformationen<br>';
  724.             var_dump($bestellinformationen);
  725.             echo '</pre>';
  726.             die();
  727.         }
  729.         if (!isset($_SESSION['prevent_order_export']) || $_SESSION['prevent_order_export'] === false) {
  730.             $_SESSION['prevent_order_export'] = true;
  731.             $url =
  732.                 'https://' .
  733.                 $_SERVER['SERVER_NAME'] .
  734.                 '/_api/order_export.php?order_id=' .
  735.                 $order->getId() .
  736.                 $bestellinformationen['db_order_getter'];
  737.             $url = str_replace(' ', '%20', $url);
  738.             $curl = curl_init($url);
  739.             curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  740.             $result = curl_exec($curl);
  741.             curl_close($curl);
  742.         }
  743.     }
  745.     public function onCheckoutCartPageLoaded(CheckoutCartPageLoadedEvent $event) {
  746.         $page = $event->getPage();
  747.         $cart = $page->getCart();
  749.         $lineitems = $cart->getLineItems()->getFlat();
  750.         $cart_price = $cart->getPrice();
  751.         $this->changeCartPriceForAboProducts($cart_price, $lineitems);
  753.         $product_authors = [
  754.             'product_authors' => [],
  755.         ];
  756.         $crossselling_return = get_cross_selling_items($lineitems);
  758.         foreach ($lineitems as $lineitem) {
  759.             $line_item_id = $lineitem->getId();
  761.             $custom_fields = $lineitem->getPayload()['customFields'];
  762.             if (
  763.                 isset($custom_fields['custom_product_attributs_autor_ids']) &&
  764.                 $custom_fields['custom_product_attributs_autor_ids'] != ''
  765.             ) {
  766.                 $result = $this->connection->executeQuery(
  767.                     'SELECT * ' .
  768.                         'From cbax_lexicon_entry_translation ' .
  769.                         'WHERE attribute6 IN (' .
  770.                         $custom_fields['custom_product_attributs_autor_ids'] .
  771.                         ')',
  772.                 );
  773.                 $authors['authors'] = [];
  774.                 while ($row = $result->fetch(PDO::FETCH_ASSOC)) {
  775.                     $authors[] = $row;
  776.                 }
  777.                 $event->getPage()->assign($authors);
  778.                 $product_authors['product_authors'][$line_item_id] = $authors;
  779.             }
  780.         }
  782.         $event->getPage()->assign($product_authors);
  783.         $event->getPage()->assign($crossselling_return);
  784.         if (isset($_SESSION['bestellinformationen'])) {
  785.             $bestellinformationen['bestellinformationen'] = $_SESSION['bestellinformationen'];
  786.             $event
  787.                 ->getPage()
  788.                 ->getCart()
  789.                 ->assign($bestellinformationen);
  790.         }
  791.     }
  793.     public function onOffcanvasCartPageLoaded(OffcanvasCartPageLoadedEvent $event) {
  794.         $page = $event->getPage();
  795.         $cart = $page->getCart();
  797.         $lineitems = $cart->getLineItems()->getFlat();
  798.         $cart_price = $cart->getPrice();
  799.         $this->changeCartPriceForAboProducts($cart_price, $lineitems);
  800.     }
  802.     public function onAddressListingPageLoaded(AddressListingPageLoadedEvent $event) {
  803.     }
  804.     public function onAddressDetailPageLoaded(AddressDetailPageLoadedEvent $event) {
  805.     }
  806.     public function onAccountOverviewPageLoaded(AccountOverviewPageLoadedEvent $event) {
  807.         $cookieBisNameUser = $event
  808.             ->getSalesChannelContext()
  809.             ->getSalesChannel()
  810.             ->getCustomFields()['cookie_bis'];
  811.         $cookieBisNameToBis = $event
  812.             ->getSalesChannelContext()
  813.             ->getSalesChannel()
  814.             ->getCustomFields()['cookie_bis_sending'];
  815.         $nwbService = $event
  816.             ->getSalesChannelContext()
  817.             ->getSalesChannel()
  818.             ->getCustomFields()['bis_url'];
  819.         if (isset($_SESSION['next_url'])) {
  820.             $next_url = $_SESSION['next_url'];
  821.             if (isset($_COOKIE[$cookieBisNameUser]) && $_COOKIE[$cookieBisNameUser] != '') {
  822.                 $url = 'https://' . $nwbService . '/customercare/api/accounts/info';
  823.                 $curl = curl_init($url);
  824.                 curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  825.                 curl_setopt($curl, CURLOPT_COOKIE, $cookieBisNameToBis . '=' . $_COOKIE[$cookieBisNameUser]);
  826.                 $response = curl_exec($curl);
  827.                 curl_close($curl);
  828.                 $user_data = json_decode($response);
  829.             }
  831.             $next_url = str_replace('widgets/checkout/info', 'account', $next_url);
  832.             unset($_SESSION['next_url']);
  833.             header('Location: ' . $next_url);
  834.             exit();
  835.         }
  836.     }
  838.     public function onLineItemAdded(LineItemAddedEvent $event): void {
  839.         $lineItem = $event->getLineItem();
  840.         $lineItem->setLabel('Mein Custom Design');
  841.     }
  843.     private function changeCartPriceForAboProducts($cart_price, $lineitems) {
  844.         $abo_price = 0;
  845.         $abo_net = 0;
  846.         $abo_prices = [
  847.             '7' => 0,
  848.             '19' => 0,
  849.         ];
  850.         $abo_tax = [
  851.             '7' => 0,
  852.             '19' => 0,
  853.         ];
  854.         if (count($lineitems) > 0) {
  855.             foreach ($lineitems as $lineitem) {
  856.                 if (
  857.                     isset($lineitem->getPayload()['customFields']['nwb_free_test_product']) &&
  858.                     $lineitem->getPayload()['customFields']['nwb_free_test_product']
  859.                 ) {
  860.                     $lineitem->getPrice()->getTotalPrice();
  861.                     $net = 0;
  863.                     if (
  864.                         isset(
  865.                             $lineitem
  866.                                 ->getPrice()
  867.                                 ->getCalculatedTaxes()
  868.                                 ->getElements()[19],
  869.                         )
  870.                     ) {
  871.                         $abo_tax[19] =
  872.                             $abo_tax[19] +
  873.                             $lineitem
  874.                                 ->getPrice()
  875.                                 ->getCalculatedTaxes()
  876.                                 ->getElements()[19]
  877.                                 ->getTax();
  878.                         $abo_prices[19] = $abo_prices[19] + $lineitem->getPrice()->getTotalPrice();
  879.                         $net =
  880.                             $lineitem->getPrice()->getTotalPrice() -
  881.                             $lineitem
  882.                                 ->getPrice()
  883.                                 ->getCalculatedTaxes()
  884.                                 ->getElements()[19]
  885.                                 ->getTax();
  886.                     }
  887.                     if (
  888.                         isset(
  889.                             $lineitem
  890.                                 ->getPrice()
  891.                                 ->getCalculatedTaxes()
  892.                                 ->getElements()[7],
  893.                         )
  894.                     ) {
  895.                         $abo_tax[7] =
  896.                             $abo_tax[7] +
  897.                             $lineitem
  898.                                 ->getPrice()
  899.                                 ->getCalculatedTaxes()
  900.                                 ->getElements()[7]
  901.                                 ->getTax();
  902.                         $abo_prices[7] = $abo_prices[7] + $lineitem->getPrice()->getTotalPrice();
  903.                         $net =
  904.                             $lineitem->getPrice()->getTotalPrice() -
  905.                             $lineitem
  906.                                 ->getPrice()
  907.                                 ->getCalculatedTaxes()
  908.                                 ->getElements()[7]
  909.                                 ->getTax();
  910.                     }
  912.                     $abo_price = $abo_price + $lineitem->getPrice()->getTotalPrice();
  913.                     $abo_net = $abo_net + $net;
  914.                 }
  915.             }
  917.             if (isset($cart_price->getCalculatedTaxes()->getElements()[19])) {
  918.                 $old_tax = $cart_price
  919.                     ->getCalculatedTaxes()
  920.                     ->getElements()[19]
  921.                     ->getTax();
  922.                 $old_price = $cart_price
  923.                     ->getCalculatedTaxes()
  924.                     ->getElements()[19]
  925.                     ->getPrice();
  927.                 $new_cart_tax = $old_tax - $abo_tax[19];
  928.                 $new_price = $old_price - $abo_prices[19];
  930.                 $cart_price
  931.                     ->getCalculatedTaxes()
  932.                     ->getElements()[19]
  933.                     ->setTax($new_cart_tax);
  934.                 $cart_price
  935.                     ->getCalculatedTaxes()
  936.                     ->getElements()[19]
  937.                     ->setPrice($new_price);
  938.             }
  940.             if (isset($cart_price->getCalculatedTaxes()->getElements()[7])) {
  941.                 $old_tax = $cart_price
  942.                     ->getCalculatedTaxes()
  943.                     ->getElements()[7]
  944.                     ->getTax();
  945.                 $old_price = $cart_price
  946.                     ->getCalculatedTaxes()
  947.                     ->getElements()[7]
  948.                     ->getPrice();
  950.                 $new_cart_tax = $old_tax - $abo_tax[7];
  951.                 $new_price = $old_price - $abo_prices[7];
  953.                 $cart_price
  954.                     ->getCalculatedTaxes()
  955.                     ->getElements()[7]
  956.                     ->setTax($new_cart_tax);
  957.                 $cart_price
  958.                     ->getCalculatedTaxes()
  959.                     ->getElements()[7]
  960.                     ->setPrice($new_price);
  961.             }
  963.             $new_cart_price = round($cart_price->getTotalPrice() - $abo_price, 2);
  964.             $new_raw_total_price = round($cart_price->getRawTotal() - $abo_price, 2);
  965.             $new_position_price = round($cart_price->getPositionPrice() - $abo_price, 2);
  967.             $new_cart_net = $cart_price->getNetPrice() - floatval($abo_net);
  968.             if ($new_cart_net < 0) {
  969.                 $new_cart_net = 0;
  970.             }
  971.             $cart_price->assign([
  972.                 'netPrice' => $new_cart_net,
  973.                 'totalPrice' => $new_cart_price,
  974.                 'positionPrice' => $new_position_price,
  975.                 'totalAboPrice' => $abo_price,
  976.                 'rawTotal' => $new_raw_total_price,
  977.             ]);
  978.         }
  979.     }
  981.     public function onOrderPlaced(CheckoutOrderPlacedEvent $event) {
  982.     }
  983. }
  985. function get_cross_selling_items($lineitems, $is_finish_page = false) {
  986.     $crossselling_return = [
  987.         'additional_items' => [],
  988.     ];
  989.     $line_item_ids = [];
  990.     foreach ($lineitems as $lineitem) {
  991.         if ($is_finish_page) {
  992.             $line_item_id = $lineitem->getProductId();
  993.         } else {
  994.             $line_item_id = $lineitem->getId();
  995.         }
  996.         $line_item_ids[] = $line_item_id;
  998.         if (!isset($_SESSION['cross_selling_items'][$line_item_id])) {
  999.             $url = 'https://' . $_SERVER['SERVER_NAME'] . '/product_api/get_cross_selling_by_prdouct_id.php';
  1000.             $curl = curl_init($url);
  1001.             curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
  1002.             curl_setopt($curl, CURLOPT_POST, true);
  1003.             curl_setopt($curl, CURLOPT_POSTFIELDS, ['line_item_id' => $line_item_id]);
  1005.             $additional_items = curl_exec($curl);
  1006.             curl_close($curl);
  1008.             $_SESSION['cross_selling_items'][$line_item_id] = json_decode($additional_items);
  1010.             $crossselling_return['additional_items'][$line_item_id] = json_decode($additional_items);
  1012.             if (isset($_GET['test']) && $_GET['test'] == 'additem') {
  1013.                 echo '<pre>hier<br>';
  1014.                 var_dump($lineitem);
  1015.                 echo '</pre>';
  1016.                 echo '<pre>hier<br>';
  1017.                 var_dump($url);
  1018.                 echo '</pre>';
  1019.                 echo '<pre>hier<br>';
  1020.                 var_dump($line_item_id);
  1021.                 echo '</pre>';
  1022.                 echo '<pre>hier<br>';
  1023.                 var_dump($crossselling_return);
  1024.                 echo '</pre>';
  1025.                 die();
  1026.             }
  1027.         } else {
  1028.             $crossselling_return['additional_items'][$line_item_id] =
  1029.                 $_SESSION['cross_selling_items'][$line_item_id];
  1030.         }
  1031.     }
  1033.     if (isset($_SESSION['cross_selling_items'])) {
  1034.         foreach ($_SESSION['cross_selling_items'] as $item_id => $item) {
  1035.             if (!in_array($item_id, $line_item_ids)) {
  1036.                 unset($_SESSION['cross_selling_items'][$item_id]);
  1037.             }
  1038.         }
  1039.     }
  1040.     if (isset($crossselling_return['additional_items'])) {
  1041.         foreach ($crossselling_return['additional_items'] as $item_id => $additional_items) {
  1042.             if (!is_null($additional_items)) {
  1043.                 foreach ($additional_items as $add_item_id => $additional_item) {
  1044.                     if (in_array($additional_item->id, $line_item_ids)) {
  1045.                         unset($crossselling_return['additional_items'][$item_id][$add_item_id]);
  1046.                     }
  1047.                 }
  1048.             }
  1049.         }
  1050.     }
  1051.     return $crossselling_return;
  1052. }