100 lines
3.6 KiB
PHP
100 lines
3.6 KiB
PHP
<?php
|
|
|
|
namespace SoundPress\WHIOrders\Observer\Checkout;
|
|
|
|
use SoundPress\WHIOrders\Helper\ConfigHelper;
|
|
use Magento\Framework\Event\Observer;
|
|
use Magento\Framework\Event\ObserverInterface;
|
|
use GuzzleHttp\ClientFactory;
|
|
use GuzzleHttp\Exception\GuzzleException;
|
|
use Psr\Log\LoggerInterface;
|
|
|
|
class SendWHIOrder implements ObserverInterface
|
|
{
|
|
protected $clientFactory;
|
|
protected $configHelper;
|
|
protected $logger;
|
|
|
|
public function __construct(
|
|
ClientFactory $clientFactory,
|
|
ConfigHelper $configHelper,
|
|
LoggerInterface $logger
|
|
) {
|
|
$this->clientFactory = $clientFactory;
|
|
$this->configHelper = $configHelper;
|
|
$this->logger = $logger;
|
|
}
|
|
|
|
function execute(Observer $observer)
|
|
{
|
|
$order = $observer->getEvent()->getOrder();
|
|
$shippingAddress = $order->getShippingAddress();
|
|
$billingAddress = $order->getBillingAddress();
|
|
|
|
$whiOrder = [
|
|
'metadata' => [
|
|
'platform' => 'Magento',
|
|
'plaformOrderId' => $order->getId(),
|
|
],
|
|
'billingAddress' => [
|
|
'firstName' => $billingAddress->getFirstname(),
|
|
'lastName' => $billingAddress->getLastname(),
|
|
'address1' => $billingAddress->getStreet()[0],
|
|
'address2' => count($billingAddress->getStreet()) > 1 ? $billingAddress->getStreet()[1] : null,
|
|
'city' => $billingAddress->getCity(),
|
|
'state' => $billingAddress->getRegion(),
|
|
'zip' => $billingAddress->getPostCode(),
|
|
'email' => $billingAddress->getEmail(),
|
|
'phone' => $billingAddress->getTelephone()
|
|
],
|
|
'shippingAddress' => [
|
|
'firstName' => $shippingAddress->getFirstname(),
|
|
'lastName' => $shippingAddress->getLastname(),
|
|
'address1' => $shippingAddress->getStreet()[0],
|
|
'address2' => count($shippingAddress->getStreet()) > 1 ? $shippingAddress->getStreet()[1] : null,
|
|
'city' => $shippingAddress->getCity(),
|
|
'state' => $shippingAddress->getRegion(),
|
|
'zip' => $shippingAddress->getPostCode(),
|
|
],
|
|
'amounts' => [
|
|
'shipping' => $order->getShippingAmount(),
|
|
'tax' => $order->getTaxAmount(),
|
|
'subtotal' => $order->getSubtotal(),
|
|
'total' => $order->getGrandTotal(),
|
|
],
|
|
'parts' => []
|
|
];
|
|
|
|
foreach ($order->getAllItems() as $item) {
|
|
$part = [
|
|
'sku' => $item->getSku(),
|
|
'price' => $item->getPrice(),
|
|
'salesTax' => $item->getTaxAmount(),
|
|
'discount' => $item->getDiscountAmount(),
|
|
'quantity' => $item->getQtyOrdered(),
|
|
];
|
|
|
|
array_push($whiOrder['parts'], $part);
|
|
}
|
|
|
|
$baseUrl = $this->configHelper->getBaseUrl();
|
|
$token = $this->configHelper->getApiToken();
|
|
|
|
$client = $this->clientFactory->create(['config' => [
|
|
'base_uri' => $baseUrl,
|
|
'headers' => [
|
|
'Content-type' => 'application/json',
|
|
'Authorization' => "Bearer $token"
|
|
]
|
|
]]);
|
|
|
|
try {
|
|
$client->request('POST', 'whi/orders', [
|
|
'body' => json_encode($whiOrder)
|
|
]);
|
|
} catch (GuzzleException $exception) {
|
|
$this->logger->error('Error sending ' . $order->getId() . ' to WHI for processing. Server returned HTTP response code ' . $exception->getCode());
|
|
}
|
|
}
|
|
}
|