Merge pull request #86 from Nosto/SSP-60_sales_is_not_tracked_in_nost…

…o_backend_anymore_v4

SSP-60 Sales is not tracked in Nosto-Backend anymore v4

src/Model/Operation/OrderSyncHandler.php

@@ -17,7 +17,10 @@
 use Shopware\Core\Framework\Context;
 use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
 use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
-use Shopware\Core\Framework\DataAbstractionLayer\{EntityCollection, EntityRepository};
+use Shopware\Core\Framework\DataAbstractionLayer\{EntityCollection, EntityRepository, Search\Filter\EqualsFilter};
+use Shopware\Core\Framework\Uuid\Uuid;
+use Shopware\Core\System\SalesChannel\Context\AbstractSalesChannelContextFactory;
+use Shopware\Core\System\SalesChannel\Context\SalesChannelContextService;
 use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
 use Throwable;
 
@@ -26,6 +29,7 @@ class OrderSyncHandler implements JobHandlerInterface
     public const HANDLER_CODE = 'nosto-integration-order-sync';
 
     public function __construct(
+        private readonly AbstractSalesChannelContextFactory $channelContextFactory,
         private readonly EntityRepository $orderRepository,
         private readonly Account\Provider $accountProvider,
         private readonly OrderBuilder $nostoOrderbuilder,
@@ -41,7 +45,14 @@ public function execute(object $message): JobResult
     {
         $operationResult = new JobResult();
         foreach ($this->accountProvider->all($message->getContext()) as $account) {
-            $accountOperationResult = $this->doOperation($account, $message->getContext(), $message);
+            $channelContext = $this->channelContextFactory->create(
+                Uuid::randomHex(),
+                $account->getChannelId(),
+                [
+                    SalesChannelContextService::LANGUAGE_ID => $account->getLanguageId(),
+                ],
+            );
+            $accountOperationResult = $this->doOperation($account, $channelContext->getContext(), $message);
             foreach ($accountOperationResult->getErrors() as $error) {
                 $operationResult->addError($error);
             }
@@ -82,6 +93,7 @@ private function getOrders(Context $context, array $orderIds): EntityCollection
         $criteria->addAssociation('transactions.paymentMethod');
         $criteria->addAssociation('lineItems.orderLineItem.product');
         $criteria->addFilter(new EqualsAnyFilter('id', $orderIds));
+        $criteria->addFilter(new EqualsFilter('languageId', $context->getLanguageId()));
         $this->eventDispatcher->dispatch(new NostoOrderCriteriaEvent($criteria, $context));
         return $this->orderRepository->search($criteria, $context)->getEntities();
     }

src/Resources/config/services.xml

@@ -30,6 +30,7 @@
         <service id="Nosto\NostoIntegration\Model\Operation\OrderSyncHandler">
             <tag name="nosto.job_handler" code="nosto-integration-order-sync" />
 
+            <argument key="$channelContextFactory" type="service" id="Shopware\Core\System\SalesChannel\Context\SalesChannelContextFactory" />
             <argument key="$orderRepository" type="service" id="order.repository" />
         </service>