mirror of
https://github.com/OpenXE-org/OpenXE.git
synced 2024-11-15 04:27:14 +01:00
1066 lines
47 KiB
PHP
1066 lines
47 KiB
PHP
<?php
|
|
|
|
use Xentral\Components\Logger\Logger;
|
|
|
|
/*
|
|
* SPDX-FileCopyrightText: 2022 Andreas Palm
|
|
* SPDX-FileCopyrightText: 2024 OpenXE project
|
|
*
|
|
* SPDX-License-Identifier: LicenseRef-EGPL-3.1
|
|
*/
|
|
|
|
class Shopimporter_Mirakl extends ShopimporterBase {
|
|
|
|
private $app;
|
|
public $logger;
|
|
private $intern;
|
|
private $shopid;
|
|
private $protocol;
|
|
private $apiKey;
|
|
private $shopUrl;
|
|
private $mirakl_shopid;
|
|
private $idbearbeitung;
|
|
private $idabgeschlossen;
|
|
public $data;
|
|
// TODO
|
|
private $langidToIso = [3 => 'de', 1 => 'en'];
|
|
private $taxationByDestinationCountry;
|
|
private $orderSearchLimit;
|
|
|
|
private $configuration_identifier;
|
|
|
|
private $mirakl_error_text_product_missing;
|
|
|
|
private $normalTaxId;
|
|
private $reducedTaxId;
|
|
|
|
private $offer_configuration;
|
|
private $product_configuration;
|
|
|
|
public function __construct($app, $intern = false) {
|
|
$this->app = $app;
|
|
$this->logger = $app->Container->get('Logger');
|
|
$this->intern = $intern;
|
|
if ($intern)
|
|
return;
|
|
}
|
|
|
|
/*
|
|
* See widget.shopexport.php, ShowExtraeinstellungen()
|
|
*/
|
|
|
|
public function EinstellungenStruktur() {
|
|
$einstellungen = [
|
|
'ausblenden' => ['abholmodus' => ['ab_nummer', 'zeitbereich']],
|
|
'functions' => ['getarticlelist'],
|
|
'felder' => [
|
|
'apikey' => [
|
|
'typ' => 'text',
|
|
'bezeichnung' => '{|API Key|}:',
|
|
'size' => 40,
|
|
],
|
|
'shopurl' => [
|
|
'typ' => 'text',
|
|
'bezeichnung' => '{|Shop URL|}:',
|
|
'size' => 40,
|
|
],
|
|
'mirakl_shopid' => [
|
|
'typ' => 'text',
|
|
'bezeichnung' => '{|Shop ID des Shops|}:',
|
|
'size' => 40,
|
|
'info' => 'optional, int64'
|
|
],
|
|
'configuration_identifier_source' => [
|
|
'typ' => 'select',
|
|
'bezeichnung' => '{|Konfigurationsidentifizierer-Typ|}:',
|
|
'size' => 40,
|
|
'info' => 'Woher soll die Konfiguration des jeweiligen Artikels bezogen werden?',
|
|
'default' => 'feld',
|
|
'optionen' => ['feld' => '{|Feld|}', 'freifeld' => '{|Freifeld|}', 'eigenschaft' => '{|Eigenschaft|}', 'wert' => '{|Fester Wert|}']
|
|
],
|
|
'configuration_identifier_source_value' => [
|
|
'typ' => 'text',
|
|
'bezeichnung' => '{|Konfigurationsidentifizierer-Wert|}:',
|
|
'size' => 40,
|
|
'info' => '',
|
|
'default' => 'kategoriename'
|
|
],
|
|
'mirakl_error_text_product_missing' => [
|
|
'typ' => 'text',
|
|
'bezeichnung' => '{|Fehlertext Produkt fehlt|}:',
|
|
'size' => 40,
|
|
'info' => 'Der Fehlertext der anzeigt dass das Produkt nicht existiert (Angebotsimport, Fehlerbericht)',
|
|
'default' => 'The product does not exist'
|
|
],
|
|
'normalTaxId' => [
|
|
'typ' => 'text',
|
|
'bezeichnung' => '{|TaxId für Steuersatz "normal"|}',
|
|
'size' => 40,
|
|
],
|
|
'reducedTaxId' => [
|
|
'typ' => 'text',
|
|
'bezeichnung' => '{|TaxId für Steuersatz "ermäßigt"|}',
|
|
'size' => 40,
|
|
],
|
|
'product_configuration' => [
|
|
'typ' => 'textarea',
|
|
'bezeichnung' => '{|Zuordnung Produkt-Felder je Konfiguration (JSON)|}:',
|
|
'cols' => 80,
|
|
'rows' => 20,
|
|
'info' => 'Die Felder werden vom Mirakl-Betreiber vorgegeben. Ist keine Konfiguration definiert, gilt der Eintrag für alle Artikel. Jedes Feld kann wie folgt zugeordnet werden:<br>Artikelfeld: "Mirakel-Feldname": {"feld": "xyz"} oder kurz "Mirakel-Feldname": "xyz",<br>Freifeld: "Mirakel-Feldname": {"freifeld": "Bezeichnung in Shop"} (Siehe Reiter "Freifelder"),<br>Eigenschaft: "Mirakel-Feldname": {"eigenschaft": "Eigenschaftenname xyz"},<br>Fester Wert: "Mirakel-Feldname": {"wert": "xyz"}<br><br>Optionen:<br>Text voranstellen: "praefix: "Dieser Text vorne",<br>Text hinten anstellen: "postfix: "Dieser Text hinten",<br>Standardwert: "standardwert: "Dieser Wert wenn nichts gefunden wurde",<br>Als Zusatzfeld senden: "zusatzfeld": true',
|
|
'placeholder' => '[
|
|
{
|
|
"konfigurationen": [
|
|
"Schuhe", "Hosen"
|
|
],
|
|
"felder": {
|
|
"category": {"freifeld": "Kategorie"},
|
|
"Product.SellerProductID": {"feld": "nummer"},
|
|
"SHOP.PRODUCT.TITLE": {"feld": "nummer"},
|
|
"ATT.GLOBAL.Brandname": {"feld": "preis"},
|
|
"Product.BaseUnit": {"freifeld": "Kategorie"},
|
|
"ATT.GLOBAL.NoCUperOU": {"eigenschaft": "Mirakl Steuertext", "praefix": "ST-"},
|
|
"ATT.GLOBAL.NoCUperOU__UNIT": {"wert": "false","zusatzfeld": true},
|
|
"Product.TaxIndicator": {"wert": "1","zusatzfeld": true}
|
|
}
|
|
}
|
|
]'
|
|
],
|
|
|
|
'offer_configuration' => [
|
|
'typ' => 'textarea',
|
|
'bezeichnung' => '{|Zuordnung Angebots-Felder je Konfiguration (JSON)|}:',
|
|
'cols' => 80,
|
|
'rows' => 20,
|
|
'info' => '',
|
|
'placeholder' => '[
|
|
{
|
|
"konfigurationen": [
|
|
"Schuhe", "Hosen"
|
|
],
|
|
"felder": {
|
|
"product_id_type": {"wert": "SHOP_SKU"},
|
|
"product_id": {"feld": "nummer"},
|
|
"shop_sku": {"feld": "nummer"},
|
|
"price": {"feld": "preis"},
|
|
"description": {"freifeld": "Kategorie"},
|
|
"internal_description": {"eigenschaft": "Mirakl Steuertext"},
|
|
"reversecharge": {"wert": "false","zusatzfeld": true},
|
|
"warehouse": {"wert": "1","zusatzfeld": true},
|
|
"quantity": {"feld": "anzahl_lager"}
|
|
}
|
|
}
|
|
]'
|
|
],
|
|
'Artikelfelder' => [
|
|
'heading' => 'Zusatzinformationen',
|
|
'typ' => 'info',
|
|
'text' => 'Folgende Artikelfelder stehen zur Verfügung:',
|
|
'bezeichnung' => null,
|
|
'info' => 'artikel, artikelid, nummer, inaktiv, name_de, name_en, einheit, hersteller, herstellernummer, ean, artikelnummer_fremdnummern, kurztext_de, kurztext_en, anabregs_text, anabregs_text_en, beschreibung_de, beschreibung_en, uebersicht_de, uebersicht_en, herkunftsland, texteuebertragen, metadescription_de, metadescription_en, metakeywords_de, metakeywords_en, metatitle_de, metatitle_en, links_de, altersfreigabe, links_en, startseite_de, startseite_en, restmenge, startseite, standardbild, herstellerlink, lieferzeit, lieferzeitmanuell, gewicht, laenge, breite, hoehe, wichtig, porto, gesperrt, sperrgrund, gueltigbis, umsatzsteuer, ausverkauft, variante, variante_von_id, variantevon, pseudopreis, keinrabatterlaubt, einkaufspreis, pseudolager, downloadartikel, zolltarifnummer, freifeld_Kategorie, typ, kategoriename, steuer_art_produkt, steuer_art_produkt_download, anzahl_bilder, anzahl_lager, lagerkorrekturwert, autolagerlampe, waehrung, preis, steuersatz, bruttopreis, checksum, variantevorhanden'
|
|
]
|
|
]
|
|
];
|
|
|
|
return($einstellungen);
|
|
}
|
|
|
|
public function getKonfig($shopid, $data) {
|
|
|
|
$this->shopid = $shopid;
|
|
$this->data = $data;
|
|
$importerSettings = $this->app->DB->SelectArr("SELECT `einstellungen_json` FROM `shopexport` WHERE `id` = '$shopid' LIMIT 1");
|
|
$importerSettings = reset($importerSettings);
|
|
$einstellungen = [];
|
|
if (!empty($importerSettings['einstellungen_json'])) {
|
|
$einstellungen = json_decode($importerSettings['einstellungen_json'], true);
|
|
}
|
|
$this->protocol = $einstellungen['felder']['protokoll'];
|
|
$this->apiKey = $einstellungen['felder']['apikey'];
|
|
$this->shopUrl = rtrim($einstellungen['felder']['shopurl'], '/') . '/';
|
|
$this->mirakl_shopid = $einstellungen['felder']['mirakl_shopid'];
|
|
|
|
$this->configuration_identifier = array($einstellungen['felder']['configuration_identifier_source'] => $einstellungen['felder']['configuration_identifier_source_value']);
|
|
|
|
$this->mirakl_error_text_product_missing = $einstellungen['felder']['mirakl_error_text_product_missing'];
|
|
|
|
$this->normalTaxId = $einstellungen['felder']['normalTaxId'];
|
|
$this->reducedTaxId = $einstellungen['felder']['reducedTaxId'];
|
|
|
|
$this->offer_configuration = json_decode($einstellungen['felder']['offer_configuration'], true, flags: JSON_THROW_ON_ERROR);
|
|
$this->product_configuration = json_decode($einstellungen['felder']['product_configuration'], true, flags: JSON_THROW_ON_ERROR);
|
|
|
|
}
|
|
|
|
private function miraklRequest(string $endpoint, $postdata = null, array $getdata = null, string $content_type = null, bool $raw = false, $debug = false, $debugurl = null) {
|
|
$ch = curl_init();
|
|
$url_addition = "";
|
|
|
|
$headers = array("Authorization: " . $this->apiKey);
|
|
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
|
|
if (!empty($this->mirakl_shopid)) {
|
|
$getdata['shop_id'] = $this->mirakl_shopid;
|
|
}
|
|
|
|
if (!empty($getdata)) {
|
|
$url_addition = "?";
|
|
$ampersand = "";
|
|
foreach ($getdata as $key => $value) {
|
|
$url_addition .= $ampersand . $key . "=" . $value;
|
|
$ampersand = "&";
|
|
}
|
|
}
|
|
if (!empty($postdata)) {
|
|
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST');
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $postdata);
|
|
|
|
$headers[] = 'Content-Type: ' . $content_type;
|
|
}
|
|
|
|
if ($debugurl) {
|
|
$url = $debugurl;
|
|
} else {
|
|
$url = $this->shopUrl;
|
|
}
|
|
|
|
curl_setopt($ch, CURLOPT_URL, $url . $endpoint . $url_addition);
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
|
|
curl_setopt($ch, CURLINFO_HEADER_OUT, true);
|
|
curl_setopt($ch, CURLOPT_VERBOSE, true);
|
|
|
|
$response = curl_exec($ch);
|
|
if (curl_error($ch)) {
|
|
$this->error[] = curl_error($ch);
|
|
}
|
|
curl_close($ch);
|
|
|
|
$information = curl_getinfo($ch);
|
|
|
|
if ($debug) {
|
|
print_r($information);
|
|
print_r($postdata);
|
|
print_r($response);
|
|
}
|
|
|
|
if ($raw)
|
|
return $response;
|
|
|
|
return simplexml_load_string($response);
|
|
}
|
|
|
|
public function ImportAuth() {
|
|
$ch = curl_init($this->shopUrl . "version");
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, array("Authorization: " . $this->apiKey));
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
$response = curl_exec($ch);
|
|
$code = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
|
|
if ($code == 200) {
|
|
return 'success';
|
|
}
|
|
return $response;
|
|
}
|
|
|
|
/*
|
|
* Fetches article list from the shop, puts them into table shopexport_getarticles, starts the prozessstarter getarticles which fetches details for each article via ImportGetArticle()
|
|
*/
|
|
|
|
public function ImportGetArticleList() {
|
|
$result = [];
|
|
|
|
$response = $this->miraklRequest('offers', raw: true);
|
|
|
|
$result_array = json_decode($response);
|
|
|
|
foreach ($result_array->offers as $offer) {
|
|
$result[] = $offer->shop_sku;
|
|
}
|
|
|
|
array_unique($result);
|
|
return $result;
|
|
}
|
|
|
|
/*
|
|
* Fetches article details from the shop
|
|
*/
|
|
|
|
public function ImportGetArticle() {
|
|
|
|
$articlelist = $this->CatchRemoteCommand('data');
|
|
|
|
$parameters = array('product_references' => 'productID', 'product_');
|
|
|
|
$response = $this->miraklRequest('products?', raw: true);
|
|
|
|
throw new Exception("Not implemented");
|
|
}
|
|
|
|
/*
|
|
* Gets a flexible mapped fieldvalue from feld, wert or eigenschaft
|
|
*/
|
|
public function GetFieldValue($article, $field_map_entry) {
|
|
|
|
$prefix = null;
|
|
$postfix = null;
|
|
$returnval = null;
|
|
|
|
foreach ($field_map_entry as $key => $value) {
|
|
switch ($key) {
|
|
case 'feld':
|
|
if (isset($article[$value])) {
|
|
$returnval = $article[$value];
|
|
} else {
|
|
throw new Exception("Artikelfeld existiert nicht: \"".$value."\"");
|
|
}
|
|
break;
|
|
case 'freifeld':
|
|
if (isset($article['freifelder']['DE'][$value])) {
|
|
$returnval = $article['freifelder']['DE'][$value];
|
|
} else {
|
|
throw new Exception("Freifeld existiert nicht: \"".$value."\"");
|
|
}
|
|
break;
|
|
case 'eigenschaft':
|
|
$sql = "SELECT wert FROM artikeleigenschaften ae INNER JOIN artikeleigenschaftenwerte aew ON aew.artikeleigenschaften = ae.id WHERE aew.artikel = '".$article['artikelid']."' AND ae.name = '".$value."' LIMIT 1";
|
|
$result = $this->app->DB->SelectRow($sql);
|
|
if (!empty($result)) {
|
|
$returnval = $result['wert'];
|
|
}
|
|
break;
|
|
case 'wert':
|
|
return($prefix.$value.$postfix);
|
|
break;
|
|
case 'praefix':
|
|
$prefix = $value;
|
|
break;
|
|
case 'postfix':
|
|
$postfix = $value;
|
|
break;
|
|
case 'standardwert':
|
|
if(empty($returnval)) {
|
|
$returnval = $value;
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
return($prefix.$returnval.$postfix);
|
|
}
|
|
|
|
public function ImportSendListLager() {
|
|
return $this->mirakl_export_offers_and_products(export_products : false);
|
|
}
|
|
|
|
public function ImportSendList() {
|
|
return $this->mirakl_export_offers_and_products(export_products : true);
|
|
}
|
|
|
|
/*
|
|
* Send articles to shop
|
|
*/
|
|
public function mirakl_export_offers_and_products(bool $export_products) {
|
|
|
|
// $this->Log(Logger::DEBUG, "mirakl_export_offers_and_products", array('export products' => $export_products));
|
|
|
|
$message = "";
|
|
$komma = "";
|
|
$status = true;
|
|
|
|
$level = Logger::NOTICE;
|
|
$log_result = null;
|
|
|
|
$articlelist = $this->CatchRemoteCommand('data');
|
|
|
|
if ($export_products) {
|
|
$export_products_result = $this->mirakl_export_products($articlelist);
|
|
if ($export_products_result['export_products_returncode'] != 0) {
|
|
$level = Logger::ERROR;
|
|
$message = "Produktsync nach Mirakl hat Fehler";
|
|
$komma = ", ";
|
|
$status = false;
|
|
} else {
|
|
$level = Logger::NOTICE;
|
|
$this->Log(Logger::INFO, "Produktsync nach Mirakl ok", $export_products_result);
|
|
$message = "Produktimport in Mirakl ok";
|
|
$komma = ", ";
|
|
}
|
|
}
|
|
|
|
$export_offers_result = $this->mirakl_export_offers($articlelist);
|
|
|
|
if ($export_offers_result['returncode'] != 0) {
|
|
$level = Logger::ERROR;
|
|
$message .= $komma."Angebotsync in Mirakl hat Fehler";
|
|
$status = false;
|
|
} else {
|
|
$this->Log(Logger::INFO, "Angebotsync nach Mirakl ok", $export_offers_result);
|
|
$message .= $komma."Angebotsimport in Mirakl ok";
|
|
}
|
|
|
|
$this->Log($level, $message, array('export_products_result' => $export_products_result, 'export_offers_result' => $export_offers_result));
|
|
|
|
foreach ($articlelist as $key => $article) {
|
|
$articlelist[$key] = (array) $export_products_result['articlelist'][$key] + (array) $export_offers_result['articlelist'][$key]; // This merges the fields for each article
|
|
}
|
|
|
|
return(
|
|
array(
|
|
'status' => $status,
|
|
'message' => $message,
|
|
'articlelist' => $articlelist
|
|
)
|
|
);
|
|
|
|
// Check for missing products and try to create
|
|
/* if ($export_products) {
|
|
|
|
$export_products_list = array();
|
|
|
|
foreach ($export_offers_result['articlelist'] as $key => $article) {
|
|
if ($article['mirakl_export_offers_result']['returncode'] == 12) {
|
|
switch ($article['mirakl_export_offers_result']['message']) {
|
|
case $this->mirakl_error_text_product_missing:
|
|
$export_products_list[] = $article;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
if (empty($export_products_list)) {
|
|
return(array('status' => false, 'message' => "Produktimport nicht möglich"));
|
|
}
|
|
|
|
$export_products_result = $this->mirakl_export_products($export_products_list);
|
|
|
|
if ($export_products_result['returncode'] != 0) {
|
|
$this->Log(Logger::DEBUG, "Produktimport in Mirakl hat Fehler", $export_products_result);
|
|
return(array('status' => false, 'message' => "Produktimport in Mirakl hat Fehler"));
|
|
}
|
|
|
|
// Retry offer import
|
|
$export_offers_result = $this->mirakl_export_offers($articlelist);
|
|
if ($export_offers_result['returncode'] == 0) {
|
|
return(array('status' => true, 'message' => "Angebots und Produktimport in Mirakl ok"));
|
|
}
|
|
}
|
|
$this->Log(Logger::DEBUG, "Angebotsimport in Mirakl hat Fehler", $export_offers_result);
|
|
|
|
return(array('status' => false, 'message' => "Angebotsimport in Mirakl hat Fehler")); */
|
|
|
|
}
|
|
|
|
// STAGING, WAITING_ACCEPTANCE, WAITING_DEBIT, WAITING_DEBIT_PAYMENT, SHIPPING, SHIPPED, TO_COLLECT, RECEIVED, CLOSED, REFUSED, CANCELED
|
|
public function ImportGetAuftraegeAnzahl() {
|
|
$response = $this->miraklRequest('orders', getdata: array('order_state_codes' => 'WAITING_ACCEPTANCE'), raw: true);
|
|
$this->Log(Logger::DEBUG, 'ImportGetAuftraegeAnzahl', $response);
|
|
$result_array = json_decode($response);
|
|
return($result_array->total_count);
|
|
}
|
|
|
|
public function ImportGetAuftrag() {
|
|
|
|
$parameters = array('order_state_codes' => 'WAITING_ACCEPTANCE');
|
|
|
|
if(!empty($this->data['nummer'])) {
|
|
$parameters['order_ids'] = $this->data['nummer'];
|
|
}
|
|
|
|
$response = $this->miraklRequest('orders', getdata: $parameters, raw: true);
|
|
$this->Log(Logger::DEBUG, 'ImportGetAuftrag', $response);
|
|
$result_array = json_decode($response);
|
|
|
|
$fetchedOrders = [];
|
|
foreach ($result_array->orders as $order) {
|
|
$cart = [];
|
|
$cart['zeitstempel'] = strval($order->created_date);
|
|
|
|
$cart['auftrag'] = strval($order->order_id);
|
|
$cart['onlinebestellnummer'] = strval($order->commercial_id);
|
|
$cart['gesamtsumme'] = strval($order->total_price);
|
|
|
|
$cart['bestelldatum'] = strval($order->created_date);
|
|
|
|
$cart['lieferung'] = strval($order->shipping_type_code);
|
|
|
|
$cart['email'] = strval($order->customer_notification_email);
|
|
|
|
// $cart['kunde_sprache'] = '?';
|
|
$cart['kundennummer'] = $order->customer->customer_id;
|
|
|
|
$cart['name'] = ($order->customer->civility?$order->customer->civility." ":"").$order->customer->firstname." ".$order->customer->lastname;
|
|
|
|
if (!empty($order->customer->billing_address->company)) {
|
|
$cart['anrede'] = 'firma';
|
|
$cart['ansprechpartner'] = $cart['name'];
|
|
$cart['name'] = strval($order->customer->billing_address->company);
|
|
}
|
|
|
|
$cart['strasse'] = strval($order->customer->billing_address->street_1);
|
|
$cart['adresszusatz'] = strval($order->customer->billing_address->street_2);
|
|
$cart['telefon'] = strval($order->customer->billing_address->phone);
|
|
$cart['plz'] = strval($order->customer->billing_address->zip_code);
|
|
$cart['ort'] = strval($order->customer->billing_address->city);
|
|
|
|
// $cart['ustid'] = '?';
|
|
$sql = "SELECT iso FROM laender WHERE iso3 = '".$order->customer->billing_address->country_iso_code."'";
|
|
$cart['land'] = $this->app->DB->Select($sql);
|
|
|
|
$cart['abweichendelieferadresse'] = 1;
|
|
|
|
$sql = "SELECT iso FROM laender WHERE iso3 = '".$order->customer->shipping_address->country_iso_code."'";
|
|
$cart['lieferadresse_land'] = $this->app->DB->Select($sql);
|
|
|
|
$cart['lieferadresse_name'] = ($order->customer->shipping_address->civility?$order->customer->shipping_address->civility." ":"").$order->customer->shipping_address->firstname." ".$order->customer->shipping_address->lastname;
|
|
|
|
if (!empty(strval($order->customer->shipping_address->company))) {
|
|
$cart['lieferadresse_ansprechpartner'] = $cart['lieferadresse_name'];
|
|
$cart['lieferadresse_name'] = strval($deliveryAddress->company);
|
|
}
|
|
|
|
$cart['lieferadresse_strasse'] = strval($order->customer->shipping_address->street_1);
|
|
$cart['lieferadresse_adresszusatz'] = strval($order->customer->shipping_address->street_2);
|
|
$cart['lieferadresse_telefon'] = strval($order->customer->shipping_address->phone);
|
|
$cart['lieferadresse_plz'] = strval($order->customer->shipping_address->zip_code);
|
|
$cart['lieferadresse_ort'] = strval($order->customer->shipping_address->city);
|
|
|
|
$cart['zahlungsweise'] = strval($order->payment_type);
|
|
|
|
$cart['waehrung'] = strval($order->currency_iso_code);
|
|
|
|
// $cart['ust_befreit'] = '?'; // 1, 2
|
|
|
|
// $cart['steuersatz_normal'] = 19;//strval($order->taxes[0]->amount);
|
|
// $cart['steuersatz_ermaessigt'] 07; // strval($order->taxes[0]->amount);
|
|
|
|
$cart['articlelist'] = [];
|
|
|
|
|
|
$shipping_tax_amount = 0;
|
|
|
|
foreach ($order->order_lines as $order_row) {
|
|
|
|
$steuersatz = 0;
|
|
$umsatzsteuer_typ = 'normal';
|
|
foreach($order_row->taxes as $tax) {
|
|
if($tax->rate > $steuersatz) {
|
|
$steuersatz = $tax->rate;
|
|
}
|
|
switch ($order->row->taxes[0]->code) {
|
|
case $this->reducedTaxId:
|
|
$umsatzsteuer_typ = 'ermaessigt';
|
|
break;
|
|
default:
|
|
case $this->normalTaxId:
|
|
$umsatzsteuer_typ = 'normal';
|
|
break;
|
|
}
|
|
}
|
|
|
|
$article = [
|
|
'articleid' => strval($order_row->offer_sku),
|
|
// 'name' => strval($order_row->product_title),
|
|
'quantity' => strval($order_row->quantity),
|
|
'price_netto' => strval($order_row->price_unit),
|
|
'umsatzsteuer' => $steuersatz
|
|
];
|
|
|
|
foreach ($order_row->shipping_taxes as $shipment_tax) {
|
|
$shipping_tax_amount += $shipment_tax->amount;
|
|
}
|
|
$cart['articlelist'][] = $article;
|
|
} // foreach articles
|
|
|
|
$cart['versandkostennetto'] = round(strval($order->shipping_price),2);
|
|
$cart['versandkostenbrutto'] = round($cart['versandkostennetto']+$shipping_tax_amount,2);
|
|
|
|
} // foreach orders
|
|
|
|
$fetchedOrders[] = [
|
|
'id' => $cart['auftrag'],
|
|
'sessionid' => $cart['onlinebestellnummer'],
|
|
'logdatei' => '',
|
|
'warenkorb' => base64_encode(serialize($cart)),
|
|
'warenkorbjson' => base64_encode(json_encode($cart))
|
|
];
|
|
|
|
$this->Log(Logger::DEBUG, 'Auftragsimport', $cart);
|
|
return $fetchedOrders;
|
|
}
|
|
|
|
/*
|
|
* Send offer data to mirakl
|
|
* $articlelist = $this->CatchRemoteCommand('data');
|
|
* Return
|
|
* array (returncode, message, articlelist) articlelist with added mirakl_export_offers_result element (array (returncode, message)) for further processing (e.g. create product)
|
|
* returncode 0 = ok, 1 = not ok
|
|
* returncode articlelist 0 = ok, 10 = missing required attributes, 11 category not found, 12 rejected from mirakl
|
|
*/
|
|
private function mirakl_export_offers(array $articlelist) : array {
|
|
|
|
$mirakl_export_offers_return_value = array();
|
|
$mirakl_export_offers_return_value['returncode'] = 0;
|
|
|
|
$this->Log(Logger::DEBUG, 'Angebotsexport Start', $articlelist);
|
|
|
|
// First gather all articles as offers and send them
|
|
// Wait for import to finish
|
|
// Evaluate import
|
|
|
|
foreach ($articlelist as $key => $article) {
|
|
|
|
$return_article =
|
|
array(
|
|
'artikel' => $article['artikel'],
|
|
'nummer' => $article['nummer']
|
|
);
|
|
|
|
$skip_article = false;
|
|
|
|
/*
|
|
* Export offer
|
|
*/
|
|
$configuration_found = false;
|
|
$additional_fields = array();
|
|
|
|
$offer_for_mirakl = array(
|
|
'state_code' => '11', // ?!?!
|
|
'update_delete' => null // Update delete flag. Could be empty (means "update"), "update" or "delete".
|
|
);
|
|
|
|
$offer_configuration_name = $this->GetFieldValue($article, $this->configuration_identifier);
|
|
$return_article['offer_configuration'] = $offer_configuration_name;
|
|
|
|
foreach ($this->offer_configuration as $offer_configuration_entry) {
|
|
if ($offer_configuration_entry['konfigurationen'] != null) {
|
|
if (!in_array($offer_configuration_name,$offer_configuration_entry['konfigurationen'])) {
|
|
continue;
|
|
}
|
|
}
|
|
$configuration_found = true;
|
|
$offer_configuration = $offer_configuration_entry;
|
|
break;
|
|
}
|
|
|
|
if ($configuration_found) {
|
|
// Check required attributes
|
|
$required = [
|
|
'product_id_type',
|
|
'product_id',
|
|
'shop_sku',
|
|
'price'
|
|
];
|
|
$missing = null;
|
|
foreach ($required as $key) {
|
|
if (!isset($offer_configuration['felder'][$key])) {
|
|
$missing[] = $key;
|
|
}
|
|
}
|
|
if ($missing) {
|
|
$mirakl_export_offers_return_value['returncode'] = 1;
|
|
$return_article['export_offers_returncode'] = 10;
|
|
$return_article['export_offers_message'] = "Pflichtfelder fehlen in Angebotskonfiguration \"".$offer_configuration_name."\": ".implode(', ',$missing);
|
|
$mirakl_export_offers_return_value['articlelist'][] = $return_article;
|
|
$skip_article = true;
|
|
}
|
|
// Check Required attributes
|
|
|
|
foreach ($offer_configuration['felder'] as $offer_field => $offer_field_source) {
|
|
if (!is_array($offer_field_source)) {
|
|
$offer_field_source = array('feld' => $offer_field_source);
|
|
}
|
|
$offer_field_value = null;
|
|
$is_additional_field = false;
|
|
$offer_field_value = $this->GetFieldValue($article, $offer_field_source);
|
|
if (in_array('zusatzfeld', $offer_field_source)) {
|
|
$is_additional_field = true;
|
|
}
|
|
if ($is_additional_field) {
|
|
$additional_field = array (
|
|
"code" => $offer_field,
|
|
"value" => $offer_field_value
|
|
);
|
|
$additional_fields[] = $additional_field;
|
|
} else {
|
|
$offer_for_mirakl[$offer_field] = $offer_field_value;
|
|
}
|
|
}
|
|
|
|
if ($skip_article) {
|
|
continue;
|
|
}
|
|
|
|
if (!empty($additional_fields)) {
|
|
$offer_for_mirakl['offer_additional_fields'] = $additional_fields;
|
|
}
|
|
|
|
$offers_for_mirakl[] = $offer_for_mirakl;
|
|
|
|
$return_article['export_offers_returncode'] = 0;
|
|
$mirakl_export_offers_return_value['articlelist'][] = $return_article;
|
|
|
|
} else { // configuration_found
|
|
$mirakl_export_offers_return_value['returncode'] = 1;
|
|
$return_article['export_offers_returncode'] = 11;
|
|
$return_article['export_offers_message'] = "Angebotskonfiguration für Artikel ".$article['nummer'].", Konfiguration \"".$offer_configuration_name."\" nicht gefunden";
|
|
$mirakl_export_offers_return_value['articlelist'][] = $return_article;
|
|
continue;
|
|
}
|
|
}
|
|
|
|
if (empty($offers_for_mirakl)) {
|
|
$mirakl_export_offers_return_value['returncode'] = 1;
|
|
$this->Log(Logger::ERROR, 'Angebotsexport keine Artikel bereit', $mirakl_export_offers_return_value);
|
|
$mirakl_export_offers_return_value['message'] = "Angebotsexport keine Artikel bereit";
|
|
return($mirakl_export_offers_return_value);
|
|
}
|
|
|
|
$data_for_mirakl = array();
|
|
$data_for_mirakl['offers'] = $offers_for_mirakl;
|
|
|
|
$json_for_mirakl = json_encode($data_for_mirakl);
|
|
|
|
$this->Log(Logger::DEBUG, 'Angebotsexport Daten', $json_for_mirakl);
|
|
|
|
$result = [];
|
|
$response = $this->miraklRequest('offers', postdata: $json_for_mirakl, content_type: 'application/json', raw: true);
|
|
|
|
$result = json_decode($response);
|
|
|
|
if (!isset($result->import_id)) {
|
|
$mirakl_export_offers_return_value['returncode'] = 1;
|
|
$this->Log(Logger::ERROR, 'Angebotsimport abgelehnt', $response);
|
|
$mirakl_export_offers_return_value['message'] = "Angebotsimport abgelehnt: ".print_r($response,true);
|
|
return($mirakl_export_offers_return_value);
|
|
}
|
|
|
|
$this->Log(Logger::INFO, 'Angebotsimport angelegt', $response);
|
|
|
|
$import_id = $result->import_id;
|
|
|
|
// Wait for import to finish
|
|
|
|
$status = null;
|
|
|
|
/*
|
|
WAITING_SYNCHRONIZATION_PRODUCT, WAITING, RUNNING, COMPLETE, FAILED
|
|
*/
|
|
|
|
while ($status != 'COMPLETE' && $status != 'FAILED') {
|
|
sleep(5);
|
|
$response = $this->miraklRequest('offers/imports/'.$import_id, raw: true);
|
|
$result = json_decode($response);
|
|
$status = $result->status;
|
|
}
|
|
|
|
if ($status == 'FAILED') {
|
|
$this->Log(Logger::ERROR, 'Angebotsimport fehlgeschlagen', $response);
|
|
|
|
$mirakl_export_offers_return_value['returncode'] = 2;
|
|
$mirakl_export_offers_return_value['message'] = "Angebotsimport fehlgeschlagen: ".print_r($response,true);
|
|
return($mirakl_export_offers_return_value);
|
|
}
|
|
|
|
if ($result->lines_in_error == 0) {
|
|
$this->Log(Logger::INFO, 'Angebotsimport ok', $response);
|
|
return($mirakl_export_offers_return_value);
|
|
}
|
|
|
|
$this->Log(Logger::ERROR, 'Angebotsimport meldet Fehler in '.$result->lines_in_error.' Zeilen', $response);
|
|
|
|
$result = array();
|
|
// Check errors with CSV unfucking...
|
|
$response = $this->miraklRequest('offers/imports/'.$import_id.'/error_report', raw: true);
|
|
$response_lines = preg_split('/\R/', $response, flags: PREG_SPLIT_NO_EMPTY);
|
|
|
|
$error_message_key = null;
|
|
$firstline = true;
|
|
|
|
foreach ($response_lines as $key => $response_line) {
|
|
$response_array = str_getcsv($response_line,';','"');
|
|
if ($firstline) {
|
|
$error_message_key = array_search("error-message",$response_array);
|
|
$firstline = false;
|
|
continue;
|
|
}
|
|
|
|
$article_key = array_search(
|
|
$response_array['product_id'],
|
|
array_column(
|
|
$mirakl_export_offers_return_value['articlelist'],
|
|
'product_id')
|
|
);
|
|
|
|
$mirakl_export_offers_return_value['articlelist'][$article_key]['mirakl_export_offers_result'] = array('returncode' => 12, 'message' => $response_array[$error_message_key]);
|
|
}
|
|
|
|
$this->Log(Logger::ERROR, 'Angebotsimport Fehlerbericht', $response);
|
|
|
|
$mirakl_export_offers_return_value['returncode'] = 1;
|
|
|
|
return($mirakl_export_offers_return_value);
|
|
}
|
|
|
|
/*
|
|
* Create products
|
|
* Return
|
|
* array (returncode, message, articlelist) articlelist with added mirakl_export_offers_result element (array (returncode, message)) for further processing
|
|
* returncode 0 = ok, 1 = not ok
|
|
* returncode articlelist 0 = ok
|
|
*/
|
|
private function mirakl_export_products(array $articlelist) : array {
|
|
|
|
$mirakl_export_products_return_value = array();
|
|
$mirakl_export_products_return_value['export_products_returncode'] = 0;
|
|
|
|
$this->Log(Logger::DEBUG, 'Produktexport Start', $articlelist);
|
|
|
|
$articlelist_per_configuration = array();
|
|
|
|
foreach ($articlelist as $key => $article) {
|
|
|
|
// Determine configuration
|
|
$configuration_found = false;
|
|
$product_configuration_name = $this->GetFieldValue($article, $this->configuration_identifier);
|
|
|
|
$mirakl_export_products_return_value['articlelist'][] =
|
|
array(
|
|
'artikel' => $article['artikel'],
|
|
'nummer' => $article['nummer'],
|
|
'product_configuration' => $product_configuration_name
|
|
);
|
|
|
|
foreach ($this->product_configuration as $product_configuration_id => $product_configuration) {
|
|
if ($product_configuration['konfigurationen'] != null) {
|
|
if (!in_array($product_configuration_name,$product_configuration['konfigurationen'])) {
|
|
continue;
|
|
}
|
|
}
|
|
$configuration_found = true;
|
|
break;
|
|
}
|
|
|
|
if (!$configuration_found) {
|
|
$mirakl_export_products_return_value['export_products_returncode'] = 1;
|
|
$mirakl_export_products_return_value['articlelist'][$key]['export_products_returncode'] = 11;
|
|
$mirakl_export_products_return_value['articlelist'][$key]['export_products_message'] = "Produktkonfiguration für Artikel ".$article['nummer'].", Konfiguration \"".$product_configuration_name."\" nicht gefunden";
|
|
continue;
|
|
}
|
|
|
|
$articlelist_per_configuration[$product_configuration_name]['product_configuration'] = $product_configuration;
|
|
$articlelist_per_configuration[$product_configuration_name]['product_configuration_name'] = $product_configuration_name;
|
|
$articlelist_per_configuration[$product_configuration_name]['articles'][] = $article;
|
|
}
|
|
|
|
// $this->Log(Logger::DEBUG, 'Articlelist per config', $articlelist_per_configuration);
|
|
|
|
$komma = '';
|
|
|
|
foreach ($articlelist_per_configuration as $articlelist_one_configuration) {
|
|
$result = $this->mirakl_export_products_one_configuration($articlelist_one_configuration);
|
|
|
|
// $this->Log(Logger::DEBUG, 'Articlelist per config result', $result);
|
|
|
|
if ($result['export_products_returncode']) {
|
|
$mirakl_export_products_return_value['export_products_returncode'] = 1;
|
|
$mirakl_export_products_return_value['message'] .= $komma.$result['message']." (".$articlelist_one_configuration['product_configuration_name'].")";
|
|
$komma = ', ';
|
|
}
|
|
|
|
foreach ($result['articlelist'] as $article_result) {
|
|
$article_key = array_search(
|
|
$article_result['artikel'],
|
|
array_column(
|
|
$mirakl_export_products_return_value['articlelist'],
|
|
'artikel')
|
|
);
|
|
|
|
$mirakl_export_products_return_value['articlelist'][$article_key] += $article_result;
|
|
}
|
|
|
|
// $this->Log(Logger::DEBUG, 'mirakl_export_products_return_value', $mirakl_export_products_return_value);
|
|
|
|
}
|
|
|
|
return($mirakl_export_products_return_value);
|
|
}
|
|
|
|
private function mirakl_export_products_one_configuration (array $articlelist_one_configuration) {
|
|
|
|
// Build CSV
|
|
$csv_header = "";
|
|
$newline = "";
|
|
|
|
$mirakl_export_products_return_value = array();
|
|
|
|
foreach ($articlelist_one_configuration['articles'] as $article) {
|
|
$product_for_mirakl = array();
|
|
|
|
$mirakl_export_products_return_value['articlelist'][] =
|
|
array(
|
|
'artikel' => $article['artikel'],
|
|
'nummer' => $article['nummer'],
|
|
'product_configuration' => $product_configuration_name,
|
|
'export_products_returncode' => 0
|
|
);
|
|
|
|
foreach ($articlelist_one_configuration['product_configuration']['felder'] as $product_field => $product_field_source) {
|
|
if (!is_array($product_field_source)) {
|
|
$product_field_source = array('feld' => $product_field_source);
|
|
}
|
|
$product_field_value = null;
|
|
$product_field_value = $this->GetFieldValue($article, $product_field_source);
|
|
$product_for_mirakl[$product_field] = $product_field_value;
|
|
}
|
|
|
|
// Create CSV from array
|
|
if (empty($csv_header)) {
|
|
$csv_header .= '"'.implode('";"',array_keys($product_for_mirakl)).'"';
|
|
}
|
|
$csv .= $newline.'"'.implode('";"',$product_for_mirakl).'"';
|
|
$newline = "\r\n";
|
|
}
|
|
|
|
if (!$csv) { // No articles found
|
|
return($mirakl_export_products_return_value);
|
|
}
|
|
|
|
$csv = $csv_header.$newline.$csv;
|
|
|
|
$result = [];
|
|
|
|
$this->Log(Logger::DEBUG, 'Produktexport Daten '.$articlelist_one_configuration['product_configuration_name'], array('csv' => $csv));
|
|
|
|
$postdata = array('file' => new CURLStringFile(postname: 'import.csv', data: $csv));
|
|
|
|
$response = $this->miraklRequest('products/imports', postdata: $postdata, content_type: 'multipart/form-data', raw: true);
|
|
|
|
$result = json_decode($response);
|
|
|
|
if (!isset($result->import_id)) {
|
|
$this->Log(Logger::ERROR, 'Produktimport abgelehnt', $response);
|
|
$mirakl_export_products_return_value['export_products_returncode'] = 1;
|
|
$mirakl_export_products_return_value['export_products_message'] = 'Produktimport abgelehnt';
|
|
return($mirakl_export_products_return_value);
|
|
}
|
|
|
|
$this->Log(Logger::INFO, 'Produktimport angelegt', $result);
|
|
|
|
$import_id = $result->import_id;
|
|
|
|
// Wait for import to finish
|
|
|
|
$status = null;
|
|
|
|
/*
|
|
WAITING_SYNCHRONIZATION_PRODUCT, WAITING, RUNNING, COMPLETE, FAILED
|
|
*/
|
|
|
|
while ($status != 'COMPLETE' && $status != 'FAILED') {
|
|
sleep(30);
|
|
$response = $this->miraklRequest('products/imports/'.$import_id, raw: true);
|
|
$result = json_decode($response);
|
|
$status = $result->import_status;
|
|
}
|
|
|
|
if ($status == 'FAILED') {
|
|
$this->Log(Logger::ERROR, 'Produktimport fehlgeschlagen', $response);
|
|
$mirakl_export_products_return_value['export_products_returncode'] = 1;
|
|
return($mirakl_export_products_return_value);
|
|
}
|
|
|
|
if (!$result->has_error_report && !$result->has_transformation_error_report) {
|
|
$this->Log(Logger::INFO, 'Produktimport ok', $response);
|
|
} else {
|
|
$this->Log(Logger::ERROR, 'Produktimport meldet Fehler', $response);
|
|
$mirakl_export_products_return_value['export_products_returncode'] = 1;
|
|
}
|
|
|
|
if ($result->has_new_product_report) {
|
|
$response = $this->miraklRequest('products/imports/'.$import_id.'/new_product_report', raw: true);
|
|
$this->Log(Logger::DEBUG, 'Produktimport "Hinzugefügte Produkte"-Bericht', $response);
|
|
}
|
|
|
|
if ($result->has_transformed_file) {
|
|
$response = $this->miraklRequest('products/imports/'.$import_id.'/transformed_file', raw: true);
|
|
$this->Log(Logger::DEBUG, 'Produktimport Datei im Marketplace-Format', $response);
|
|
}
|
|
|
|
if ($result->has_error_report) {
|
|
// Check errors with CSV unfucking...
|
|
$response = $this->miraklRequest('products/imports/'.$import_id.'/error_report', raw: true);
|
|
$response_lines = preg_split('/\R/', $response, flags: PREG_SPLIT_NO_EMPTY);
|
|
$error_message_key = null;
|
|
$firstline = true;
|
|
foreach ($response_lines as $key => $response_line) {
|
|
$response_array = str_getcsv($response_line,';','"');
|
|
if ($firstline) {
|
|
$error_message_key = array_search("ERRORS",$response_array);
|
|
$firstline = false;
|
|
continue;
|
|
}
|
|
$article_key = array_search(
|
|
$response_array['product_id'],
|
|
array_column(
|
|
$mirakl_export_products_return_value['articlelist'],
|
|
'product_id')
|
|
);
|
|
|
|
$mirakl_export_products_return_value['articlelist'][$article_key]['export_products_returncode'] = 13;
|
|
$mirakl_export_products_return_value['articlelist'][$article_key]['export_products_message'] = $response_array[$error_message_key];
|
|
}
|
|
$this->Log(Logger::ERROR, 'Produktimport Fehlerbericht', $response);
|
|
}
|
|
|
|
if ($result->has_transformation_error_report) {
|
|
// Check errors with CSV unfucking...
|
|
$response = $this->miraklRequest('products/imports/'.$import_id.'/transformation_error_report', raw: true);
|
|
$response_lines = preg_split('/\R/', $response, flags: PREG_SPLIT_NO_EMPTY);
|
|
$error_message_key = null;
|
|
$firstline = true;
|
|
foreach ($response_lines as $key => $response_line) {
|
|
$response_array = str_getcsv($response_line,';','"');
|
|
if ($firstline) {
|
|
$error_message_key = array_search("errors",$response_array);
|
|
$firstline = false;
|
|
continue;
|
|
}
|
|
$article_key = array_search(
|
|
$response_array['product_id'],
|
|
array_column(
|
|
$mirakl_export_products_return_value['articlelist'],
|
|
'product_id')
|
|
);
|
|
|
|
$mirakl_export_products_return_value['articlelist'][$article_key]['export_products_returncode'] = 14;
|
|
$mirakl_export_products_return_value['articlelist'][$article_key]['export_products_message'] = $response_array[$error_message_key];
|
|
}
|
|
$this->Log(Logger::ERROR, 'Produktimport Transformation-Fehlerbericht', $response);
|
|
}
|
|
|
|
return($mirakl_export_products_return_value);
|
|
|
|
}
|
|
|
|
private function Log($level, $message, $dump = array()) {
|
|
$this->logger->Log($level, 'Mirakl (Shop '.$this->shopid.') '.$message, (array) $dump);
|
|
}
|
|
|
|
private function getOrdersToProcess(int $limit) {
|
|
echo("getOrdersToProcess");
|
|
exit();
|
|
}
|
|
|
|
public function ImportDeleteAuftrag() {
|
|
echo("ImportDeleteAuftrag");
|
|
exit();
|
|
}
|
|
|
|
public function ImportUpdateAuftrag() {
|
|
echo("ImportUpdateAuftrag");
|
|
exit();
|
|
}
|
|
|
|
|
|
}
|
|
|