custom/plugins/MagmodulesWebshopnl/src/Api/Controller/OrderProcess.php line 570

  1. <?php
  2. declare(strict_types=1);
  4. namespace MagmodulesWebshopnl\Api\Controller;
  6. use Doctrine\DBAL\Exception\UniqueConstraintViolationException;
  7. use MagmodulesWebshopnl\Core\Content\WebShopOrder\WebShopOrderEntity;
  8. use MagmodulesWebshopnl\Service\WebShopLogger;
  9. use Shopware\Core\Checkout\Order\Aggregate\OrderDelivery\OrderDeliveryStates;
  10. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionStates;
  11. use Shopware\Core\Checkout\Order\OrderStates;
  12. use Shopware\Core\Content\Product\ProductEntity;
  13. use Shopware\Core\Defaults;
  14. use Shopware\Core\Framework\Context;
  15. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\OrFilter;
  19. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  20. use Shopware\Core\Framework\Util\Random;
  21. use Shopware\Core\Framework\Uuid\Uuid;
  22. use Shopware\Core\System\Currency\CurrencyEntity;
  23. use Shopware\Core\System\NumberRange\NumberRangeEntity;
  24. use Shopware\Core\System\SalesChannel\SalesChannelEntity;
  25. use Shopware\Core\System\SystemConfig\SystemConfigService;
  26. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  27. use Symfony\Component\HttpFoundation\JsonResponse;
  29. class OrderProcess extends AbstractController
  30. {
  31.     public function __construct(
  32.         private SystemConfigService $systemConfigService,
  33.         private WebShopLogger $webShopLogger,
  34.         private EntityRepository $orderRepository,
  35.         private EntityRepository $salesChannelRepository,
  36.         private EntityRepository $languageRepository,
  37.         private EntityRepository $stateMachineRepository,
  38.         private EntityRepository $stateMachineStateRepository,
  39.         private EntityRepository $customerRepository,
  40.         private EntityRepository $paymentRepository,
  41.         private EntityRepository $salutationRepository,
  42.         private EntityRepository $numberRangeRepository,
  43.         private EntityRepository $shippingMethodRepository,
  44.         private EntityRepository $numberRangeStateRepository,
  45.         private EntityRepository $webshopnlOrderRepository,
  46.         private EntityRepository $productRepository,
  47.         private EntityRepository $countryRepository,
  48.         private EntityRepository $currencyRepository,
  49.     ) {
  50.     }
  52.     public function processOrder(array $order, string $salesChannelId, Context $context): array
  53.     {
  54.         if ($this->getCheckExistOrder($order, $context) > 0) {
  55.             $logdata = $this->getLoggerData($order, "Rejected", "Order already imported");
  57.             $log = $this->systemConfigService->get('MagmodulesWebshopnl.settings.debug', $salesChannelId);
  58.             if ($log) {
  59.                 $this->webShopLogger->addOrderLog($context, $logdata);
  60.             }
  62.             return $logdata;
  63.         }
  65.         return $this->orderDataCreate($order, $salesChannelId, $context);
  66.     }
  68.     private function getCheckExistOrder(array $order, Context $context): int
  69.     {
  70.         return $this->webshopnlOrderRepository->searchIds(
  71.             (new Criteria())->addFilter(new EqualsFilter('webShopOrderId', $order['order_id'])),
  72.             $context
  73.         )->getTotal();
  74.     }
  76.     private function getLoggerData(array $order, string $status, string $message): array
  77.     {
  78.         return [
  79.             'order_id' => $order['order_id'] ?? null,
  80.             'merchant_id' => $order['merchant_id'] ?? null,
  81.             'status' => $status,
  82.             'message' => $message,
  83.         ];
  84.     }
  86.     private function orderDataCreate(array $orderData, string $salesChannelId, Context $context): array
  87.     {
  88.         $orderData['billing_address'] = $orderData['billing_address'] ?? $orderData['delivery_address'];
  89.         $orderData['delivery_address'] = $orderData['delivery_address'] ?? $orderData['billing_address'];
  91.         $billingHash = md5(json_encode($orderData['billing_address']));
  92.         $shippingHash = md5(json_encode($orderData['delivery_address']));
  94.         $salesChannelEntity = $this->getSaleChannelDetails($salesChannelId, $context);
  96.         $orderId = Uuid::randomHex();
  97.         $billingAddress = $this->getOrderAddressData(
  98.             $orderId,
  99.             $orderData['billing_address'],
  100.             $salesChannelEntity->getCountryId(),
  101.             $context
  102.         );
  103.         if ($billingHash !== $shippingHash) {
  104.             $shippingAddress = $this->getOrderAddressData(
  105.                 $orderId,
  106.                 $orderData['delivery_address'],
  107.                 $salesChannelEntity->getCountryId(),
  108.                 $context
  109.             );
  110.         } else {
  111.             $shippingAddress = $billingAddress;
  112.         }
  114.         $orderCustomerId = $this->findOrCreateCustomerId(
  115.             $orderData['billing_address']['email'],
  116.             $salesChannelId,
  117.             $context,
  118.             $salesChannelEntity->getLanguageId(),
  119.             $billingAddress,
  120.             $shippingAddress
  121.         );
  123.         /** @var CurrencyEntity $currency */
  124.         $currency = $this->getCurrency($orderData['currency'] ?? '', $context)
  125.             ?? $salesChannelEntity->getCurrency();
  127.         $orderNumberRange = $this->getOrderNumberRange($context);
  128.         $nextOrderNumber = (string)$orderNumberRange->getStart();
  129.         if ($orderNumberRange->getState() !== null) {
  130.             $nextOrderNumber = (string)($orderNumberRange->getState()->getLastValue() + 1);
  131.         }
  133.         $order = [];
  134.         $order['id'] = $orderId;
  135.         $order['billingAddress'] = $billingAddress;
  136.         $order['shippingAddress'] = $shippingAddress;
  137.         $order['currencyId'] = $currency->getId();
  138.         $order['orderNumber'] = $nextOrderNumber;
  139.         $order['orderCustomer'] = $this->getOrderCustomerData(
  140.             $orderId,
  141.             $orderCustomerId,
  142.             $orderData['billing_address']['email'],
  143.             $billingAddress,
  144.             $context
  145.         );
  146.         $order['languageId'] = $salesChannelEntity->getLanguageId();
  147.         $order['salesChannelId'] = $salesChannelId;
  148.         $order['price'] = $this->getPrice($orderData);
  149.         $order['lineItems'] = $this->getLineItems($orderId, $orderData, $context);
  150.         $order['orderDateTime'] = (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT);
  151.         $order['customerId'] = $orderCustomerId;
  152.         $order['currencyFactor'] = $currency->getFactor();
  153.         $order['deepLinkCode'] = Random::getBase64UrlString(32);
  154.         $order['transactions'] = $this->getOrderTransactions($orderId, $orderData, $context);
  155.         $order['deliveries'] = $this->getOrderDeliveries($orderId, $shippingAddress['id'], $orderData, $context);
  156.         $order['shippingCosts'] = $this->getShippingCost($orderData);
  157.         $order['stateId'] = $this->getInitialStateIdByName(OrderStates::STATE_MACHINE, $context);
  159.         $order['orderDeliveryStateId'] = $this->getInitialStateIdByName(OrderDeliveryStates::STATE_MACHINE, $context);
  160.         $order['itemRounding'] = $currency->getItemRounding()->jsonSerialize();
  161.         $order['totalRounding'] = $currency->getTotalRounding()->jsonSerialize();
  163.         $log = $this->systemConfigService->get('MagmodulesWebshopnl.settings.debug', $salesChannelId);
  165.         try {
  166.             $this->orderRepository->create([$order], $context);
  167.             $this->updateOrderNumber($orderNumberRange, (int)$nextOrderNumber, $context);
  168.             $this->addWebShopOrder($order['id'], $orderData, $context, $salesChannelId);
  169.             if ($log) {
  170.                 $status = "Confirmed";
  171.                 $message = "Order was imported";
  172.                 $this->webShopLogger->addOrderLog($context, $this->getLoggerData($orderData, $status, $message));
  173.             }
  174.         } catch (UniqueConstraintViolationException $exception) {
  175.             if ($log) {
  176.                 $status = "Rejected";
  177.                 $message = $exception->getMessage();
  178.                 $this->webShopLogger->addOrderLog($context, $this->getLoggerData($orderData, $status, $message));
  179.             }
  180.         }
  182.         return $order;
  183.     }
  185.     private function addWebShopOrder(string $orderId, array $getOrder, Context $context, string $salesChannelId): void
  186.     {
  187.         $this->webshopnlOrderRepository->create([
  188.             [
  189.                 'id' => Uuid::randomHex(),
  190.                 'salesChannelId' => $salesChannelId,
  191.                 'webShopOrderId' => $getOrder['order_id'],
  192.                 'status' => 'imported',
  193.                 'orderId' => $orderId,
  194.                 'merchantId' => $getOrder['merchant_id'],
  195.             ],
  196.         ], $context);
  197.     }
  199.     private function getOrderDeliveries(
  200.         string $orderId,
  201.         string $shippingAddressId,
  202.         array $orderData,
  203.         Context $context
  204.     ): array {
  205.         $shippingDateEarliest = date("Y/m/d");
  206.         $latestDate = strtotime("+4 day", strtotime($shippingDateEarliest));
  207.         $shippingDateLatest = date('Y/m/d', $latestDate);
  209.         return [
  210.             [
  211.                 'orderId' => $orderId,
  212.                 //'shippingOrderAddressId' => $shippingAddressId,
  213.                 'shippingMethodId' => $this->getShippingMethodId($context),
  214.                 'stateId' => $this->getInitialStateIdByName(OrderDeliveryStates::STATE_MACHINE, $context),
  215.                 'trackingCodes' => [],
  216.                 'shippingDateEarliest' => $shippingDateEarliest,
  217.                 'shippingDateLatest' => $shippingDateLatest,
  218.                 'shippingCosts' => $this->getShippingCost($orderData),
  219.             ],
  220.         ];
  221.     }
  223.     private function getShippingMethodId($context)
  224.     {
  225.         $paymentCriteria = new Criteria();
  226.         $paymentCriteria->addFilter(new EqualsFilter('name', 'webshopnl'));
  228.         return $this->shippingMethodRepository->search($paymentCriteria, $context)->first()->getId();
  229.     }
  231.     private function getOrderTransactions(string $orderId, array $orderData, Context $context): array
  232.     {
  233.         if (array_key_exists('paid_at', $orderData) && $orderData['paid_at'] !== null) {
  234.             $stateId = $this->getIdByTransactionStateName(OrderTransactionStates::STATE_PAID,
  235.                 $context);
  236.         } else {
  237.             $stateId = $this->getInitialStateIdByName(
  238.                 OrderTransactionStates::STATE_MACHINE,
  239.                 $context
  240.             );
  241.         }
  243.         return [
  244.             [
  245.                 'orderId' => $orderId,
  246.                 'paymentMethodId' => $this->getPaymentMethodID($context),
  247.                 'amount' => $this->getTransactionAmount($orderData),
  248.                 'stateId' => $stateId,
  249.             ],
  250.         ];
  251.     }
  253.     private function getPaymentMethodID(Context $context): ?string
  254.     {
  255.         $paymentCriteria = new Criteria();
  256.         $paymentCriteria->addFilter(new EqualsFilter('name', 'webshopnl'));
  258.         return $this->paymentRepository->searchIds($paymentCriteria, $context)->firstId();
  259.     }
  261.     private function getTransactionAmount(array $orderData): array
  262.     {
  263.         $quantity = $orderData['items']['quantity'];
  264.         $productIds = $orderData['items']['products'];
  265.         foreach ($productIds as $data) {
  266.             $price = $data['per_item'];
  267.         }
  269.         return [
  270.             "quantity" => $quantity,
  271.             "taxRules" => [
  272.                 [
  273.                     "taxRate" => 0,
  274.                     "percentage" => 0,
  275.                 ],
  276.             ],
  277.             "listPrice" => null,
  278.             "unitPrice" => $price,
  279.             "totalPrice" => $price * $quantity / 100,
  280.             "referencePrice" => null,
  281.             "calculatedTaxes" => [
  282.                 [
  283.                     "tax" => 0,
  284.                     "price" => 0,
  285.                     "taxRate" => 0,
  286.                 ],
  287.             ],
  288.             "regulationPrice" => null,
  289.         ];
  290.     }
  292.     private function getLineItems(string $orderId, array $orderData, Context $context): array
  293.     {
  294.         $lineItemReturn = [];
  295.         foreach ($orderData['items']['products'] as $lineItem) {
  296.             $lineItemNew = [
  297.                 'id' => Uuid::randomHex(),
  298.                 'orderId' => $orderId,
  299.                 'payload' => [],
  300.                 'label' => $lineItem['name'],
  301.                 'quantity' => $lineItem['quantity'],
  302.                 'price' => $this->getOrderLineItemPrice($lineItem),
  303.                 'removable' => true,
  304.                 'stackable' => true,
  305.                 'type' => 'product',
  306.                 'identifier' => $lineItem['remote_id'],
  307.             ];
  309.             if ($product = $this->getProductEntity($lineItem['remote_id'], $context)) {
  310.                 $lineItemNew['productId'] = $product->getId();
  311.                 $lineItemNew['referencedId'] = $product->getId();
  312.                 $lineItemNew['payload'] = [
  313.                     'stock' => $product->getStock(),
  314.                     'productNumber' => $product->getProductNumber(),
  315.                 ];
  316.             }
  319.             $lineItemReturn[] = $lineItemNew;
  320.         }
  322.         return $lineItemReturn;
  323.     }
  325.     private function getProductEntity($productId, $context): ?ProductEntity
  326.     {
  327.         $criteria = new  Criteria();
  328.         $criteria->addFilter(new EqualsFilter('id', $productId));
  330.         return $this->productRepository->search($criteria, $context)->first();
  331.     }
  333.     private function getOrderLineItemPrice(array $lineItem): array
  334.     {
  335.         return [
  336.             "quantity" => $lineItem['quantity'],
  337.             "taxRules" => [
  338.                 [
  339.                     "taxRate" => 0,
  340.                     "extensions" => [],
  341.                     "percentage" => 0,
  342.                 ],
  343.             ],
  344.             "listPrice" => null,
  345.             "unitPrice" => $lineItem['per_item'] / 100,
  346.             "totalPrice" => ($lineItem['per_item'] / 100) * $lineItem['quantity'],
  347.             "referencePrice" => null,
  348.             "calculatedTaxes" => [
  349.                 [
  350.                     "tax" => 0,
  351.                     "price" => 0,
  352.                     "taxRate" => 0,
  353.                     "extensions" => [],
  354.                 ],
  355.             ],
  356.         ];
  357.     }
  359.     private function getOrderCustomerData(
  360.         string $orderId,
  361.         $customerId,
  362.         string $email,
  363.         array $billingAddress,
  364.         Context $context
  365.     ): array {
  366.         return [
  367.             'customerId' => $customerId,
  368.             'orderId' => $orderId,
  369.             'email' => $email,
  370.             'salutationId' => $this->getValidSalutationId($context),
  371.             'firstName' => $billingAddress['firstName'],
  372.             'lastName' => $billingAddress['lastName'],
  373.         ];
  374.     }
  376.     private function getShippingCost(array $orderData): array
  377.     {
  378.         return [
  379.             "quantity" => $orderData['items']['quantity'],
  380.             "taxRules" => [
  381.                 [
  382.                     "taxRate" => 0,
  383.                     "extensions" => [],
  384.                     "percentage" => 0,
  385.                 ],
  386.             ],
  387.             "listPrice" => null,
  388.             "unitPrice" => 0,
  389.             "totalPrice" => $orderData['items']['delivery_cost'] / 100,
  390.             "referencePrice" => null,
  391.             "calculatedTaxes" => [
  392.                 [
  393.                     "tax" => 0,
  394.                     "price" => 0,
  395.                     "taxRate" => 0,
  396.                     "extensions" => [],
  397.                 ],
  398.             ],
  399.             "regulationPrice" => null,
  400.         ];
  401.     }
  403.     private function getOrderNumberRange(Context $context): NumberRangeEntity
  404.     {
  405.         $criteria = new  Criteria();
  406.         $criteria->addFilter(new EqualsFilter('type.technicalName', 'order'));
  407.         $criteria->addAssociation('state');
  409.         return $this->numberRangeRepository->search($criteria, $context)->first();
  410.     }
  412.     private function getPrice(array $orderData): array
  413.     {
  414.         return [
  415.             "totalPrice" => $orderData['items']['total'] / 100,
  416.             "netPrice" => $orderData['items']['total'] / 100,
  417.             "rawTotal" => $orderData['items']['total'] / 100,
  418.             "taxRules" => [
  419.                 [
  420.                     "taxRate" => 0,
  421.                     "extensions" => [],
  422.                     "percentage" => 0,
  423.                 ],
  424.             ],
  425.             "taxStatus" => "gross",
  426.             "positionPrice" => $orderData['items']['products_cost'],
  427.             "calculatedTaxes" => [
  428.                 [
  429.                     "tax" => 0,
  430.                     "price" => 0,
  431.                     "taxRate" => 0,
  432.                     "extensions" => [],
  433.                 ],
  434.             ],
  435.         ];
  436.     }
  438.     private function updateOrderNumber(NumberRangeEntity $orderNumberRange, int $newValue, Context $context): void
  439.     {
  440.         $numberRange = [
  441.             'id' => $orderNumberRange->getState()?->getId() ?? Uuid::randomHex(),
  442.             'numberRangeId' => $orderNumberRange->getId(),
  443.             'lastValue' => $newValue,
  444.         ];
  446.         $this->numberRangeStateRepository->upsert([$numberRange], $context);
  447.     }
  449.     private function findOrCreateCustomerId(
  450.         string $email,
  451.         string $salesChannelId,
  452.         Context $context,
  453.         string $languageId,
  454.         array $billingAddress,
  455.         array $shippingAddress
  456.     ): string {
  457.         $criteria = new Criteria();
  458.         $criteria->addFilter(new EqualsFilter('email', $email));
  459.         $customerId = $this->customerRepository->searchIds($criteria, $context)->firstId();
  461.         if ($customerId) {
  462.             return $customerId;
  463.         }
  465.         $customerId = Uuid::randomHex();
  466.         $this->customerRepository->create([
  467.             [
  468.                 'id' => $customerId,
  469.                 'groupId' => $this->systemConfigService->get(
  470.                     'MagmodulesWebshopnl.settings.defaultCustomerGroup',
  471.                     $salesChannelId
  472.                 ),
  473.                 'defaultPaymentMethodId' => $this->getValidPaymentMethodId($salesChannelId, $context),
  474.                 'salesChannelId' => $salesChannelId,
  475.                 'languageId' => $languageId,
  476.                 'defaultBillingAddress' => $billingAddress,
  477.                 'defaultShippingAddress' => $shippingAddress,
  478.                 'customerNumber' => "10142",
  479.                 'firstName' => $billingAddress['firstName'],
  480.                 'lastName' => $billingAddress['lastName'],
  481.                 'email' => $email,
  482.             ],
  483.         ], $context);
  485.         return $customerId;
  486.     }
  488.     private function getValidPaymentMethodId(?string $salesChannelId, Context $context): string
  489.     {
  490.         $criteria = (new Criteria())
  491.             ->setLimit(1)
  492.             ->addFilter(new EqualsFilter('active', true));
  494.         if ($salesChannelId) {
  495.             $criteria->addFilter(new EqualsFilter('salesChannels.id', $salesChannelId));
  496.         }
  498.         /** @var string $id */
  499.         $id = $this->paymentRepository->searchIds($criteria, $context)->firstId();
  501.         return $id;
  502.     }
  504.     private function getIdByTransactionStateName(string $name, Context $context): ?string
  505.     {
  506.         $stateMachineCriteria = new Criteria();
  507.         $stateMachineCriteria->addFilter(new EqualsFilter('technicalName', $name));
  509.         return $this->stateMachineStateRepository->search($stateMachineCriteria, $context)->first()?->getId();
  510.     }
  512.     private function getInitialStateIdByName(string $name, $context)
  513.     {
  514.         $stateMachineCriteria = new Criteria();
  515.         $stateMachineCriteria->addFilter(new EqualsFilter('technicalName', $name));
  517.         return $this->stateMachineRepository->search($stateMachineCriteria, $context)->first()->getInitialStateId();
  518.     }
  520.     private function getSaleChannelDetails(string $salesChannelId, Context $context): SalesChannelEntity
  521.     {
  522.         $criteria = new  Criteria();
  523.         $criteria->addAssociation('currency');
  524.         $criteria->addFilter(new EqualsFilter('id', $salesChannelId));
  526.         return $this->salesChannelRepository->search($criteria, $context)->first();
  527.     }
  529.     private function getLanguageDetails(Context $context)
  530.     {
  531.         $criteria = new  Criteria();
  532.         $criteria->addFilter(new EqualsFilter('locale.code', 'en-GB'));
  534.         return $this->languageRepository->search($criteria, $context)->first()->getId();
  535.     }
  537.     private function getOrderAddressData(
  538.         string $orderId,
  539.         array $addressData,
  540.         string $fallbackCountryId,
  541.         Context $context
  542.     ): array {
  543.         return [
  544.             'id' => Uuid::randomHex(),
  545.             'countryId' => $this->getCountryIdByCode($addressData['country_code'], $context) ?? $fallbackCountryId,
  546.             'orderId' => $orderId,
  547.             'salutationId' => $this->getValidSalutationId($context),
  548.             'firstName' => $addressData['first_name'],
  549.             'lastName' => $addressData['surname'],
  550.             'street' => $addressData['street_name'],
  551.             'zipcode' => $addressData['zip_code'],
  552.             'city' => $addressData['city'],
  553.             'additionalAddressLine1' => $addressData['extra_address_information'],
  554.             'created_at' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  555.         ];
  556.     }
  558.     private function getValidSalutationId(Context $context): string
  559.     {
  560.         $criteria = (new Criteria())
  561.             ->setLimit(1)
  562.             ->addSorting(new FieldSorting('salutationKey'));
  564.         /** @var string $id */
  565.         $id = $this->salutationRepository->searchIds($criteria, $context)->firstId();
  567.         return $id;
  568.     }
  570.     public function getOrderStatus(string $orderId, Context $context)
  571.     {
  572.         $getOrderCriteria = new  Criteria();
  573.         $getOrderCriteria->addFilter(new OrFilter([
  574.             new EqualsFilter('orderId', $orderId),
  575.             new EqualsFilter('webShopOrderId', $orderId)
  576.         ]));
  577.         $getOrderCriteria->addAssociation('order.stateMachineState');
  579.         $order = $this->webshopnlOrderRepository->search($getOrderCriteria, $context)->first();
  581.         if ($order instanceof WebShopOrderEntity && $order->getOrder() !== null) {
  582.             return new JsonResponse([
  583.                 'id' => $orderId,
  584.                 'order_status' => $order->getOrder()->getStateMachineState()?->getTechnicalName() ?? 'error',
  585.             ]);
  586.         }
  588.         return new JsonResponse([
  589.             'status' => "No order found",
  590.         ]);
  591.     }
  593.     private function getCountryIdByCode(string $code, Context $context): ?string
  594.     {
  595.         $criteria = new Criteria();
  596.         $criteria->addFilter(new EqualsFilter('iso', $code));
  598.         return $this->countryRepository->searchIds($criteria, $context)->firstId();
  599.     }
  601.     private function getCurrency(string $code, Context $context): ?CurrencyEntity
  602.     {
  603.         if (empty($code)) {
  604.             return null;
  605.         }
  607.         $criteria = new Criteria();
  608.         $criteria->addFilter(new EqualsFilter('isoCode', $code));
  610.         return $this->currencyRepository->search($criteria, $context)->first();
  611.     }
  612. }