custom/plugins/SwagHoggi/src/Flow/Action/SendMailActionDecorator.php line 42

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace SwagHoggi\Flow\Action;
  6. use Psr\Log\LoggerInterface;
  7. use Shopware\Core\Checkout\Order\Aggregate\OrderCustomer\OrderCustomerEntity;
  8. use Shopware\Core\Content\Flow\Dispatching\Action\SendMailAction;
  9. use Shopware\Core\Content\Flow\Dispatching\StorableFlow;
  10. use Shopware\Core\Framework\Event\FlowEvent;
  11. use Symfony\Contracts\EventDispatcher\Event;
  12. use Shopware\Core\Framework\Context;
  14. class SendMailActionDecorator extends SendMailAction
  15. {
  16.     private SendMailAction $inner;
  17.     private LoggerInterface $logger;
  19.     private const TARGET_CUSTOM_FIELD = 'custom_customer_receipients';
  21.     public function __construct(
  22.         SendMailAction $inner,
  23.         LoggerInterface $logger
  24.     )
  25.     {
  26.         $this->inner = $inner;
  27.         $this->logger = $logger;
  28.     }
  30.     public static function getName(): string
  31.     {
  32.         return SendMailAction::getName();
  33.     }
  36.     public function requirements(): array
  37.     {
  38.         return $this->inner->requirements();
  39.     }
  42.     public function handle (Event $event): void
  43.     {
  44.         $this->inner->handle($event);
  46.         if ($event instanceof FlowEvent) {
  47.             try {
  48.                 $customer = $event->getEvent()->getOrder()->getOrderCustomer();
  49.                 $config = $event->getConfig();
  50.                 $context = $event->getContext();
  52.                 $this->processAdditionalRecipients($config, $customer, $event, $context);
  53.             } catch (\Exception $e) {
  54.                 $this->logger->error('HoggiFlow: Error in legacy handle: ' . $e->getMessage());
  55.             }
  56.         }
  57.     }
  60.     public function handleFlow(StorableFlow $flow): void
  61.     {
  62.         $this->inner->handleFlow($flow);
  63.     }
  66.     private function processAdditionalRecipients(array $config, OrderCustomerEntity $customer, $originator, Context $context): void
  67.     {
  68.         $customFields = $customer->getCustomFields() ?? [];
  70.         if (empty($customFields) || empty($customFields[self::TARGET_CUSTOM_FIELD])) {
  71.             $this->logger->info('HoggiFlow: Target field not found. Looking for: ' . self::TARGET_CUSTOM_FIELD);
  72.             return;
  73.         }
  75.         if (empty($customFields[self::TARGET_CUSTOM_FIELD])) {
  76.             $this->logger->info('HoggiFlow: Custom fields found, but TARGET key missing.', ['available_fields' => array_keys($customFields)]);
  77.             return;
  78.         }
  80.         $rawEmails = $customFields[self::TARGET_CUSTOM_FIELD];
  83.         $emailList = $this->parseEmails($rawEmails);
  85.         if (empty($emailList)) {
  86.             return;
  87.         }
  89.         foreach ($emailList as $email) {
  90.             $newConfig = $config;
  91.             $newConfig['recipient'] = [
  92.                 'type' => 'custom',
  93.                 'data' => [
  94.                     $email => 'Hoggi - Kopie Empfänger Anfrageformular'
  95.                 ]
  96.             ];
  98.             if ($originator instanceof FlowEvent) {
  99.                 $this->inner->handle(
  100.                     new FlowEvent($originator->getActionName(), $originator->getFlowState(), $newConfig)
  101.                 );
  103.                 $this->logger->info('HoggiFlow: Sent additional email to ' . $email);
  104.             }
  106.         }
  107.     }
  110.     private function parseEmails(mixed $raw): array
  111.     {
  112.         if (empty($raw)) {
  113.             return [];
  114.         }
  116.         if (is_array($raw)) {
  117.             $list = $raw;
  118.         } elseif (is_string($raw)) {
  119.             if (str_starts_with(trim($raw), '[')) {
  120.                 $decoded = json_decode($raw, true);
  121.                 $list = (json_last_error() === JSON_ERROR_NONE) ? $decoded : explode(',', $raw);
  122.             } else {
  123.                 $list = explode(',', $raw);
  124.             }
  125.         } else {
  126.             return [];
  127.         }
  129.         $emails = [];
  130.         foreach ($list as $item) {
  131.             if (is_string($item)) {
  132.                 $email = trim($item);
  133.                 if (filter_var($email, FILTER_VALIDATE_EMAIL)) {
  134.                     $emails[] = $email;
  135.                 }
  136.             }
  137.         }
  139.         return array_unique($emails);
  140.     }
  141. }