custom/plugins/AMGIamapprovedPlugin/src/Subscriber/CheckoutCompleteSubscriber.php line 59

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace AMG\IamapprovedPlugin\Subscriber;
  5. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  6. use Shopware\Core\Checkout\Order\Aggregate\OrderCustomer\OrderCustomerEntity;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Shopware\Core\Content\Product\ProductEvents;
  12. class CheckoutCompleteSubscriber implements EventSubscriberInterface
  13. {
  15.     function CallAPI($method, $url, $data = false)
  16.     {
  17.         $curl = curl_init();
  19.         switch ($method)
  20.         {
  21.             case "POST":
  22.                 curl_setopt($curl, CURLOPT_POST, 1);
  24.                 if ($data)
  26.                     curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
  27.                 break;
  28.             case "PUT":
  29.                 curl_setopt($curl, CURLOPT_PUT, 1);
  30.                 break;
  31.             default:
  32.                 if ($data)
  33.                     $url = sprintf("%s?%s", $url, http_build_query($data));
  34.         }
  36.         // Optional Authentication:
  37.         curl_setopt($curl, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
  38.         // Username + Password
  39.         curl_setopt($curl, CURLOPT_USERPWD, "shop:c4a7b55e-b40d-4dc5-b7ec-c07b019b93d7");
  41.         curl_setopt($curl, CURLOPT_HTTPHEADER, array('Content-Type:application/json'));
  42.         curl_setopt($curl, CURLOPT_URL, $url);
  43.         curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
  45.         $result = curl_exec($curl);
  47.         curl_close($curl);
  49.         return $result;
  50.     }
  52.     public static function getSubscribedEvents(): array
  53.     {
  54.         return [
  55.             CheckoutOrderPlacedEvent::class => 'onCheckoutOrderPlaced',
  56.         ];
  57.     }
  59.     public function onCheckoutOrderPlaced(CheckoutOrderPlacedEvent $event): void
  60.     {
  61.         /*        $event->getContext()->addAssociation('manufacturer.media');*/
  62.         error_log("Checkout 1", 0);
  63.         //Datenabruf zu Bestellung und Kunde
  64.         $order = $event->getOrder();
  66.         $customer = $order->getOrderCustomer();
  67.         $addresses = $order->getAddresses();
  69.         //Bestelldaten
  70.         $order_number = $order->getOrderNumber();
  71.         $order_date = $order->getOrderDateTime();
  72.         $amount_total = $order->getAmountTotal();                   // not needed
  73.         $amount_net = $order->getAmountNet();                       // not needed
  74.         $order_id = $order->getId();
  76.         $products = $order->getLineItems()->filterByOrderId($order_id); //->filterType(LineItem::PRODUCT_LINE_ITEM_TYPE)->getReferenceIds();
  78.         //Kundendaten
  79.         $first_name = $customer->getFirstName();
  80.         $last_name = $customer->getLastName();
  81.         $salutation = $customer->getSalutation()->getDisplayName();
  82.         $customer_number = $customer->getCustomerNumber();
  83.         $company = $customer->getCompany();
  84.         $email = $customer->getEmail();
  85.         //$ActiveShippingAddress = $customer->getActiveShippingAddress();
  87. //         error_log("Checkout 2", 0);
  88. //
  89. //         //// PARTS
  90. //         $parts = array();
  91. //         foreach($products as $product ){
  92. //
  93. //
  94. //             error_log(json_encode($product));
  95. //             /*            $customFields = $product->getProduct()->getCustomFields();
  96. //                         // loop through each product's custom fields
  97. //                         foreach($customFields as $name => $value) {
  98. //                             if ($name !== 'custom_linked_product' || empty($value)) {
  99. //                                return;
  100. //                             }
  101. //
  102. //                             // resolve the $value here
  103. //                         }
  104. //                         $product->setCustomFields($customFields);*/
  105. //
  106. //             /*$manufacturerId = $product->getPayload();*/
  107. //             array_push($parts, array(
  108. //                 "id"=>$product->getIdentifier(),
  109. //                 "type"=>$product->getType(),
  110. //                 "quantity"=>$product->getQuantity(),
  111. //                 "label"=>$product->getLabel(),
  112. //                 "weight"=>0.2,
  113. //                 "create_at"=>$product->getCreatedAt()->format("d-M-Y h:m:s"),
  114. //                 /*"article_number"=>$product->getPayload()["productNumber"],*/
  115. //                 "order_number"=>$order_number,
  116. //                 "payload"=>$product->getPayload()
  117. //             ));
  118. //         }
  119. //         /// END PARTS
  120. //
  121. //         // Shipping address
  122. //         $address=$addresses->last();
  123. //
  124. //         $country = array(
  125. //             "name"=>$address->getCountry()->getName(),
  126. //             "iso"=>$address->getCountry()->getIso(),
  127. //             "iso3"=>$address->getCountry()->getIso3()
  128. //         );
  129. //
  130. //         $order_address = array(
  131. //             "first_name"=>$address->getFirstName(),
  132. //             "last_name"=>$address->getLastName(),
  133. //             "street"=>$address->getStreet(),
  134. //             "zip"=>$address->getZipcode(),
  135. //             "city"=>$address->getCity(),
  136. //             "company"=>$address->getCompany(),
  137. //             "department"=>$address->getDepartment(),
  138. //             "country"=>$country
  139. //         );
  140. //
  141. //         $customer_obj = array(
  142. //             "id"=>$customer->getCustomerId(),
  143. //             "first_name"=>$first_name,
  144. //             "last_name"=>$last_name,
  145. //             "salutation"=>$salutation,
  146. //             "customer_number"=>$customer_number,
  147. //             "company"=>$company,
  148. //             "email"=>$email,
  149. //             "address"=>$order_address
  150. //         );
  151. //         // Order-JSON
  152.         $arr = array(
  153.             "id"=>$order_id,
  154.             "number"=>$order_number,
  155.             "date"=>$order_date->format("d-M-Y"), // h:m:s
  156. //             "partArray"=>$parts,
  157. //             "customer"=>$customer_obj
  158.         );
  159.         //json_encode($arr); host.docker.internal
  161.         //Produktversion
  162.        // $this->CallAPI("POST", "https://amcc.iam-approved.com/Controller-2.4.5/api/v1/order", json_encode($arr));
  163. //         $this->CallAPI("POST", "https://amcc.iam-approved.com/api/v1/order", json_encode($arr));
  165. //         $this->CallAPI("POST", "http://localhost:2701/api/v1/order", json_encode($arr));
  166.         $this->CallAPI("POST", "https://iam-controller.additive-marking.de/api/test/v1/order", json_encode($arr));
  168.         error_log(json_encode($arr), 0);
  170.         //Testcall
  171.         //$this->CallAPI("GET", "https://amcc.iam-approved.com/api/test", json_encode($output));       //testAll
  172.         //error_log($output, 0);
  173. //         error_log("Hallo Welt! Ich habe fertig!");
  175.     }
  176. }