custom/plugins/MasterFFLCheckout/src/Subscriber/OrderPlacedSubscriber.php line 104

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace MasterFFL\Checkout\Subscriber;
  5. use MasterFFL\Checkout\Service\FFLConfigService;
  6. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  7. use Shopware\Core\Checkout\Order\Event\OrderStateMachineStateChangeEvent;
  8. use Shopware\Core\Checkout\Order\OrderEvents;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent; // FIXED IMPORT
  10. use Shopware\Core\Checkout\Order\OrderEntity;
  11. use Shopware\Core\Content\Product\ProductEntity;
  12. use Shopware\Core\Framework\Context;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  16. use Shopware\Core\System\SystemConfig\SystemConfigService;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\HttpFoundation\RequestStack;
  20. class OrderPlacedSubscriber implements EventSubscriberInterface
  21. {
  22.     private EntityRepository $orderRepository;
  23.     private EntityRepository $stateMachineStateRepository;
  24.     private EntityRepository $productRepository;
  25.     private SystemConfigService $systemConfigService;
  26.     private FFLConfigService $configService;
  27.     private RequestStack $requestStack;
  29.     public function __construct(
  30.         EntityRepository $orderRepository,
  31.         EntityRepository $productRepository,
  32.         SystemConfigService $systemConfigService,
  33.         FFLConfigService $configService,
  34.         EntityRepository $stateMachineStateRepository,
  35.         RequestStack $requestStack
  36.     ) {
  37.         $this->orderRepository = $orderRepository;
  38.         $this->productRepository = $productRepository;
  39.         $this->systemConfigService = $systemConfigService;
  40.         $this->configService = $configService;
  41.         $this->stateMachineStateRepository = $stateMachineStateRepository;
  42.         $this->requestStack = $requestStack;
  43.     }
  45.     public static function getSubscribedEvents(): array
  46.     {
  47.         return [
  48.             // Listen to multiple events to catch order placement
  49.             OrderEvents::ORDER_WRITTEN_EVENT => 'onOrderWritten',
  50.             OrderStateMachineStateChangeEvent::class => 'onOrderStateChanged',
  51.             'checkout.order.placed' => 'onOrderPlaced'
  52.         ];
  53.     }
  55.     public function onOrderWritten(EntityWrittenEvent $event): void // FIXED TYPE HINT
  56.     {
  57.         error_log("=== SHOPWARE ORDER WRITTEN EVENT TRIGGERED ===");
  58.         error_log("Event class: " . get_class($event));
  59.         error_log("Entity name: " . $event->getEntityName());
  60.         error_log("Write results count: " . count($event->getWriteResults()));
  61.         
  62.         foreach ($event->getWriteResults() as $writeResult) {
  63.             $payload = $writeResult->getPayload();
  64.             error_log("Order ID from write result: " . ($payload['id'] ?? 'N/A'));
  65.             
  66.             if (isset($payload['id'])) {
  67.                 $this->processOrder($payload['id'], $event->getContext());
  68.             }
  69.         }
  70.     }
  72.     public function onOrderPlaced($event): void
  73.     {
  74.         error_log("=== SHOPWARE ORDER PLACED EVENT TRIGGERED ===");
  75.         error_log("Event class: " . get_class($event));
  76.         
  77.         if (method_exists($event, 'getOrder')) {
  78.             $order = $event->getOrder();
  79.             error_log("Order ID from placed event: " . $order->getId());
  80.             $this->processOrder($order->getId(), $event->getContext());
  81.         }
  82.     }
  84.     private function getOrderStatusTechnicalName(string $statusId, Context $context): string
  85.     {
  86.         if (empty($statusId)) {
  87.             return 'open'; // default fallback
  88.         }
  90.         try {
  91.             $criteria = new Criteria([$statusId]);
  92.             $status = $this->stateMachineStateRepository->search($criteria, $context)->first();
  93.             
  94.             if ($status) {
  95.                 return $status->getTechnicalName();
  96.             }
  97.         } catch (\Exception $e) {
  98.             error_log('Error getting status technical name: ' . $e->getMessage());
  99.         }
  100.         
  101.         return 'open'; // fallback
  102.     }
  104.     public function onOrderStateChanged(OrderStateMachineStateChangeEvent $event): void
  105.     {
  106.         $order = $event->getOrder();
  107.         $salesChannelId = $order->getSalesChannelId();
  108.         
  109.         // Only process when order is placed/confirmed
  110.         if ($event->getToPlace()->getTechnicalName() !== 'open') {
  111.             return;
  112.         }
  114.         try {
  115.             // Get FFL configuration
  116.             $fflConfig = $this->configService->getFFLConfig($salesChannelId);
  117.             $environment = $fflConfig['environment'] ?? false;
  118.             
  119.             $webhookUrl = $environment 
  120.                 ? ($fflConfig['webhookUrlTest'] ?? 'https://api-qa.masterffl.com/ffl/bigcommerce/app/api/order/shopware/submittransfer')
  121.                 : ($fflConfig['webhookUrl'] ?? 'https://ffl-api.masterffl.com/ffl/bigcommerce/app/api/order/shopware/submittransfer');
  123.             $orderStatusMapping = $fflConfig['orderStatusMapping'] ?? 'open';
  125.             // Get full order with associations
  126.             $fullOrder = $this->getFullOrder($order->getId(), $event->getContext());
  127.             if (!$fullOrder) {
  128.                 return;
  129.             }
  131.             // Check if order has FFL products and build item data
  132.             $itemData = $this->buildFFLItemData($fullOrder, $event->getContext(), $salesChannelId);
  133.             
  134.             if (empty($itemData)) {
  135.                 return; // No FFL products, skip webhook
  136.             }
  138.             // Build order data for webhook
  139.             $orderData = $this->buildOrderData($fullOrder, $itemData, $orderStatusMapping);
  141.             // Send webhook using cURL (like Magento)
  142.             $this->sendWebhookWithCurl($webhookUrl, $orderData);
  144.         } catch (\Exception $e) {
  145.             // Log error but don't throw to avoid breaking order process
  146.             error_log('FFL Webhook Error: ' . $e->getMessage());
  147.         }
  148.     }
  151.     private function processOrder(string $orderId, Context $context): void
  152.     {
  153.         try {
  154.             error_log("=== PROCESSING ORDER: " . $orderId . " ===");
  155.             
  156.             // Get full order
  157.             $order = $this->getFullOrder($orderId, $context);
  158.             if (!$order) {
  159.                 error_log("ERROR: Could not retrieve order");
  160.                 return;
  161.             }
  163.             $salesChannelId = $order->getSalesChannelId();
  164.             error_log("Sales Channel ID: " . $salesChannelId);
  165.             error_log("Order Number: " . $order->getOrderNumber());
  166.             error_log("Order State: " . $order->getStateMachineState()->getTechnicalName());
  167.             error_log("Order Total: " . $order->getAmountTotal());
  168.             error_log("Customer Email: " . $order->getOrderCustomer()->getEmail());
  170.             // Get FFL configuration
  171.             $fflConfig = $this->configService->getFFLConfig($salesChannelId);
  172.             $environment = $fflConfig['environment'] ?? false;
  173.             
  174.             error_log("Environment: " . ($environment ? 'DEVELOPMENT/TEST' : 'PRODUCTION'));
  175.             $webhookUrl = $environment 
  176.             ? ($fflConfig['webhookUrlTest'] ?? 'https://api-qa.masterffl.com/ffl/bigcommerce/app/api/order/shopware/submittransfer')
  177.             : ($fflConfig['webhookUrl'] ?? 'https://ffl-api.masterffl.com/ffl/bigcommerce/app/api/order/shopware/submittransfer');
  178.             
  179.             
  180.             $orderStatusMapping = $fflConfig['orderStatusMapping'] ?? 'open';
  181.             
  182.             error_log("Webhook URL: " . $webhookUrl);
  183.             error_log("Order Status Mapping: " . $orderStatusMapping);
  184.             
  185.             // Check if order has FFL products and build item data
  186.             // echo "<pre>"; print_r($order); die;
  187.             $itemData = $this->buildFFLItemData($order, $context, $salesChannelId);
  188.             error_log("FFL Items found: " . count($itemData));
  189.             
  190.             if (empty($itemData)) {
  191.                 error_log("No FFL products found in order - skipping webhook");
  192.                 return;
  193.             }
  194.             $dealerId = $this->getDealerId($order);
  195.             $this->updateOrderCustomFields($orderId, $dealerId, $context);
  196.             // Log FFL items details
  197.             foreach ($itemData as $index => $item) {
  198.                 error_log("FFL Item " . ($index + 1) . ":");
  199.                 error_log("  - ID: " . $item['item_id']);
  200.                 error_log("  - Name: " . $item['item_name']);
  201.                 error_log("  - SKU: " . $item['item_sku']);
  202.                 error_log("  - Qty: " . $item['item_qty']);
  203.                 error_log("  - Price: " . $item['item_price']);
  204.                 error_log("  - Custom Fields: " . json_encode($item['custom_fields']));
  205.             }
  206.             
  207.             // Build order data for webhook
  208.             $orderData = $this->buildOrderData($order, $itemData, $orderStatusMapping);
  209.             
  210.             error_log("=== ORDER DATA BUILT FOR WEBHOOK ===");
  211.             error_log("Platform: " . $orderData['platform']);
  212.             error_log("Callback URL: " . $orderData['callback_url']);
  213.             error_log("Order Total: " . $orderData['order_total']);
  214.             error_log("Customer Email: " . $orderData['customer_email']);
  215.             error_log("License ID: " . $orderData['license_id']);
  216.             error_log("Domain: " . $orderData['domain']);
  217.             
  218.             // Send webhook using cURL (like Magento)
  219.             error_log("=== SENDING WEBHOOK ===");
  220.             
  221.             $this->sendWebhookWithCurl($webhookUrl, $orderData);
  223.         } catch (\Exception $e) {
  224.             error_log('=== FFL WEBHOOK ERROR ===');
  225.             error_log('Error Message: ' . $e->getMessage());
  226.             error_log('Error File: ' . $e->getFile() . ':' . $e->getLine());
  227.             error_log('Stack Trace: ' . $e->getTraceAsString());
  228.         }
  229.     }
  231.     /**
  232.      * Send webhook using cURL (same as Magento implementation)
  233.      */
  234.     private function sendWebhookWithCurl(string $webhookUrl, array $orderData): void
  235.     {
  236.         try {
  237.             $json_shipping_add = json_encode($orderData);
  238.             
  239.             // Initialize cURL
  240.             $ch = curl_init();
  241.             
  242.             // Set cURL options (same as Magento's Curl client)
  243.             curl_setopt($ch, CURLOPT_URL, $webhookUrl);
  244.             curl_setopt($ch, CURLOPT_POST, true);
  245.             curl_setopt($ch, CURLOPT_POSTFIELDS, $json_shipping_add);
  246.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  247.             curl_setopt($ch, CURLOPT_HTTPHEADER, [
  248.                 'Content-Type: application/json'
  249.             ]);
  250.             curl_setopt($ch, CURLOPT_TIMEOUT, 30);
  251.             curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  252.             
  253.             // Execute the request
  254.             $response = curl_exec($ch);
  255.             
  256.             // Get response info
  257.             $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  258.             $error = curl_error($ch);
  259.             
  260.             // Close cURL
  261.             curl_close($ch);
  262.             
  263.             // Handle errors
  264.             if ($error) {
  265.                 throw new \Exception('cURL Error: ' . $error);
  266.             }
  267.             
  268.             // Log response (optional, like Magento)
  269.             error_log("FFL Webhook sent. Status: {$httpCode}, Response: {$response}");
  270.             
  271.         } catch (\Exception $e) {
  272.             error_log('=== WEBHOOK FAILURE ===');
  273.             error_log('FFL Webhook failed: ' . $e->getMessage());
  274.             throw $e;
  275.         }
  276.     }
  278.     private function getFullOrder(string $orderId, Context $context): ?OrderEntity
  279.     {
  280.         $criteria = new Criteria([$orderId]);
  281.         $criteria->addAssociation('addresses');
  282.         $criteria->addAssociation('lineItems');
  283.         $criteria->addAssociation('deliveries.shippingOrderAddress');
  284.         $criteria->addAssociation('transactions.paymentMethod');
  285.         $criteria->addAssociation('salesChannel');
  286.         $criteria->addAssociation('salesChannel.domains'); // Add this line
  287.         $criteria->addAssociation('currency');
  288.         $criteria->addAssociation('orderCustomer.customer');
  290.         return $this->orderRepository->search($criteria, $context)->first();
  291.     }
  293.     private function buildFFLItemData(OrderEntity $order, Context $context, string $salesChannelId): array
  294.     {
  295.         $itemData = [];
  296.         $productIds = [];
  298.         // Collect product IDs
  299.         foreach ($order->getLineItems() as $lineItem) {
  300.             if ($lineItem->getType() === LineItem::PRODUCT_LINE_ITEM_TYPE) {
  301.                 $productIds[] = $lineItem->getReferencedId();
  302.             }
  303.         }
  305.         if (empty($productIds)) {
  306.             return [];
  307.         }
  309.         // Get products with categories
  310.         $criteria = new Criteria();
  311.         $criteria->addFilter(new EqualsAnyFilter('id', $productIds));
  312.         $criteria->addAssociation('categories');
  313.         $products = $this->productRepository->search($criteria, $context);
  315.         // Get FFL configuration
  316.         $fflAttributeName = $this->systemConfigService->get('MasterFFLCheckout.config.fflAttributeName', $salesChannelId);
  317.         $fflAttributeValue = $this->systemConfigService->get('MasterFFLCheckout.config.fflAttributeValue', $salesChannelId);
  318.         $firearmAttributeName = $this->systemConfigService->get('MasterFFLCheckout.config.firearmAttributeName', $salesChannelId);
  319.         
  320.         // Get firearm type mappings
  321.         $firearmTypes = [
  322.             'hand_gun' => $this->systemConfigService->get('MasterFFLCheckout.config.handGunType', $salesChannelId),
  323.             'long_gun' => $this->systemConfigService->get('MasterFFLCheckout.config.longGunType', $salesChannelId),
  324.             'other_firearm' => $this->systemConfigService->get('MasterFFLCheckout.config.otherFirearmType', $salesChannelId),
  325.             'nfa' => $this->systemConfigService->get('MasterFFLCheckout.config.nfaType', $salesChannelId)
  326.         ];
  328.         // Get FFL category mappings
  329.         $fflCategoryMappings = $this->getFFLCategoryMappings($salesChannelId);
  330.         
  331.         foreach ($order->getLineItems() as $lineItem) {
  332.             if ($lineItem->getType() !== LineItem::PRODUCT_LINE_ITEM_TYPE) {
  333.                 continue;
  334.             }
  336.             $product = $products->get($lineItem->getReferencedId());
  337.             if (!$product) {
  338.                 continue;
  339.             }
  341.             $customAttributes = [];
  342.             $isFFLProduct = false;
  343.             $firearmType = '';
  345.             // Check custom fields first
  346.             $customFields = $product->getCustomFields() ?? [];
  347.             
  348.             // Check if FFL field exists (try multiple variations)
  349.             $fflFieldValue = null;
  350.             if (isset($customFields[$fflAttributeName])) {
  351.                 $fflFieldValue = $customFields[$fflAttributeName];
  352.             } elseif (isset($customFields[strtolower($fflAttributeName)])) {
  353.                 $fflFieldValue = $customFields[strtolower($fflAttributeName)];
  354.             } elseif (isset($customFields[strtoupper($fflAttributeName)])) {
  355.                 $fflFieldValue = $customFields[strtoupper($fflAttributeName)];
  356.             }
  358.             if ($fflFieldValue !== null) {
  359.                 $fflFieldValueLower = strtolower(trim((string)$fflFieldValue));
  360.                 $configValueLower = strtolower(trim($fflAttributeValue));
  361.                 
  362.                 // Check for NO values first
  363.                 if ($fflFieldValueLower === 'no' || $fflFieldValueLower === 'false' || $fflFieldValueLower === '0') {
  364.                     continue; // Skip this product
  365.                 }
  366.                 
  367.                 // Check for YES values
  368.                 if ($fflFieldValue === $configValueLower || $fflFieldValueLower == $fflAttributeValue) {
  369.                     
  370.                     $isFFLProduct = true;
  371.                     
  372.                     // Get firearm type - try multiple field name variations
  373.                     $firearmTypeValue = null;
  374.                     if (isset($customFields[$firearmAttributeName])) {
  375.                         $firearmTypeValue = $customFields[$firearmAttributeName];
  376.                     } 
  377.                     
  378.                     if ($firearmTypeValue) {
  379.                         $firearmTypeValueLower = strtolower(trim((string)$firearmTypeValue));
  380.                         $firearmType = $firearmTypes[$firearmTypeValueLower] ?? $firearmTypeValue;
  381.                     }
  382.                 }
  383.             }
  385.             // Check category mapping if not explicitly set
  386.             if (!$isFFLProduct) {
  387.                 if ($product->getCategories()) {
  388.                     foreach ($product->getCategories() as $category) {
  389.                         foreach ($fflCategoryMappings as $mapping) {
  390.                             if ($mapping['storeCategory'] === $category->getId()) {
  391.                                 $isFFLProduct = true;
  392.                                 $fflMapping = strtolower($mapping['fflMapping'] ?? '');
  393.                                 $firearmType = $firearmTypes[$fflMapping] ?? $mapping['fflMapping'] ?? '';
  394.                                 break 2;
  395.                             }
  396.                         }
  397.                     }
  398.                 }
  399.             }
  401.             if ($isFFLProduct) {
  402.                 $customAttributes[] = [
  403.                     'name' => $fflAttributeName,
  404.                     'value' => $fflAttributeValue
  405.                 ];
  406.                 
  407.                 if ($firearmType) {
  408.                     if (strtolower($firearmType) === 'nfa' || strpos(strtolower($firearmType), 'suppressor') !== false) {
  409.                         $customAttributes[] = ['name' => $firearmAttributeName, 'value' => 'suppressor'];
  410.                     } else {
  411.                         $customAttributes[] = ['name' => $firearmAttributeName, 'value' => $firearmType];
  412.                     }
  413.                 }
  415.                 $itemData[] = [
  416.                     'item_id' => $lineItem->getReferencedId(),
  417.                     'item_name' => $lineItem->getLabel(),
  418.                     'item_sku' => $lineItem->getPayload()['productNumber'] ?? '',
  419.                     'price_ex_tax' => $lineItem->getUnitPrice(),
  420.                     'item_qty' => $lineItem->getQuantity(),
  421.                     'item_price' => $lineItem->getUnitPrice(),
  422.                     'custom_fields' => $customAttributes
  423.                 ];
  424.             }
  425.         }
  426.         
  427.         return $itemData;
  428.     }
  430.     private function checkProductCategories(ProductEntity $product, array $fflCategoryMappings, array $firearmTypes): array
  431.     {
  432.         $result = ['isFFLProduct' => false, 'firearmType' => ''];
  434.         if (!$product->getCategories()) {
  435.             error_log("Product has no categories");
  436.             return $result;
  437.         }
  439.         error_log("Product categories: " . $product->getCategories()->count());
  441.         foreach ($product->getCategories() as $category) {
  442.             error_log("Checking category: " . $category->getName() . " (ID: " . $category->getId() . ")");
  443.             
  444.             foreach ($fflCategoryMappings as $mapping) {
  445.                 if ($mapping['storeCategory'] === $category->getId()) {
  446.                     error_log("Found FFL category mapping: " . json_encode($mapping));
  447.                     $result['isFFLProduct'] = true;
  448.                     $fflMapping = strtolower($mapping['fflMapping'] ?? '');
  449.                     $result['firearmType'] = $firearmTypes[$fflMapping] ?? $mapping['fflMapping'] ?? '';
  450.                     error_log("Category mapped to firearm type: " . $result['firearmType']);
  451.                     return $result;
  452.                 }
  453.             }
  454.         }
  456.         error_log("No FFL category mapping found for product");
  457.         return $result;
  458.     }
  460.     private function getFFLCategoryMappings(string $salesChannelId): array
  461.     {
  462.         $configKey = 'MasterFFLCheckout.config.categoryMappingTable';
  463.         $categoryMappings = $this->systemConfigService->get($configKey, $salesChannelId);
  464.         
  465.         error_log("Raw category mappings from config: " . json_encode($categoryMappings));
  466.         
  467.         return is_array($categoryMappings) ? $categoryMappings : [];
  468.     }
  470.     private function buildOrderData(OrderEntity $order, array $itemData, string $orderStatusMapping): array
  471.     {
  472.         $billingAddress = null;
  473.         $shippingAddress = null;
  475.         // Get addresses
  476.         foreach ($order->getAddresses() as $address) {
  477.             if ($address->getId() === $order->getBillingAddressId()) {
  478.                 $billingAddress = $address;
  479.             }
  480.             if ($order->getDeliveries()->first() && 
  481.                 $address->getId() === $order->getDeliveries()->first()->getShippingOrderAddressId()) {
  482.                 $shippingAddress = $address;
  483.             }
  484.         }
  486.         // Get payment method
  487.         $paymentMethod = '';
  488.         if ($order->getTransactions()->first() && $order->getTransactions()->first()->getPaymentMethod()) {
  489.             $paymentMethod = $order->getTransactions()->first()->getPaymentMethod()->getName();
  490.         }
  492.         // Get shipping method
  493.         $shippingMethod = '';
  494.         if ($order->getDeliveries()->first() && $order->getDeliveries()->first()->getShippingMethod()) {
  495.             $shippingMethod = $order->getDeliveries()->first()->getShippingMethod()->getName();
  496.         }
  498.         $baseUrl = '';
  499.         if ($order->getSalesChannel() && 
  500.             $order->getSalesChannel()->getDomains() && 
  501.             $order->getSalesChannel()->getDomains()->first()) {
  502.             $baseUrl = $order->getSalesChannel()->getDomains()->first()->getUrl();
  503.         } else {
  504.             if (isset($_SERVER['HTTP_HOST'])) {
  505.                 $protocol = isset($_SERVER['HTTPS']) && $_SERVER['HTTPS'] === 'on' ? 'https' : 'http';
  506.                 $baseUrl = $protocol . '://' . $_SERVER['HTTP_HOST'];
  507.             }
  508.         }
  509.         
  510.         $siteUrl = parse_url($baseUrl, PHP_URL_HOST) ?: 'localhost';
  511.         $billStreet = $billingAddress ? $billingAddress->getStreet() : '';
  512.         $bill_street_one = $billStreet;
  513.         $bill_street_two = $billingAddress ? ($billingAddress->getAdditionalAddressLine1() ?? '') : '';
  514.         $shipStreet = $shippingAddress ? $shippingAddress->getStreet() : '';
  515.         $ship_street_one = $shipStreet;
  516.         $ship_street_two = $shippingAddress ? ($shippingAddress->getAdditionalAddressLine1() ?? '') : '';
  517.         $callbackUrl = rtrim($baseUrl, '/') . '/api/_action/ffl/update-shipping-address/' . $order->getOrderNumber();
  518.         $orderStatusTechnicalName = $this->getOrderStatusTechnicalName($orderStatusMapping, Context::createDefaultContext());
  519.         $dealerId = $this->getDealerId($order);
  520.         $token = $this->getToken($order);
  522.         $orderData = [
  523.             'platform' => 'shopware',
  524.             'callback_url' => $callbackUrl,
  525.             'order_id' => $order->getOrderNumber(),
  526.             'order_number' => $order->getId(),
  527.             'order_date' => $order->getOrderDateTime()->format('Y-m-d H:i:s'),
  528.             'date_modified' => $order->getUpdatedAt() ? $order->getUpdatedAt()->format('Y-m-d H:i:s') : $order->getOrderDateTime()->format('Y-m-d H:i:s'),
  529.             'status' => $order->getStateMachineState()->getTechnicalName(),
  530.             'shipping_total' => $order->getShippingTotal(),
  531.             'shipping_tax_total' => 0,
  532.             'fee_total' => '',
  533.             'fee_tax_total' => '',
  534.             'tax_total' => $order->getAmountTotal() - $order->getAmountNet(),
  535.             'order_discount' => 0,
  536.             'discount_total' => 0,
  537.             'order_total' => $order->getAmountTotal(),
  538.             'order_currency' => $order->getCurrency()->getIsoCode(),
  539.             'payment_method' => $paymentMethod,
  540.             'payment_amount' => $order->getAmountTotal(),
  541.             'shipping_method' => $shippingMethod,
  542.             'shipping_cost_ex_tax' => $order->getShippingTotal(),
  543.             'customer_id' => $order->getOrderCustomer()->getCustomerId() ?? '',
  544.             'customer_email' => $order->getOrderCustomer()->getEmail(),
  545.             'billing_first_name' => $billingAddress ? $billingAddress->getFirstName() : '',
  546.             'billing_last_name' => $billingAddress ? $billingAddress->getLastName() : '',
  547.             'billing_company' => $billingAddress ? $billingAddress->getCompany() : '',
  548.             'billing_email' => $order->getOrderCustomer()->getEmail(),
  549.             'billing_phone' => $billingAddress->getPhoneNumber() ?? '0000000000',
  550.             'billing_address_1' => $bill_street_one,
  551.             'billing_address_2' => $bill_street_two,
  552.             'billing_postcode' => $billingAddress ? $billingAddress->getZipcode() : '',
  553.             'billing_city' => $billingAddress ? $billingAddress->getCity() : '',
  554.             'billing_state' => $billingAddress && $billingAddress->getCountryState() ? $billingAddress->getCountryState()->getName() : '',
  555.             'billing_country' => $billingAddress && $billingAddress->getCountry() ? $billingAddress->getCountry()->getIso() : '',
  556.             'shipping_first_name' => $shippingAddress ? $shippingAddress->getFirstName() : ($billingAddress ? $billingAddress->getFirstName() : ''),
  557.             'shipping_last_name' => $shippingAddress ? $shippingAddress->getLastName() : ($billingAddress ? $billingAddress->getLastName() : ''),
  558.             'shipping_company' => $shippingAddress ? $shippingAddress->getCompany() : '',
  559.             'shipping_address_1' => $ship_street_one,
  560.             'shipping_address_2' => $ship_street_two,
  561.             'shipping_postcode' => $shippingAddress ? $shippingAddress->getZipcode() : '',
  562.             'shipping_city' => $shippingAddress ? $shippingAddress->getCity() : '',
  563.             'shipping_phone' => $shippingAddress ? $shippingAddress->getPhoneNumber() : '',
  564.             'shipping_state' => $shippingAddress && $shippingAddress->getCountryState() ? $shippingAddress->getCountryState()->getShortCode() : '',
  565.             'shipping_country' => $shippingAddress && $shippingAddress->getCountry() ? $shippingAddress->getCountry()->getIso() : '',
  566.             'customer_note' => $order->getCustomerComment() ?? '',
  567.             'domain' => $siteUrl,
  568.             'license_id' => $dealerId,
  569.             'token' => $token,
  570.             'order_status_mapping' => $orderStatusTechnicalName,
  571.             'item' => $itemData,
  572.         ];
  573.         return $orderData;
  574.     }
  576.     private function getDealerId(OrderEntity $order): string
  577.     {
  578.         $request = $this->requestStack->getCurrentRequest();
  579.         if ($request && $request->hasSession()) {
  580.             $session = $request->getSession();
  581.             $fflDealerData = $session->get('ffl_dealer_data');
  583.             if ($fflDealerData && isset($fflDealerData['dealer_id'])) {
  584.                 return $fflDealerData['dealer_id'];
  585.             }
  586.         }
  587.         return '';
  588.     }
  590.     private function getToken(OrderEntity $order): string
  591.     {
  592.         $request = $this->requestStack->getCurrentRequest();
  593.         if ($request && $request->hasSession()) {
  594.             $session = $request->getSession();
  595.             $seassionData = $session->get('ffl_dealer_data');
  596.             $token = $seassionData['token'];
  597.             
  598.             if ($token) {
  599.                 return $token;
  600.             }
  601.         }
  602.         return '';
  603.     }
  605.     private function updateOrderCustomFields(string $orderId, string $dealerId, Context $context): void
  606.     {
  607.         try {
  608.             if (empty($dealerId)) {
  609.                 error_log("Dealer ID is empty, skipping update");
  610.                 return;
  611.             }
  613.             error_log("Updating order {$orderId} with dealer ID: {$dealerId}");
  614.             
  615.             // Get existing custom fields to preserve other data
  616.             $order = $this->getFullOrder($orderId, $context);
  617.             if (!$order) {
  618.                 error_log("Order not found: {$orderId}");
  619.                 return;
  620.             }
  622.             $existingCustomFields = $order->getCustomFields() ?? [];
  623.             
  624.             // Check if already set to avoid unnecessary updates
  625.             if (isset($existingCustomFields['masterffl_license_number']) && 
  626.                 $existingCustomFields['masterffl_license_number'] === $dealerId) {
  627.                 error_log("Dealer ID already set for order {$orderId}, skipping update");
  628.                 return;
  629.             }
  630.             
  631.             // Add/update the masterffl_license_number field
  632.             $existingCustomFields['masterffl_license_number'] = $dealerId;
  633.             // Update with complete custom fields array
  634.             $this->orderRepository->update([
  635.                 [
  636.                     'id' => $orderId,
  637.                     'customFields' => $existingCustomFields
  638.                 ]
  639.             ], $context);
  640.             
  641.             error_log("Successfully updated masterffl_license_number with: " . $dealerId);
  642.             
  643.         } catch (\Exception $e) {
  644.             error_log('Error updating order custom fields: ' . $e->getMessage());
  645.             error_log('Stack trace: ' . $e->getTraceAsString());
  646.             // Don't throw exception to avoid breaking order process
  647.         }
  648.     }
  649. }