crm.twinpol.com/modules/EcmSales/bimit_importEdiOrders.php

<?php
require_once('modules/EcmSales/EcmSale.php');
require_once 'include/phpMailer2/class.phpmailer.php';
require_once 'include/phpMailer2/class.smtp.php';

$path = "/var/edi/twinpol/orders";
$folders = array('imported', 'temp', 'failed');
$allFiles = scandir($path);

//searchForOrderByNumber('195761101', "/var/edi/twinpol/orders/imported");
//searchForOrderILN('4335347169230', "/var/edi/twinpol/orders/imported");
//getSellerILN("/var/edi/twinpol/orders/imported");
//return;

if (is_array($allFiles)) {
    $msg = array();
    foreach ($allFiles as $file) {
        if (!is_dir($file) && !in_array($file, $folders) && substr($file, -3) == 'xml') {
            try {
                $msg[] = importSale($path . '/' . $file);
                rename($path . '/' . $file, $path . '/imported/' . $file);
            } catch (Exception $e) {
                echo 'Import error ' . $e->getMessage(), PHP_EOL;
            }
        }
    }
    $parents = array();
    foreach ($msg as $m) {
        $parents[] = $m['parent'];
    }
    $parents = array_unique($parents);
    $orders = array();
    foreach ($msg as $m) {
        $orders[] = $m['number'];
    }
    sendEmail($parents, $orders);
    echo 'Import finished: ' . $file . PHP_EOL;
    return;
}

function importSale($file)
{
    $db = $GLOBALS['db'];
    $xml = simplexml_load_file($file);

    if (!$xml) {
        throw new Exception("Can't load (or parse) XML");
    }

    $sale = new EcmSale();

    // AUCHAN
    $buyerILN = $xml->{'Order-Parties'}->Buyer->ILN;
    if ($xml->{'Order-Parties'}->BuyerHeadquarters->ILN == '5900014000001') {
        $buyerILN = $xml->{'Order-Parties'}->BuyerHeadquarters->ILN;
    }

    $buyer = $db->fetchByAssoc($db->query("
        SELECT to_vatid, register_address_street, register_address_city, register_address_postalcode,
            register_address_country, id, assigned_user_id, name,parent_id, 
            supplier_code, ecmpaymentcondition_id, ecmpaymentcondition_name, payment_date_days,
            assigned_user_id, parent_id, payment_date_days, supplier_code
        FROM accounts where iln like '" . $buyerILN . "' AND deleted=0"));

    $isCarrefour = false;
    if ($xml->{'Order-Parties'}->Buyer->ILN == '5900000930015') {
        $isCarrefour = true;
    }
    $isMM = false;
    if ($buyer['parent_id'] == '1249') {
        $isMM = true;
    }
    $isAuchan = false;
    if ($buyer['id'] == '226a168c-2fef-b92f-0918-6200de91bb31') {
        $isAuchan = true;
    }

    $sale->order_source = 'edi';

    $sale->parent_id = $buyer['id'];
    $sale->parent_name = $buyer['name'];
    $sale->parent_iln = $xml->{'Order-Parties'}->Buyer->ILN;
    $sale->parent_nip = $buyer['to_vatid'];
    $sale->parent_address_street = $buyer['register_address_street'];
    $sale->parent_address_city = $buyer['register_address_city'];
    $sale->parent_address_postalcode = $buyer['register_address_postalcode'];
    $sale->parent_address_country = $buyer['register_address_country'];
    $sale->parent_document_no = $xml->{'Order-Header'}->OrderNumber;

    $sale->stock_id = '754a59d6-979f-7006-a202-57c96a3eb06b';

    if ($isMM) {
        $address = $db->fetchByAssoc(
            $db->query(
                "SELECT * FROM account_addresses WHERE account_id='$sale->parent_id' AND deleted='0' ORDER BY position LIMIT 1"
            )
        );
        $sale->shipping_address_name = $address['name'];
        $sale->shipping_addresses = $address['name'];
        $sale->shipping_address_street = $address['street'];
        $sale->shipping_address_city = $address['city'];
        $sale->shipping_address_postalcode = $address['postalcode'];
        $sale->shipping_address_country = $address['country'];
        $sale->shipping_iln = $xml->{'Order-Parties'}->DeliveryPoint->ILN;
        $sale->shipping_nip = "";
        if ($buyer['payment_date_days'])
            $sale->payment_date_days = $buyer['payment_date_days'];
        if ($buyer['supplier_code'])
            $sale->supplier_code = $buyer['supplier_code'];
    } else {

        $delivery = $db->fetchByAssoc($db->query("
    SELECT to_vatid, register_address_street, register_address_city, register_address_postalcode,
        register_address_country, id, assigned_user_id, name,parent_id, 
        supplier_code, ecmpaymentcondition_id, ecmpaymentcondition_name, payment_date_days 
    FROM accounts where iln like '" . $xml->{'Order-Parties'}->DeliveryPoint->ILN . "' AND deleted=0"));

        $sale->shipping_address_name = $delivery['name'];
        $sale->shipping_addresses = $delivery['name'];
        $sale->shipping_address_street = $delivery['register_address_street'];
        $sale->shipping_address_city = $delivery['register_address_city'];
        $sale->shipping_address_postalcode = $delivery['register_address_postalcode'];
        $sale->shipping_address_country = $delivery['register_address_country'];
        $sale->shipping_iln = $xml->{'Order-Parties'}->DeliveryPoint->ILN;
        $sale->shipping_nip = $delivery['to_vatid'];
        if ($delivery['payment_date_days'])
            $sale->payment_date_days = $delivery['payment_date_days'];
        if ($delivery['supplier_code'])
            $sale->supplier_code = $delivery['supplier_code'];
    }

    $sale->register_date = date("d.m.Y", strtotime($xml->{'Order-Header'}->OrderDate));
    $sale->delivery_date = date("d.m.Y", strtotime($xml->{'Order-Header'}->ExpectedDeliveryDate));
    $date = new DateTime(date("d.m.Y", strtotime($xml->{'Order-Header'}->OrderDate)));
    if ($sale->payment_date_days != "") {
        $date->modify("+" . $sale->payment_date_days . " day");
    }
    $sale->payment_date = $date->format("d.m.Y");
    $sale->payment_method = 'PRZELEW';
    $sale->assigned_user_id = $buyer['assigned_user_id'];
    $sale->edi_file = $file;
    $sale->type = 'sales_order';
    $sale->status = 's30';
    $sale->ecmlanguage = 'pl_pl';

    $sale->position_list = loadProducts($xml->{'Order-Lines'}->Line, $isCarrefour, $isAuchan);
    $sum_netto = 0;
    $sum_brutto = 0;
    foreach ($sale->position_list as $p) {
        $sum_netto += $p['total_netto'];
        $sum_brutto += $p['total_brutto'];
    }
    $sale->total_netto = $sum_netto;
    $sale->total_brutto = $sum_brutto;

    $sale->save(false);

    $parent = '';
    if ($isMM) {
        $parent = 'MediaMarkt';
    } else if ($isAuchan) {
        $parent = 'Auchan';
    } else if ($isCarrefour) {
        $parent = 'Carrefour';
    }
    $msg = array();
    $msg['parent'] = $parent;
    $msg['number'] = $sale->document_no;
    return $msg;
}

function loadProducts($products, $isCarrefour = false, $isAuchan = false)
{
    $db = $GLOBALS['db'];
    $counter = 0;
    foreach ($products as $prod) {
        if ($isCarrefour) {
            $pId = $db->fetchByAssoc($db->query("select p.id from ecmproducts as p where TRIM(p.ean2)='" . trim($prod->{'Line-Item'}->EAN) . "' and p.deleted='0'"));
        } else if ($isAuchan) {
            $pId = $db->fetchByAssoc($db->query("select p.id from ecmproducts as p where TRIM(p.ean2)='" . trim($prod->{'Line-Item'}->EAN) . "' and p.deleted='0'"));
            if (!isset($pId) || $pId == null) {
                $pId = $db->fetchByAssoc($db->query("select p.id from ecmproducts as p where TRIM(p.ean)='" . trim($prod->{'Line-Item'}->EAN) . "' and p.deleted='0'"));
            }
        } else {
            $pId = $db->fetchByAssoc($db->query("select p.id from ecmproducts as p where (TRIM(p.ean)='" . trim($prod->{'Line-Item'}->EAN) . "' OR TRIM(p.ean2)='" . trim($prod->{'Line-Item'}->EAN) . "') and p.deleted='0'"));
        }
        if (!isset($pId) || $pId == null) {
            sendEmail("Nie znaleziono produktu: " . trim($prod->{'Line-Item'}->EAN));
        }
        $p = new EcmProduct();
        $p->retrieve($pId['id']);
        $response[$counter]['product_id'] = $p->id;
        $response[$counter]['position'] = (string) $prod->{'Line-Item'}->LineNumber;
        $response[$counter]['product_code'] = $p->code;
        $response[$counter]['name'] = $p->name;
        $response[$counter]['quantity'] = (string) $prod->{'Line-Item'}->OrderedQuantity;
        $response[$counter]['price_start'] = (string) $prod->{'Line-Item'}->OrderedUnitNetPrice;
        $response[$counter]['price_netto'] = (string) $prod->{'Line-Item'}->OrderedUnitNetPrice;
        $response[$counter]['discount'] = 0;
        $response[$counter]['total_netto'] = (string) $prod->{'Line-Item'}->OrderedUnitNetPrice * $prod->{'Line-Item'}->OrderedQuantity;
        $response[$counter]['unit_id'] = 1;
        $response[$counter]['unit_name'] = 'szt.';
        $response[$counter]['ecmvat_id'] = $p->vat_id;
        $response[$counter]['ecmvat_name'] = $p->vat_name;
        $response[$counter]['ecmvat_value'] = $p->vat_value;
        $response[$counter]['recipient_code'] = (string) $prod->{'Line-Item'}->BuyerItemCode;
        $response[$counter]['product_ean'] = (string) trim($prod->{'Line-Item'}->EAN);
        $counter++;
    }
    return $response;
}

function searchForOrderByNumber($number, $path)
{
    $allFiles = scandir($path);
    $folders = array('imported', 'temp', 'failed');
    if (is_array($allFiles)) {
        foreach ($allFiles as $file) {
            if (!is_dir($file) && !in_array($file, $folders) && substr($file, -3) == 'xml') {
                $xml = simplexml_load_file($path . '/' . $file);
                if (!$xml) {
                    throw new Exception("Can't load (or parse) XML");
                }
                if ($xml->{'Order-Header'}->OrderNumber == $number) {
                    echo 'Found: ' . $file . PHP_EOL;
                    return;
                }
            }
        }
        return;
    }
}

function searchForOrderILN($number, $path)
{
    $allFiles = scandir($path);
    $folders = array('imported', 'temp', 'failed');
    if (is_array($allFiles)) {
        foreach ($allFiles as $file) {
            if (!is_dir($file) && !in_array($file, $folders) && substr($file, -3) == 'xml') {
                $xml = simplexml_load_file($path . '/' . $file);
                if (!$xml) {
                    throw new Exception("Can't load (or parse) XML");
                }
                if ($xml->{'Order-Parties'}->Buyer->ILN == $number) {
                    echo 'Found (Buyer): ' . $file . PHP_EOL;
                    return;
                }
                if ($xml->{'Order-Parties'}->DeliveryPoint->ILN == $number) {
                    echo 'Found (DeliveryPoint): ' . $file . PHP_EOL;
                    return;
                }
            }
        }
        echo 'Not found: ' . $number . PHP_EOL;
        return;
    }
}

function getSellerILN($path)
{
    $allFiles = scandir($path);
    $folders = array('imported', 'temp', 'failed');
    $media = array();
    if (is_array($allFiles)) {
        foreach ($allFiles as $file) {
            if (!is_dir($file) && !in_array($file, $folders) && substr($file, -3) == 'xml') {
                $xml = simplexml_load_file($path . '/' . $file);
                if (!$xml) {
                    throw new Exception("Can't load (or parse) XML");
                }
                // create array with seller iln without duplicates
                $iln = (string) $xml->{'Order-Parties'}->Seller->ILN;

                if ($iln === '5909000896239') {
                    echo '5909000896239 ' . $file . PHP_EOL;
                }
            }
        }
    }
    var_dump($media);
    return;
}

function brecho($msg)
{
    echo '<br><br>';
    var_dump($msg);
    echo '<br><br>';
}

function sendEmail($parents, $orders)
{
    $mail = new PHPMailer2(true);
    $mail->isSMTP();
    $mail->setFrom('system@e5.pl', 'Twinpol CRM - usługa importu EDI');
    $mail->Host       = 'smtp.gmail.com';
    $mail->SMTPAuth   = true;
    $mail->Username   = 'system@e5.pl';
    $mail->Password   = 'upkb sxxb pmxw lsaj';
    $mail->SMTPSecure = 'tls';
    $mail->Port       = 587;
    $mail->CharSet = 'UTF-8';
    $mail->addAddress('mz@bim-it.pl', 'Michał Zieliński');
    $mail->addAddress('mf@e5.pl', 'Małgorzata Franiewska');
    if (in_array('Auchan', $parents) || in_array('Carrefour', $parents) || true) {
        $mail->addAddress('justyna.pawlak@twinpol.com', 'Justyna Pawlak');
    }
    $mail->isHTML(true);
    $mail->Subject = 'Twinpol: zaimportowano zamówienia EDI dla: ' . implode(', ', $parents);
    $body = '';
    foreach ($orders as $order) {
        $body .= 'Zaimportowano zamówienie: ' . $order . '<br>';
    }
    $mail->Body = $body;
    $mail->send();
}