custom/plugins/DreiwmBrandstetterPlugin/src/Subscriber/BrandstetterSubscriber.php line 245

Open in your IDE?
  1. <?php
  3. namespace DreiwmBrandstetterPlugin\Subscriber;
  5. use DateMalformedStringException;
  6. use DateTime;
  7. use DreiwmBrandstetterPlugin\Core\Checkout\Cart\Custom\Error\CustomerTooLateForPackstationError;
  8. use DreiwmBrandstetterPlugin\DreiwmBrandstetterPlugin;
  9. use DreiwmBrandstetterPlugin\Service\DateValidator;
  10. use DreiwmBrandstetterPlugin\Service\PackingStationService;
  11. use Psr\Log\LoggerInterface;
  12. use Shopware\Core\Checkout\Cart\Event\AfterLineItemAddedEvent;
  13. use Shopware\Core\Content\Category\CategoryEvents;
  14. use Shopware\Core\Content\Product\Events\ProductListingCriteriaEvent;
  15. use Shopware\Core\Content\Product\Events\ProductListingResultEvent;
  16. use Shopware\Core\Content\Product\Events\ProductSearchCriteriaEvent;
  17. use Shopware\Core\Content\Product\ProductEntity;
  18. use Shopware\Core\Content\Product\SalesChannel\ProductListResponse;
  19. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductCollection;
  20. use Shopware\Core\Content\Seo\SeoUrlPlaceholderHandlerInterface;
  21. use Shopware\Core\Framework\Context;
  22. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  23. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  24. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\ContainsFilter;
  25. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  26. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  27. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  28. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\OrFilter;
  29. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\RangeFilter;
  30. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  31. use Shopware\Core\Framework\Log\LoggerFactory;
  32. use Shopware\Core\System\SalesChannel\Context\AbstractSalesChannelContextFactory;
  33. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextService;
  34. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  35. use Shopware\Storefront\Framework\Routing\RequestTransformer;
  36. use Shopware\Storefront\Framework\Routing\StorefrontResponse;
  37. use Shopware\Storefront\Page\GenericPageLoadedEvent;
  38. use Shopware\Storefront\Page\Navigation\NavigationPage;
  39. use Shopware\Storefront\Page\Navigation\NavigationPageLoadedEvent;
  40. use Shopware\Storefront\Page\Product\Configurator\ProductCombinationFinder;
  41. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  42. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  43. use Symfony\Component\HttpFoundation\RedirectResponse;
  44. use Symfony\Component\HttpFoundation\RequestStack;
  45. use Symfony\Component\HttpKernel\Event\RequestEvent;
  46. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  47. use Symfony\Component\HttpKernel\KernelEvents;
  48. use Symfony\Component\VarDumper\VarDumper;
  50. class BrandstetterSubscriber implements EventSubscriberInterface
  51. {
  52.     private RequestStack $requestStack;
  53.     private SeoUrlPlaceholderHandlerInterface $seoUrlPlaceholderHandler;
  55.     private EntityRepository $freeLockerRepository;
  56.     /**
  57.      * @deprecated tag:v6.5.0 - will be removed
  58.      */
  59.     private ProductCombinationFinder $productCombinationFinder;
  60.     private $salesChannelContextFactory;
  62.     private PackingStationService $packingStationService;
  63.     private DateValidator $dateValidator;
  64.     private LoggerInterface $logger;
  65.     private EntityRepository $productRepository;
  67.     public function __construct(
  68.         RequestStack $requestStack,
  69.         ProductCombinationFinder $productCombinationFinder,
  70.         SeoUrlPlaceholderHandlerInterface $seoUrlPlaceholderHandler,
  71.         AbstractSalesChannelContextFactory $salesChannelContextFactory,
  72.         PackingStationService $packingStationService,
  73.         $freeLockerRepository,
  74.         DateValidator $dateValidator,
  75.         EntityRepository $productRepository,
  76.         LoggerFactory $loggerFactory
  77.     ) {
  78.         $this->requestStack = $requestStack;
  79.         $this->productCombinationFinder = $productCombinationFinder;
  80.         $this->seoUrlPlaceholderHandler = $seoUrlPlaceholderHandler;
  81.         $this->salesChannelContextFactory = $salesChannelContextFactory;
  82.         $this->packingStationService = $packingStationService;
  83.         $this->freeLockerRepository = $freeLockerRepository;
  84.         $this->dateValidator = $dateValidator;
  85.         $this->productRepository = $productRepository;
  86.         $this->logger = $loggerFactory->createRotating('dreiwm_brandstetter_subscriber', 7);
  87.     }
  89.     public static function getSubscribedEvents(): array
  90.     {
  91.         return [
  92.             KernelEvents::REQUEST => 'setVariantIdToDisplayFilter',
  93.             KernelEvents::RESPONSE => 'setVariantIdToDisplay',
  94.             AfterLineItemAddedEvent::class => 'addPaketinLocker',
  95.             ProductListingCriteriaEvent::class => ['productListingResult', 500],
  96.         ];
  97.     }
  99.     /**
  100.      * Filtere die Produkte nach Verfügbarkeit
  101.      * @param ProductListingCriteriaEvent $event
  102.      * @return void
  103.      * @throws DateMalformedStringException
  104.      */
  105.     public function productListingResult(ProductListingCriteriaEvent $event): void
  106.     {
  107. //        return;
  108.         $this->frontendProductAssociation($event->getCriteria());
  109.         // reload the page
  111.         // --- 1. Wochentag aus dem aktuellen Datum ermitteln ---
  112.         // hole das aktuelle Datum aus dem Cookie
  113.         $currentDate = $this->requestStack->getCurrentRequest()->cookies->get('customerSelectedDate');
  115.         // hole die ausgewählte Versandart aus dem Cookie
  116.         $customerSelectedDeliveryId = $this->requestStack->getCurrentRequest()->cookies->get('customerSelectedDeliveryId');
  118.         // Wenn Post ausgewählt ist, dann setze das gewählte Datum auf heute
  119.         if ($customerSelectedDeliveryId == DreiwmBrandstetterPlugin::POST_ID) {
  120. //            return;
  121.             $currentDate = (new DateTime())->format('Y-m-d');
  122.         }
  124.         // wenn kein aktuelles Datum gesetzt ist und die Versandart nicht Post ist, dann breche ab
  125.         if ($currentDate == null && $customerSelectedDeliveryId !== DreiwmBrandstetterPlugin::POST_ID) {
  126.             return;
  127.         }
  129.         // Datum in DateTime umwandeln
  130.         $currentDate = (new DateTime($currentDate))->format('Y-m-d');
  132.         // Filtere Produkte mit Lagerbestand
  133.         $event->getCriteria()->addFilter(new EqualsFilter('product.available', 1));
  136.         // Erstelle ein DateTime-Objekt aus dem aktuellen Datum
  137.         $dt = new DateTime($currentDate);
  139.         // Ermittle den englischen Wochentag, z. B. "Mon", "Tue", etc.
  140.         $englishDay = $dt->format('D');
  142.         // Mappen des englischen Wochentags auf das deutsche Kürzel
  143.         $dayMap = [
  144.             'Mon' => 'Mo',
  145.             'Tue' => 'Di',
  146.             'Wed' => 'Mi',
  147.             'Thu' => 'Do',
  148.             'Fri' => 'Fr',
  149.             'Sat' => 'Sa',
  150.             'Sun' => 'So'
  151.         ];
  152.         $desiredDay = $dayMap[$englishDay] ?? null;
  153.         // --- 2. Gemeinsamer Datum-Filter ("common date filter") ---
  154.         // Dieser Filter deckt die üblichen Fälle ab, wie z.B.:
  155.         // - Produkte, die sowohl 'product_available_from' als auch 'product_available_until' gesetzt haben und in den Zeitraum fallen,
  156.         // - Produkte, bei denen nur eines der Felder gesetzt ist,
  157.         // - Produkte ohne beide Felder (immer verfügbar).
  158.         $commonDateFilter = new OrFilter([
  159.             // Fall 1: Beide Felder vorhanden und aktuelles Datum liegt dazwischen
  160.             new MultiFilter(MultiFilter::CONNECTION_AND, [
  161.                 new RangeFilter('customFields.product_available_from', [RangeFilter::LTE => $currentDate]),
  162.                 new RangeFilter('customFields.product_available_until', [RangeFilter::GTE => $currentDate]),
  163.             ]),
  164.             // Fall 2: Nur 'product_available_from' vorhanden
  165.             new MultiFilter(MultiFilter::CONNECTION_AND, [
  166.                 new RangeFilter('customFields.product_available_from', [RangeFilter::LTE => $currentDate]),
  167.                 new EqualsFilter('customFields.product_available_until', null),
  168.             ]),
  169.             // Fall 3: Nur 'product_available_until' vorhanden
  170.             new MultiFilter(MultiFilter::CONNECTION_AND, [
  171.                 new EqualsFilter('customFields.product_available_from', null),
  172.                 new RangeFilter('customFields.product_available_until', [RangeFilter::GTE => $currentDate]),
  173.             ]),
  174.             // Fall 4: Keine Datumsfelder gesetzt
  175.             new MultiFilter(MultiFilter::CONNECTION_AND, [
  176.                 new EqualsFilter('customFields.product_available_from', null),
  177.                 new EqualsFilter('customFields.product_available_until', null),
  178.             ]),
  179.         ]);
  181.         // --- 3. Filter für Produkte ohne baking_days (Gruppe A) ---
  182.         // Diese Produkte dürfen kein baking_days-Feld gesetzt haben und müssen nur den Datumskriterien genügen.
  183.         $filterWithoutBakingDays = new MultiFilter(MultiFilter::CONNECTION_AND, [
  184.             new EqualsFilter('customFields.baking_days', null),
  185.             $commonDateFilter,
  186.         ]);
  188.         // 4. Gruppe B (mit baking_days)
  189.         $filterWithBakingDays = new MultiFilter(MultiFilter::CONNECTION_AND, [
  190.             // baking_days gesetzt
  191.             new NotFilter(NotFilter::CONNECTION_AND, [
  192.                 new EqualsFilter('customFields.baking_days', null),
  193.             ]),
  194.             // enthält gewähltes Kürzel? (z. B. "Wed")
  195.             new ContainsFilter('customFields.baking_days', $desiredDay),
  196.             // Datumskriterien
  197.             $commonDateFilter,
  198.         ]);
  200.         // 5. Final immer beide Gruppen zusammenführen:
  201.         $finalFilter = new OrFilter([
  202.             $filterWithoutBakingDays,
  203.             $filterWithBakingDays,
  204.         ]);
  205.         $event->getCriteria()->addFilter($finalFilter);
  206.     }
  208.     private function loadProductCustomField(ProductListingCriteriaEvent $event, string $productNumber): array
  209.     {
  210.         // ganz simple EINE Abfrage nur für Debug:
  211.         $criteria = new Criteria();
  212.         $criteria->addFilter(new EqualsFilter('product.productNumber', $productNumber));
  213.         $criteria->addAssociation('customFields');
  214.         $product = $this->productRepository->search($criteria, $event->getContext())->first();
  215.         return $product ? $product->getCustomFields() : [];
  216.     }
  218.     /**
  219.      * Füge die Association für die Frontend-Produktanzeige hinzu
  220.      * @param $criteria
  221.      */
  222.     private function frontendProductAssociation($criteria): void
  223.     {
  224.         $criteria->addAssociation('properties');
  225.         $criteria->addAssociation('properties.group');
  226.     }
  228.     /**
  229.      * Erstelle einen SalesChannelContext
  230.      * @param string $salesChannelId
  231.      * @param string $languageId
  232.      * @return SalesChannelContext $salesChannelContext
  233.      */
  234.     public function createSalesChannelContext(string $salesChannelId, string $languageId): SalesChannelContext
  235.     {
  236.         return $this->salesChannelContextFactory->create('', $salesChannelId,
  237.             [SalesChannelContextService::LANGUAGE_ID => $languageId]);
  238.     }
  240.     /**
  241.      * Leite auf der Detail-Seite um, wenn eine Variante ausgewählt wurde.
  242.      * @param ResponseEvent $event
  243.      * @return void
  244.      */
  245.     public function setVariantIdToDisplay(ResponseEvent $event): void
  246.     {
  247.         // prüfe ob die Route frontend.detail.page ist
  248.         $currentRoute = $event->getRequest()->attributes->get('_route');
  250.         // wenn nicht -> nicht weiterleiten
  251.         if ($currentRoute !== 'frontend.detail.page') {
  252.             return;
  253.         }
  255.         /**@var StorefrontResponse $storefrontResponse */
  256.         $storefrontResponse = $event->getResponse();
  257.         if ($storefrontResponse->getStatusCode() !== 200) {
  258.             return;
  259.         }
  260.         // hole die parentId aus der Route
  261.         $parentProductId = $storefrontResponse->getData()['page']->getProduct()->getParentId();
  262.         // hole die productId aus der Route
  263.         $currentProductId = $storefrontResponse->getData()['page']->getProduct()->getId();
  264.         // wenn parentId == null -> dann ist es ein Produkt ohne Varianten -> nicht weiterleiten
  265.         if ($parentProductId == null) {
  266.             return;
  267.         }
  268.         // SalesChannelContext holen
  269.         $salesChannelContext = $event->getRequest()->attributes->get('sw-sales-channel-context');
  270.         // schaue, welche Variante im Cookie gespeichert ist
  271.         $variantIdToDisplay = $this->requestStack->getCurrentRequest()->cookies->get('variantIdToDisplay');
  272.         // wenn keine Variante im Cookie gespeichert ist -> nicht weiterleiten
  273.         if ($variantIdToDisplay == null) {
  274.             return;
  275.         }
  276.         // setze die PropertyGroup und die Optionen für den ProductCombinationFinder um die richtige Variante zu finden
  277.         $options = [
  278.             DreiwmBrandstetterPlugin::PROPERTY_GROUP_ID => $variantIdToDisplay,
  279.         ];
  280.         // hole das gefundene Produkt
  281.         $finderResponse = $this->productCombinationFinder->find(
  282.             $parentProductId,
  283.             DreiwmBrandstetterPlugin::PROPERTY_GROUP_ID,
  284.             $options ?? [],
  285.             $salesChannelContext
  286.         );
  287.         
  288.         $parentProductId = $finderResponse->getVariantId();
  289.         // gefundenes Produkt ist das aktuelle Produkt -> leite nicht um
  290.         if ($parentProductId == $currentProductId) {
  291.             return;
  292.         }
  293.         // redirect to the new URL
  294.         $host = $this->requestStack->getCurrentRequest()->attributes->get(RequestTransformer::SALES_CHANNEL_ABSOLUTE_BASE_URL)
  295.             . $this->requestStack->getCurrentRequest()->attributes->get(RequestTransformer::SALES_CHANNEL_BASE_URL);
  296.         $url = $this->seoUrlPlaceholderHandler->replace(
  297.             $this->seoUrlPlaceholderHandler->generate(
  298.                 'frontend.detail.page',
  299.                 ['productId' => $parentProductId]
  300.             ),
  301.             $host,
  302.             $salesChannelContext
  303.         );
  304.         $response = new RedirectResponse($url);
  305.         $event->setResponse($response);
  306.     }
  308.     /**
  309.      * Wähle die Variante aus, die angezeigt werden soll. Die ausgewählte Variante wird in einem Cookie gespeichert.
  310.      * Greift auf der Listing-Seite
  311.      * @param RequestEvent $event
  312.      */
  313.     public function setVariantIdToDisplayFilter(RequestEvent $event): void
  314.     {
  315.         // hole das Cookie für die ausgewählte Variante
  316.         $variantIdToDisplay = $this->requestStack->getCurrentRequest()->cookies->get('variantIdToDisplay');
  317.         // hole das Cookie für die ausgewählte Versandart
  318.         $customerAvailableShippingMethodPropertyId = $this->requestStack->getCurrentRequest()->cookies->get('customerAvailableShippingMethodProperty');
  319.         // wird für das Listing benötigt
  320.         // nur ausführen, wenn die ausgewählte Variante und die ausgewählte Versandart gesetzt sind
  321.         if ($variantIdToDisplay and $customerAvailableShippingMethodPropertyId) {
  322.             // hole die Properties aus der URL
  323.             $lx_properties = $event->getRequest()->query->get('properties');
  324.             // wenn Properties gesetzt sind, dann hänge die ausgewählte Variante und die ausgewählte Versandart an
  325.             if ($lx_properties !== null) {
  326.                 $ls_properties = $lx_properties . '|' . $variantIdToDisplay . '|' . $customerAvailableShippingMethodPropertyId . '|';
  327.                 // wenn Properties nicht gesetzt sind, dann hänge nur die ausgewählte Variante und die ausgewählte Versandart an
  328.             } else {
  329.                 $ls_properties = $variantIdToDisplay . '|' . $customerAvailableShippingMethodPropertyId . '|';
  330.             }
  331.             if ($ls_properties !== '') {
  332.                 $event->getRequest()->query->set('properties', $ls_properties);
  333.             }
  334.         }
  335.     }
  337.     /**
  338.      * Beim Hinzufügen eines Produkts zum Warenkorb wird geprüft, ob es sich um eine Paketstation handelt.
  339.      * Wenn ja, wird ein Fach reserviert und die Daten in der Datenbank gespeichert
  340.      * @param AfterLineItemAddedEvent $event
  341.      * @return void
  342.      * @throws \Exception
  343.      */
  344.     public function addPaketinLocker(AfterLineItemAddedEvent $event): void
  345.     {
  346.         $shippingMethodId = $event->getCart()->getDeliveries()->first()->getShippingMethod()->getId();
  347.         // wenn nicht Paketstation → nichts machen
  348.         if ($shippingMethodId !== DreiwmBrandstetterPlugin::PAKETSTATION_ID) {
  349.             return;
  350.         }
  351.         // hole das Datum aus dem Cookie
  352.         $desiredDate = $this->requestStack->getCurrentRequest()->cookies->get('customerSelectedDate');
  353.         // prüfe, ob schon ein Fach reserviert wurde
  354.         $context = Context::createDefaultContext();
  355.         $criteria = new Criteria();
  356.         // filtere nach dem Cart-Token und dem Datum
  357.         $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_AND, [
  358.             new EqualsFilter('date', $desiredDate),
  359.             new EqualsFilter('cartToken', $event->getCart()->getToken()),
  360.         ]));
  361.         $reservedLocker = $this->freeLockerRepository->searchIds($criteria, $context)->firstId();
  362.         // wenn schon ein Fach reserviert wurde → nichts machen
  363.         if ($reservedLocker) {
  364.             return;
  365.         }
  366.         // alle Datensätze löschen, die den gleichen Cart-Token haben aber ein anderes Datum
  367.         $deleteCriteria = new Criteria();
  368.         $deleteCriteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_AND, [
  369.             new EqualsFilter('cartToken', $event->getCart()->getToken()),
  370.             new NotFilter(NotFilter::CONNECTION_AND, [
  371.                 new EqualsFilter('date', $desiredDate),
  372.             ]),
  373.         ]));
  375.         $dataToDelete = $this->freeLockerRepository->search($deleteCriteria, $context);
  376.         if($dataToDelete->count() > 0) {
  377.             // gehe die Einträge durch. Jeder Eintrag enthält die Daten für ein Fach
  378.             foreach ($dataToDelete as $entry) {
  379.                 $pinsToDelete = [$entry->getMerchantPin(), $entry->getCustomerPin()];
  380.                 // lösche die Pins für das Fach
  381.                 $this->packingStationService->deletePins($entry->getBoxId(),$pinsToDelete);
  382.                 // lösche den Eintrag in der Tabelle dreiwm_free_locker
  383.                 $this->freeLockerRepository->delete([['id' => $entry->getId()]], $context);
  384.             }
  385.         }
  387.         // reserviere ein Fach
  388.         $reservedLockerData = $this->packingStationService->reservePaketinLockerOnDate(new DateTime($desiredDate),
  389.             $event->getCart()->getToken());
  390.         // wenn kein Fach reserviert werden konnte → Fehlermeldung
  391.         if ($reservedLockerData == null) {
  392.             // Fehlermeldung CustomerTooLateForPackstationError
  393.             $event->getCart()->addErrors(new CustomerTooLateForPackstationError());
  394.             return;
  395.         }
  396.         // speichere das Cart-Token in 3wmfreelocker
  397.         $this->freeLockerRepository->upsert([
  398.             [
  399.                 'cartToken' => $event->getCart()->getToken(),
  400.                 'boxId' => $reservedLockerData['boxId'],
  401.                 'boxName' => $reservedLockerData['boxName'],
  402.                 'merchantPin' => $reservedLockerData['merchantPin'],
  403.                 'customerPin' => $reservedLockerData['customerPin'],
  404.                 'date' => $desiredDate,
  405.                 'freeLocker' => 1,
  406.             ]
  407.         ], $context);
  408.     }
  409. }