custom/plugins/CioTetra/src/Subscriber/OrderExportSubscriber.php line 49

Open in your IDE?
  1. <?php
  3. namespace CioTetra\Subscriber;
  5. use CioTetra\CioTetra;
  6. use CioTetra\Traits\SftpTrait;
  7. use CioTetra\Traits\UTF8Trait;
  8. use Shopware\Core\Framework\Context;
  9. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  10. use Shopware\Core\Checkout\Order\Aggregate\OrderCustomer\OrderCustomerEntity;
  11. use Shopware\Core\Checkout\Order\OrderEntity;
  12. use Shopware\Core\System\SystemConfig\SystemConfigService;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  18. class OrderExportSubscriber implements EventSubscriberInterface
  19. {
  20.     use SftpTrait;
  21.     use UTF8Trait;
  23.     private SystemConfigService $configService;
  25.     private EntityRepositoryInterface $customerRepository;
  27.     private EntityRepositoryInterface $countryRepository;
  29.     private EntityRepositoryInterface $languageRepository;
  31.     private $GERMAN_LANGUAGE_ID;
  33.     public function __construct(SystemConfigService $configService, EntityRepositoryInterface $customerRepository, EntityRepositoryInterface $countryRepository, EntityRepositoryInterface $languageRepository)
  34.     {
  35.         $this->configService = $configService;
  36.         $this->customerRepository = $customerRepository;
  37.         $this->countryRepository = $countryRepository;
  38.         $this->languageRepository = $languageRepository;
  39.         $this->GERMAN_LANGUAGE_ID = $this->getGermanLanguageId();
  40.     }
  42.     public static function getSubscribedEvents(): array
  43.     {
  44.         return [
  45.             CheckoutOrderPlacedEvent::class => 'onOrderPlaced',
  46.         ];
  47.     }
  49.     public function onOrderPlaced(CheckoutOrderPlacedEvent $event): void
  50.     {
  51.         [$fullPath, $filename] = $this->getFileName($event->getOrder()->getOrderNumber());
  53.         $filecontent = $this->generateOrderFile($event->getOrder()->getOrderCustomer(), $event->getOrder(), $event);
  55.         if (file_put_contents($fullPath, $filecontent)) {
  56.             $uploadSuccess = $this->directUpload($fullPath, $filename, $filecontent);
  58.             if (!$uploadSuccess) {
  59. //            TODO: inplement false handling
  60.             }
  62.         } else {
  63. //            TODO: inplement false handling
  64.         }
  66.     }
  68.     private function getCountryNameInGerman($isoCode)
  69.     {
  70.         $criteria = new Criteria();
  71.         $criteria->addAssociation('translations');
  72.         $criteria->addFilter(new EqualsFilter('iso3', $isoCode));
  73.         $country =  $this->countryRepository->search($criteria, Context::createDefaultContext())->first();
  75.         foreach ($country->translations->getElements() as $item){
  76.             if( $item->getLanguageId() == $this->GERMAN_LANGUAGE_ID){
  77.                 return $item->getName();
  78.             }
  79.         }
  80.     }
  82.     private function getKStatus1($isoCode)
  83.     {
  84.         if( in_array($isoCode, ["DEU"]))
  85.         {
  86.             return "EU";
  87.         }
  88.         if( in_array($isoCode, ["AUT", "BEL", "BGR", "HRV", "CYP", "CZE", "DNK", "EST", "FIN", "FRA", "GRC", "HUN", "IRL", "ITA", "LVA", "LTU", "LUX", "MLT", "NLD", "POL", "PRT", "ROU", "SVK", "SVN", "ESP", "SWE"]))
  89.         {
  90.             return "EU";
  91.         }
  92.         return "Int";
  93.     }
  95.     private function getGermanLanguageId()
  96.     {
  97.         $criteria = new Criteria();
  98.         $criteria->addAssociation('locale');
  99.         $criteria->addFilter(new EqualsFilter('locale.code', 'de-DE'));
  101.         $language = $this->languageRepository->search($criteria, Context::createDefaultContext())->first();
  103.         return $language->getId();
  104.     }
  106.     private function getShippingCost($deliveries = null)
  107.     {
  108.         $shippingCost = 0;
  109.         if($deliveries){
  110.             foreach($deliveries as $delivery){
  111.                 if($delivery->getShippingCosts()->getTotalPrice() > $shippingCost){
  112.                     $shippingCost = $delivery->getShippingCosts()->getTotalPrice();
  113.                 }
  114.             }
  115.         }
  116.         return number_format($shippingCost,2,',', '');
  117.     }
  119.     private function getShippingCostDiscount($deliveries = null)
  120.     {
  121.         $shippingCostDiscount = 0;
  122.         if($deliveries){
  123.             foreach($deliveries as $delivery){
  124.                 if($delivery->getShippingCosts()->getTotalPrice() < $shippingCostDiscount){
  125.                     $shippingCostDiscount = $delivery->getShippingCosts()->getTotalPrice();
  126.                 }
  127.             }
  128.         }
  129.         return $shippingCostDiscount;
  130.     }
  132.     private function generateOrderFile(OrderCustomerEntity $customer, OrderEntity $order, CheckoutOrderPlacedEvent $event): string
  133.     {
  134.         $criteria = new Criteria([$customer->getCustomerId()]);
  135.         $customer = $this->customerRepository->search($criteria, Context::createDefaultContext())->first();
  137.         $existingCustomer         = false;
  138.         $differentDeliveryAddress = false;
  140.         $exportText[] = '[Vor]';
  141.         $exportText[] = 'Art=164';
  142.         $exportText[] = 'StArt=4';
  143.         $exportText[] = 'VDat=#' . $order->getCreatedAt()->format('m.d.Y') . '#';
  144.         $exportText[] = 'Zeichen="' . $order->getOrderNumber() . '"';
  145.         $exportText[] = 'Betreff="Webshop Bestellung"';
  147.         $useObjID = false;
  148.         $useObjIDString = '';
  149.         if( $order->getCustomerComment() != '') {
  150.             $useObjID = true;
  151.             $useObjIDString .= "Bestellkommentar: " . str_replace(array("\r\n", "\r", "\n"), " ", $order->getCustomerComment());
  152.         }
  154.         if( $order->getCustomFields() ){
  155.             if( array_key_exists('custom_field_budget_name_save_on_order', $order->getCustomFields())){
  156.                 if( $useObjID ){
  157.                     $useObjIDString .= " | ";
  158.                 }
  159.                 $useObjIDString .= 'Budgetbestellung: ' . $order->getCustomFields()['custom_field_budget_name_save_on_order'];
  160.             }
  161.         }
  164.         if( $useObjID == true ){
  165.             $exportText[] = 'ObjID="' . $useObjIDString . '"';
  166.         }
  168.         $customFields = $customer->getCustomFields();
  170.         $billingAddress  = $order->getAddresses()->first();
  171.         $shippingAddress = $order->getAddresses()->last();
  173.         if( $billingAddress->getId() != $shippingAddress->getId() )
  174.         {
  175.             $differentDeliveryAddress = true;
  176.         }
  178.         if(is_array($customFields))
  179.         {
  180.             if(array_key_exists('custom_customer_itpnumber', $customFields) && !empty($customFields['custom_customer_itpnumber']))
  181.             {
  182.                 $existingCustomer = true;
  183.                 $itpNumber        = $customFields['custom_customer_itpnumber'];
  184.             }
  185.         }
  187.         if( $existingCustomer )
  188.         {
  189.             $exportText[] = '[VAdr]';
  190.             $exportText[] = 'AdrNr="' . $itpNumber . '"';
  191.             $exportText[] = 'Name1="' . $billingAddress->getFirstName() . ' ' . $billingAddress->getLastName() . '"';
  193.             if( $differentDeliveryAddress )
  194.             {
  195.                 $exportText[] = '[Adr]';
  196.                 $exportText[] = 'AdrNr="######"';
  197.                 $exportText[] = 'Anrede="(Firma)"';
  198.                 $exportText[] = 'Name="' . $shippingAddress->getFirstName() . ' ' . $shippingAddress->getLastName() . '"';
  199.                 $exportText[] = 'Str="' . $shippingAddress->getStreet() . '"';
  200.                 $exportText[] = 'Plz="' . $shippingAddress->getZipcode() . '"';
  201.                 $exportText[] = 'Ort="' . $shippingAddress->getCity() . '"';
  202.                 $exportText[] = 'Nation=Nation("' . $this->getCountryNameInGerman($shippingAddress->getCountry()->getIso3()) . '")';
  203.                 $exportText[] = 'KGruppe=32';
  204.                 $exportText[] = 'KStatus1="' . $this->getKStatus1($shippingAddress->getCountry()->getIso3()) . '"';
  205.                 $exportText[] = '[Ansp]';
  206.                 $exportText[] = 'Anrede="Herr"';
  207.                 $exportText[] = 'Name="Ingo Hillebrand"';
  208.                 $exportText[] = '[Komm]';
  209.                 $exportText[] = 'MOpt=0';
  210.                 $exportText[] = 'Typ=48';
  211.                 $exportText[] = 'Nr="Ingo.Hillebrand@connect-io.de"';
  212.                 $exportText[] = '[VAdr]';
  213.                 $exportText[] = 'Typ=30';
  214.             }
  215.         }else
  216.         {
  217.             $exportText[] = '[Adr]';
  218.             $exportText[] = 'AdrNr="######"';
  219.             $exportText[] = 'Anrede="(Firma)"';
  220.             $exportText[] = 'Name="' . $customer->getCompany() . '"';
  221.             $exportText[] = 'Str="' . $billingAddress->getStreet() . '"';
  222.             $exportText[] = 'Plz="' . $billingAddress->getZipcode() . '"';
  223.             $exportText[] = 'Ort="' . $billingAddress->getCity() . '"';
  224.             $exportText[] = 'Nation=Nation("' . $billingAddress->getCountry()->getName() . '")';
  225.             $exportText[] = 'KGruppe=32';
  226.             $exportText[] = 'KStatus1="' . $this->getKStatus1($billingAddress->getCountry()->getIso3()) . '"';
  227.             $exportText[] = '[Ansp]';
  228.             $exportText[] = 'Anrede="' . $billingAddress->getSalutation()->getDisplayName() . '"';
  229.             $exportText[] = 'Name="' . $billingAddress->getFirstName() . ' ' . $billingAddress->getLastName() . '"';
  230.             $exportText[] = '[Komm]';
  231.             $exportText[] = 'MOpt=0';
  232.             $exportText[] = 'Typ=48';
  233.             $exportText[] = 'Nr="' . $customer->getEmail() . '"';
  234.             $exportText[] = '[VAdr]';
  235.             $exportText[] = 'Typ=0';
  237.             if( $differentDeliveryAddress )
  238.             {
  239.                 $exportText[] = 'AdrNr="######"';
  240.                 $exportText[] = 'Anrede="(Firma)"';
  241.                 $exportText[] = 'Name="' . $shippingAddress->getCompany() . '"';
  242.                 $exportText[] = 'Str="' . $shippingAddress->getStreet() . '"';
  243.                 $exportText[] = 'Plz="' . $shippingAddress->getZipcode() . '"';
  244.                 $exportText[] = 'Ort="' . $shippingAddress->getCity() . '"';
  245.                 $exportText[] = 'Nation=Nation("' . $shippingAddress->getCountry()->getName() . '")';
  246.                 $exportText[] = 'KGruppe=32';
  247.                 $exportText[] = 'KStatus1="' . $this->getKStatus1($shippingAddress->getCountry()->getIso3()) . '"';
  248.                 $exportText[] = '[Ansp]';
  249.                 $exportText[] = 'Anrede="' . $shippingAddress->getSalutation()->getDisplayName() . '"';
  250.                 $exportText[] = 'Name="' . $shippingAddress->getFirstName() . ' ' . $shippingAddress->getLastName() . '"';
  251.                 $exportText[] = '[Komm]';
  252.                 $exportText[] = 'MOpt=0';
  253.                 $exportText[] = 'Typ=48';
  254.                 $exportText[] = 'Nr="' . $customer->getEmail() . '"';
  255.                 $exportText[] = '[VAdr]';
  256.                 $exportText[] = 'Typ=30';
  257.             }
  258.         }
  260.         $i = 1;
  261.         $isShippingDiscountUsed = false;
  262.         foreach ($order->getLineItems() as $item) {
  264.             $payload = $item->getPayload();
  266.             if( $item->getType() == 'product' ) {
  267.                 if (array_key_exists('productNumber', $payload)) {
  268.                     $exportText[] = "[VPos]";
  269.                     $exportText[] = 'Pos=' . $i++;
  270.                     $exportText[] = 'ArtId=ArtNr2ID("' . $item->getPayload()['productNumber'] . '")';
  271.                     $exportText[] = 'VarId=ArtNr2ID("' . $item->getPayload()['productNumber'] . '-I";1)';
  272.                     $exportText[] = 'PosMg=' . number_format($item->getQuantity(), 2, ',', '');
  273.                     $exportText[] = 'Preis=' . number_format($item->getTotalPrice(), 2, ',', '');
  274.                 }
  275.             }
  277.             if( $item->getType() == 'promotion') {
  278.                 $price = $item->getTotalPrice();
  279.                 if( $price == 0 && $isShippingDiscountUsed == false ){
  280.                     $price += $this->getShippingCostDiscount($order->getDeliveries());
  281.                 }
  282.                 $exportText[] = "[VPos]";
  283.                 $exportText[] = 'Pos=' . $i++;
  284.                 $exportText[] = 'ObjID="Rabatt"';
  285.                 $exportText[] = 'ArtNr="Rabatt"';
  286.                 $exportText[] = 'PosMg=' . number_format($item->getQuantity(), 2, ',', '');
  287.                 $exportText[] = 'Preis=' . number_format($price, 2, ',', '');
  288.             }
  289.         }
  292.         $exportText[] = "[VPos]";
  293.         $exportText[] = 'Pos=' . $i++;
  294.         $exportText[] = 'ObjID="Versandkosten"';
  295.         $exportText[] = 'ArtNr="Versandkosten"';
  296.         $exportText[] = 'PosMg=1';
  297.         $exportText[] = 'Preis=' . $this->getShippingCost($order->getDeliveries());
  299.         $exportText = implode(PHP_EOL, $exportText);
  300.         return $exportText;
  301.     }
  303.     private function getFileName(string $ordernumber): array
  304.     {
  305.         $path = getcwd() . '/..' . CioTetra::ROUTE_EXPORT_DIRECTORY;
  306.         $filename = date('d_m_Y_H_i_s') . '_tetra_export-' . $ordernumber;
  307.         return [$path . $filename . '.txt', $filename . '.txt'];
  309.     }
  311.     private function directUpload(string $fullPath, string $filename, string $data): bool
  312.     {
  313.         $message = "Start direct Upload from Order File" . PHP_EOL;
  314.         $success = $this->uploadOrderFile($data, $filename, $message);
  316.         if ($success) {
  317.             unlink($fullPath);
  318.         }
  319.         return $success;
  320.     }
  321. }