mirror of
https://github.com/OpenXE-org/OpenXE.git
synced 2024-12-25 14:10:28 +01:00
2367 lines
59 KiB
PHP
2367 lines
59 KiB
PHP
<?php
|
|
/*
|
|
**** COPYRIGHT & LICENSE NOTICE *** DO NOT REMOVE ****
|
|
*
|
|
* Xentral (c) Xentral ERP Sorftware GmbH, Fuggerstrasse 11, D-86150 Augsburg, * Germany 2019
|
|
*
|
|
* This file is licensed under the Embedded Projects General Public License *Version 3.1.
|
|
*
|
|
* You should have received a copy of this license from your vendor and/or *along with this file; If not, please visit www.wawision.de/Lizenzhinweis
|
|
* to obtain the text of the corresponding license version.
|
|
*
|
|
**** END OF COPYRIGHT & LICENSE NOTICE *** DO NOT REMOVE ****
|
|
*/
|
|
?>
|
|
<?php
|
|
use Xentral\Components\Http\JsonResponse;
|
|
use Xentral\Modules\Onlineshop\Data\OrderStatus;
|
|
use Xentral\Modules\Onlineshop\Data\OrderStatusUpdateRequest;
|
|
use Xentral\Components\Logger\Logger;
|
|
|
|
class Shopimporter_Woocommerce extends ShopimporterBase
|
|
{
|
|
// protected $canexport = false;
|
|
|
|
public $intern = false;
|
|
public $shopid;
|
|
public $data;
|
|
|
|
/**
|
|
* @var $client WCClient $client
|
|
*/
|
|
public $client;
|
|
public $url;
|
|
|
|
/** These variables hold the status strings WooCommerce is using to represent
|
|
* the order status. They can easily be adjusted by the user via the GUI.
|
|
*/
|
|
public $statusPending;
|
|
public $statusProcessing;
|
|
public $statusCompleted;
|
|
public $priceType;
|
|
|
|
/**
|
|
* Stores the preferences that the user can change when editing this shop importer
|
|
* TODO: Looks like this should be moved to ShopimporterBase
|
|
* Unlike the other shop importers this is stored as an object variable - we dont
|
|
* want every single function that needs some prefrences to init a new SQL query
|
|
* @var $preferences array
|
|
*/
|
|
protected $preferences;
|
|
|
|
private $protokoll;
|
|
/**
|
|
* @var Application
|
|
*/
|
|
protected $app;
|
|
protected $dump;
|
|
|
|
/** @var Logger $logger */
|
|
public $logger;
|
|
|
|
public function __construct($app, $intern = false)
|
|
{
|
|
$this->app=$app;
|
|
$this->intern = true;
|
|
$this->logger = $app->Container->get('Logger');
|
|
}
|
|
|
|
public function ImportList()
|
|
{
|
|
$msg = $this->app->erp->base64_url_encode('<div class="info">Sie können hier die Shops einstellen</div>');
|
|
header('Location: index.php?module=onlineshops&action=list&msg='.$msg);
|
|
exit;
|
|
}
|
|
|
|
/**
|
|
* This function returns the number of orders which have not yet been imported
|
|
*/
|
|
public function ImportGetAuftraegeAnzahl()
|
|
{
|
|
// Query the API to get new orders, filtered by the order status as specifed by the user.
|
|
// We set per_page to 100 - this could lead to a situation where there are more than
|
|
// 100 new Orders, but we still only return 100.
|
|
|
|
// Array containing additional settings, namely 'ab_nummer' (containting the next order number to get)
|
|
// and 'holeallestati' (an integer)
|
|
$tmp = $this->CatchRemoteCommand('data');
|
|
|
|
// Only orders having an order number greater or equal than this should be fetched. null otherwise
|
|
$number_from = empty($tmp['ab_nummer']) ? null : (int)$tmp['ab_nummer'];
|
|
|
|
// pending orders will be fetched into this array. it's length is returned at the end of the funciton
|
|
$pendingOrders = array();
|
|
|
|
if ($number_from) {
|
|
// Number-based import is selected
|
|
|
|
// The WooCommerce API doenst allow for a proper "greater than id n" request.
|
|
// we fake this behavior by creating an array that contains 'many' (~ 1000) consecutive
|
|
// ids that are greater than $from_number and use this array with the 'include' property
|
|
// of the WooCommerce API
|
|
|
|
$number_to = $number_from+800;
|
|
if(!empty($tmp['bis_nummer'])){
|
|
$number_to = $tmp['bis_nummer'];
|
|
}
|
|
|
|
$fakeGreaterThanIds = range($number_from, $number_to);
|
|
|
|
$pendingOrders = $this->client->get('orders', [
|
|
'per_page' => 100,
|
|
'include' => implode(",",$fakeGreaterThanIds),
|
|
]);
|
|
|
|
} else {
|
|
// fetch posts by status
|
|
|
|
$pendingOrders = $this->client->get('orders', [
|
|
'status' => array_map('trim',explode(';', $this->statusPending)),
|
|
'per_page' => 100
|
|
]);
|
|
|
|
}
|
|
|
|
return (!empty($pendingOrders)?count($pendingOrders):0);
|
|
}
|
|
|
|
/**
|
|
* Calling this function queries the api for pending orders and returns them
|
|
* as an array.
|
|
*
|
|
* TODO: Only one single order is returned per invocation of this function.
|
|
* Given that we have to perform an exteremly expensive external HTTP call
|
|
* every time we call this function and could easily process more than one
|
|
* order this seems very bad performance-wise.
|
|
*/
|
|
public function ImportGetAuftrag()
|
|
{
|
|
// Array containing additional settings, namely 'ab_nummer' (containting the next order number to get)
|
|
// and 'holeallestati' (an integer)
|
|
$tmp = $this->CatchRemoteCommand('data');
|
|
|
|
// Only orders having an order number greater or equal than this should be fetched. null otherwise
|
|
$number_from = empty($tmp['ab_nummer']) ? null : (int)$tmp['ab_nummer'];
|
|
|
|
// pending orders will be fetched into this array. it's length is returned at the end of the funciton
|
|
$pendingOrders = array();
|
|
|
|
if ($number_from) {
|
|
// Number-based import is selected
|
|
|
|
// The WooCommerce API doenst allow for a proper "greater than id n" request.
|
|
// we fake this behavior by creating an array that contains 'many' (~ 1000) consecutive
|
|
// ids that are greater than $from_number and use this array with the 'include' property
|
|
// of the WooCommerce API
|
|
|
|
$number_to = $number_from+800;
|
|
if(!empty($tmp['bis_nummer'])){
|
|
$number_to = $tmp['bis_nummer'];
|
|
}
|
|
|
|
$fakeGreaterThanIds = range($number_from, $number_to);
|
|
|
|
$pendingOrders = $this->client->get('orders', [
|
|
'per_page' => 20,
|
|
'include' => implode(',',$fakeGreaterThanIds),
|
|
'order' => 'asc',
|
|
'orderby' => 'id'
|
|
]);
|
|
|
|
} else {
|
|
// fetch posts by status
|
|
|
|
$pendingOrders = $this->client->get('orders', [
|
|
'status' => array_map('trim',explode(';', $this->statusPending)),
|
|
'per_page' => 20,
|
|
'order' => 'asc',
|
|
'orderby' => 'id'
|
|
]);
|
|
|
|
}
|
|
|
|
// Return an empty array in case there are no orders to import
|
|
if ((!empty($pendingOrders)?count($pendingOrders):0) === 0) {
|
|
return null;
|
|
}
|
|
|
|
$tmp = [];
|
|
|
|
foreach ($pendingOrders as $pendingOrder){
|
|
$wcOrder = $pendingOrder;
|
|
$order = $this->parseOrder($wcOrder);
|
|
|
|
if (is_null($wcOrder)) {
|
|
continue;
|
|
}
|
|
|
|
$tmp[] = [
|
|
'id' => $order['auftrag'],
|
|
'sessionid' => '',
|
|
'logdatei' => '',
|
|
'warenkorb' => base64_encode(serialize($order)),
|
|
];
|
|
}
|
|
return $tmp;
|
|
}
|
|
|
|
// This function searches the wcOrder for the specified WC Meta key
|
|
// and returns it if found, null otherise
|
|
public function get_wc_meta($wcOrder, $meta_key) {
|
|
$value = null;
|
|
foreach ($wcOrder->meta_data as $meta) {
|
|
if ($meta->key == $meta_key) {
|
|
$value = $meta->value;
|
|
break;
|
|
}
|
|
}
|
|
return $value;
|
|
}
|
|
|
|
// Parse the given WooCommerce order, return a Xentral array-represented order.
|
|
// Overload this method whenever additional attributes are required.
|
|
public function parseOrder($wcOrder) {
|
|
|
|
|
|
$order = array();
|
|
$order['auftragsdaten'] = $wcOrder;
|
|
|
|
$isBillingCompany = !self::emptyString(
|
|
$wcOrder->billing->company
|
|
);
|
|
|
|
$isShippingCompany = !self::emptyString(
|
|
$wcOrder->shipping->company
|
|
);
|
|
|
|
$seperateShippingAddress = !self::compareObjects(
|
|
$wcOrder->billing,
|
|
$wcOrder->shipping,
|
|
['first_name', 'second_name', 'company', 'address_1', 'address_2',
|
|
'city', 'state', 'postcode', 'country']
|
|
);
|
|
|
|
if ($isBillingCompany) {
|
|
$order['name'] = $wcOrder->billing->company;
|
|
$order['anrede'] = 'firma';
|
|
$order['ansprechpartner'] = $wcOrder->billing->first_name . ' ' . $wcOrder->billing->last_name;
|
|
} else {
|
|
$order['name'] = $wcOrder->billing->first_name . ' ' . $wcOrder->billing->last_name;
|
|
|
|
// Retrieve title from meta data
|
|
// This is not a standard WC Feature! Should work with the very popuplar "WooCommerce germanized" plugin though
|
|
$meta_title = $this->get_wc_meta($wcOrder, "_billing_title");
|
|
if (!is_null($meta_title)) {
|
|
$order['anrede'] = ($meta_title == 'mrs') ? 'frau' : 'herr';
|
|
}
|
|
}
|
|
|
|
if(!empty($wcOrder->subshop)){
|
|
$order['subshop'] = $wcOrder->subshop;
|
|
}
|
|
|
|
// General order properties and billing address
|
|
$order['auftrag'] = $wcOrder->id;
|
|
$order['order'] = json_decode(json_encode($wcOrder), true);
|
|
$order['strasse'] = $wcOrder->billing->address_1;
|
|
if(!empty($wcOrder->billing->address_2)){
|
|
$order['adresszusatz'] = $wcOrder->billing->address_2;
|
|
}
|
|
$order['plz'] = $wcOrder->billing->postcode;
|
|
$order['ort'] = $wcOrder->billing->city;
|
|
$order['land'] = $wcOrder->billing->country;
|
|
$order['email'] = $wcOrder->billing->email;
|
|
$order['telefon'] = $wcOrder->billing->phone;
|
|
$order['bestelldatum'] = $wcOrder->date_created;
|
|
$order['gesamtsumme'] = $wcOrder->total;
|
|
$order['transaktionsnummer'] = $wcOrder->transaction_id;
|
|
$order['onlinebestellnummer'] = $wcOrder->number;
|
|
$order['versandkostenbrutto'] = $wcOrder->shipping_total + $wcOrder->shipping_tax;
|
|
$order['internebemerkung'] = $wcOrder->customer_note;
|
|
|
|
if(!empty((string)$wcOrder->currency)){
|
|
$warenkorb['waehrung'] = (string)$wcOrder->currency;
|
|
}
|
|
//
|
|
|
|
//
|
|
// Coupon Codes
|
|
//
|
|
$discount_total = (float)$wcOrder->discount_total;
|
|
$discount_tax = (float)$wcOrder->discount_tax;
|
|
|
|
if($discount_total != 0) { // Discount was applied to this order
|
|
|
|
// Calculate coupon amount
|
|
if($discount_tax == 0) {
|
|
// Tax calculations are not enabled for any used coupon
|
|
$order['rabattnetto'] = -abs((float)$discount_total);
|
|
} else{
|
|
// At least one used coupon has tax calculations enabled
|
|
$order['rabattbrutto'] = -abs((float)$discount_total);
|
|
$order['rabattbrutto'] += -abs((float)$discount_tax);
|
|
}
|
|
|
|
// Set coupon name
|
|
$couponLine = $wcOrder->coupon_lines;
|
|
|
|
// Check if we have a valid coupon line just to be sure and set the coupon name
|
|
if($couponLine && is_array($couponLine) && isset($couponLine[0]) && (String)$couponLine[0]->code !== '') {
|
|
$order['rabattname'] = (String)$couponLine[0]->code;
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
$seperateShippingAddress = !self::compareObjects(
|
|
$wcOrder->billing,
|
|
$wcOrder->shipping,
|
|
['first_name', 'second_name', 'company', 'address_1', 'address_2',
|
|
'city', 'state', 'postcode', 'country']
|
|
);
|
|
|
|
if ($seperateShippingAddress) {
|
|
$order['abweichendelieferadresse'] = '1';
|
|
|
|
if ($isShippingCompany) {
|
|
$order['lieferadresse_name'] = $wcOrder->shipping->company;
|
|
$order['lieferadresse_ansprechpartner'] = $wcOrder->shipping->first_name . ' ' . $wcOrder->shipping->last_name;
|
|
} else {
|
|
$order['lieferadresse_name'] = $wcOrder->shipping->first_name . ' ' . $wcOrder->shipping->last_name;
|
|
}
|
|
|
|
$order['lieferadresse_strasse'] = $wcOrder->shipping->address_1;
|
|
if(!empty($wcOrder->shipping->address_2)){
|
|
$order['lieferadresse_adresszusatz'] = $wcOrder->shipping->address_2;
|
|
}
|
|
$order['lieferadresse_plz'] = $wcOrder->shipping->postcode;
|
|
$order['lieferadresse_ort'] = $wcOrder->shipping->city;
|
|
$order['lieferadresse_land'] = $wcOrder->shipping->country;
|
|
}
|
|
|
|
// VAT stuff
|
|
|
|
$vatId = $this->get_wc_meta($wcOrder, "_billing_ustid");
|
|
if (!is_null($vatId) && !self::emptyString($vatId)) {
|
|
$order['ustid'] = $vatId;
|
|
}
|
|
|
|
foreach ($wcOrder->line_items as $wcOrderItem){
|
|
$order['articlelist'][] = $this->parseItem($wcOrderItem);
|
|
}
|
|
|
|
$order['zahlungsweise'] = $wcOrder->payment_method;
|
|
$order['lieferung'] = $wcOrder->shipping_lines[0]->method_id;
|
|
|
|
return $order;
|
|
}
|
|
|
|
function parseItem($wcOrderItem){
|
|
// The WC API doesnt expose the net price of a single product in the get order endpoint.
|
|
// We could query each individual product and get the price, but that would result in a
|
|
// huge amount of HTTP requests.
|
|
//
|
|
// We could use the price_netto attribute in the order item, but we get a higher precision using
|
|
// this custom calculation as we have access to the exact `total_tax` amount.
|
|
// Passing the net value of the line eliminates rounding issues if the position happens to have large quantites
|
|
|
|
switch ($this->priceType){
|
|
case 'grosscalculated':
|
|
$priceValue = ((float)$wcOrderItem->subtotal + (float)$wcOrderItem->subtotal_tax) / (float)$wcOrderItem->quantity;
|
|
$priceType = 'price';
|
|
break;
|
|
case 'netcalculated':
|
|
default:
|
|
$priceType = 'price_netto';
|
|
$priceValue = (float)$wcOrderItem->subtotal / (float)$wcOrderItem->quantity;
|
|
break;
|
|
}
|
|
|
|
$orderItem = array();
|
|
$orderItem['articleid'] = $wcOrderItem->sku;
|
|
$orderItem['name'] = $wcOrderItem->name;
|
|
$orderItem[$priceType] = $priceValue;
|
|
$orderItem['quantity'] = $wcOrderItem->quantity;
|
|
|
|
// The item could be a variable product in which case we have to retrieve the sku of the variation product
|
|
if (!empty($wcOrderItem->variation_id)) {
|
|
$variation_product_sku = $this->getSKUByShopId($wcOrderItem->product_id,$wcOrderItem->variation_id);
|
|
if (!empty($variation_product_sku)) {
|
|
$orderItem['articleid'] = $variation_product_sku;
|
|
}
|
|
}
|
|
|
|
return $orderItem;
|
|
}
|
|
|
|
/**
|
|
* Sets the Order status to processing, meaning we've successfully imported
|
|
* the order into our DB. This prevents the order from beeing imported again.
|
|
*/
|
|
public function ImportDeleteAuftrag()
|
|
{
|
|
$orderId = $this->CatchRemoteCommand('data')['auftrag'];
|
|
|
|
if (!empty($orderId)) {
|
|
$this->client->put('orders/'.$orderId, [
|
|
'status' => $this->statusProcessing,
|
|
]);
|
|
}
|
|
|
|
return 'ok';
|
|
}
|
|
|
|
/**
|
|
* Updates the order status once payment and shipping are set to ok.
|
|
* Also updates the order with the shipping tracking code
|
|
* @return string
|
|
* @throws WCHttpClientException
|
|
*/
|
|
public function ImportUpdateAuftrag()
|
|
{
|
|
/** @var OrderStatusUpdateRequest $data */
|
|
$data = $this->CatchRemoteCommand('data');
|
|
|
|
if ($data->orderStatus !== OrderStatus::Completed)
|
|
return;
|
|
|
|
if (isset($data->shipments)) {
|
|
$trackingCode = $data->shipments[0]?->trackingNumber;
|
|
}
|
|
|
|
if (!empty($trackingCode)) {
|
|
$this->client->post('orders/'.$data->shopOrderId.'/notes', [
|
|
'note' => 'Tracking Code: ' . $trackingCode
|
|
]);
|
|
|
|
$this->logger->info("WooCommerce Tracking Code Rückmeldung für Auftrag: ".$data->orderId,
|
|
[
|
|
'orderId' => $data->shopOrderId,
|
|
'trackingCode' => $trackingCode
|
|
]
|
|
);
|
|
}
|
|
|
|
$updateData = [
|
|
'status' => $this->statusCompleted,
|
|
'meta_data' => [
|
|
[
|
|
'key' => 'tracking_code',
|
|
'value' => $trackingCode
|
|
],
|
|
[
|
|
'key' => 'shipping_carrier',
|
|
'value' => $data->shipments[0]?->shippingMethod
|
|
]
|
|
],
|
|
];
|
|
$this->client->put('orders/'.$data->shopOrderId, $updateData);
|
|
|
|
$this->logger->info("WooCommerce Statusrückmeldung 'completed' für Auftrag: ".$data->orderId,
|
|
[
|
|
'orderId' => $data->shopOrderId,
|
|
'status' => $this->statusCompleted
|
|
]
|
|
);
|
|
return 'ok';
|
|
}
|
|
|
|
/**
|
|
* This function syncs the current stock to the remote WooCommerce shop
|
|
* @return int
|
|
* @throws WCHttpClientException
|
|
*/
|
|
public function ImportSendListLager()
|
|
{
|
|
$tmp = $this->CatchRemoteCommand('data');
|
|
$anzahl = 0;
|
|
$ctmp = (!empty($tmp)?count($tmp):0);
|
|
|
|
for($i=0;$i<$ctmp;$i++)
|
|
{
|
|
// Get important values from input data
|
|
$artikel = $tmp[$i]['artikel'];
|
|
if($artikel === 'ignore') {
|
|
continue;
|
|
}
|
|
$nummer = $tmp[$i]['nummer'];
|
|
if(!empty($tmp[$i]['artikelnummer_fremdnummern'][0]['nummer'])){
|
|
$nummer = $tmp[$i]['artikelnummer_fremdnummern'][0]['nummer'];
|
|
}
|
|
$lageranzahl = $tmp[$i]['anzahl_lager'];
|
|
$pseudolager = trim($tmp[$i]['pseudolager']);
|
|
$inaktiv = $tmp[$i]['inaktiv'];
|
|
$status ='publish';
|
|
|
|
// Do some computations, sanitize input
|
|
|
|
if($pseudolager !== ''){
|
|
$lageranzahl = $pseudolager;
|
|
}
|
|
|
|
if($tmp[$i]['ausverkauft']){
|
|
$lageranzahl = 0;
|
|
}
|
|
|
|
if($inaktiv){
|
|
$status = 'private';
|
|
}
|
|
|
|
// get the product id that WooCommerce uses to represent the current article
|
|
$remoteIdInformation = $this->getShopIdBySKU($nummer);
|
|
|
|
if (empty($remoteIdInformation['id'])) {
|
|
// The online shop doesnt know this article, write to log and continue with next product
|
|
|
|
$this->logger->error("WooCommerce Artikel $nummer wurde im Online-Shop nicht gefunden! Falsche Artikelnummer im Shop hinterlegt?");
|
|
continue;
|
|
}
|
|
|
|
// Sync settings to online store
|
|
$updateProductParams = [
|
|
'manage_stock' => true,
|
|
'status' => $status,
|
|
'stock_quantity' => $lageranzahl
|
|
// WooCommerce doesnt have a standard property for the other values, we're ignoring them
|
|
];
|
|
if($remoteIdInformation['isvariant']){
|
|
$result = $this->client->put('products/' . $remoteIdInformation['parent'].'/variations/'. $remoteIdInformation['id'], $updateProductParams);
|
|
}else{
|
|
$result = $this->client->put('products/' . $remoteIdInformation['id'], $updateProductParams);
|
|
}
|
|
|
|
$this->logger->error("WooCommerce Lagerzahlenübertragung für Artikel: $nummer / $remoteIdInformation[id] - Anzahl: $lageranzahl",
|
|
[
|
|
'result' => $result
|
|
]
|
|
);
|
|
$anzahl++;
|
|
}
|
|
return $anzahl;
|
|
}
|
|
|
|
public function ImportStorniereAuftrag() {
|
|
$orderId = $this->CatchRemoteCommand('data')['auftrag'];
|
|
if (!empty($orderId)) {
|
|
$this->client->put('orders/'.$orderId, [
|
|
'status' => 'cancelled',
|
|
]);
|
|
} else {
|
|
return 'failed';
|
|
}
|
|
return 'ok';
|
|
}
|
|
|
|
public function ImportSendList() {
|
|
$tmp = $this->catchRemoteCommand('data');
|
|
$anzahl = 0;
|
|
for($i=0;$i<(!empty($tmp)?count($tmp):0);$i++){
|
|
$artikel = $tmp[$i]['artikel'];
|
|
$nummer = $tmp[$i]['nummer'];
|
|
if(!empty($tmp[$i]['artikelnummer_fremdnummern'][0]['nummer'])){
|
|
$nummer = $tmp[$i]['artikelnummer_fremdnummern'][0]['nummer'];
|
|
}
|
|
$laststock = $tmp[$i]['restmenge'];
|
|
$inaktiv = $tmp[$i]['inaktiv'];
|
|
$shippingtime = $tmp[$i]['lieferzeitmanuell'];
|
|
|
|
$hersteller = $tmp[$i]['hersteller'];
|
|
$herstellerlink = $tmp[$i]['herstellerlink'];
|
|
|
|
$name_de = $tmp[$i]['name_de'];
|
|
$name_en = $tmp[$i]['name_en'];
|
|
$description = html_entity_decode($tmp[$i]['uebersicht_de']);
|
|
$description_en = html_entity_decode($tmp[$i]['uebersicht_en']);
|
|
$preis = $tmp[$i]['preis'];
|
|
|
|
$kurzbeschreibung = $tmp[$i]['kurztext_de'];
|
|
|
|
$weight_kg = $tmp[$i]['gewicht'];
|
|
$dim_length = $tmp[$i]['laenge'];
|
|
$dim_width = $tmp[$i]['breite'];
|
|
$dim_height = $tmp[$i]['hoehe'];
|
|
|
|
// Sanitize dimensions
|
|
if (self::emptyString($weight_kg))
|
|
$weight_kg = null;
|
|
|
|
if (self::emptyString($dim_length))
|
|
$dim_length = null;
|
|
|
|
if (self::emptyString($dim_width))
|
|
$dim_width = null;
|
|
|
|
if (self::emptyString($dim_height))
|
|
$dim_height = null;
|
|
|
|
|
|
$meta_desc = $tmp[$i]['metadescription_de'];
|
|
$meta_title = $tmp[$i]['metatitle_de'];
|
|
|
|
$pseudopreis = $tmp[$i]['pseudopreis'];//*1.19;
|
|
if($pseudopreis <= $preis)$pseudopreis = $preis;
|
|
$steuersatz = $tmp[$i]['steuersatz'];
|
|
if($steuersatz > 1.10){
|
|
$steuersatz = 'normal';
|
|
}
|
|
else{
|
|
$steuersatz = 'ermaessigt';
|
|
}
|
|
|
|
$lageranzahl = $tmp[$i]['anzahl_lager'];
|
|
$pseudolager = trim($tmp[$i]['pseudolager']);
|
|
|
|
if($pseudolager > 0) $lageranzahl=$pseudolager;
|
|
if($tmp[$i]['ausverkauft']=="1"){
|
|
$lageranzahl=0; $laststock="1";
|
|
}
|
|
|
|
if($inaktiv)$aktiv=0;
|
|
else $aktiv=1;
|
|
|
|
$product_id = 0;
|
|
if($laststock!="1") $laststock=0;
|
|
|
|
$remoteIdInformation = $this->getShopIdBySKU($nummer);
|
|
$product_id = $remoteIdInformation['id'];
|
|
|
|
$commonMetaData = [
|
|
['key' => '_yoast_wpseo_metadesc', 'value' => $meta_desc],
|
|
['key' => '_yoast_wpseo_title', 'value' => $meta_title],
|
|
];
|
|
|
|
|
|
// Attributes that are used for both updating an existing product as well as creating a new one
|
|
$commonProductAtts = [
|
|
'name' => $name_de,
|
|
'description' => $description,
|
|
'status'=>($aktiv?'publish':'private'),
|
|
'regular_price' => number_format($pseudopreis,2,'.',''),
|
|
'sale_price' => number_format($preis,2,'.',''),
|
|
'short_description' => $kurzbeschreibung,
|
|
'weight' => $weight_kg,
|
|
'dimensions' => [
|
|
'length' => $dim_length,
|
|
'width' => $dim_width,
|
|
'height' => $dim_height
|
|
],
|
|
'meta_data' => $commonMetaData,
|
|
];
|
|
|
|
if($lageranzahl===0){
|
|
$commonProductAtts['stock_status'] = 'outofstock';
|
|
$commonProductAtts['manage_stock'] = true;
|
|
}
|
|
elseif($lageranzahl===''){
|
|
$commonProductAtts['stock_status'] = 'instock';
|
|
$commonProductAtts['manage_stock'] = false;
|
|
}
|
|
else{
|
|
$commonProductAtts['stock_status'] = 'instock';
|
|
$commonProductAtts['manage_stock'] = true;
|
|
}
|
|
|
|
if($lageranzahl!=='') {
|
|
$commonProductAtts['stock_quantity'] = (int)$lageranzahl;
|
|
}
|
|
|
|
if(!is_null($product_id)) {
|
|
// Such a product already appears to exist, so we update it
|
|
$this->client->put('products/'.$product_id, array_merge([
|
|
|
|
], $commonProductAtts));
|
|
|
|
$this->logger->info("WooCommerce Artikel geändert für Artikel: $nummer / $product_id");
|
|
}
|
|
else{
|
|
// create a new product
|
|
$product_id = $this->client->post('products/', array_merge([
|
|
'sku' => $nummer,
|
|
], $commonProductAtts))->id;
|
|
$this->logger->info("WooCommerce neuer Artikel angelegt: $nummer");
|
|
}
|
|
|
|
// TODO: Kategoriebaum und Bilder werden noch nicht uebertragen
|
|
|
|
// if(isset($tmp[$i]['kompletter_kategorienbaum'])){
|
|
// $baum = $tmp[$i]['kompletter_kategorienbaum'];
|
|
// $this->updateKategorieBaum($baum);
|
|
// }
|
|
|
|
// if(isset($tmp[$i]['Dateien'])){
|
|
// $dateien = $tmp[$i]['Dateien'];
|
|
// $this->save_images($dateien, $product_id);
|
|
// }
|
|
|
|
// Update the associated product categories
|
|
|
|
$chosenCats = array();
|
|
if(isset($tmp[$i]['kategorien']) || isset($tmp[$i]['kategoriename'])){
|
|
$kategorien = $tmp[$i]['kategorien'];
|
|
if (!($kategorien) && !self::emptyString($tmp[$i]['kategoriename'])) {
|
|
$kategorien = array(
|
|
array(
|
|
'name' => $tmp[$i]['kategoriename'],
|
|
)
|
|
);
|
|
}
|
|
if((!empty($kategorien)?count($kategorien):0)>0){
|
|
// Retrive all WC categories via API
|
|
$allWooCommerceCategories = $this->client->get('products/categories', ['per_page' => '100']);
|
|
|
|
$searchWpCategories = [];
|
|
foreach($allWooCommerceCategories as $a){
|
|
$searchWpCategories[$a->id] = $a->name;
|
|
}
|
|
// searchWPCategories is an assoc array of type WCCatId(Int) -> WCCatName(string)
|
|
|
|
// Iterate over the categories that are choosen in xentral
|
|
foreach($kategorien as $k => $v){
|
|
$wawi_cat_name = $v['name'];
|
|
|
|
$wcCatId = null;
|
|
|
|
// If WC has a matching category. We match based on name!
|
|
if(array_search($wawi_cat_name,array_values($searchWpCategories)) !== false) {
|
|
// get id of that WC Category
|
|
$wcCatId = array_search($wawi_cat_name,$searchWpCategories);
|
|
|
|
} else {
|
|
// No matching category exists
|
|
$wcCatId = $this->client->post('products/categories', [
|
|
'name' => $wawi_cat_name,
|
|
])->id;
|
|
|
|
}
|
|
|
|
if ($wcCatId) {
|
|
// update category. We first retrieve the product and append the new product category, not replace the entire category array.
|
|
$alreadyAssignedWCCats = $this->client->get('products/'.$product_id, [
|
|
'per_page' => 1,
|
|
])->categories;
|
|
|
|
// Get ids of existing categories
|
|
$existingCategoryIds = [];
|
|
foreach ($alreadyAssignedWCCats as $cat) {
|
|
$existingCategoryIds[] = $cat->id;
|
|
}
|
|
|
|
$allCatIds = array_merge($existingCategoryIds, array($wcCatId));
|
|
|
|
// prepare data to be in correct format for WC api. should be individual items with key 'id' and id as value
|
|
$allCatIdsWCAPIRep = array();
|
|
foreach($allCatIds as $id) {
|
|
$allCatIdsWCAPIRep[] = ['id' => $id];
|
|
}
|
|
|
|
// Update category assignment
|
|
$this->client->put('products/'.$product_id, [
|
|
'categories' => $allCatIdsWCAPIRep,
|
|
]);
|
|
|
|
$chosenCats[] = $wcCatId;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
$anzahl++;
|
|
}
|
|
|
|
return $anzahl;
|
|
// return array($product_id,$anzahl,$nummer,$steuersatz, $preis);
|
|
}
|
|
|
|
/**
|
|
* Checks the connection to the WooCommerce API by trying a simple API request
|
|
*
|
|
* @return string
|
|
*/
|
|
public function ImportAuth()
|
|
{
|
|
try {
|
|
$orders = $this->client->get('orders', ['per_page' => '1']);
|
|
return 'success';
|
|
} catch (Exception $e) {
|
|
return 'failed: Keine Verbindung zur API - ' . $e->getMessage();
|
|
}
|
|
}
|
|
|
|
/**
|
|
* This is called by class.remote.php, initializes some class variables from the DB
|
|
* @param [type] $shopid [description]
|
|
* @param [type] $data [description]
|
|
* @return [type] [description]
|
|
* @throws WCHttpClientException
|
|
*/
|
|
public function getKonfig($shopid, $data)
|
|
{
|
|
$this->shopid = $shopid;
|
|
$this->data = $data;
|
|
|
|
$preferences_json = $this->app->DB->Select("SELECT einstellungen_json FROM shopexport WHERE id = '$this->shopid' LIMIT 1");
|
|
if($preferences_json){
|
|
$preferences = json_decode($preferences_json,true);
|
|
}
|
|
|
|
$this->protokoll = $preferences['felder']['protokoll'];
|
|
$this->ssl_ignore = $preferences['felder']['ssl_ignore'];
|
|
$ImportWooCommerceApiSecret = $preferences['felder']['ImportWoocommerceApiSecret'];
|
|
$ImportWooCommerceApiKey = $preferences['felder']['ImportWoocommerceApiKey'];
|
|
$ImportWooCommerceApiUrl = $preferences['felder']['ImportWoocommerceApiUrl'];
|
|
|
|
$this->statusPending = $preferences['felder']['statusPending'];
|
|
$this->statusProcessing = $preferences['felder']['statusProcessing'];
|
|
$this->statusCompleted = $preferences['felder']['statusCompleted'];
|
|
|
|
$this->priceType = $preferences['felder']['priceType'];
|
|
|
|
$this->url = $ImportWooCommerceApiUrl;
|
|
$this->client = new WCClient(
|
|
//URL des WooCommerce Rest Servers
|
|
$ImportWooCommerceApiUrl,
|
|
//WooCommerce API Key
|
|
$ImportWooCommerceApiKey,
|
|
//WooCommerce API Secret
|
|
$ImportWooCommerceApiSecret,
|
|
["query_string_auth" => true],
|
|
$this->logger,
|
|
$this->ssl_ignore
|
|
);
|
|
|
|
}
|
|
|
|
/**
|
|
* @param array $shopArr
|
|
* @param array $postData
|
|
*
|
|
* @return array
|
|
*/
|
|
public function updateShopexportArr($shopArr, $postData)
|
|
{
|
|
$shopArr['demomodus'] = 0;
|
|
$shopArr['anzgleichzeitig'] = 1;
|
|
$shopArr['cronjobaktiv'] = 1;
|
|
|
|
return $shopArr;
|
|
}
|
|
|
|
/**
|
|
* @return JsonResponse|null
|
|
*/
|
|
public function AuthByAssistent()
|
|
{
|
|
$ImportWooCommerceApiKey = $this->app->Secure->GetPOST('ImportWoocommerceApiKey');
|
|
$ImportWooCommerceApiSecret = $this->app->Secure->GetPOST('ImportWoocommerceApiSecret');
|
|
$ImportWooCommerceApiUrl = $this->app->Secure->GetPOST('ImportWoocommerceApiUrl');
|
|
|
|
if(empty($ImportWooCommerceApiUrl)) {
|
|
return new JsonResponse(['error' => 'Bitte die API-Url angeben'], JsonResponse::HTTP_BAD_REQUEST);
|
|
}
|
|
if(empty($ImportWooCommerceApiKey)) {
|
|
return new JsonResponse(['error' => 'Bitte den API-Key angeben'], JsonResponse::HTTP_BAD_REQUEST);
|
|
}
|
|
if(empty($ImportWooCommerceApiSecret)) {
|
|
return new JsonResponse(['error' => 'Bitte das API-Secret angeben'], JsonResponse::HTTP_BAD_REQUEST);
|
|
}
|
|
$this->client = new WCClient(
|
|
$ImportWooCommerceApiUrl,
|
|
$ImportWooCommerceApiKey,
|
|
$ImportWooCommerceApiSecret,
|
|
['query_string_auth' => true],
|
|
$this->logger,
|
|
$this->ssl_ignore
|
|
);
|
|
$auth = $this->ImportAuth();
|
|
|
|
if ($auth !== 'success') {
|
|
return new JsonResponse(['error' => $auth], JsonResponse::HTTP_BAD_REQUEST);
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
/**
|
|
* @return array[]
|
|
*/
|
|
public function getCreateForm()
|
|
{
|
|
return [
|
|
[
|
|
'id' => 0,
|
|
'name' => 'urls',
|
|
'inputs' => [
|
|
[
|
|
'label' => 'API Url',
|
|
'type' => 'text',
|
|
'name' => 'ImportWoocommerceApiUrl',
|
|
'validation' => true,
|
|
],
|
|
|
|
],
|
|
],
|
|
[
|
|
'id' => 1,
|
|
'name' => 'username',
|
|
'inputs' => [
|
|
[
|
|
'label' => 'API Key',
|
|
'type' => 'text',
|
|
'name' => 'ImportWoocommerceApiKey',
|
|
'validation' => true,
|
|
],
|
|
],
|
|
],
|
|
[
|
|
'id' => 2,
|
|
'name' => 'password',
|
|
'inputs' => [
|
|
[
|
|
'label' => 'API Secret',
|
|
'type' => 'password',
|
|
'name' => 'ImportWoocommerceApiSecret',
|
|
'validation' => true,
|
|
],
|
|
],
|
|
],
|
|
];
|
|
}
|
|
|
|
/**
|
|
* Returns the WooCommerce Product Id of a product given the SKU (= Xentral arikelnummer)
|
|
*
|
|
* @param string $sku Artikelnummer
|
|
*
|
|
* @return array|null The WooCommerce product id of the given product, null if such a product does not exist
|
|
* @throws WCHttpClientException
|
|
*/
|
|
private function getShopIdBySKU($sku) {
|
|
// Retrieve the product with the given sku.
|
|
// Note: We limit the result set to 1 (per_page=1), so this doesnt work
|
|
// if there are multiple products with the same sku. should not happen in practice anyway
|
|
$product = $this->client->get('products', ['sku' => $sku, 'per_page' => 1]);
|
|
|
|
// We look at the first product in the array.
|
|
// We may get an empty array, in that case null is returned
|
|
if (isset($product[0])){
|
|
return [
|
|
'id' => $product[0]->id,
|
|
'parent' => $product[0]->parent_id,
|
|
'isvariant' => !empty($product[0]->parent_id)];
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
private function getSKUByShopId($articleid, $variationid) {
|
|
$product = $this->client->get("products/$articleid/variations/$variationid");
|
|
|
|
// We look at the first product in the array.
|
|
// We may get an empty array, in that case null is returned
|
|
if (!empty($product))
|
|
return $product->sku;
|
|
return null;
|
|
}
|
|
|
|
public function EinstellungenStruktur()
|
|
{
|
|
return
|
|
array(
|
|
'ausblenden'=>array('abholmodus'=>array('zeitbereich')),
|
|
'archiv'=>array('ab_nummer'),
|
|
'felder'=>array(
|
|
// 'protokoll'=>array('typ'=>'checkbox','bezeichnung'=>'Protokollierung im Logfile:'),
|
|
'ssl_ignore'=>array('typ'=>'checkbox','bezeichnung'=>'SSL-Prüfung abschalten:','info' => 'Nur für Testzwecke!'),
|
|
'ImportWoocommerceApiKey'=>array('typ'=>'text','bezeichnung'=>'{|API Key:','size'=>60),
|
|
'ImportWoocommerceApiSecret'=>array('typ'=>'text','bezeichnung'=>'{|API Secret|}:','size'=>60),
|
|
'ImportWoocommerceApiUrl'=>array('typ'=>'text','bezeichnung'=>'{|API Url|}:','size'=>40),
|
|
'statusPending'=>array('typ'=>'text','bezeichnung'=>'{|Statusname Bestellung offen|}:','size'=>40, 'default' => 'pending', 'info' => '({|ggfs. getrennt durch ";": pending;on-hold|})'),
|
|
'statusProcessing'=>array('typ'=>'text','bezeichnung'=>'{|Statusname Bestellung in Bearbeitung|}:','size'=>10, 'default' => 'processing'),
|
|
'statusCompleted'=>array('typ'=>'text','bezeichnung'=>'{|Statusname Bestellung fertig|}:','size'=>10, 'default' => 'completed'),
|
|
'priceType'=>array('typ'=>'select','bezeichnung'=>'{|Preisberechnungsgrundlage bei Auftragsimport|}','optionen'=>array('netcalculated'=>'{|Nettopreis zurückrechnen (Standard)|}','grosscalculated'=>'{|Bruttopreis zurückrechnen|}')),
|
|
));
|
|
}
|
|
|
|
/**
|
|
* Compares two Objects and returns true if every variable in items
|
|
* is the same in $a and $b
|
|
* @param Obj $a [description]
|
|
* @param Obj $b [description]
|
|
* @param array $items [description]
|
|
* @return Bool [description]
|
|
*/
|
|
protected static function compareObjects($a, $b, $items) {
|
|
foreach($items as $v) {
|
|
if (property_exists($a, $v) && property_exists($b, $v)) {
|
|
if ($a->$v != $b->$v) {
|
|
//print_r($v);
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* Returns true when the string entered is empty, after stripping whitespace
|
|
* @param String $string input
|
|
* @return String output
|
|
*/
|
|
protected static function emptyString($string) {
|
|
return (strlen(trim($string)) == 0);
|
|
}
|
|
|
|
}
|
|
|
|
class WCClient
|
|
{
|
|
/**
|
|
* WooCommerce REST API WCClient version.
|
|
*/
|
|
const VERSION = '3.0.0';
|
|
|
|
/**
|
|
* HttpClient instance.
|
|
*
|
|
* @var WCHttpClient
|
|
*/
|
|
public $http;
|
|
|
|
/** @var Logger $logger */
|
|
public $logger;
|
|
|
|
public $ssl_ignore = false;
|
|
|
|
/**
|
|
* Initialize client.
|
|
*
|
|
* @param string $url Store URL.
|
|
* @param string $consumerKey Consumer key.
|
|
* @param string $consumerSecret Consumer secret.
|
|
* @param array $options WCOptions (version, timeout, verify_ssl).
|
|
*
|
|
* @throws WCHttpClientException
|
|
*/
|
|
public function __construct($url, $consumerKey, $consumerSecret, $options = [], $logger, $ssl_ignore)
|
|
{
|
|
$this->http = new WCHttpClient($url, $consumerKey, $consumerSecret, $options, $logger, $ssl_ignore);
|
|
$this->logger = $logger;
|
|
}
|
|
|
|
/**
|
|
* POST method.
|
|
*
|
|
* @param string $endpoint API endpoint.
|
|
* @param array $data WCRequest data.
|
|
*
|
|
* @throws WCHttpClientException
|
|
*
|
|
* @return array
|
|
*/
|
|
public function post($endpoint, $data)
|
|
{
|
|
return $this->http->request($endpoint, 'POST', $data);
|
|
}
|
|
|
|
/**
|
|
* PUT method.
|
|
*
|
|
* @param string $endpoint API endpoint.
|
|
* @param array $data WCRequest data.
|
|
*
|
|
* @throws WCHttpClientException
|
|
*
|
|
* @return array
|
|
*/
|
|
public function put($endpoint, $data)
|
|
{
|
|
return $this->http->request($endpoint, 'PUT', $data);
|
|
}
|
|
|
|
/**
|
|
* GET method.
|
|
*
|
|
* @param string $endpoint API endpoint.
|
|
* @param array $parameters WCRequest parameters.
|
|
*
|
|
* @throws WCHttpClientException
|
|
*
|
|
* @return array
|
|
*/
|
|
public function get($endpoint, $parameters = [])
|
|
{
|
|
return $this->http->request($endpoint, 'GET', [], $parameters);
|
|
}
|
|
|
|
/**
|
|
* DELETE method.
|
|
*
|
|
* @param string $endpoint API endpoint.
|
|
* @param array $parameters WCRequest parameters.
|
|
*
|
|
* @throws WCHttpClientException
|
|
*
|
|
* @return array
|
|
*/
|
|
public function delete($endpoint, $parameters = [])
|
|
{
|
|
return $this->http->request($endpoint, 'DELETE', [], $parameters);
|
|
}
|
|
|
|
/**
|
|
* OPTIONS method.
|
|
*
|
|
* @param string $endpoint API endpoint.
|
|
*
|
|
* @throws WCHttpClientException
|
|
*
|
|
* @return array
|
|
*/
|
|
public function options($endpoint)
|
|
{
|
|
return $this->http->request($endpoint, 'OPTIONS');
|
|
}
|
|
}
|
|
|
|
class WCResponse
|
|
{
|
|
/**
|
|
* WCResponse code.
|
|
*
|
|
* @var int
|
|
*/
|
|
private $code;
|
|
|
|
/**
|
|
* WCResponse headers.
|
|
*
|
|
* @var array
|
|
*/
|
|
private $headers;
|
|
|
|
/**
|
|
* WCResponse body.
|
|
*
|
|
* @var string
|
|
*/
|
|
private $body;
|
|
|
|
/**
|
|
* Initialize response.
|
|
*
|
|
* @param int $code WCResponse code.
|
|
* @param array $headers WCResponse headers.
|
|
* @param string $body WCResponse body.
|
|
*/
|
|
public function __construct($code = 0, $headers = [], $body = '')
|
|
{
|
|
$this->code = $code;
|
|
$this->headers = $headers;
|
|
$this->body = $body;
|
|
}
|
|
|
|
/**
|
|
* Set code.
|
|
*
|
|
* @param int $code WCResponse code.
|
|
*/
|
|
public function setCode($code)
|
|
{
|
|
$this->code = (int) $code;
|
|
}
|
|
|
|
/**
|
|
* Set headers.
|
|
*
|
|
* @param array $headers WCResponse headers.
|
|
*/
|
|
public function setHeaders($headers)
|
|
{
|
|
$this->headers = $headers;
|
|
}
|
|
|
|
/**
|
|
* Set body.
|
|
*
|
|
* @param string $body WCResponse body.
|
|
*/
|
|
public function setBody($body)
|
|
{
|
|
$this->body = $body;
|
|
}
|
|
|
|
/**
|
|
* Get code.
|
|
*
|
|
* @return int
|
|
*/
|
|
public function getCode()
|
|
{
|
|
return $this->code;
|
|
}
|
|
|
|
/**
|
|
* Get headers.
|
|
*
|
|
* @return array $headers WCResponse headers.
|
|
*/
|
|
public function getHeaders()
|
|
{
|
|
return $this->headers;
|
|
}
|
|
|
|
/**
|
|
* Get body.
|
|
*
|
|
* @return string $body WCResponse body.
|
|
*/
|
|
public function getBody()
|
|
{
|
|
return $this->body;
|
|
}
|
|
}
|
|
|
|
class WCOptions
|
|
{
|
|
/**
|
|
* Default WooCommerce REST API version.
|
|
*/
|
|
const VERSION = 'wc/v3';
|
|
|
|
/**
|
|
* Default request timeout.
|
|
*/
|
|
const TIMEOUT = 30;
|
|
|
|
/**
|
|
* Default WP API prefix.
|
|
* Including leading and trailing slashes.
|
|
*/
|
|
const WP_API_PREFIX = '/wp-json/';
|
|
|
|
/**
|
|
* Default User Agent.
|
|
* No version number.
|
|
*/
|
|
const USER_AGENT = 'WooCommerce API Client-PHP';
|
|
|
|
/**
|
|
* WCOptions.
|
|
*
|
|
* @var array
|
|
*/
|
|
private $options;
|
|
|
|
/**
|
|
* Initialize HTTP client options.
|
|
*
|
|
* @param array $options Client options.
|
|
*/
|
|
public function __construct($options)
|
|
{
|
|
$this->options = $options;
|
|
}
|
|
|
|
/**
|
|
* Get API version.
|
|
*
|
|
* @return string
|
|
*/
|
|
public function getVersion()
|
|
{
|
|
return isset($this->options['version']) ? $this->options['version'] : self::VERSION;
|
|
}
|
|
|
|
/**
|
|
* Check if need to verify SSL.
|
|
*
|
|
* @return bool
|
|
*/
|
|
public function verifySsl()
|
|
{
|
|
return isset($this->options['verify_ssl']) ? (bool) $this->options['verify_ssl'] : true;
|
|
}
|
|
|
|
/**
|
|
* Get timeout.
|
|
*
|
|
* @return int
|
|
*/
|
|
public function getTimeout()
|
|
{
|
|
return isset($this->options['timeout']) ? (int) $this->options['timeout'] : self::TIMEOUT;
|
|
}
|
|
|
|
/**
|
|
* Basic Authentication as query string.
|
|
* Some old servers are not able to use CURLOPT_USERPWD.
|
|
*
|
|
* @return bool
|
|
*/
|
|
public function isQueryStringAuth()
|
|
{
|
|
return isset($this->options['query_string_auth']) ? (bool) $this->options['query_string_auth'] : false;
|
|
}
|
|
|
|
/**
|
|
* Check if is WP REST API.
|
|
*
|
|
* @return bool
|
|
*/
|
|
public function isWPAPI()
|
|
{
|
|
return isset($this->options['wp_api']) ? (bool) $this->options['wp_api'] : true;
|
|
}
|
|
|
|
/**
|
|
* Custom API Prefix for WP API.
|
|
*
|
|
* @return string
|
|
*/
|
|
public function apiPrefix()
|
|
{
|
|
return isset($this->options['wp_api_prefix']) ? $this->options['wp_api_prefix'] : self::WP_API_PREFIX;
|
|
}
|
|
|
|
/**
|
|
* oAuth timestamp.
|
|
*
|
|
* @return string
|
|
*/
|
|
public function oauthTimestamp()
|
|
{
|
|
return isset($this->options['oauth_timestamp']) ? $this->options['oauth_timestamp'] : \time();
|
|
}
|
|
|
|
/**
|
|
* Custom user agent.
|
|
*
|
|
* @return string
|
|
*/
|
|
public function userAgent()
|
|
{
|
|
return isset($this->options['user_agent']) ? $this->options['user_agent'] : self::USER_AGENT;
|
|
}
|
|
|
|
/**
|
|
* Get follow redirects
|
|
*
|
|
* @return bool
|
|
*/
|
|
public function getFollowRedirects()
|
|
{
|
|
return isset($this->options['follow_redirects']) ? (bool) $this->options['follow_redirects'] : false;
|
|
}
|
|
}
|
|
|
|
class WCRequest
|
|
{
|
|
/**
|
|
* WCRequest url.
|
|
*
|
|
* @var string
|
|
*/
|
|
private $url;
|
|
|
|
/**
|
|
* WCRequest method.
|
|
*
|
|
* @var string
|
|
*/
|
|
private $method;
|
|
|
|
/**
|
|
* WCRequest paramenters.
|
|
*
|
|
* @var array
|
|
*/
|
|
private $parameters;
|
|
|
|
/**
|
|
* WCRequest headers.
|
|
*
|
|
* @var array
|
|
*/
|
|
private $headers;
|
|
|
|
/**
|
|
* WCRequest body.
|
|
*
|
|
* @var string
|
|
*/
|
|
private $body;
|
|
|
|
/**
|
|
* Initialize request.
|
|
*
|
|
* @param string $url WCRequest url.
|
|
* @param string $method WCRequest method.
|
|
* @param array $parameters WCRequest paramenters.
|
|
* @param array $headers WCRequest headers.
|
|
* @param string $body WCRequest body.
|
|
*/
|
|
public function __construct($url = '', $method = 'POST', $parameters = [], $headers = [], $body = '')
|
|
{
|
|
$this->url = $url;
|
|
$this->method = $method;
|
|
$this->parameters = $parameters;
|
|
$this->headers = $headers;
|
|
$this->body = $body;
|
|
}
|
|
|
|
/**
|
|
* Set url.
|
|
*
|
|
* @param string $url WCRequest url.
|
|
*/
|
|
public function setUrl($url)
|
|
{
|
|
$this->url = $url;
|
|
}
|
|
|
|
/**
|
|
* Set method.
|
|
*
|
|
* @param string $method WCRequest method.
|
|
*/
|
|
public function setMethod($method)
|
|
{
|
|
$this->method = $method;
|
|
}
|
|
|
|
/**
|
|
* Set parameters.
|
|
*
|
|
* @param array $parameters WCRequest paramenters.
|
|
*/
|
|
public function setParameters($parameters)
|
|
{
|
|
$this->parameters = $parameters;
|
|
}
|
|
|
|
/**
|
|
* Set headers.
|
|
*
|
|
* @param array $headers WCRequest headers.
|
|
*/
|
|
public function setHeaders($headers)
|
|
{
|
|
$this->headers = $headers;
|
|
}
|
|
|
|
/**
|
|
* Set body.
|
|
*
|
|
* @param string $body WCRequest body.
|
|
*/
|
|
public function setBody($body)
|
|
{
|
|
$this->body = $body;
|
|
}
|
|
|
|
/**
|
|
* Get url.
|
|
*
|
|
* @return string
|
|
*/
|
|
public function getUrl()
|
|
{
|
|
return $this->url;
|
|
}
|
|
|
|
/**
|
|
* Get method.
|
|
*
|
|
* @return string
|
|
*/
|
|
public function getMethod()
|
|
{
|
|
return $this->method;
|
|
}
|
|
|
|
/**
|
|
* Get parameters.
|
|
*
|
|
* @return array
|
|
*/
|
|
public function getParameters()
|
|
{
|
|
return $this->parameters;
|
|
}
|
|
|
|
/**
|
|
* Get headers.
|
|
*
|
|
* @return array
|
|
*/
|
|
public function getHeaders()
|
|
{
|
|
return $this->headers;
|
|
}
|
|
|
|
/**
|
|
* Get raw headers.
|
|
*
|
|
* @return array
|
|
*/
|
|
public function getRawHeaders()
|
|
{
|
|
$headers = [];
|
|
|
|
foreach ($this->headers as $key => $value) {
|
|
$headers[] = $key . ': ' . $value;
|
|
}
|
|
|
|
return $headers;
|
|
}
|
|
|
|
/**
|
|
* Get body.
|
|
*
|
|
* @return string
|
|
*/
|
|
public function getBody()
|
|
{
|
|
return $this->body;
|
|
}
|
|
}
|
|
|
|
class WCOAuth
|
|
{
|
|
/**
|
|
* OAuth signature method algorithm.
|
|
*/
|
|
const HASH_ALGORITHM = 'SHA256';
|
|
|
|
/**
|
|
* API endpoint URL.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $url;
|
|
|
|
/**
|
|
* Consumer key.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $consumerKey;
|
|
|
|
/**
|
|
* Consumer secret.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $consumerSecret;
|
|
|
|
/**
|
|
* API version.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $apiVersion;
|
|
|
|
/**
|
|
* WCRequest method.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $method;
|
|
|
|
/**
|
|
* WCRequest parameters.
|
|
*
|
|
* @var array
|
|
*/
|
|
protected $parameters;
|
|
|
|
/**
|
|
* Timestamp.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $timestamp;
|
|
|
|
/**
|
|
* Initialize oAuth class.
|
|
*
|
|
* @param string $url Store URL.
|
|
* @param string $consumerKey Consumer key.
|
|
* @param string $consumerSecret Consumer Secret.
|
|
* @param string $method WCRequest method.
|
|
* @param string $apiVersion API version.
|
|
* @param array $parameters WCRequest parameters.
|
|
* @param string $timestamp Timestamp.
|
|
*/
|
|
public function __construct(
|
|
$url,
|
|
$consumerKey,
|
|
$consumerSecret,
|
|
$apiVersion,
|
|
$method,
|
|
$parameters = [],
|
|
$timestamp = ''
|
|
) {
|
|
$this->url = $url;
|
|
$this->consumerKey = $consumerKey;
|
|
$this->consumerSecret = $consumerSecret;
|
|
$this->apiVersion = $apiVersion;
|
|
$this->method = $method;
|
|
$this->parameters = $parameters;
|
|
$this->timestamp = $timestamp;
|
|
}
|
|
|
|
/**
|
|
* Encode according to RFC 3986.
|
|
*
|
|
* @param string|array $value Value to be normalized.
|
|
*
|
|
* @return string
|
|
*/
|
|
//TODO Rückgbabetyp prüfen
|
|
protected function encode($value)
|
|
{
|
|
if (is_array($value)) {
|
|
return array_map([$this, 'encode'], $value);
|
|
} else {
|
|
return str_replace(['+', '%7E'], [' ', '~'], rawurlencode($value));
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Normalize parameters.
|
|
*
|
|
* @param array $parameters Parameters to normalize.
|
|
*
|
|
* @return array
|
|
*/
|
|
protected function normalizeParameters($parameters)
|
|
{
|
|
$normalized = [];
|
|
|
|
foreach ($parameters as $key => $value) {
|
|
// Percent symbols (%) must be double-encoded.
|
|
$key = $this->encode($key);
|
|
$value = $this->encode($value);
|
|
|
|
$normalized[$key] = $value;
|
|
}
|
|
|
|
return $normalized;
|
|
}
|
|
|
|
/**
|
|
* Process filters.
|
|
*
|
|
* @param array $parameters WCRequest parameters.
|
|
*
|
|
* @return array
|
|
*/
|
|
protected function processFilters($parameters)
|
|
{
|
|
if (isset($parameters['filter'])) {
|
|
$filters = $parameters['filter'];
|
|
unset($parameters['filter']);
|
|
foreach ($filters as $filter => $value) {
|
|
$parameters['filter[' . $filter . ']'] = $value;
|
|
}
|
|
}
|
|
|
|
return $parameters;
|
|
}
|
|
|
|
/**
|
|
* Get secret.
|
|
*
|
|
* @return string
|
|
*/
|
|
protected function getSecret()
|
|
{
|
|
$secret = $this->consumerSecret;
|
|
|
|
// Fix secret for v3 or later.
|
|
if (!\in_array($this->apiVersion, ['v1', 'v2'])) {
|
|
$secret .= '&';
|
|
}
|
|
|
|
return $secret;
|
|
}
|
|
|
|
/**
|
|
* Generate oAuth1.0 signature.
|
|
*
|
|
* @param array $parameters WCRequest parameters including oauth.
|
|
*
|
|
* @return string
|
|
*/
|
|
protected function generateOauthSignature($parameters)
|
|
{
|
|
$baseRequestUri = rawurlencode($this->url);
|
|
|
|
// Extract filters.
|
|
$parameters = $this->processFilters($parameters);
|
|
|
|
// Normalize parameter key/values and sort them.
|
|
$parameters = $this->normalizeParameters($parameters);
|
|
uksort($parameters, 'strcmp');
|
|
|
|
// Set query string.
|
|
$queryString = implode('%26', $this->joinWithEqualsSign($parameters)); // Join with ampersand.
|
|
$stringToSign = $this->method . '&' . $baseRequestUri . '&' . $queryString;
|
|
$secret = $this->getSecret();
|
|
|
|
return base64_encode(hash_hmac(self::HASH_ALGORITHM, $stringToSign, $secret, true));
|
|
}
|
|
|
|
/**
|
|
* Creates an array of urlencoded strings out of each array key/value pairs.
|
|
*
|
|
* @param array $params Array of parameters to convert.
|
|
* @param array $queryParams Array to extend.
|
|
* @param string $key Optional Array key to append
|
|
* @return string Array of urlencoded strings
|
|
*/
|
|
protected function joinWithEqualsSign($params, $queryParams = [], $key = '')
|
|
{
|
|
foreach ($params as $paramKey => $paramValue) {
|
|
if ($key) {
|
|
$paramKey = $key . '%5B' . $paramKey . '%5D'; // Handle multi-dimensional array.
|
|
}
|
|
|
|
if (is_array($paramValue)) {
|
|
//TODO Typ prüfen
|
|
$queryParams = $this->joinWithEqualsSign($paramValue, $queryParams, $paramKey);
|
|
} else {
|
|
$string = $paramKey . '=' . $paramValue; // Join with equals sign.
|
|
$queryParams[] = $this->encode($string);
|
|
}
|
|
}
|
|
|
|
return $queryParams;
|
|
}
|
|
|
|
/**
|
|
* Sort parameters.
|
|
*
|
|
* @param array $parameters Parameters to sort in byte-order.
|
|
*
|
|
* @return array
|
|
*/
|
|
protected function getSortedParameters($parameters)
|
|
{
|
|
uksort($parameters, 'strcmp');
|
|
|
|
foreach ($parameters as $key => $value) {
|
|
if (is_array($value)) {
|
|
uksort($parameters[$key], 'strcmp');
|
|
}
|
|
}
|
|
|
|
return $parameters;
|
|
}
|
|
|
|
/**
|
|
* Get oAuth1.0 parameters.
|
|
*
|
|
* @return string
|
|
*/
|
|
public function getParameters()
|
|
{
|
|
$parameters = \array_merge($this->parameters, [
|
|
'oauth_consumer_key' => $this->consumerKey,
|
|
'oauth_timestamp' => $this->timestamp,
|
|
'oauth_nonce' => \sha1(\microtime()),
|
|
'oauth_signature_method' => 'HMAC-' . self::HASH_ALGORITHM,
|
|
]);
|
|
|
|
// The parameters above must be included in the signature generation.
|
|
$parameters['oauth_signature'] = $this->generateOauthSignature($parameters);
|
|
|
|
//TODO Typ prüfen
|
|
return $this->getSortedParameters($parameters);
|
|
}
|
|
}
|
|
|
|
class WCHttpClientException extends \Exception
|
|
{
|
|
/**
|
|
* WCRequest.
|
|
*
|
|
* @var WCRequest
|
|
*/
|
|
private $request;
|
|
|
|
/**
|
|
* WCResponse.
|
|
*
|
|
* @var WCResponse
|
|
*/
|
|
private $response;
|
|
|
|
/**
|
|
* Initialize exception.
|
|
*
|
|
* @param string $message Error message.
|
|
* @param int $code Error code.
|
|
* @param WCRequest $request Request data.
|
|
* @param WCResponse $response Response data.
|
|
*/
|
|
public function __construct($message, $code, WCRequest $request, WCResponse $response)
|
|
{
|
|
parent::__construct($message, $code);
|
|
|
|
$this->request = $request;
|
|
$this->response = $response;
|
|
}
|
|
|
|
/**
|
|
* Get request data.
|
|
*
|
|
* @return WCRequest
|
|
*/
|
|
public function getRequest()
|
|
{
|
|
return $this->request;
|
|
}
|
|
|
|
/**
|
|
* Get response data.
|
|
*
|
|
* @return WCResponse
|
|
*/
|
|
public function getResponse()
|
|
{
|
|
return $this->response;
|
|
}
|
|
}
|
|
|
|
class WCHttpClient
|
|
{
|
|
/**
|
|
* cURL handle.
|
|
*
|
|
* @var resource
|
|
*/
|
|
protected $ch;
|
|
|
|
/**
|
|
* Store API URL.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $url;
|
|
|
|
/**
|
|
* Consumer key.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $consumerKey;
|
|
|
|
/**
|
|
* Consumer secret.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $consumerSecret;
|
|
|
|
/**
|
|
* WCClient options.
|
|
*
|
|
* @var WCOptions
|
|
*/
|
|
protected $options;
|
|
|
|
/**
|
|
* WCRequest.
|
|
*
|
|
* @var WCRequest
|
|
*/
|
|
private $request;
|
|
|
|
/**
|
|
* WCResponse.
|
|
*
|
|
* @var WCResponse
|
|
*/
|
|
private $response;
|
|
|
|
/**
|
|
* WCResponse headers.
|
|
*
|
|
* @var string
|
|
*/
|
|
private $responseHeaders;
|
|
|
|
/** @var Logger $logger */
|
|
public $logger;
|
|
|
|
public $ssl_ignore = false;
|
|
|
|
/**
|
|
* Initialize HTTP client.
|
|
*
|
|
* @param string $url Store URL.
|
|
* @param string $consumerKey Consumer key.
|
|
* @param string $consumerSecret Consumer Secret.
|
|
* @param array $options WCClient options.
|
|
*
|
|
* @throws WCHttpClientException
|
|
*/
|
|
public function __construct($url, $consumerKey, $consumerSecret, $options, $logger, $ssl_ignore)
|
|
{
|
|
if (!function_exists('curl_version')) {
|
|
throw new WCHttpClientException('cURL is NOT installed on this server', -1, new WCRequest(), new WCResponse());
|
|
}
|
|
|
|
$this->options = new WCOptions($options);
|
|
$this->url = $this->buildApiUrl($url);
|
|
$this->consumerKey = $consumerKey;
|
|
$this->consumerSecret = $consumerSecret;
|
|
$this->logger = $logger;
|
|
$this->ssl_ignore = $ssl_ignore;
|
|
}
|
|
|
|
/**
|
|
* Check if is under SSL.
|
|
*
|
|
* @return bool
|
|
*/
|
|
protected function isSsl()
|
|
{
|
|
return strpos($this->url,'https://')===0;
|
|
|
|
}
|
|
|
|
/**
|
|
* Build API URL.
|
|
*
|
|
* @param string $url Store URL.
|
|
*
|
|
* @return string
|
|
*/
|
|
protected function buildApiUrl($url)
|
|
{
|
|
$api = $this->options->isWPAPI() ? $this->options->apiPrefix() : '/wc-api/';
|
|
|
|
return rtrim($url, '/') . $api . $this->options->getVersion() . '/';
|
|
}
|
|
|
|
/**
|
|
* Build URL.
|
|
*
|
|
* @param string $url URL.
|
|
* @param array $parameters Query string parameters.
|
|
*
|
|
* @return string
|
|
*/
|
|
protected function buildUrlQuery($url, $parameters = [])
|
|
{
|
|
if (!empty($parameters)) {
|
|
$url .= '?' . http_build_query($parameters);
|
|
}
|
|
|
|
return $url;
|
|
}
|
|
|
|
/**
|
|
* Authenticate.
|
|
*
|
|
* @param string $url WCRequest URL.
|
|
* @param string $method WCRequest method.
|
|
* @param array $parameters WCRequest parameters.
|
|
*
|
|
* @return array
|
|
*/
|
|
protected function authenticate($url, $method, $parameters = [])
|
|
{
|
|
// Setup authentication.
|
|
if ($this->isSsl()) {
|
|
$basicAuth = new WCBasicAuth(
|
|
$this->ch,
|
|
$this->consumerKey,
|
|
$this->consumerSecret,
|
|
$this->options->isQueryStringAuth(),
|
|
$parameters
|
|
);
|
|
$parameters = $basicAuth->getParameters();
|
|
} else {
|
|
$oAuth = new WCOAuth(
|
|
$url,
|
|
$this->consumerKey,
|
|
$this->consumerSecret,
|
|
$this->options->getVersion(),
|
|
$method,
|
|
$parameters,
|
|
$this->options->oauthTimestamp()
|
|
);
|
|
//TODO Typ prüfen
|
|
$parameters = $oAuth->getParameters();
|
|
}
|
|
|
|
return $parameters;
|
|
}
|
|
|
|
/**
|
|
* Setup method.
|
|
*
|
|
* @param string $method WCRequest method.
|
|
*/
|
|
protected function setupMethod($method)
|
|
{
|
|
if ('POST' === $method) {
|
|
curl_setopt($this->ch, CURLOPT_POST, true);
|
|
} elseif (in_array($method, ['PUT', 'DELETE', 'OPTIONS'])) {
|
|
curl_setopt($this->ch, CURLOPT_CUSTOMREQUEST, $method);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get request headers.
|
|
*
|
|
* @param bool $sendData If request send data or not.
|
|
*
|
|
* @return array
|
|
*/
|
|
protected function getRequestHeaders($sendData = false)
|
|
{
|
|
$headers = [
|
|
'Accept' => 'application/json',
|
|
'User-Agent' => $this->options->userAgent() . '/' . WCClient::VERSION,
|
|
];
|
|
|
|
if ($sendData) {
|
|
$headers['Content-Type'] = 'application/json;charset=utf-8';
|
|
}
|
|
|
|
return $headers;
|
|
}
|
|
|
|
/**
|
|
* Create request.
|
|
*
|
|
* @param string $endpoint WCRequest endpoint.
|
|
* @param string $method WCRequest method.
|
|
* @param array $data WCRequest data.
|
|
* @param array $parameters WCRequest parameters.
|
|
*
|
|
* @return WCRequest
|
|
*/
|
|
protected function createRequest($endpoint, $method, $data = [], $parameters = [])
|
|
{
|
|
$body = '';
|
|
$url = $this->url . $endpoint;
|
|
$hasData = !empty($data);
|
|
|
|
// Setup authentication.
|
|
$parameters = $this->authenticate($url, $method, $parameters);
|
|
|
|
// Setup method.
|
|
$this->setupMethod($method);
|
|
|
|
// Include post fields.
|
|
if ($hasData) {
|
|
$body = json_encode($data);
|
|
curl_setopt($this->ch, CURLOPT_POSTFIELDS, $body);
|
|
}
|
|
|
|
$this->request = new WCRequest(
|
|
$this->buildUrlQuery($url, $parameters),
|
|
$method,
|
|
$parameters,
|
|
$this->getRequestHeaders($hasData),
|
|
$body
|
|
);
|
|
|
|
return $this->getRequest();
|
|
}
|
|
|
|
/**
|
|
* Get response headers.
|
|
*
|
|
* @return array
|
|
*/
|
|
protected function getResponseHeaders()
|
|
{
|
|
$headers = [];
|
|
$lines = explode("\n", $this->responseHeaders);
|
|
$lines = array_filter($lines, 'trim');
|
|
|
|
foreach ($lines as $index => $line) {
|
|
// Remove HTTP/xxx params.
|
|
if (strpos($line, ': ') === false) {
|
|
continue;
|
|
}
|
|
|
|
list($key, $value) = explode(': ', $line);
|
|
|
|
$headers[$key] = isset($headers[$key]) ? $headers[$key] . ', ' . trim($value) : trim($value);
|
|
}
|
|
|
|
return $headers;
|
|
}
|
|
|
|
/**
|
|
* Create response.
|
|
*
|
|
* @return WCResponse
|
|
*/
|
|
protected function createResponse()
|
|
{
|
|
// Set response headers.
|
|
$this->responseHeaders = '';
|
|
curl_setopt($this->ch, CURLOPT_HEADERFUNCTION, function ($_, $headers) {
|
|
$this->responseHeaders .= $headers;
|
|
return strlen($headers);
|
|
});
|
|
|
|
// Get response data.
|
|
$body = curl_exec($this->ch);
|
|
$code = curl_getinfo($this->ch, CURLINFO_HTTP_CODE);
|
|
$headers = $this->getResponseHeaders();
|
|
|
|
// Register response.
|
|
$this->response = new WCResponse($code, $headers, $body);
|
|
|
|
return $this->getResponse();
|
|
}
|
|
|
|
/**
|
|
* Set default cURL settings.
|
|
*/
|
|
protected function setDefaultCurlSettings()
|
|
{
|
|
if (!$this->ssl_ignore) {
|
|
$verifySsl = $this->options->verifySsl();
|
|
}
|
|
|
|
$timeout = $this->options->getTimeout();
|
|
$followRedirects = $this->options->getFollowRedirects();
|
|
|
|
curl_setopt($this->ch, CURLOPT_SSL_VERIFYPEER, $verifySsl);
|
|
if (!$verifySsl) {
|
|
curl_setopt($this->ch, CURLOPT_SSL_VERIFYHOST, $verifySsl);
|
|
}
|
|
if ($followRedirects) {
|
|
curl_setopt($this->ch, CURLOPT_FOLLOWLOCATION, true);
|
|
}
|
|
curl_setopt($this->ch, CURLOPT_CONNECTTIMEOUT, $timeout);
|
|
curl_setopt($this->ch, CURLOPT_TIMEOUT, $timeout);
|
|
curl_setopt($this->ch, CURLOPT_RETURNTRANSFER, true);
|
|
curl_setopt($this->ch, CURLOPT_HTTPHEADER, $this->request->getRawHeaders());
|
|
curl_setopt($this->ch, CURLOPT_URL, $this->request->getUrl());
|
|
}
|
|
|
|
/**
|
|
* Look for errors in the request.
|
|
*
|
|
* @throws WCHttpClientException
|
|
*
|
|
* @param array $parsedResponse Parsed body response.
|
|
*/
|
|
protected function lookForErrors($parsedResponse)
|
|
{
|
|
// Any non-200/201/202 response code indicates an error.
|
|
if (!in_array($this->response->getCode(), ['200', '201', '202'])) {
|
|
$errors = isset($parsedResponse->errors) ? $parsedResponse->errors : $parsedResponse;
|
|
$errorMessage = '';
|
|
$errorCode = '';
|
|
|
|
if (is_array($errors)) {
|
|
$errorMessage = $errors[0]->message;
|
|
$errorCode = $errors[0]->code;
|
|
} elseif (isset($errors->message, $errors->code)) {
|
|
$errorMessage = $errors->message;
|
|
$errorCode = $errors->code;
|
|
}
|
|
|
|
$this->logger->error('WooCommerce Error',
|
|
[
|
|
'request' => $this->request,
|
|
'response' => $this->response
|
|
]
|
|
);
|
|
|
|
throw new WCHttpClientException(
|
|
sprintf('Error: %s [%s]', $errorMessage, $errorCode),
|
|
$this->response->getCode(),
|
|
$this->request,
|
|
$this->response
|
|
);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Process response.
|
|
*
|
|
* @throws WCHttpClientException
|
|
* @return array
|
|
*/
|
|
|
|
protected function processResponse()
|
|
{
|
|
$body = $this->response->getBody();
|
|
|
|
// Look for UTF-8 BOM and remove.
|
|
if (0 === strpos(bin2hex(substr($body, 0, 4)), 'efbbbf')) {
|
|
$body = substr($body, 3);
|
|
}
|
|
|
|
$parsedResponse = json_decode($body);
|
|
|
|
// Test if return a valid JSON.
|
|
if (JSON_ERROR_NONE !== json_last_error()) {
|
|
$message = function_exists('json_last_error_msg') ? json_last_error_msg() : 'Invalid JSON returned';
|
|
throw new WCHttpClientException(
|
|
sprintf('JSON ERROR: %s', $message),
|
|
$this->response->getCode(),
|
|
$this->request,
|
|
$this->response
|
|
);
|
|
}
|
|
|
|
$this->lookForErrors($parsedResponse);
|
|
|
|
return $parsedResponse;
|
|
}
|
|
|
|
/**
|
|
* Make requests.
|
|
*
|
|
* @param string $endpoint WCRequest endpoint.
|
|
* @param string $method WCRequest method.
|
|
* @param array $data WCRequest data.
|
|
* @param array $parameters WCRequest parameters.
|
|
*
|
|
* @throws WCHttpClientException
|
|
*
|
|
* @return array
|
|
*/
|
|
public function request($endpoint, $method, $data = [], $parameters = [])
|
|
{
|
|
|
|
// Initialize cURL.
|
|
$this->ch = curl_init();
|
|
|
|
// Set request args.
|
|
$request = $this->createRequest($endpoint, $method, $data, $parameters);
|
|
|
|
// Default cURL settings.
|
|
$this->setDefaultCurlSettings();
|
|
|
|
// Get response.
|
|
$response = $this->createResponse();
|
|
|
|
// Check for cURL errors.
|
|
if (curl_errno($this->ch)) {
|
|
throw new WCHttpClientException('cURL Error: ' . \curl_error($this->ch), 0, $request, $response);
|
|
}
|
|
|
|
curl_close($this->ch);
|
|
|
|
return $this->processResponse();
|
|
}
|
|
|
|
/**
|
|
* Get request data.
|
|
*
|
|
* @return WCRequest
|
|
*/
|
|
public function getRequest()
|
|
{
|
|
return $this->request;
|
|
}
|
|
|
|
/**
|
|
* Get response data.
|
|
*
|
|
* @return WCResponse
|
|
*/
|
|
public function getResponse()
|
|
{
|
|
return $this->response;
|
|
}
|
|
}
|
|
|
|
class WCBasicAuth
|
|
{
|
|
/**
|
|
* cURL handle.
|
|
*
|
|
* @var resource
|
|
*/
|
|
protected $ch;
|
|
|
|
/**
|
|
* Consumer key.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $consumerKey;
|
|
|
|
/**
|
|
* Consumer secret.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $consumerSecret;
|
|
|
|
/**
|
|
* Do query string auth.
|
|
*
|
|
* @var bool
|
|
*/
|
|
protected $doQueryString;
|
|
|
|
/**
|
|
* WCRequest parameters.
|
|
*
|
|
* @var array
|
|
*/
|
|
protected $parameters;
|
|
|
|
/**
|
|
* Initialize Basic Authentication class.
|
|
*
|
|
* @param resource $ch cURL handle.
|
|
* @param string $consumerKey Consumer key.
|
|
* @param string $consumerSecret Consumer Secret.
|
|
* @param bool $doQueryString Do or not query string auth.
|
|
* @param array $parameters WCRequest parameters.
|
|
*/
|
|
public function __construct($ch, $consumerKey, $consumerSecret, $doQueryString, $parameters = [])
|
|
{
|
|
$this->ch = $ch;
|
|
$this->consumerKey = $consumerKey;
|
|
$this->consumerSecret = $consumerSecret;
|
|
$this->doQueryString = $doQueryString;
|
|
$this->parameters = $parameters;
|
|
|
|
$this->processAuth();
|
|
}
|
|
|
|
/**
|
|
* Process auth.
|
|
*/
|
|
protected function processAuth()
|
|
{
|
|
if ($this->doQueryString) {
|
|
$this->parameters['consumer_key'] = $this->consumerKey;
|
|
$this->parameters['consumer_secret'] = $this->consumerSecret;
|
|
} else {
|
|
\curl_setopt($this->ch, CURLOPT_USERPWD, $this->consumerKey . ':' . $this->consumerSecret);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get parameters.
|
|
*
|
|
* @return array
|
|
*/
|
|
public function getParameters()
|
|
{
|
|
return $this->parameters;
|
|
}
|
|
}
|