custom/plugins/MyCustomFieldNotifier/src/Subscriber/OrderCustomFieldChangeSubscriber.php line 641

Open in your IDE?
  1. <?php
  3. namespace MyCustomFieldNotifier\Subscriber;
  5. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Component\Mailer\MailerInterface;
  8. use Symfony\Component\Mime\Email;
  9. use Psr\Log\LoggerInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  11. use Shopware\Core\Framework\Context;
  13. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  16. use Shopware\Core\Checkout\Cart\Order\CartConvertedEvent;
  17. use Symfony\Component\HttpFoundation\RequestStack;
  19. use Symfony\Component\Routing\RouterInterface;
  21. use Shopware\Storefront\Page\GenericPageLoadedEvent;
  22. use Shopware\Core\System\SystemConfig\SystemConfigService;
  23. use Shopware\Core\Framework\Struct\ArrayStruct;
  25. use Shopware\Core\Framework\Api\Event\SearchCriteriaEvent;
  26. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  28. use src\Core\Content\Cms\CmsPageEvents;
  29. use src\Core\Content\Cms\Events\CmsPageLoadedEvent;
  31. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntitySearchedEvent;
  32. use Shopware\Core\Checkout\Order\OrderDefinition;
  33. use Shopware\Core\Framework\Api\Context\AdminApiSource;
  35. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntitySearchRequestEvent;
  36. use Shopware\Core\System\Tag\Aggregate\TagEntity;
  38. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  40. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  42. class OrderCustomFieldChangeSubscriber implements EventSubscriberInterface
  43. {
  44.     private MailerInterface $mailer;
  45.     private LoggerInterface $logger;
  46.     private EntityRepositoryInterface $orderRepository;
  48.     private RequestStack $requestStack;
  50.     private SystemConfigService $configService;
  52.     private EntityRepository $userRepository;
  54.     public function __construct(
  55.         MailerInterface $mailer,
  56.         LoggerInterface $logger,
  57.         EntityRepositoryInterface $orderRepository,
  58.         RequestStack $requestStack,
  59.         RouterInterface $router,
  60.         SystemConfigService $configService,
  61.         EntityRepository $userRepository
  62.     ) {
  63.         $this->mailer = $mailer;
  64.         $this->logger = $logger;
  65.         $this->orderRepository = $orderRepository;
  66.         $this->requestStack = $requestStack;
  67.         $this->router = $router;
  68.         $this->configService = $configService;
  69.         $this->userRepository = $userRepository;
  70.     }
  72.     public static function getSubscribedEvents(): array
  73.     {
  74.         return [
  75.             'order.written' => 'onOrderWritten',
  76.             CheckoutOrderPlacedEvent::class => 'onCheckoutOrderPlaced',
  77.             CartConvertedEvent::class => 'addCustomFieldsToOrder',
  78.             GenericPageLoadedEvent::class => 'onGenericPageLoaded',
  79.             SearchCriteriaEvent::class => 'onSearchCriteria',
  80.             'cms_page.loaded' => 'onCMSPageLoaded',
  81.             EntitySearchedEvent::class => 'onEntitySearched',
  82.             'order.search.request' => 'onOrderSearchRequest',
  84.         ];
  85.     }
  87. // NEW START
  88. //     public function onOrderWritten(EntityWrittenEvent $event): void
  89. //     {
  90. //         $this->logger->info('TEST23 ENTERED onOrderWritten()');
  92. //         foreach ($event->getWriteResults() as $writeResult) {
  93. //             $payload = $writeResult->getPayload();
  95. //             $this->logger->info('TEST23 ENTERED foreach ($event->getWriteResults()');
  96. //             $payloadString = print_r($payload, true);
  97. //             $this->logger->info('TEST234 $writeResult->getPayload() {payloadString}', [
  98. //                 'payloadString' => $payloadString,
  99. //             ]);
  100.             
  101. //             if ($writeResult->getChangeSet()) {
  102. //                 $this->logger->info('TEST234 $writeResult->getChangeSet(): {changeSetString}', [
  103. //                     'changeSetString' => $writeResult->getChangeSet(),
  104. //                 ]);
  105. //             } else {
  106. //                 $this->logger->info('TEST234 ChangeSet IS EMPTY');
  107. //             }
  109. //             // Check if the custom field is present in the payload
  110. //             if (isset($payload['customFields']['custom_downloads_testfield'])) {
  111. //                 $newValue = $payload['customFields']['custom_downloads_testfield'];
  113. //                 // Get the changeset to compare old and new values
  114. //                 $changeSet = $writeResult->getChangeSet();
  117. //                 // if ( !$changeSet ) {$this->logger->info('TEST234 CHANGESET is EMPTY');}
  118.                 
  120. //                 $changeSetString = print_r($changeSet, true);
  121. //                 $this->logger->info('TEST234 $writeResult->getChangeSet(): {changeSetString}', [
  122. //                     'changeSetString' => $changeSetString,
  123. //                 ]);
  125. //                 $this->logger->info('TEST234 $writeResult->getChangeSet(): {changeSet}', [
  126. //                     'changeSet' => $changeSet,
  127. //                 ]);
  130. //                 if ($changeSet) {
  131. //                     $this->logger->info('ChangeSet detected');
  132. //                     $oldValue = $changeSet->getBefore('customFields')['custom_downloads_testfield'] ?? null;
  134. //                     if ($oldValue !== $newValue) {
  135. //                         // Custom field value has actually changed
  136. //                         $this->logger->info('TEST23 Custom field updated', [
  137. //                             'oldValue' => $oldValue,
  138. //                             'newValue' => $newValue,
  139. //                         ]);
  141. //                         // Send an email to the customer (for demonstration purposes, using dummy email)
  142. //                         $email = (new Email())
  143. //                             ->from('noreply@comentire.de')
  144. //                             ->to('szymanski@comentire.de')  // Replace with actual customer email
  145. //                             ->subject('Your order has been updated')
  146. //                             ->text(sprintf(
  147. //                                 'Dear customer,
  149. // Your order custom field "custom_downloads_testfield" has been updated.
  151. // Old Value: %s
  152. // New Value: %s
  154. // Thank you for your business!
  156. // Best regards,
  157. // Your Company',
  158. //                                 $oldValue,
  159. //                                 $newValue
  160. //                             ));
  162. //                         $this->mailer->send($email);
  163. //                     }
  164. //                 }
  165. //             }
  166. //         }
  167. //     }    
  168. // NEW END    
  170. // OLD START
  171.     public function onOrderWritten(EntityWrittenEvent $event): void
  172.     {
  173.         $this->logger->info('TEST23 ENTERED onOrderWritten() TEST24TEST24TEST24TEST24TEST24TEST24');
  174.         $this->logger->info('TEST23 ENTERED onOrderWritten()');
  176.         foreach ($event->getPayloads() as $payload) {
  177.             if ((isset($payload['customFields']['custom_downloads_download_1']) || isset($payload['customFields']['custom_downloads_download_2'])) && isset($payload['updatedById'])) {
  178.                 $orderId = $payload['id'];
  179.                 // $this->logger->info('TEST23 Order custom field change detected', [
  180.                 //     'customFieldName' => 'custom_downloads_testfield',
  181.                 //     'newValue' => $payload['customFields']['custom_downloads_testfield'],
  182.                 //     'orderId' => $orderId,
  183.                 // ]);
  185.                 // Fetch the order to get customer data
  186.                 $criteria = new \Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria([$orderId]);
  187.                 $criteria->addAssociation('orderCustomer'); // Load customer data
  189.                 $order = $this->orderRepository->search($criteria, Context::createDefaultContext())->first();
  191.                 if ($order) {
  192.                     $customerEmail = $order->getOrderCustomer()->getEmail();
  193.                     $orderNumber = $order->getOrderNumber(); // Retrieve the order number
  194.                     // $url = $this->router->generate('frontend.account.order.page', ['orderNumber' => $orderNumber], RouterInterface::ABSOLUTE_URL);
  195.                     $this->logger->info('TEST23 Customer email found for order', ['email' => $customerEmail]);
  198.                     $deepLinkCode = $order->getDeepLinkCode();
  199.                     $url = $this->router->generate(
  200.                         'frontend.account.order.page',
  201.                         [],
  202.                         RouterInterface::ABSOLUTE_URL
  203.                     );
  204.                     $url .= "/" . $deepLinkCode;
  207.                     $email = (new Email())
  208.                         ->from('noreply@sw6afg.ce1.eu')
  209.                         ->to($customerEmail)
  210.                         ->subject('New document available')
  211.                         ->text(sprintf(
  212.                             'Hello %s %s,
  214. New documents have been added to your orders / ordered products.
  216. The download section in your order (Order Number: %s) was changed.
  218. Please log in to retrieve them:
  220. %s
  222. You can check your order status at any time in your account under “Orders”.
  224. If you have any questions, please do not hesitate to contact us.
  226. With kind regards,
  227. Your AUTOFLUG FLYWEIGHT® Team',
  228.                             $order->getOrderCustomer()->getFirstName(),
  229.                             $order->getOrderCustomer()->getLastName(),
  230.                             $orderNumber,
  231.                             $url,
  232.                         ));
  234.                     // Convert payload to a readable format
  235.                     $payloadString = print_r($payload, true);
  237.                     $this->mailer->send($email);
  239.                     $email = (new Email())
  240.                         ->from('noreply@comentire.de')
  241.                         ->addTo('szymanski@comentire.de')
  242.                         ->subject('Order Custom Field Updated')
  243.                         ->text(sprintf(
  244.                             'FOR USER: %s ORDER NUMBER: %s A custom field in your order was updated. PAYLOAD: %s',
  245.                             $customerEmail,
  246.                             $orderNumber,
  247.                             $payloadString
  248.                         ));
  250.                     $this->mailer->send($email);
  252.                 } else {
  253.                     $this->logger->warning('Order not found for ID', ['orderId' => $orderId]);
  254.                 }
  255.             }
  257.             // if (isset($payload['customFields']['custom_downloads_download_1']) && isset($payload['updatedById'])) {
  258.             //     $orderId = $payload['id'];
  259.             //     $this->logger->info('TEST23 Order custom field change detected', [
  260.             //         'customFieldName' => 'custom_downloads_testfield',
  261.             //         'newValue' => $payload['customFields']['custom_downloads_download_1'],
  262.             //         'orderId' => $orderId,
  263.             //     ]);
  265.             //     // Fetch the order to get customer data
  266.             //     $criteria = new \Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria([$orderId]);
  267.             //     $criteria->addAssociation('orderCustomer'); // Load customer data
  269.             //     $order = $this->orderRepository->search($criteria, Context::createDefaultContext())->first();
  271.             //     if ($order) {
  272.             //         $customerEmail = $order->getOrderCustomer()->getEmail();
  273.             //         $orderNumber = $order->getOrderNumber(); // Retrieve the order number
  274.             //         $this->logger->info('TEST23 Customer email found for order', ['email' => $customerEmail]);
  276.             //         $email = (new Email())
  277.             //             ->from('noreply@comentire.de')
  278.             //             ->to($customerEmail)
  279.             //             ->subject('Order Custom Field Updated')
  280.             //             ->text(sprintf(
  281.             //                 'Dear customer,',
  282.             //                 $orderNumber,
  283.             //                 'custom_downloads_download_1',
  284.             //                 $payload['customFields']['custom_downloads_download_1']
  285.             //             ));
  287.             //         // Convert payload to a readable format
  288.             //         $payloadString = print_r($payload, true);
  290.             //         $this->mailer->send($email);
  292.             //         $email = (new Email())
  293.             //             ->from('noreply@comentire.de')
  294.             //             ->addTo('szymanski@comentire.de')
  295.             //             ->subject('Order Custom Field Updated')
  296.             //             ->text(sprintf(
  297.             //                 'FOR USER: %s ORDER NUMBER: %s The custom field "%s" in your order was updated. New value: %s PAYLOAD: %s',
  298.             //                 $customerEmail,
  299.             //                 $orderNumber,
  300.             //                 'custom_downloads_download_1',
  301.             //                 $payload['customFields']['custom_downloads_download_1'],
  302.             //                 $payloadString
  303.             //             ));
  305.             //         $this->mailer->send($email);
  307.             //     } else {
  308.             //         $this->logger->warning('Order not found for ID', ['orderId' => $orderId]);
  309.             //     }
  310.             // }
  312.             // if (isset($payload['customFields']['custom_downloads_download_2']) && isset($payload['updatedById'])) {
  313.             //     $orderId = $payload['id'];
  314.             //     $this->logger->info('TEST23 Order custom field change detected', [
  315.             //         'customFieldName' => 'custom_downloads_download_2',
  316.             //         'newValue' => $payload['customFields']['custom_downloads_download_2'],
  317.             //         'orderId' => $orderId,
  318.             //     ]);
  320.             //     // Fetch the order to get customer data
  321.             //     $criteria = new \Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria([$orderId]);
  322.             //     $criteria->addAssociation('orderCustomer'); // Load customer data
  324.             //     $order = $this->orderRepository->search($criteria, Context::createDefaultContext())->first();
  326.             //     if ($order) {
  327.             //         $customerEmail = $order->getOrderCustomer()->getEmail();
  328.             //         $orderNumber = $order->getOrderNumber(); // Retrieve the order number
  329.             //         $this->logger->info('TEST23 Customer email found for order', ['email' => $customerEmail]);
  331.             //         $email = (new Email())
  332.             //             ->from('noreply@comentire.de')
  333.             //             ->to($customerEmail)
  334.             //             ->subject('Order Custom Field Updated')
  335.             //             ->text(sprintf(
  336.             //                 'Dear customer,',
  337.             //                 $orderNumber,
  338.             //                 'custom_downloads_download_2',
  339.             //                 $payload['customFields']['custom_downloads_download_2']
  340.             //             ));
  342.             //         // Convert payload to a readable format
  343.             //         $payloadString = print_r($payload, true);
  345.             //         $this->mailer->send($email);
  347.             //         $email = (new Email())
  348.             //             ->from('noreply@comentire.de')
  349.             //             ->addTo('szymanski@comentire.de')
  350.             //             ->subject('Order Custom Field Updated')
  351.             //             ->text(sprintf(
  352.             //                 'FOR USER: %s ORDER NUMBER: %s The custom field "%s" in your order was updated. New value: %s PAYLOAD: %s',
  353.             //                 $customerEmail,
  354.             //                 $orderNumber,
  355.             //                 'custom_downloads_download_2',
  356.             //                 $payload['customFields']['custom_downloads_download_2'],
  357.             //                 $payloadString
  358.             //             ));
  360.             //         $this->mailer->send($email);
  362.             //     } else {
  363.             //         $this->logger->warning('Order not found for ID', ['orderId' => $orderId]);
  364.             //     }
  365.             // }
  366.         }
  367.     }
  368. // OLD END
  371.     public function onCheckoutOrderPlaced(CheckoutOrderPlacedEvent $event): void
  372.     {
  373.         $this->logger->info('TEST233 ENTERED onCheckoutOrderPlaced()');
  375.         // FIRST TRY START //
  376.         // $order = $event->getOrder();
  377.         // $customFields = $event->getContext()->getRequestDataBag()->get('customFields');
  379.         // if (!empty($customFields['custom_order_fields_customer_reference_ID'])) {
  380.         //     $this->orderRepository->update([
  381.         //         [
  382.         //             'id' => $order->getId(),
  383.         //             'customFields' => [
  384.         //                 'custom_order_fields_customer_reference_ID' => $customFields['custom_order_fields_customer_reference_ID']
  385.         //             ],
  386.         //         ],
  387.         //     ], $event->getContext());
  388.         // }
  389.         // FIRST TRY END //
  395.         // SECOND TRY START //
  396.         // $orderId = $event->getOrderId();
  397.         // $context = $event->getContext();
  399.         // // Fetch the order using its ID
  400.         // $criteria = new Criteria([$orderId]);
  401.         // $order = $this->orderRepository->search($criteria, $context)->first();
  403.         // if (!$order) {
  404.         //     return;
  405.         // }
  407.         // // Get custom field data from request
  408.         // $customFields = $event->getContext()->getRequestDataBag()->get('customFields');
  410.         // if (!empty($customFields['custom_order_fields_customer_reference_ID'])) {
  411.         //     $this->orderRepository->update([
  412.         //         [
  413.         //             'id' => $orderId,
  414.         //             'customFields' => array_merge($order->getCustomFields() ?? [], [
  415.         //                 'custom_order_fields_customer_reference_ID' => $customFields['custom_order_fields_customer_reference_ID']
  416.         //             ]),
  417.         //         ],
  418.         //     ], $context);
  419.         // }   
  420.         // SECOND TRY END //
  424.         $orderId = $event->getOrderId();
  425.         $context = $event->getContext();
  427.         // Fetch the order using its ID
  428.         $criteria = new Criteria([$orderId]);
  429.         $criteria->addAssociation('orderCustomer'); // Ensure order data is fully loaded
  430.         $order = $this->orderRepository->search($criteria, $context)->first();
  432.         if (!$order) {
  433.             return;
  434.         }
  436.         // Retrieve existing custom fields
  437.         $existingCustomFields = $order->getCustomFields() ?? [];
  438.         if ($order->getCustomFields()) {
  439.             $this->logger->info('TEST233 FOUND $order->getCustomFields()', ['$order->getCustomFields()' => $order->getCustomFields()]);
  440.             //$this->logger->info('TEST23 Customer email found for order', ['email' => $customerEmail]);
  441.         }
  442.         else {
  443.             $this->logger->info('TEST233 NOT FOUND $order->getCustomFields()');
  444.         }
  445.         if ($order) {
  446.             $this->logger->info('TEST233 FOUND $order', ['$order' => $order]);
  447.         }
  448.         else {
  449.             $this->logger->info('TEST233 NOT FOUND $order');
  450.         }        
  452.         // Ensure the field exists before modifying
  453.         // if (!isset($existingCustomFields['custom_order_fields_customer_reference_ID'])) {
  454.         //     return;
  455.         // }
  456.         // else {
  457.         //     $this->logger->info('TEST23 FOUND custom_order_fields_customer_reference_ID found');
  458.         // }
  460.         // // Example: Modify the custom field (if needed)
  461.         // $existingCustomFields['custom_order_fields_customer_reference_ID'] .= ' - Processed';
  466.         //TODO DELETE THIS START
  467.         // foreach ($event->getPayloads() as $payload) {
  468.         //     if ( isset($payload['customFields']['custom_order_fields_customer_reference_ID']) ) {
  469.         //         $this->logger->info('TEST233 FOUND custom_order_fields_customer_reference_ID');
  470.         //     }
  471.         // }
  473.         $this->logger->info('TEST233 EVENT: ', ['$event->getOrder()' => $event->getOrder()] );
  474.         $this->logger->info('TEST233 EVENT: ', ['$event->getAvailableData()' => $event->getAvailableData()] );
  475.         $this->logger->info('TEST233 EVENT: ', ['$event->getContext()' => $event->getContext()] );
  477.         $existingCustomFields = [
  478.             "foo" => "bar",
  479.             "bar" => "foo",
  480.             "custom_order_fields_customer_reference_ID" => "#TEST@@@2324",
  481.         ];
  482.         //TODO DELETE THIS END
  484.         // // Update the order with the modified custom field
  485.         // $this->orderRepository->update([
  486.         //     [
  487.         //         'id' => $orderId,
  488.         //         'customFields' => $existingCustomFields,
  489.         //     ],
  490.         // ], $context);
  492.         $this->logger->info('TEST233 FOUND $order', ['$order' => $order]);
  493.         $this->logger->info('TEST233 FOUND $order', ['$order' => $this->orderRepository->search($criteria, $context)->first()]);
  495.     }
  499.     public function addCustomFieldsToOrder(CartConvertedEvent $event): void
  500.     {
  501.         $this->logger->info('Subscriber triggered: ');
  502.         dump('Subscriber triggered: ');
  503.         $orderData = $event->getConvertedCart();
  504.         $orderCustomFields = $orderData['customFields'] ?? [];
  506.        $customerReferenceID = $this->requestStack->getCurrentRequest()->request->get('custom_order_fields_customer_reference_ID');
  508.         if ($customerReferenceID) {
  509.             $orderCustomFields['custom_order_fields_customer_reference_ID'] = $customerReferenceID;
  510.         }
  512.         $orderData['customFields'] = $orderCustomFields;
  518.        // $customerReferenceID = $this->requestStack->getCurrentRequest()->request->get('custom_order_fields_comment');
  520.        //  if ($customerReferenceID) {
  521.        //      $orderCustomFields['custom_order_fields_test_textarea'] = $customerReferenceID;
  522.        //  }
  524.        //  $orderData['customFields'] = $orderCustomFields;
  530.         $event->setConvertedCart($orderData);
  531.     }
  533.     // make basicInformation.email accessible in the frontend
  534.     public function onGenericPageLoaded(GenericPageLoadedEvent $event): void
  535.     {
  536.         $this->logger->info( 'Subscriber triggered: onGenericPageLoaded() ');
  537.         $salesChannelId = $event->getSalesChannelContext()->getSalesChannelId();
  538.         $email = $this->configService->get('core.basicInformation.email', $salesChannelId);
  540.         $event->getPage()->addExtension('shopEmail', new ArrayStruct([
  541.             'email' => $email
  542.         ]));
  543.     }
  546.     public function onOrderSearchRequest(EntitySearchRequestEvent $event): void
  547.     {
  548.         $this->logger->info( 'Subscriber triggered: onOrderSearchRequest() ');
  549.         $request = $this->requestStack->getCurrentRequest();
  550.         $context = $request->attributes->get('sw-context');
  551.         $source = $context->getSource();
  553.         if (!$source || $source->getType() !== 'admin') {
  554.             return;
  555.         }
  557.         $user = $source->getUser();
  558.         if (!$user) {
  559.             return;
  560.         }
  562.         // Check for a specific ACL role
  563.         $hasRole = false;
  564.         foreach ($user->getAclRoles()->getElements() ?? [] as $role) {
  565.             if ($role->getName() === 'testFirma-MRO') {
  566.                 $hasRole = true;
  567.                 break;
  568.             }
  569.         }
  571.         if (!$hasRole) {
  572.             return;
  573.         }
  575.         // Apply filter: orders where customer has tag "VIP"
  576.         $criteria = $event->getCriteria();
  578.         // Add customer and tags associations
  579.         $criteria->addAssociation('orderCustomer.customer.tags');
  581.         // Filter by customer tag name (make sure it matches exactly)
  582.         $criteria->addFilter(
  583.             new EqualsFilter('orderCustomer.customer.tags.name', 'testFirma-mro-visible')
  584.         );
  585.     }    
  587.     public function onSearchCriteria(SearchCriteriaEvent $event): void
  588.     {
  589.         $this->logger->info( 'Subscriber triggered: onSearchCriteria() ');
  590.         // Only act on the "order" entity
  591.         if ($event->getDefinition()->getEntityName() !== 'order') {
  592.             return;
  593.         }
  595.         $context = $event->getContext();
  596.         $source = $context->getSource();
  598.         if ($source->getType() !== 'admin') {
  599.             return;
  600.         }
  602.         $user = $source->getUser();
  603.         if (!$user) {
  604.             return;
  605.         }
  607.         // Check if the user has the specific role
  608.         $hasRole = false;
  609.         $aclRoles = $user->getAclRoles();
  611.         if ($aclRoles !== null) {
  612.             foreach ($aclRoles->getElements() as $role) {
  613.                 if ($role->getName() === 'order_view_customer_tag_vip') {
  614.                     $hasRole = true;
  615.                     break;
  616.                 }
  617.             }
  618.         }
  620.         if (!$hasRole) {
  621.             return;
  622.         }
  624.         // Apply filter: only show orders where customer has tag "VIP"
  625.         $criteria = $event->getCriteria();
  627.         // Include the customer tag association
  628.         $criteria->addAssociation('orderCustomer.customer.tags');
  630.         // Filter orders by customer tag
  631.         $criteria->addFilter(
  632.             new EqualsFilter('orderCustomer.customer.tags.name', 'VIP')
  633.         );
  634.     }
  636.     public function onCMSPageLoaded(): void
  637.     {
  638.         $this->logger->info( 'Subscriber triggered: onCMSPageLoaded() ');
  639.     }
  641.     public function onEntitySearched(EntitySearchedEvent $event): void
  642.     {
  643.         $this->logger->info( 'Subscriber triggered: onEntitySearched() ');
  645.         // Only act on orders
  646.         if (!$event->getDefinition() instanceof OrderDefinition) {
  647.             return;
  648.         }
  650.         $context = $event->getContext();
  651.         $source = $context->getSource();
  653.         // Only apply in Admin API
  654.         if (!$source instanceof AdminApiSource) {
  655.             return;
  656.         }
  658.         $userId = $source->getUserId();
  660.         if (!$userId) {
  661.             return;
  662.         }
  664.         // Load user with ACL roles
  665.         $criteria = new Criteria([$userId]);
  666.         $criteria->addAssociation('aclRoles');
  668.         /** @var \Shopware\Core\System\User\UserEntity|null $user */
  669.         $user = $this->userRepository->search($criteria, $context)->first();
  671.         if (!$user) {
  672.             return;
  673.         }
  675.         // // Check for specific role
  676.         // $hasRole = false;
  677.         // $aclRoles = $user->getAclRoles();
  679.         // if ($aclRoles !== null) {
  680.         //     foreach ($aclRoles->getElements() as $role) {
  681.         //         if ($role->getName() === 'testFirma-MRO') {
  682.         //             $hasRole = true;
  683.         //             break;
  684.         //         }
  685.         //     }
  686.         // }
  688.         // if (!$hasRole) {
  689.         //     return;
  690.         // }
  692.         // // Correct way: add filter to criteria!
  693.         // $criteria = $event->getCriteria();
  695.         // // Example filter: orders whose customers have tag 'VIP'
  696.         // // Here you would need to filter by customer tag, but customer tags are in a related entity
  697.         // // so you'll need an association filter (multi-level filter), something like this:
  699.         // $criteria->addAssociation('orderCustomer.customer.tags');
  700.         // $criteria->addFilter(
  701.         //     new EqualsFilter('orderCustomer.customer.tags.name', 'testFirma-mro-visible')
  702.         // );
  704.         $aclRoles = $user->getAclRoles();
  705.         if (!$aclRoles) {
  706.             return;
  707.         }
  709.         $hasMroRole = false;
  710.         $tagNamesToShare = [];
  712.         foreach ($aclRoles->getElements() as $role) {
  713.             $roleName = $role->getName();
  715.             if ($roleName === 'MRO') {
  716.                 $hasMroRole = true;
  717.             }
  719.             if (str_starts_with($roleName, 'share-tag-')) {
  720.                 // Extract tag name and add to list
  721.                 $tagName = substr($roleName, strlen('share-tag-'));
  722.                 $tagNamesToShare[] = $tagName;
  723.             }
  724.         }
  725.         $this->logger->info('TEST233 FOUND $tagNamesToShare[] = ', ['$tagNamesToShare' => $tagNamesToShare]);
  728.         // Must have both: MRO role and at least one share-tag role
  729.         if (!$hasMroRole || empty($tagNamesToShare)) {
  730.             return;
  731.         }
  733.         // ✅ Filter orders: customer must have any of the tags in $tagNamesToShare
  734.         $criteria = $event->getCriteria();
  736.         // Make sure we load customer tags in this search
  737.         $criteria->addAssociation('orderCustomer.customer.tags');
  739.         // Add filter: orders where customer has any of the allowed tags
  740.         $criteria->addFilter(
  741.             new EqualsAnyFilter('orderCustomer.customer.tags.name', $tagNamesToShare)
  742.         );
  745.         // OLD 2
  746.         // // Filter orders: Only include orders where customer has tag "VIP"
  747.         // $filtered = $event->getEntities()->filter(function ($order) {
  748.         //     $orderCustomer = $order->getOrderCustomer();
  749.         //     if (!$orderCustomer) {
  750.         //         return false;
  751.         //     }
  753.         //     $customer = $orderCustomer->getCustomer();
  754.         //     if (!$customer) {
  755.         //         return false;
  756.         //     }
  758.         //     $tags = $customer->getTags();
  759.         //     if (!$tags) {
  760.         //         return false;
  761.         //     }
  763.         //     foreach ($tags as $tag) {
  764.         //         if ($tag->getName() === 'VIP') {
  765.         //             return true;
  766.         //         }
  767.         //     }
  769.         //     return false;
  770.         // });
  772.         // // Overwrite entities with filtered ones
  773.         // $event->getEntities()->clear();
  774.         // foreach ($filtered as $entity) {
  775.         //     $event->getEntities()->add($entity);
  776.         // }
  784.         // OLD
  785.         // // Only act on the "order" entity
  786.         // if (!$event->getDefinition() instanceof OrderDefinition) {
  787.         //     return;
  788.         // }
  790.         // $context = $event->getContext();
  791.         // $source = $context->getSource();
  793.         // if (!$source instanceof AdminApiSource) {
  794.         //     return;
  795.         // }
  797.         // $userId = $source->getUserId();
  799.         // if (!$userId) {
  800.         //     return;
  801.         // }
  802.         //
  803.         //     // Load user with roles
  804.         //     $criteria = new \Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria([$userId]);
  805.         //     $criteria->addAssociation('aclRoles');
  807.         //     /** @var \Shopware\Core\System\User\UserEntity|null $user */
  808.         //     $user = $this->userRepository->search($criteria, $event->getContext())->first();
  810.         //     if (!$user) {
  811.         //         return;
  812.         //     }
  814.         //     // Now you can check roles safely
  815.         //     $hasRole = false;
  816.         //     $aclRoles = $user->getAclRoles();
  818.         //     if ($aclRoles !== null) {
  819.         //         foreach ($aclRoles->getElements() as $role) {
  820.         //             if ($role->getName() === 'order_view_customer_tag_vip') {
  821.         //                 $hasRole = true;
  822.         //                 break;
  823.         //             }
  824.         //         }
  825.         //     }
  827.         //     if (!$hasRole) {
  828.         //         return;
  829.         //     }
  831.         //     // Filter out orders where the customer does NOT have tag "VIP"
  832.         //     $filtered = $event->getEntities()->filter(function ($order) {
  833.         //         $orderCustomer = $order->getOrderCustomer();
  834.         //         if (!$orderCustomer) {
  835.         //             return false;
  836.         //         }
  838.         //         $customer = $orderCustomer->getCustomer();
  839.         //         if (!$customer) {
  840.         //             return false;
  841.         //         }
  843.         //         $tags = $customer->getTags();
  844.         //         foreach ($tags as $tag) {
  845.         //             if ($tag->getName() === 'VIP') {
  846.         //                 return true;
  847.         //             }
  848.         //         }
  850.         //         // If no matching tag, exclude the order
  851.         //         return false;
  852.         //     });
  854.         //     // Override the entity result with the filtered list
  855.         //     $event->getEntities()->clear();
  856.         //     foreach ($filtered as $entity) {
  857.         //         $event->getEntities()->add($entity);
  858.         //     }
  859.     }    
  860. }