custom/plugins/NextagFlow/src/Flow/ProcessOrderAction.php line 82

Open in your IDE?
  1. <?php
  3. namespace Nextag\Flow\Flow;
  5. use Exception;
  6. use Elasticsearch\ClientBuilder;
  7. use Nextag\Checkout\Content\Checkout\CheckoutService;
  8. use Shopware\Core\Content\Flow\Dispatching\Action\FlowAction;
  9. use Shopware\Core\Framework\Event\FlowEvent;
  10. use Nextag\Flow\Helper\Log;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  15. class ProcessOrderAction extends FlowAction
  16. {
  17.     private Log $log;
  18.     private \Nextag\Mail\Helper\MailGenerator $mailGenerator;
  19.     private $checkoutService;
  20.     private $giftcardHelper;
  21.     private $promotionHelper;
  22.     private $orderExtensionRepository;
  23.     private $config;
  24.     private $wordpress;
  25.     private $productRepository;
  26.     private $languageRepository;
  27.     private $elasticClient = null;
  28.     protected $eventHelper;
  29.     protected $abacus;
  30.     protected $indexPrefix;
  31.     protected $hostname;
  32.     protected $port;
  33.     protected $locales;
  34.     protected $languageCache;
  37.     public function __construct(
  38.         \Shopware\Core\System\SystemConfig\SystemConfigService $config,
  39.         Log $log,
  40.         EntityRepositoryInterface $orderExtensionRepository,
  41.         \Nextag\Mail\Helper\MailGenerator $mailGenerator,
  42.         CheckoutService $checkoutService,
  43.         \Nextag\Giftcard\Helper\Giftcard $giftcardHelper,
  44.         \Nextag\Product\Helper\Event $eventHelper,
  45.         \Nextag\Giftcard\Helper\Promotion $promotionHelper,    
  46.         \Nextag\Checkout\Helper\Abacus $abacus,
  47.         \Nextag\Connector\Helper\Wordpress $wordpress,
  48.         EntityRepositoryInterface $productRepository,
  49.         EntityRepositoryInterface $languageRepository
  50.     ) {
  51.         $this->config = $config;
  52.         $this->log = $log;
  53.         $this->orderExtensionRepository = $orderExtensionRepository;
  54.         $this->checkoutService = $checkoutService;
  55.         $this->giftcardHelper = $giftcardHelper;
  56.         $this->eventHelper = $eventHelper;
  57.         $this->promotionHelper = $promotionHelper;
  58.         $this->mailGenerator = $mailGenerator;      
  59.         $this->abacus = $abacus;
  60.         $this->wordpress = $wordpress;
  61.         $this->productRepository = $productRepository;
  62.         $this->languageRepository = $languageRepository;        
  63.     }
  65.     public static function getName(): string
  66.     {
  67.         return 'action.flow.nextag.processorder';
  68.     }
  70.     public static function getSubscribedEvents(): array
  71.     {
  72.         return [
  73.             self::getName() => 'handle'
  74.         ];
  75.     }
  77.     public function requirements(): array
  78.     {
  79.         return [];
  80.     }
  82.     public function handle(FlowEvent $event): void
  83.     {
  84.         try {
  85.             $this->log->info("Processorderaction start");
  86.             $language = "de";
  87.             $context = $event->getContext();
  88.             $config = $event->getConfig();
  89.             $order = null;
  90.             try {
  91.                 $order = $event->getEvent()->getOrder();
  92.             } catch (Exception $e) {
  93.                 $this->log->error($e);
  94.                 $this->log->error(new \Exception("Flow ProcessOrder: Order not found"));
  95.                 return;
  96.             }
  97.             if ($order === null) {
  98.                 $this->log->error(new \Exception("Flow ProcessOrder: Order not found"));
  99.                 return;
  100.             }
  101.             $this->log->info("Ordernumber: ".$order->getOrdernumber());
  102.             try {
  103.                 if (isset($config["processgiftcards"]) && $config["processgiftcards"]["status"]) {
  104.                     $this->log->info("process giftcards");
  105.                     $this->giftcardHelper->processGiftcardsUsed($order, $context);
  106.                     $this->giftcardHelper->processGiftcardsBuys($order, $language, $context);
  107.                 }
  108.                 if (isset($config["processpromotions"]) && $config["processpromotions"]["status"]) {
  109.                     $this->log->info("process promotions");
  110.                     $this->promotionHelper->processPromotionUsed($order, $context);
  111.                 }
  112.                 if (isset($config['processwordpressevents']) && $config['processwordpressevents']['status']) {
  113.                     $this->log->info("processwordpressevents");
  114.                     $this->wordpress->processWordpressEvents($order);   
  115.                 } else {
  116.                     $this->log->info("not processwordpressevents");
  117.                 }
  118.             } catch (Exception $e) {
  119.                 $this->log->error($e);
  120.             }
  122.             $resultExportOrder = true;
  123.          
  124.             try {
  125.                 $criteria = new Criteria();
  126.                 $criteria->addFilter(new EqualsFilter("orderId", $order->getId()));
  127.                 $orderExtension = $this->orderExtensionRepository->search($criteria, $context)->getEntities()->first();
  128.                 $data = [];
  129.                 if ($orderExtension) {
  130.                     $data["id"] = $orderExtension->getId(); 
  131.                     if ($orderExtension->getComment()) {
  132.                         $data["comment"] = $orderExtension->getComment();
  133.                     }
  134.                     if ($orderExtension->getDeliverydate()) {
  135.                         $data["deliverydate"] = $orderExtension->getDeliverydate();
  136.                     }
  137.                     if ($orderExtension->getDeliverytype()) {
  138.                         $data["deliverytype"] = $orderExtension->getDeliverytype();
  139.                     }
  140.                     if ($orderExtension->getDeliverylocation()) {
  141.                         $data["deliverylocation"] = $orderExtension->getDeliverylocation();
  142.                     }
  143.                     if ($orderExtension->getDeliverylocationcomment()) {
  144.                         $data["deliverylocationcomment"] = $orderExtension->getDeliverylocationcomment();
  145.                     }
  147.                     if ($orderExtension->getGiftmessagefrom()) {
  148.                         $data["giftmessagefrom"] = $orderExtension->getGiftmessagefrom();
  149.                     }
  150.                     if ($orderExtension->getGiftmessageto()) {
  151.                         $data["giftmessageto"] = $orderExtension->getGiftmessageto();
  152.                     }
  153.                     if ($orderExtension->getGiftmessage()) {
  154.                         $data["giftmessage"] = $orderExtension->getGiftmessage();
  155.                     }
  157.                     if ($orderExtension->getGiftbox1qty()) {
  158.                         $data["giftbox1qty"] = $orderExtension->getGiftbox1qty();
  159.                     }
  160.                     if ($orderExtension->getGiftbox2qty()) {
  161.                         $data["giftbox2qty"] = $orderExtension->getGiftbox2qty();
  162.                     }
  163.                     if ($orderExtension->getGiftbox3qty()) {
  164.                         $data["giftbox3qty"] = $orderExtension->getGiftbox3qty();
  165.                     }
  166.                     if ($orderExtension->getGiftbox4qty()) {
  167.                         $data["giftbox14qty"] = $orderExtension->getGiftbox4qty();
  168.                     }
  169.                     if ($orderExtension->getGiftbox5qty()) {
  170.                         $data["giftbox5qty"] = $orderExtension->getGiftbox5qty();
  171.                     }
  172.                     if ($orderExtension->getGiftbox6qty()) {
  173.                         $data["giftbox6qty"] = $orderExtension->getGiftbox6qty();
  174.                     }
  175.                     if ($orderExtension->getGiftbox7qty()) {
  176.                         $data["giftbox7qty"] = $orderExtension->getGiftbox7qty();
  177.                     }
  178.                     if ($orderExtension->getGiftbox8qty()) {
  179.                         $data["giftbox8qty"] = $orderExtension->getGiftbox8qty();
  180.                     }
  181.                     if ($orderExtension->getGiftbox1comment()) {
  182.                         $data["giftbox1comment"] = $orderExtension->getGiftbox1comment();
  183.                     }
  184.                     if ($orderExtension->getGiftbox2comment()) {
  185.                         $data["giftbox2comment"] = $orderExtension->getGiftbox2comment();
  186.                     }
  187.                     if ($orderExtension->getGiftbox3comment()) {
  188.                         $data["giftbox3comment"] = $orderExtension->getGiftbox3comment();
  189.                     }
  190.                     if ($orderExtension->getGiftbox4comment()) {
  191.                         $data["giftbox4comment"] = $orderExtension->getGiftbox4comment();
  192.                     }
  193.                     if ($orderExtension->getGiftbox5comment()) {
  194.                         $data["giftbox5comment"] = $orderExtension->getGiftbox5comment();
  195.                     }
  196.                     if ($orderExtension->getGiftbox6comment()) {
  197.                         $data["giftbox6comment"] = $orderExtension->getGiftbox6comment();
  198.                     }
  199.                     if ($orderExtension->getGiftbox7comment()) {
  200.                         $data["giftbox7comment"] = $orderExtension->getGiftbox7comment();
  201.                     }
  202.                     if ($orderExtension->getGiftbox8comment()) {
  203.                         $data["giftbox8comment"] = $orderExtension->getGiftbox8comment();
  204.                     }
  205.                     if ($orderExtension->getRetouren()) {
  206.                         $data["retouren"] = $orderExtension->getRetouren();
  207.                     }
  209.                     if ($orderExtension->getVoigtkundennummer()) {
  210.                         $data["voigtkundennummer"] = $orderExtension->getVoigtkundennummer();
  211.                     }
  213.                     if ($orderExtension->getLanguage()) {
  214.                         $data["language"] = $orderExtension->getLanguage();
  215.                     }
  216.                     if ($resultExportOrder) {
  217.                         $data["exportordererp"] = 1;
  218.                     } else {
  219.                         $data["exportordererp"] = 2;
  220.                     }
  221.                     $this->checkoutService->save($data, $event->getEvent());
  222.                 }
  223.             } catch (Exception $e) {
  224.                 $this->log->error($e);
  225.             }
  227.             $config["exportorder"]["result"] = $resultExportOrder;
  229.             $this->reduceProductStocks($context, $order);
  231.             $this->log->info("process order emails");
  232.             $this->mailGenerator->processOrderEmails($order, $config, $orderExtension);
  233.             $this->eventHelper->sendEvent($order,"de-CH");   
  234.            
  235.             try {
  236.                if ($config["exportorder"]["status"]) {
  237.                     if ($this->config->get("NextagCheckout.config.abacusExportActive")) {
  238.                         $this->log->info("Abacus order export active", false);
  239.                         $this->abacus->exportOrder($order,$context);
  240.                     } else {
  241.                         $this->log->info("Abacus order export inactive",false);
  242.                     }            
  243.                }
  244.             } catch (Exception $e) {
  245.                 $this->log->error($e);
  246.             }
  248.             $this->log->info("Processorderaction end");
  249.         } catch (\Exception $e) {
  250.             $this->log->error($e);
  251.             throw $e;
  252.         }
  253.     }
  255.     private function reduceProductStocks($context,$order) {
  256.         try {
  257.             $lc = $this->config->get("NextagFilter.config.languageCodes");
  258.             if ($lc) {
  259.                 $this->locales = array_map(
  260.                     'trim',
  261.                     explode(",", $lc)
  262.                 );
  263.             }
  265.             $criteria = new Criteria();
  266.             $criteria->addAssociation('locale');
  267.             $lc = $this->languageRepository->search($criteria, $context);
  268.             foreach ($lc as $k => $v) {
  269.                 $this->languageCache[str_replace("-", "_", $v->getLocale()->getCode())] = $k;
  270.             }
  272.             foreach($order->getLineItems() as $lineItem) {
  273.                 $customFields = $lineItem->getPayload()["customFields"];
  274.                 $customData = [];
  275.                 if (isset($lineItem->getPayload()["customData"]) && !is_array($lineItem->getPayload()["customData"])) {
  276.                     $customData = json_decode($lineItem->getPayload()["customData"], true);
  277.                 }
  278.                 if (!isset($customData["isGiftcard"])  && !isset($lineItem->getPayload()["isShopPromotion"]) && !isset($lineItem->getPayload()["isUsedPromotion"]) && !isset($lineItem->getPayload()["isGiftcardUsed"])) {
  279.                     $availableQty = $lineItem->getPayload()["stock"];
  280.                     $quantity = $lineItem->getQuantity();
  281.                     $newQuantity = $availableQty - $quantity;
  282.                     if ($newQuantity < 0) {
  283.                         $newQuantity = 0;                        
  284.                     }
  285.                     if ($newQuantity == 0) {
  286.                         $d = [
  287.                             "id" => $lineItem->getReferencedId(),
  288.                             "stock" => $newQuantity,
  289.                             "customFields" => [
  290.                                 "custom_produkt_label_produkt_ausverkauft" => true
  291.                             ]
  292.                         ];
  293.                     } else {
  294.                         $d = [
  295.                             "id" => $lineItem->getReferencedId(),
  296.                             "stock" => $newQuantity
  297.                         ];
  298.                     }  
  299.                                       
  300.                     $this->updateElasticsearchProduct($lineItem,$d);                 
  302.                     $data[] = $d;
  303.                 }               
  304.             }
  305.             if (!empty($data)) {
  306.                 $this->productRepository->upsert($data,$context);            
  307.             }
  308.         } catch (Exception $e) {
  309.             $this->log->error($e);
  310.         }
  311.     }
  313.     private function updateElasticsearchProduct($lineItem, $data)
  314.     {
  315.         try {
  316.             //Elasticindexes updaten
  317.             $this->indexPrefix = $this->config->get("NextagFilter.config.elasticIndexprefix");
  318.             $this->hostname = $this->config->get("NextagFilter.config.elasticHostname");
  319.             $this->port = $this->config->get("NextagFilter.config.elasticPort");
  320.             
  321.             if ($this->hostname) {
  322.                 $hosts = [
  323.                     $this->hostname . ":" . $this->port
  324.                 ];
  325.                 if (!$this->elasticClient) {
  326.                     $this->elasticClient = ClientBuilder::create()
  327.                     ->setHosts($hosts)->build();
  328.                 }
  329.             }
  330.        
  331.             foreach ($this->locales as $locale) {
  332.                 if (isset($this->languageCache[$locale])) {
  333.                     $languageId = $this->languageCache[$locale];                                    
  334.                     $alias = strtolower($this->indexPrefix . $languageId);
  335.                     $searchParams = [
  336.                         "index" => $alias,
  337.                         "size" => 1,
  338.                         "q" => "productNumber:".$lineItem->getPayload()["productNumber"]
  339.                     ];
  340.                     $searchItem = $this->elasticClient->search($searchParams);                   
  341.                     if (!empty($searchItem["hits"]["hits"])) {
  342.                         $item = [
  343.                             "stock" => $data["stock"]
  344.                         ];
  346.                         if (isset($data["customFields"]) && isset($data["customFields"]["custom_produkt_label_produkt_ausverkauft"])) {   
  347.                             $item["custom_produkt_label_produkt_ausverkauft"] = $data["customFields"]["custom_produkt_label_produkt_ausverkauft"];
  348.                             $item["custom_produkt_label_produkt_ausverkauft_lowercase"] = $data["customFields"]["custom_produkt_label_produkt_ausverkauft"];
  349.                         }
  350.                         $payload = [
  351.                             'index' => $alias,
  352.                             'id' => (string) $searchItem["hits"]["hits"][0]["_source"]["elasticid"],
  353.                             'body' => ["doc" => $item]                        
  354.                         ];
  356.                         //Update
  357.                         $result = $this->elasticClient->update($payload);
  358.                     }                    
  359.                 }
  360.             }           
  361.         } catch (\Exception $exception) {
  362.             $this->log->error($exception);
  363.         }
  364.     }
  365. }