OpenXE/www/pages/shopimport.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

class Shopimport 
{
  public $error;
  /** @var Application $app */
  public $app;

  const MODULE_NAME = 'Shopimport';

  public $javascript = [
    './classes/Modules/Shopimport/www/js/shopimport.js'
  ];

  /**
   * Shopimport constructor.
   *
   * @param Application $app
   * @param bool        $intern
   */
  public function __construct($app, $intern = false)
  {
    $this->app=$app;
    if($intern) {
      return;
    }
    $this->app->ActionHandlerInit($this);

    $this->app->ActionHandler("login","ShopimportLogin");
    $this->app->ActionHandler("main","ShopimportMain");
    $this->app->ActionHandler("list","ShopimportList");
    $this->app->ActionHandler("alle","ShopimportAlle");
    $this->app->ActionHandler("import","ShopimportImport");
    $this->app->ActionHandler("einzelimport","ShopimportEinzelimport");
    $this->app->ActionHandler("navigation","ShopimportNavigation");
    $this->app->ActionHandler("logout","ShopimportLogout");
    $this->app->ActionHandler("archiv","ShopimportArchiv");

    $this->app->DefaultActionHandler("list");


    $this->app->Tpl->Set('UEBERSCHRIFT','Shop Import');
    $this->app->ActionHandlerListen($app);
  }

  /**
   * @param int   $shopId
   * @param array $data
   *
   * @return int
   *
   * @throws Exception
   */
  public function Refund($shopId, $data)
  {
    if(empty($shopId)) {
      throw new Exception('no Shop given');
    }
    if(empty($data)) {
      throw new Exception('no Data given');
    }

    $shop = $this->app->DB->SelectRow(
      sprintf(
        'SELECT `aktiv`, `id`, `artikelrabatt` FROM `shopexport` WHERE `id` = %d',
        $shopId
      )
    );
    if(empty($shop)) {
      throw new Exception('Shop not found');
    }
    if(empty($shop['aktiv'])) {
      throw new Exception('Shop is not active');
    }

    if(!empty($data->extid)) {
      $order = $this->app->DB->SelectRow(
        sprintf(
          "SELECT * 
          FROM `auftrag` 
          WHERE `shop` = %d AND `shopextid` = '%s' AND `shopextid` <> '' 
          AND `status` <> 'storniert'
          LIMIT 1",
          $shopId, $this->app->DB->real_escape_string((string)$data->extid)
        )
      );
    }
    elseif(!empty($data->internet)) {
      $order = $this->app->DB->SelectRow(
        sprintf(
          "SELECT * 
          FROM `auftrag` 
          WHERE `shop` = %d AND `internet` = '%s' AND `internet` <> '' 
          AND `status` <> 'storniert'
          LIMIT 1",
          $shopId, $this->app->DB->real_escape_string((string)$data->extid)
        )
      );
    }
    else {
      throw new Exception('No order given');
    }

    if(empty($order)) {
      throw new Exception('order not found');
    }

    $invoice = $this->app->DB->SelectRow(
      sprintf(
        "SELECT * FROM `rechnung` WHERE `auftragid` = %d ORDER BY `status` = 'storniert' LIMIT 1",
        $order['id']
      )
    );

    if(empty($invoice)) {
      if(empty($data->createinvoice)){
        throw new Exception('order has no invoice');
      }
      $invoiceId = $this->app->erp->WeiterfuehrenAuftragZuRechnung($order['id']);
      $this->app->erp->AuftragProtokoll($order['id'], 'Rechnung erstellt durch Shop-Trigger');
      $this->app->erp->RechnungProtokoll($invoiceId, 'Rechnung erstellt durch Shop-Trigger');
      $this->app->erp->BelegFreigabe('rechnung', $invoiceId);
      $this->app->erp->RechnungNeuberechnen($invoiceId);
      $invoice = $this->app->DB->SelectRow(
        sprintf(
          "SELECT * FROM `rechnung` WHERE `auftragid` = %d ORDER BY `status` = 'storniert' LIMIT 1",
          $order['id']
        )
      );
    }

    if($invoice['status'] === 'storniert') {
      throw new Exception('order invoice is already cancelled');
    }
    if(!empty($data->positions)) {
      $positions = $this->app->DB->SelectArr(
        sprintf(
          "SELECT `op`.webid, ip.artikel, ip.menge,ip.preis, ip.rabatt, ip.auftrag_position_id
          FROM `rechnung_position` AS `ip`
          INNER JOIN `auftrag_position` AS `op` ON ip.auftrag_position_id = op.id 
          WHERE `ip`.rechnung = %d",
          $invoice['id']
        )
      );
      if(empty($positions)) {
        throw new Exception('invoice has no positions');
      }
      $webIds = [];
      $foundWebIds = [];
      foreach($positions as $position) {
        if(!empty($position['webid'])) {
          $webIds[] = $position['webid'];
        }
      }

      $webIdToPosition = [];

      foreach($data->positions as $position) {
        if(!empty($position->webid)){
          if(!in_array((string)$position->webid, $webIds)){
            throw new Exception(sprintf('position %s not found', (string)$position->webid));
          }
          $foundWebIds[] = (string)$position->webid;
          $webIdToPosition[$position->webid] = $position;
        }
        else {
          throw new Exception('no webId given');
        }
      }

      if(empty($foundWebIds)) {
        throw new Exception('positions empty');
      }

      $toDeleteInvoicePositionIds = [0];
      foreach($positions as $position) {
        if(empty($position['webid']) || !in_array($position['webid'], $foundWebIds)) {
          $toDeleteInvoicePositionIds[] = (int)$position['auftrag_position_id'];
        }
      }

      $creditNoteId = $this->app->erp->WeiterfuehrenRechnungZuGutschrift($invoice['id']);
      $this->app->erp->RechnungProtokoll($invoice['id'], 'Rechnung durch Shop-Trigger storniert');
      $this->app->erp->GutschriftProtokoll($creditNoteId, 'Gutschrift durch Shop-Trigger angelegt');
      $this->app->erp->BelegFreigabe('gutschrift', $creditNoteId);
      $this->app->DB->Delete(
        sprintf(
          "DELETE FROM `gutschrift_position` WHERE `gutschrift` = %d AND `auftrag_position_id` IN (%s)",
          $creditNoteId, implode(',', $toDeleteInvoicePositionIds)
        )
      );
      $hasCreditNoteTax = !empty($this->app->erp->GutschriftMitUmsatzeuer($creditNoteId));
      $this->app->erp->GutschriftNeuberechnen($creditNoteId);
      $creditNote = $this->app->DB->SelectRow(
        sprintf(
          'SELECT * FROM `gutschrift` WHERE `id` = %d',
          $creditNoteId
        )
      );
      $creditNotePositions = $this->app->DB->SelectArr(
        sprintf(
          "SELECT op.webid, cnp.id, cnp.menge, cnp.preis, cnp.rabatt, cnp.umsatzsteuer, 
            cnp.steuersatz 
          FROM `gutschrift_position` AS `cnp`
          INNER JOIN `auftrag_position` AS `op` ON cnp.auftrag_position_id = op.id
          WHERE cnp.gutschrift = %d",
          $creditNoteId
        )
      );
      foreach($creditNotePositions as $creditNotePosition) {
        if(isset($webIdToPosition[$creditNotePosition['webid']])) {
          $position = $webIdToPosition[$creditNotePosition['webid']];
          if(!empty($position->quantity)) {
            $this->app->DB->Update(
              sprintf(
                "UPDATE `gutschrift_position` SET `menge` = %f WHERE `id` = %d",
                (float)$position->quantity, $creditNotePosition['id']
              )
            );
          }
          elseif(!empty($position->menge)) {
            $this->app->DB->Update(
              sprintf(
                "UPDATE `gutschrift_position` SET `menge` = %f WHERE `id` = %d",
                (float)$position->menge, $creditNotePosition['id']
              )
            );
          }
          $preis = null;
          if(isset($position->price)) {
            $preis = (float)$position->price;
          }
          elseif(isset($position->preis)) {
            $preis = (float)$position->preis;
          }
          elseif(isset($position->amount)) {
            $preis = (float)$position->amount;
          }
          if($preis !== null) {
            if($hasCreditNoteTax) {
              if($creditNotePosition['steuersatz'] !== null && $creditNotePosition['steuersatz'] >= 0) {
                $preis /= 1+ $creditNotePosition['steuersatz'] / 100;
              }
              elseif($creditNotePosition['umsatzsteuer'] === 'ermaessigt') {
                $preis /= 1+ $creditNote['steuersatz_ermaessigt'] / 100;
              }
              elseif($creditNotePosition['umsatzsteuer'] !== 'befreit') {
                $preis /= 1+ $creditNote['steuersatz_normal'] / 100;
              }
            }
            $this->app->DB->Update(
              sprintf(
                'UPDATE `gutschrift_position` SET `preis` = %f, `rabatt` = 0 WHERE `id` = %d',
                $preis, $creditNotePosition['id']
              )
            );
          }
        }
      }

      $this->app->erp->GutschriftNeuberechnen($creditNoteId);

      if(!empty($data->amount)) {
        $soll = $this->app->DB->Select(sprintf('SELECT `soll` FROM `gutschrift` WHERE `id` = %d', $creditNoteId));
        $diff = round($soll,2) - round((float)$data->amount, 2);
        if($diff == 0) {
          return $creditNoteId;
        }
        $this->app->erp->AddPositionManuellPreis(
          'gutschrift', $creditNoteId, $shop['artikelrabatt'], 1, 'Differenz', -$diff,'befreit', $invoice['waehrung']
        );
      }

      return (int)$creditNoteId;
    }
    $creditNoteId = $this->app->erp->WeiterfuehrenRechnungZuGutschrift($invoice['id']);
    $this->app->erp->RechnungProtokoll($invoice['id'], 'Rechnung durch Shop-Trigger storniert');
    $this->app->erp->GutschriftProtokoll($creditNoteId, 'Gutschrift durch Shop-Trigger angelegt');
    $this->app->erp->BelegFreigabe('gutschrift', $creditNoteId);
    $this->app->erp->GutschriftNeuberechnen($creditNoteId);
    if(!empty($data->amount)) {
      $soll = $this->app->DB->Select(sprintf('SELECT `soll` FROM `gutschrift` WHERE `id` = %d', $creditNoteId));
      $diff = round($soll,2) - round((float)$data->amount, 2);
      if($diff == 0) {
        return $creditNoteId;
      }
      $this->app->erp->AddPositionManuellPreis(
        'gutschrift', $creditNoteId, $shop['artikelrabatt'], 1, 'Differenz', -$diff,'befreit', $invoice['waehrung']
      );
    }

    return (int)$creditNoteId;
  }

  public function ShopimportList()
  {
    $msg = $this->app->Secure->GetGET('msg');
    if(!empty($msg))
    { 
      $msg = $this->app->erp->base64_url_decode($msg);
      $this->app->Tpl->Set('MESSAGE',$msg);
    }
    $this->app->erp->MenuEintrag('index.php?module=importvorlage&action=uebersicht','Zur&uuml;ck zur &Uuml;bersicht');

    //$this->app->Tpl->Add(TABS,"<li><h2 style=\"background-color: [FARBE5];\">Shopimport</h2></li>");
    $this->app->erp->Headlines('Shopimport');
    //$this->app->erp->MenuEintrag("index.php?module=shopimport&action=alle","Alle importieren");
    $this->app->erp->MenuEintrag('index.php?module=shopimport&action=list','&Uuml;bersicht');

    if($this->app->erp->RechteVorhanden('shopimport','alle')){
      $this->app->Tpl->Add('INHALT', "<center><input type=\"button\" onclick=\"window.location.href='index.php?module=shopimport&action=alle';\" value=\"Alle importieren\" class=\"buttonsave\"></center><br><br>");
    }
    //$this->app->Tpl->Set('SUBHEADING',"Imports");
    //Jeder der in Nachbesserung war egal ob auto oder manuell wandert anschliessend in Manuelle-Freigabe");
    $runningcronjob = $this->app->DB->Select("SELECT id FROM prozessstarter WHERE parameter = 'shopimport' AND aktiv=1 AND mutex = 1 AND UNIX_TIMESTAMP(now()) - UNIX_TIMESTAMP(letzteausfuerhung) < 300 LIMIT 1");
    if($runningcronjob)
    {
      $this->app->Tpl->Set('TAB1','<div class="error">Es l&auml;uft gerade ein Cronjob der Auftr&auml;ge abholt. Die manuelle Auftragsabholung ist in dieser Zeit gesperrt. Bitte warten Sie ein paar Minuten und versuchen Sie es erneut.</div>');
    }else{
      $table = new EasyTable($this->app);
      $table->Query("SELECT ae.bezeichnung,p.abkuerzung, 
          ae.id FROM shopexport ae LEFT JOIN projekt p ON p.id=ae.projekt WHERE ae.aktiv='1'");
      $table->DisplayNew('INHALT',"<a href=\"index.php?module=shopimport&action=import&id=%value%\"><img src=\"./themes/new/images/forward.svg\" title=\"Shopimport\"></a>&nbsp;<a href=\"index.php?module=onlineshops&action=edit&id=%value%\"><img src=\"./themes/new/images/edit.svg\" title=\"Onlineshops\"></a>&nbsp;<!--<a href=\"index.php?module=shopimport&action=archiv&id=%value%\">Archiv</a>-->");
      $this->app->Tpl->Parse('TAB1','rahmen.tpl');
    }
    $this->app->Tpl->Set('INHALT','');


    // Archiv GESTERN
    $table = new EasyTable($this->app);
    $table->Query("SELECT a.datum, a.internet, a.transaktionsnummer,a.name,  a.land, a.gesamtsumme as betrag, (SELECT SUM(r.soll) FROM rechnung r WHERE r.adresse=a.adresse AND r.status='offen') as mahnwesen, a.zahlungsweise, a.partnerid as Partner, a.id FROM auftrag a WHERE 
        (datum=DATE_FORMAT( DATE_SUB( NOW() , INTERVAL 1 DAY ) , '%Y-%m-%d' ) OR (datum=DATE_FORMAT( NOW(), '%Y-%m-%d' ))) AND a.internet>0 
        ORDER by a.id DESC");
    $table->DisplayNew('INHALT',"<a href=\"index.php?module=auftrag&action=edit&id=%value%\" target=\"_blank\"><img src=\"./themes/".$this->app->Conf->WFconf['defaulttheme']."/images/edit.svg\"></a>
        <a href=\"index.php?module=auftrag&action=pdf&id=%value%\"><img src=\"./themes/".$this->app->Conf->WFconf['defaulttheme']."/images/pdf.svg\"></a>");

    $this->app->Tpl->Parse('TAB2','rahmen.tpl');
    $this->app->Tpl->Set('INHALT','');


    $summe_heute = $this->app->DB->Select("SELECT SUM(a.gesamtsumme) FROM auftrag a WHERE 
        a.datum=DATE_FORMAT( NOW(), '%Y-%m-%d' ) AND a.internet>0 
        ");

    $summe_gestern = $this->app->DB->Select("SELECT SUM(a.gesamtsumme) FROM auftrag a WHERE 
        a.datum=DATE_FORMAT( DATE_SUB( NOW() , INTERVAL 1 DAY ) , '%Y-%m-%d' ) AND a.internet>0 
        ");

    $this->app->Tpl->Add('TAB2',"<div class=\"warning\">Heute: $summe_heute EUR (inkl. Steuer und Versand) <i>Umsatz aus den Online-Shop</i></div>");
    $this->app->Tpl->Add('TAB2',"<div class=\"warning\">Gestern: $summe_gestern EUR (inkl. Steuer und Versand) <i>Umsatz aus den Online-Shop</i></div>");

    $this->app->Tpl->Set('SUBHEADING','');
    $this->app->Tpl->Parse('PAGE','shopimport_list.tpl');
  }


  public function ShopimportArchiv()
  {
    $id = $this->app->Secure->GetGET('id');
    $more = $this->app->Secure->GetGET('more');
    $datum = $this->app->Secure->GetGET('datum');

    $this->app->Tpl->Set('TABTEXT','Shopimport - Archiv');


    //$this->app->YUI->TableSearch('TAB1',"shopimportarchiv");

    //$this->app->Tpl->Set('TAB1',"Shopimport - Archiv");

    if($datum=='')
    {
      $datum = date('Y-m-d');
    }

    $result = $this->app->DB->SelectArr("SELECT * FROM shopimport_auftraege WHERE DATE_FORMAT(logdatei,'%Y-%m-%d') = '$datum'");


    $table = '<table border="1" width="100%">';

    if(is_array($result))
    {
      foreach($result as $key=>$row)
      {
        //$table = $row['imported'];
        if(isset($row['jsonencoded']) && $row['jsonencoded'])
        {
          $warenkorb = json_decode(base64_decode($row['warenkorb']), true);
        }else{
          $warenkorb = unserialize(base64_decode($row['warenkorb']));
        }
        $this->app->stringcleaner->XMLArray_clean($warenkorb);

        $table .= "<tr><td>".$warenkorb["onlinebestellnummer"]."/".$warenkorb["transaktionsnummer"]."</td><td>".$warenkorb["name"]."</td><td>".$warenkorb["email"]."</td><td>".$warenkorb["gesamtsumme"]."</td><td>
          <a href=\"index.php?module=shopimport&action=archiv&id=$id&more=".$row['id']."&datum=$datum\">mehr Informationen</a></td></tr>";

      }	
    }

    $table .= '</table>';

    if($more > 0)
    {
      $result = $this->app->DB->Select("SELECT warenkorb FROM shopimport_auftraege WHERE id='$more' LIMIT 1");
      if($this->app->DB->Select("SELECT id FROM shopimport_auftraege WHERE id='$more' AND jsonencoded = 1 LIMIT 1"))
      {
        $warenkorb = json_decode(base64_decode($result), true);
      }else{
        $warenkorb = unserialize(base64_decode($result));
      }

      ob_start();
      var_dump($warenkorb);
      $var_dump_result = ob_get_clean();

      $table .='<pre>'.$var_dump_result.'</pre>';

    }

    $this->app->Tpl->Set('TAB1',$table);
    $this->app->Tpl->Parse('PAGE','tabview.tpl');
  }


  public function ShopimportAlle()
  {
    $runningcronjob = $this->app->DB->Select("SELECT id FROM prozessstarter WHERE parameter = 'shopimport' AND aktiv=1 AND mutex = 1 AND UNIX_TIMESTAMP(now()) - UNIX_TIMESTAMP(letzteausfuerhung) < 300 LIMIT 1");
    if(!empty($runningcronjob))
    {
      $this->app->Location->execute('index.php?module=shopimport&action=list');
    }
    $lastshop = false;
    $shops = $this->app->DB->SelectArr("SELECT ae.id as id FROM shopexport ae LEFT JOIN projekt p ON p.id=ae.projekt WHERE ae.aktiv='1' and ae.demomodus <> '1'");
    if(!empty($shops))
    {
      $anz = 0;
      $fp = $this->app->erp->ProzessLock('shopimport_alle');
      $cshops = (!empty($shops)?count($shops):0);
      for($i=0;$i<$cshops-1;$i++)
      {
        $anz += $this->ShopimportImport($shops[$i]['id'],$anz,true);
      }
      $lastshop=$shops[(!empty($shops)?count($shops):0)-1]['id'];
      $this->app->erp->ProzessUnlock($fp);
    }
    if($lastshop && is_numeric($lastshop)){
      $this->app->Location->execute('index.php?module=shopimport&action=import&id='.$lastshop);
    }
    else{
      $this->app->Location->execute('index.php?module=shopimport&action=list');
    }
  }

  /**
   * @param int    $shopId
   * @param string $shopOrderNumber
   * @param bool   $changeShopOrderStatus
   * @param int    $projectId
   * @param bool   $allStati
   *
   * @return array
   */
  public function importSingleOrder($shopId, $shopOrderNumber, $changeShopOrderStatus, $projectId, $allStati = false)
  {
    $pageContents = $this->app->remote->RemoteConnection($shopId);
    if($pageContents==='success')
    {
      $orderCount = $this->app->remote->RemoteGetAuftraegeAnzahlNummer($shopId, $shopOrderNumber);

      if($orderCount > 0)
      {
        if($allStati){
          $result = $this->app->remote->RemoteCommand($shopId, 'getauftrag', ['nummer' => $shopOrderNumber]);
        }
        else {
          $result = $this->app->remote->RemoteGetAuftragNummer($shopId, $shopOrderNumber);
        }

        if(is_array($result))
        {
          $result = reset($result);
          $shopExtId = $result['id'];
          $sessionid = $result['sessionid'];
          $jsonEncoded = 0;
          if(empty(!$result['warenkorbjson'])) {
            $jsonEncoded = 1;
            $warenkorb = $result['warenkorbjson'];
          } else{
            $warenkorb = $result['warenkorb'];
          }
          $logdatei = $result['logdatei'];
          $username = !empty($this->app->User)?$this->app->User->GetName():'Cronjob';
          $this->app->DB->Insert(
            sprintf(
              "INSERT INTO shopimport_auftraege (extid,sessionid,warenkorb,imported,projekt,bearbeiter,logdatei, jsonencoded, shopid) 
                  VALUES('%s','%s','%s',0,%d, '%s','%s', %d, %d)",
              $this->app->DB->real_escape_string($shopExtId),
              $this->app->DB->real_escape_string($sessionid),
              $this->app->DB->real_escape_string($warenkorb),
              (int)$projectId,
              $this->app->DB->real_escape_string($username),
              $this->app->DB->real_escape_string($logdatei),
              $jsonEncoded,
              (int)$shopId
            )
          );
          $insid = $this->app->DB->GetInsertID();
          if($changeShopOrderStatus && (String)$shopExtId !== '')
          {
            $this->app->remote->RemoteDeleteAuftrag($shopId, $shopExtId);
          }
          return ['status'=>1,'id'=>$insid,'info'=>'Auftrag wurde abgeholt.'];
        }
      }
      return ['status'=>0,'error'=>'Auftrag wurde nicht gefunden!'];
    }
    return ['status'=>0,'error'=>'Verbindung fehlgeschlagen!'];
  }

  public function ShopimportEinzelimport()
  {
    $runningcronjob = $this->app->DB->Select("SELECT id FROM prozessstarter WHERE parameter = 'shopimport' AND aktiv=1 AND mutex = 1 AND UNIX_TIMESTAMP(now()) - UNIX_TIMESTAMP(letzteausfuerhung) < 300 LIMIT 1");
    if(!empty($runningcronjob))
    {
      $this->app->Location->execute('index.php?module=shopimport&action=list');
    }
    $id = (int)$this->app->Secure->GetGET('id');
    $nummer = (String)$this->app->Secure->GetGET('nummer');
    if($nummer === '')
    {
      $nummer = (String)$this->app->Secure->GetPOST('nummer');
    }
    $deleteauftrag = (int)$this->app->Secure->GetPOST('deleteauftrag');
    if(!empty($id) && !empty($nummer))
    {
      $shoparr = $this->app->DB->SelectRow("SELECT projekt,holealle FROM shopexport WHERE id = '$id' LIMIT 1");
      $projekt = $shoparr['projekt'];//$this->app->DB->Select("SELECT projekt FROM shopexport WHERE id = '$id' LIMIT 1");
      $holealle = $shoparr['holealle'];//$this->app->DB->Select("SELECT holealle FROM shopexport WHERE id = '$id' LIMIT 1");
      if($holealle)
      {

        $res = $this->importSingleOrder($id, $nummer, $deleteauftrag, $projekt);
        if($res['status'] == 1){
          $this->app->Tpl->Add('MESSAGE','<div class="info">'.$res['info'].'</div>');
        } else {
          $this->app->Tpl->Add('MESSAGE','<div class="error">'.$res['error'].'</div>');
        }
      }else{
        $this->app->Tpl->Add('MESSAGE','<div class="error">Shop nicht auf alle Auftr&auml;ge eingstellt!</div>');
      }
    } elseif($id <= 0) {
      $msg = $this->app->erp->base64_url_encode('<div class="error">Kein Shop gew&auml;hlt!</div>');
      $this->app->Location->execute('index.php?module=shopimport&action=list&msg='.$msg);
    } else {
      $this->app->Tpl->Add('MESSAGE','<div class=\"error\">Keine Nummer angegeben!</div>');
    }
    $this->app->erp->MenuEintrag('index.php?module=shopimport&action=einzelimport&id='.$id,'Einzelimport');
    $this->app->erp->MenuEintrag('index.php?module=shopimport&action=import','Shopauftrag-Liste');
    $this->app->Tpl->Parse('PAGE','shopimport_einzelimport.tpl');
  }
  
  public function KundeAnlegenUpdate($shopimportid,$shopextid, $warenkorb, $kundennummer = 0, $import_kundennummer, &$unbekanntezahlungsweisen)
  {
    if(empty($warenkorb)) {
      return 0;
    }
    if(!empty($this->app->stringcleaner)){
      $this->app->stringcleaner->XMLArray_clean($warenkorb);
    }
    $i = 0;
    $sucess_import = 0;
    $shopid = $this->app->DB->Select("SELECT shopid FROM shopimport_auftraege WHERE id='$shopimportid' LIMIT 1");
    $shopexportArr = $this->app->DB->SelectRow(sprintf('SELECT * FROM shopexport WHERE id=%d', $shopid));
    $projekt = $shopexportArr['projekt'];//$this->app->DB->Select("SELECT projekt FROM shopexport WHERE id='$shopid'");
    if(!empty($warenkorb['projekt']) && $this->app->DB->Select("SELECT id FROM projekt WHERE id = '".(int)$warenkorb['projekt']."' LIMIT 1"))
    {
      $projekt = (int)$warenkorb['projekt'];
    }
    $adresseprojekt = '';
    $kundenurvonprojekt = $shopexportArr['kundenurvonprojekt'];//$this->app->DB->Select("SELECT kundenurvonprojekt FROM shopexport WHERE id = '".$shopid."' LIMIT 1");
    if($kundenurvonprojekt)
    {
      $adresseprojekt = $projekt;
    }

    if(isset($warenkorb['subshop']) && $warenkorb['subshop'])
    {
      $subshopprojekt = $this->app->DB->SelectArr("SELECT * FROM shopexport_subshop WHERE shop = '".$shopid."' AND aktiv = 1 AND subshopkennung = '".$this->app->DB->real_escape_string($warenkorb['subshop'])."' LIMIT 1");
      if($subshopprojekt)
      {
        if($subshopprojekt[0]['projekt'])
        {
          $adresseprojekt = $subshopprojekt[0]['projekt'];
          $projekt = $subshopprojekt[0]['projekt'];
          $arr[$i]['abkuerzung'] = $this->app->DB->Select("SELECT abkuerzung FROM projekt WHERE id = '$adresseprojekt' LIMIT 1");
        }
        if($subshopprojekt[0]['sprache'])
        {
          $defaultsprache = $this->app->DB->Select("SELECT sprache FROM shopexport_sprachen WHERE shop = '$shopid' AND (projekt = '$projekt' OR projekt = 0) AND 
          land = '' ORDER BY projekt = '$projekt' DESC, land = '".$warenkorb['land']."' DESC LIMIT 1");
          $checksprache = $this->app->DB->Select("SELECT sprache FROM shopexport_sprachen WHERE shop = '$shopid' AND (projekt = '$projekt' OR projekt = 0) AND 
          land = '".(isset($warenkorb['land'])?$warenkorb['land']:$this->app->erp->Firmendaten('land'))."' ORDER BY projekt = '$projekt' DESC, land = '".$warenkorb['land']."' DESC LIMIT 1");
          if($checksprache != ''){
            if(empty($warenkorb['kunde_sprache']))
            {
              $warenkorb['kunde_sprache'] = $checksprache;
            }
          }
          else{
            if(empty($warenkorb['kunde_sprache']))
            {
              $warenkorb['kunde_sprache'] = $defaultsprache;
            }
          }
          
          if(empty($warenkorb['kunde_sprache']))
          {
            $warenkorb['kunde_sprache'] = $subshopprojekt[0]['sprache'];
          }
        }
      }else{
        if(!$this->app->DB->Select("SELECT id FROM shopexport_subshop WHERE shop = '".$shopid."' AND subshopkennung = '".$this->app->DB->real_escape_string($warenkorb['subshop'])."' LIMIT 1"))
        {
          $this->app->DB->Insert("INSERT INTO shopexport_subshop (shop, subshopkennung, aktiv, projekt) VALUES ('".$shopid."','".$this->app->DB->real_escape_string($warenkorb['subshop'])."','0','$projekt')");
        }
      }
    }

    $kundenurvonprojekt = $this->app->DB->Select("SELECT kundenurvonprojekt FROM shopexport WHERE id = '$shopid' LIMIT 1");
    if($kundenurvonprojekt)
    {
      $adresseprojekt = " AND projekt = '".$adresseprojekt."' ";
    }else{
      $adresseprojekt = '';
    }

    if(empty($warenkorb['name'])){
      $warenkorb['name']=$warenkorb['ansprechpartner'];
      $warenkorb['ansprechpartner'] = '';
    }
    if(empty($warenkorb['name']) && !empty($warenkorb['lieferadresse_name'])) {
      $warenkorb['name'] = $warenkorb['lieferadresse_name'];
    }
    if(empty($warenkorb['lieferadresse_name'])){
      $warenkorb['lieferadresse_name']=$warenkorb['lieferadresse_ansprechpartner'];
      $warenkorb['lieferadresse_ansprechpartner'] = '';
    }
    $warenkorb['email'] = trim($warenkorb['email']," \t\n\r\0\x0B\xc2\xa0");
    if(empty($warenkorb['name'])) {
      return 0;
    }
    //$projekt = $arr[0][projekt];

      if($kundennummer=='1')
      {
        $warenkorb['kundennummer']= $import_kundennummer;
        if(strlen($warenkorb['kundennummer'])!=''){
          $adresse = $this->app->DB->Select("SELECT id FROM adresse WHERE kundennummer='{$warenkorb['kundennummer']}' AND geloescht!=1 $adresseprojekt LIMIT 1");
        }
        if($adresse<=0) {
          $adresse = $this->app->erp->KundeAnlegen($warenkorb['anrede'],$warenkorb['name'],$warenkorb['abteilung'],
          $warenkorb['unterabteilung'],$warenkorb['ansprechpartner'],$warenkorb['adresszusatz'],$warenkorb['strasse'],$warenkorb['land'],$warenkorb['plz'],$warenkorb['ort'],$warenkorb['email'],
          $warenkorb['telefon'],$warenkorb['telefax'],$warenkorb['ustid'],$warenkorb['affiliate_ref'],$projekt);
          $warenkorb['customer_created'] = true;
          if(isset($warenkorb['kunde_sprache']))
          {
            if($warenkorb['kunde_sprache'] == 'englisch' || $warenkorb['kunde_sprache'] == 'english')
            {
              $this->app->DB->Update("UPDATE adresse SET sprache = 'englisch' WHERE id = '$adresse' LIMIT 1");
            }elseif($warenkorb['kunde_sprache'] == 'deutsch' || $warenkorb['kunde_sprache'] == 'german')
            {
              $this->app->DB->Update("UPDATE adresse SET sprache = 'deutsch' WHERE id = '$adresse' LIMIT 1");
            }elseif(method_exists($this->app->erp, 'GetSprachenSelect')){
              $sprachen = $this->app->erp->GetSprachenSelect;
              if(isset($sprachen[strtolower($warenkorb['kunde_sprache'])]))
              {
                $this->app->DB->Update("UPDATE adresse SET sprache = '".strtolower($warenkorb['kunde_sprache'])."' WHERE id = '$adresse' LIMIT 1");
              }
            }
          }
          if($warenkorb['titel'] != ''){
            $this->app->DB->Update("UPDATE adresse SET titel = '".$this->app->DB->real_escape_string($warenkorb['titel'])."' WHERE id = '$adresse' LIMIT 1");
          }
          if(isset($warenkorb['ust_befreit']))
          {
            $this->app->DB->Update("UPDATE adresse SET ust_befreit = '".(int)$warenkorb['ust_befreit']."' WHERE id = '$adresse' LIMIT 1");
          }

          $kundenGruppen = $this->app->DB->SelectArr("SELECT gruppeid,type FROM shopexport_kundengruppen WHERE shopid=$shopid AND aktiv=1 AND apply_to_new_customers=1 AND type<>'Artikel' AND (projekt=0 OR projekt='$projekt')");
          if(!empty($kundenGruppen)){
            foreach ($kundenGruppen as $gruppe){
              $this->app->erp->AddRolleZuAdresse($adresse, $gruppe['type'], 'von', 'Gruppe', $gruppe['gruppeid']);
            }
          }

          if(isset($warenkorb['kundengruppe'])){
            $this->shopimportAdresseGruppenMapping($warenkorb['kundengruppe'],$adresse,$shopid,$projekt);
          }
          if($shopexportArr['vertrieb']) {
            $this->app->DB->Update(
              sprintf(
                'UPDATE adresse SET vertrieb = %d WHERE id = %d',
                $shopexportArr['vertrieb'], $adresse
              )
            );
          }
          $this->app->DB->Update(
            sprintf(
              'UPDATE adresse SET fromshop = %d WHERE fromshop = 0 AND id = %d',
              $shopexportArr['id'], $adresse
            )
          );
        }
        else {
          if(!empty($warenkorb['anrede']))
          {
            $typ = $warenkorb['anrede'];
          }else{
            $typ = $this->app->DB->Select("SELECT typ FROM adresse WHERE id = '$adresse' LIMIT 1");
          }
          $name= $warenkorb['name'];
          
          if(!empty($warenkorb['abteilung']))
          {
            $abteilung = $warenkorb['abteilung'];
          }else{
            $abteilung = $this->app->DB->Select("SELECT abteilung FROM adresse WHERE id = '$adresse' LIMIT 1");
          }
          if(!empty($warenkorb['unterabteilung']))
          {
            $unterabteilung = $warenkorb['unterabteilung'];
          }else{
            $unterabteilung = $this->app->DB->Select("SELECT unterabteilung FROM adresse WHERE id = '$adresse' LIMIT 1");
          }
          
          $ansprechpartner = $warenkorb['ansprechpartner'];
          $adresszusatz = $warenkorb['adresszusatz'];
          $strasse = $warenkorb['strasse'];
          $land = $warenkorb['land'];
          $plz = $warenkorb['plz'];
          $ort = $warenkorb['ort'];
          if(!empty($warenkorb['email']))
          {
            $email = $warenkorb['email'];
          }else{
            $email = $this->app->DB->Select("SELECT email FROM adresse WHERE id = '$adresse' LIMIT 1");
          }
          if(!empty($warenkorb['telefon']))
          {
            $telefon = $warenkorb['telefon'];
          }else{
            $telefon = $this->app->DB->Select("SELECT telefon FROM adresse WHERE id = '$adresse' LIMIT 1");
          }
          if(!empty($warenkorb['telefax']))
          {
            $telefax = $warenkorb['telefax'];
          }else{
            $telefax = $this->app->DB->Select("SELECT telefax FROM adresse WHERE id = '$adresse' LIMIT 1");
          }          
          if(!empty($warenkorb['ustid']))
          {
            $ustid = $warenkorb['ustid'];
          }else{
            $ustid = $this->app->DB->Select("SELECT ustid FROM adresse WHERE id = '$adresse' LIMIT 1");
          }          
          if(!empty($warenkorb['affiliate_ref']))
          {
            $partner = $warenkorb['affiliate_ref'];
          }else{
            $partner = $this->app->DB->Select("SELECT partner FROM adresse WHERE id = '$adresse' LIMIT 1");
          }
          // Update + protokoll
          if(!$this->app->DB->Select("SELECT adressennichtueberschreiben FROM shopexport WHERE id = '$shopid' LIMIT 1"))
          {
            if($warenkorb['mobil'] != ''){
              $this->app->DB->Update("UPDATE adresse SET mobil = '".$this->app->DB->real_escape_string($warenkorb['mobil'])."' WHERE id = '$adresse' LIMIT 1");
            }
            if($warenkorb['titel'] != ''){
              $this->app->DB->Update("UPDATE adresse SET titel = '".$this->app->DB->real_escape_string($warenkorb['titel'])."' WHERE id = '$adresse' LIMIT 1");
            }
            if($warenkorb['geburtstag'] != ''){
              $this->app->DB->Update("UPDATE adresse SET geburtstag = '".$this->app->DB->real_escape_string($warenkorb['geburtstag'])."' WHERE id = '$adresse' AND ISNULL(geburtstag) LIMIT 1");
            }
            if(isset($warenkorb['ust_befreit'])){
              $query = sprintf('UPDATE `adresse` SET `ust_befreit` = %d WHERE `id` = %d LIMIT 1',
                  $warenkorb['ust_befreit'], $adresse);
              $this->app->DB->Update($query);
            }
            $this->app->erp->KundeUpdate($adresse,$typ,$name,$abteilung,
                $unterabteilung,$ansprechpartner,$adresszusatz,$strasse,$land,$plz,$ort,$email,$telefon,$telefax,$ustid,$partner,$projekt);
                
            if(!empty($warenkorb['bundesland']))
            {
              $this->app->DB->Update("UPDATE adresse SET bundesland = '".$this->app->DB->real_escape_string($warenkorb['bundesland'])."' WHERE id = '$adresse' LIMIT 1");
            }
          }
        }
      } 
      else {
        //echo "import als Neu-Kunde $shopimportid<br>";
        $typ = $warenkorb['anrede'];
        $name= $warenkorb['name'];
        $abteilung = $warenkorb['abteilung'];
        $unterabteilung = $warenkorb['unterabteilung'];
        $ansprechpartner = $warenkorb['ansprechpartner'];
        $adresszusatz = $warenkorb['adresszusatz'];
        $strasse = $warenkorb['strasse'];
        $land = $warenkorb['land'];
        $plz = $warenkorb['plz'];
        $ort = $warenkorb['ort'];
        $email = $warenkorb['email'];
        $telefon = $warenkorb['telefon'];
        $telefax = $warenkorb['telefax'];
        $ustid = $warenkorb['ustid'];
        $partner = $warenkorb['affiliate_ref'];
       
        // denn fall das es kunde 1:1 schon gibt = alte Kundennummer verwenden kommt vor allem vor, wenn ein Kunde an einem Tag oefters bestellt hat
        //								$adresse = $this->app->erp->KundeAnlegen($typ,$name,$abteilung,
        //								$unterabteilung,$ansprechpartner,$adresszusatz,$strasse,$land,$plz,$ort,$email,$telefon,$telefax,$ustid,$partner,$projekt);
        if(strlen($warenkorb['kundennummer'])!=''){
          $adresse = $this->app->DB->Select("SELECT id FROM adresse WHERE kundennummer='{$warenkorb['kundennummer']}' $adresseprojekt AND geloescht!=1 LIMIT 1");
        }

        if(empty($adresse)){
          $adresse = $this->app->DB->Select("SELECT id FROM adresse WHERE email='{$warenkorb['email']}' and email <> '' $adresseprojekt AND geloescht!=1 LIMIT 1");
        }

        if($adresse<=0) {
          $adresse = $this->app->erp->KundeAnlegen($typ,$name,$abteilung,
              $unterabteilung,$ansprechpartner,$adresszusatz,$strasse,$land,$plz,$ort,$email,$telefon,$telefax,$ustid,$partner,$projekt);
          $warenkorb['customer_created'] = true;
          if(!empty($warenkorb['bundesland']))
          {
            $this->app->DB->Update("UPDATE adresse SET bundesland = '".$this->app->DB->real_escape_string($warenkorb['bundesland'])."' WHERE id = '$adresse' LIMIT 1");
          }

          if(isset($warenkorb['kunde_sprache']))
          {
            if($warenkorb['kunde_sprache'] === 'englisch' || $warenkorb['kunde_sprache'] === 'english')
            {
              $this->app->DB->Update("UPDATE adresse SET sprache = 'englisch' WHERE id = '$adresse' LIMIT 1");
            }elseif($warenkorb['kunde_sprache'] === 'deutsch' || $warenkorb['kunde_sprache'] === 'german')
            {
              $this->app->DB->Update("UPDATE adresse SET sprache = 'deutsch' WHERE id = '$adresse' LIMIT 1");
            }elseif(method_exists($this->app->erp, 'GetAdressSprachen')){
              $sprachen = $this->app->erp->GetAdressSprachen();
              if(isset($sprachen[strtolower($warenkorb['kunde_sprache'])]))
              {
                $this->app->DB->Update("UPDATE adresse SET sprache = '".strtolower($warenkorb['kunde_sprache'])."' WHERE id = '$adresse' LIMIT 1");
              }
            }
          }
          if($warenkorb['titel'] != ''){
            $this->app->DB->Update("UPDATE adresse SET titel = '".$this->app->DB->real_escape_string($warenkorb['titel'])."' WHERE id = '$adresse' LIMIT 1");
          }
          if(isset($warenkorb['ust_befreit']))
          {
            $this->app->DB->Update("UPDATE adresse SET ust_befreit = '".(int)$warenkorb['ust_befreit']."' WHERE id = '$adresse' LIMIT 1");
          }
          if($warenkorb['mobil'] != ''){
            $this->app->DB->Update("UPDATE adresse SET mobil = '".$this->app->DB->real_escape_string($warenkorb['mobil'])."' WHERE id = '$adresse' LIMIT 1");
          }
          if(!empty($warenkorb['geburtstag'])){
            $query = sprintf("UPDATE `adresse` SET `geburtstag` = '%s' WHERE `id` = %d",
                $this->app->DB->real_escape_string($warenkorb['geburtstag']),
                $adresse);
            $this->app->DB->Update($query);
          }
          $kundenGruppen = $this->app->DB->SelectArr("SELECT gruppeid,type FROM shopexport_kundengruppen WHERE shopid=$shopid AND aktiv=1 AND apply_to_new_customers=1 AND (projekt=0 OR projekt='$projekt')");
          if(!empty($kundenGruppen)){
            foreach ($kundenGruppen as $gruppe){
              $this->app->erp->AddRolleZuAdresse($adresse, $gruppe['type'], 'von', 'Gruppe', $gruppe['gruppeid']);
            }
          }

          if(isset($warenkorb['kundengruppe'])){
            $this->shopimportAdresseGruppenMapping($warenkorb['kundengruppe'],$adresse,$shopid,$projekt);
          }
          if($shopexportArr['vertrieb']) {
            $this->app->DB->Update(
              sprintf(
                'UPDATE adresse SET vertrieb = %d WHERE id = %d AND geloescht <> 1 AND vertrieb = 0',
                $shopexportArr['vertrieb'], $adresse
              )
            );
          }
          $this->app->DB->Update(
            sprintf(
              'UPDATE adresse SET fromshop = %d WHERE fromshop = 0 AND id = %d',
              $shopexportArr['id'], $adresse
            )
          );
        } else {
          // Update + protokoll
          if(!$this->app->DB->Select("SELECT adressennichtueberschreiben FROM shopexport WHERE id = '$shopid' LIMIT 1"))
          {
            $this->app->erp->KundeUpdate($adresse,$typ,$name,$abteilung,
                $unterabteilung,$ansprechpartner,$adresszusatz,$strasse,$land,$plz,$ort,$email,$telefon,$telefax,$ustid,$partner,$projekt);
            if(!empty($warenkorb['bundesland']))
            {
              $this->app->DB->Update("UPDATE adresse SET bundesland = '".$this->app->DB->real_escape_string($warenkorb['bundesland'])."' WHERE id = '$adresse' LIMIT 1");
            }
          }
        }
        // abweichende lieferadresse gleich angelegen?
        if(strlen($warenkorb['lieferadresse_ansprechpartner'])>3)
        {
          $this->app->DB->Insert("INSERT INTO lieferadressen (typ,name,abteilung,unterabteilung,land,strasse,ort,plz,adresszusatz,adresse) VALUES
              ('','{$warenkorb['lieferadresse_ansprechpartner']}',
               '{$warenkorb['lieferadresse_abteilung']}','{$warenkorb['lieferadresse_unterabteilung']}','{$warenkorb['lieferadresse_land']}',
               '{$warenkorb['lieferadresse_strasse']}','{$warenkorb['lieferadresse_ort']}','{$warenkorb['lieferadresse_plz']}','{$warenkorb['lieferadresse_adresszusatz']}','$adresse')");
        }

        if(strlen($warenkorb['lieferadresse_name'])>3 && $warenkorb['lieferadresse_ansprechpartner']=='')
        {
          $this->app->DB->Insert("INSERT INTO lieferadressen (typ,name,abteilung,unterabteilung,land,strasse,ort,plz,adresszusatz,adresse) VALUES
              ('','{$warenkorb['lieferadresse_name']}',
               '{$warenkorb['lieferadresse_abteilung']}','{$warenkorb['lieferadresse_unterabteilung']}','{$warenkorb['lieferadresse_land']}',
               '{$warenkorb['lieferadresse_strasse']}','{$warenkorb['lieferadresse_ort']}','{$warenkorb['lieferadresse_plz']}','{$warenkorb['lieferadresse_adresszusatz']}','$adresse')");
        }
      } 

      //print_r($warenkorb);
      //echo "<br><br>Ende";
      //exit;
      //imort auf kunde 
      //$bekanntezahlungsweisen = array('rechnung','vorkasse','nachnahme','kreditkarte','einzugsermaechtigung','bar','paypal','amazon','amazon_bestellung','sofortueberweisung','amazoncba','secupay','lastschrift');

      $bekanntezahlungsweisen = $this->app->erp->GetZahlungsweise();

      $tmpauftragid = $this->app->erp->ImportAuftrag($adresse,$warenkorb,$projekt,$shopid);
      $doctype = 'auftrag';
      if($this->app->DB->Select("SELECT angeboteanlegen FROM shopexport WHERE id = '$shopid' LIMIT 1"))
      {
        $doctype = 'angebot';
      }

      if(isset($warenkorb['doctype']) && $warenkorb['doctype']==='angebot'){
        $doctype = 'angebot';
      }

      $warenkorb['zahlungsweise'] = $this->app->DB->Select("SELECT zahlungsweise FROM $doctype WHERE id = '$tmpauftragid' LIMIT 1");
      if($warenkorb['zahlungsweise'] != ''){
        if(!isset($bekanntezahlungsweisen[$warenkorb['zahlungsweise']])){
          if(!$unbekanntezahlungsweisen || !isset($unbekanntezahlungsweisen[strtolower($warenkorb['zahlungsweise'])])){
            $unbekanntezahlungsweisen[strtolower($warenkorb['zahlungsweise'])] = false;
          }
          $tmp = array();
          $tmp['bestellnummer'] = $warenkorb['onlinebestellnummer'];
          $unbekanntezahlungsweisen[strtolower($warenkorb['zahlungsweise'])][] = $tmp;
        }
      }
      
      if($shopimportid)
      {
        $this->app->DB->Update("UPDATE shopimport_auftraege SET imported='1' WHERE id='$shopimportid' LIMIT 1");
      }
      if($shopimportid)
      {
        $shopextid = $this->app->DB->real_escape_string($this->app->DB->Select("SELECT extid FROM shopimport_auftraege WHERE id='$shopimportid' LIMIT 1"));
      }
      if($shopextid)
      {
        $this->app->DB->Select("UPDATE $doctype SET shopextid='$shopextid' WHERE id='$tmpauftragid' LIMIT 1");
      }
      $this->app->erp->RunHook('Shopimportwarenkorb', 4, $doctype, $tmpauftragid, $shopid, $warenkorb);
      $this->app->erp->RunHook('Shopimport', 3, $doctype, $tmpauftragid, $shopid);


      $adresse ='';
      $sucess_import++;

    return $sucess_import;
  }

  /**
   * @param String $gruppenBezeichnung im Shop
   * @param int $adresseId
   * @param int $shopId
   * @param int $projektId
   *
   * @return string
   */
  private function shopimportAdresseGruppenMapping($gruppenBezeichnung, $adresseId,  $shopId, $projektId){
    $kundenGruppen = $this->getShopimportKundenGruppenZuordnungen($gruppenBezeichnung, $shopId, $projektId);
    if(empty($kundenGruppen)) {
      return '';
    }
    foreach ($kundenGruppen as $gruppe => $rolle){
      $this->app->erp->AddRolleZuAdresse($adresseId, $rolle, 'von', 'Gruppe', $gruppe);
    }

    return '';
  }

  /**
   * @param String $gruppenBezeichnung im Shop
   * @param int $shopId
   * @param int $projektId
   *
   * @return array
   */
  private function getShopimportKundenGruppenZuordnungen($gruppenBezeichnung, $shopId, $projektId){
    $gefundeneGruppen = $this->app->DB->SelectArr("SELECT gruppeid, type FROM shopexport_kundengruppen WHERE shopid='$shopId' AND extgruppename='$gruppenBezeichnung' AND projekt='$projektId'");

    if(empty($gefundeneGruppen)){
      //Fallback, falls kein projektspezifisches Mapping gefunden
      $gefundeneGruppen = $this->app->DB->SelectArr("SELECT gruppeid, type FROM shopexport_kundengruppen WHERE shopid='$shopId' AND extgruppename='$gruppenBezeichnung' AND projekt='0'");
    }

    if(empty($gefundeneGruppen)) {
      return [];
    }

    $kundenGruppen = [];
    foreach ($gefundeneGruppen as $gruppe){
      $kundenGruppen[$gruppe['gruppeid']] = $gruppe['type'];
    }

    return $kundenGruppen;
  }

  /**
   * @param $shopImportedOrderId
   *
   * @return bool
   */
  public function setShopImportedOrderTrash($shopImportedOrderId) {
    $this->app->DB->Update(
      sprintf(
      'UPDATE shopimport_auftraege SET trash=1 WHERE id= %d LIMIT 1',
        (int)$shopImportedOrderId
      )
    );
    return $this->app->DB->affected_rows() > 0;
  }

  public function importShopOrder($shopImportedOrderId, $utf8coding, $customerNumber, $custumerNumberImported, &$unknownPaymentTypes) {
    $shopImportedOrder = $this->app->DB->SelectRow(
      sprintf(
        'SELECT * FROM shopimport_auftraege WHERE imported=0 AND trash=0 AND id=%d LIMIT 1',
        $shopImportedOrderId
      )
    );
    if(empty($shopImportedOrder)) {
      return ['success' => 0];
    }

    if(isset($shopImportedOrder['jsonencoded']) && $shopImportedOrder['jsonencoded'])
    {
      $shopOrder = json_decode(base64_decode($shopImportedOrder['warenkorb']), true);
    }else{
      $shopOrder = unserialize(base64_decode($shopImportedOrder['warenkorb']));
    }

    //alle leerzeichen am amfang und ende entfernen + umbrueche komplett entfernen
    if($utf8coding=='1')
    {
      $shopOrderCleaned = $this->app->erp->CleanDataBeforImportUTF8($shopOrder, false);
    } else {
      $shopOrderCleaned = $this->app->erp->CleanDataBeforImport($shopOrder, false);
    }
    if($shopOrderCleaned['name']===''){
      $shopOrderCleaned['name']=$shopOrderCleaned['ansprechpartner'];
      $shopOrderCleaned['ansprechpartner'] = '';
    }
    if($shopOrderCleaned['lieferadresse_name']==='')
    {
      $shopOrderCleaned['lieferadresse_name']=$shopOrderCleaned['lieferadresse_ansprechpartner'];
      $shopOrderCleaned['lieferadresse_ansprechpartner'] = '';
    }

    if($shopOrderCleaned['name']==='' && !empty($shopOrderCleaned['lieferadresse_name']))
    {
      $shopOrderCleaned['name'] = $shopOrderCleaned['lieferadresse_name'];
    }

    foreach($shopOrderCleaned as $k => $v)
    {
      if(!is_array($v)){
        $shopOrderCleaned[$k] = $this->app->erp->fixeUmlaute($v);
      }
    }
    $umlautefehler = false;
    if((String)$shopOrder['name'] !== '' && (String)$shopOrderCleaned['name'] === '')
    {
      $umlautefehler = true;
      $this->app->erp->LogFile('Kodierungsfehler in shopimport_auftraege '.$shopImportedOrderId);
    }
    $succes = $this->KundeAnlegenUpdate($shopImportedOrderId,'', $shopOrderCleaned, $customerNumber, $custumerNumberImported,$unknownPaymentTypes);

    return ['codingerror'=>$umlautefehler, 'success' => $succes];
  }

  public function ShopimportImport($id='', $count = 0, $returncount = false, $showonly = false)
  {
    $deletedRows = 0;
    if(!is_numeric($id) && $this->app->Secure->GetPOST('deletedouble')) {
      $id = (int)$this->app->Secure->GetGET('id');
      $this->app->DB->Update(
        sprintf(
          'UPDATE shopimport_auftraege AS sa 
          INNER JOIN auftrag a ON sa.bestellnummer = a.internet AND sa.shopid = a.shop 
          SET sa.trash = 1 
          WHERE IFNULL(a.internet,\'\') <> \'\' AND sa.trash = 0 AND sa.imported = 0 AND 
                (sa.shopid = %d OR %d = 0)',
          $id, $id
        )
      );
      $deletedRows = (int)$this->app->DB->affected_rows();
      $this->app->Tpl->Add('IMPORT','<div class="info">Es wurden '.$deletedRows.' bereits importierte Datens&auml;tze entfernt.</div>');
    }
    $runningcronjob = $this->app->DB->Select("SELECT id FROM prozessstarter WHERE parameter = 'shopimport' AND aktiv=1 AND mutex = 1 AND UNIX_TIMESTAMP(now()) - UNIX_TIMESTAMP(letzteausfuerhung) < 300 LIMIT 1");
    if($runningcronjob && !$showonly)
    {
      $this->app->Location->execute('index.php?module=shopimport&action=list');
    }
    if(!is_numeric($id)){
      $id = $this->app->Secure->GetGET('id');
    }

    $shopexportarr = $this->app->DB->SelectRow("SELECT * FROM shopexport WHERE id='$id'");
    $projekt = $shopexportarr['projekt'];//$this->app->DB->Select("SELECT projekt FROM shopexport WHERE id='$id'");
    $demomodus = $shopexportarr['demomodus'];//$this->app->DB->Select("SELECT demomodus FROM shopexport WHERE id='$id'");
    $einzelsync = $shopexportarr['einzelsync'];//$this->app->DB->Select("SELECT einzelsync FROM shopexport WHERE id='$id'");
    $utf8codierung = $shopexportarr['utf8codierung'];//$this->app->DB->Select("SELECT utf8codierung FROM shopexport WHERE id='$id'");

    if(!$returncount)
    {
      $this->app->erp->Headlines('Shopimport');
      $this->app->erp->MenuEintrag('index.php?module=shopimport&action=list','Zur&uuml;ck zur &Uuml;bersicht');
    }
    //name, strasse, ort, plz und kundenummer, emailadresse  oder bestellung kam von login account ==> Kunde aus DB verwenden
    //ACHTUNG Lieferadresse immer aus Auftrag!!! aber Lieferadresse extra bei Kunden anlegen 
    if($this->app->Secure->GetPOST('submit')!='')
    {
      $auftraege = $this->app->Secure->GetPOST('auftrag');
      $kundennummer = $this->app->Secure->GetPOST('kundennummer');
      $import= $this->app->Secure->GetPOST('import');
      $import_kundennummer= $this->app->Secure->GetPOST('import_kundennummer');

      $sucess_import = 0;
      $insgs_import = 0;
      $unbekanntezahlungsweisen = null;
      $cauftraege = $auftraege?count($auftraege):0;
      for($i=0;$i<$cauftraege;$i++)
      {
        $adresse = '';
        $shopimportid =  $auftraege[$i];
        $shopid = $this->app->DB->Select("SELECT shopid FROM shopimport_auftraege WHERE id='$shopimportid' LIMIT 1");
        if($shopid)
        {
          $demomodus = $this->app->DB->Select("SELECT demomodus FROM shopexport WHERE id='$shopid'");
          $einzelsync = $this->app->DB->Select("SELECT einzelsync FROM shopexport WHERE id='$shopid'");
          $utf8codierung = $this->app->DB->Select("SELECT utf8codierung FROM shopexport WHERE id='$shopid'");          
        }
        $projekt = $this->app->DB->Select("SELECT projekt FROM shopimport_auftraege WHERE id='$shopimportid' LIMIT 1");
        if($import[$shopimportid]==='warten')
        {

        }
        else if($import[$shopimportid]==='muell')
        {
          $this->setShopImportedOrderTrash($shopimportid);
        } else if($import[$shopimportid]==='import') {

          $res = $this->importShopOrder($shopimportid, $utf8codierung, $kundennummer[$shopimportid], $import_kundennummer[$shopimportid], $unbekanntezahlungsweisen);
          if($res['codingerror']) {
            $umlautefehler = true;
          }
          if($res['success']) {
            $sucess_import += $res['success'];
          }
          $insgs_import++;
        }
      } // ende for
      
      
      if($unbekanntezahlungsweisen)
      {
        $meldung = '';
        foreach($unbekanntezahlungsweisen as $k => $v)
        {
          $meldung .= 'Unbekannte Zahlungsart: '.$k.' in Bestellung(en): ';
          $first = true;
          foreach($v as $k2 => $v2)
          {
            if(!$first)
            {
              $meldung .= ', ';
            }
            $first = false;
            $meldung .= $v2['bestellnummer'];
            
          }
          $meldung .= "<br />\r\n";
          
        }
        
        if(isset($this->app->User) && method_exists($this->app->User,'GetID') && $this->app->User->GetID())
        {
          $this->app->erp->EventMitSystemLog($this->app->User->GetID(), $meldung, -1,'', 'warning', 1);
        }
      }
      if(!empty($umlautefehler))
      {
        $msg = $this->app->erp->base64_url_encode("<div style=\"color:red\">$sucess_import".($sucess_import != $insgs_import?" von $insgs_import ":'')." Auftr&auml;ge importiert. Auftr&auml;ge mit Kodierungsprobleme. Bitte pr&uuml;fen Sie sie UTF8-Einstellung in der Shopschnittstelle!</div>");
      }else{
        $msg = $this->app->erp->base64_url_encode("<div style=\"color:green\">$sucess_import".($sucess_import != $insgs_import?" von $insgs_import ":'')." Auftr&auml;ge importiert!</div>");
      }
      $this->app->Location->execute('index.php?module=shopimport&action=list&msg='.$msg);
    }


    if(!$showonly && $id)
    {
      try {
        $pageContents = $this->app->remote->RemoteConnection($id);
      }catch(Exception $e){
        $pageContents = $e->getMessage();
      }
      if($pageContents==='success')
      {
        $shopexportarr = $this->app->DB->SelectRow("SELECT * FROM shopexport WHERE id = '$id' LIMIT 1");
        $holealle = $shopexportarr['holealle'];//$this->app->DB->Select("SELECT holealle FROM shopexport WHERE id = '$id' LIMIT 1");
        $statusaendern = $shopexportarr['nummersyncstatusaendern'];//$this->app->DB->Select("SELECT nummersyncstatusaendern FROM shopexport WHERE id = '$id' LIMIT 1");
        $auftragabgleich = $shopexportarr['auftragabgleich'];//$this->app->DB->Select("SELECT auftragabgleich FROM shopexport WHERE id = '$id' LIMIT 1");
        $zeitraum = array('datumvon'=>$shopexportarr['datumvon'], 'datumbis'=>$shopexportarr['datumbis'],'tmpdatumvon'=>$shopexportarr['tmpdatumvon'], 'tmpdatumbis'=>$shopexportarr['tmpdatumbis'], 'anzgleichzeitig'=>$shopexportarr['anzgleichzeitig']);
        //$this->app->DB->SelectArr("SELECT datumvon, datumbis,tmpdatumvon, tmpdatumbis, anzgleichzeitig FROM shopexport WHERE id = '$id' LIMIT 1");
        /*if(!empty($zeitraum))
        {
          $zeitraum = reset($zeitraum);
        }*/
        $anzgleichzeitig = 1;
        if(isset($zeitraum['anzgleichzeitig'])){
          $anzgleichzeitig = (int)$zeitraum['anzgleichzeitig'];
        }
        
        if($anzgleichzeitig > 1)
        {
          $result = $this->app->remote->RemoteGetAuftrag($id);
          if(!empty($result) && is_array($result) && isset($result[0]))
          {
            $maxtime = false;
            $mintime = false;
            $gesamtanzahl = (!empty($result)?count($result):0);
            for($i = 0; $i < $gesamtanzahl; $i++)
            {
              $projekt = $this->app->DB->Select("SELECT projekt FROM shopexport WHERE id = '$id' LIMIT 1");
              $auftrag = $result[$i]['id'];
              if(isset($result[$i]['warenkorbjson']))
              {
                $isjson = true;
                $tmpwarenkorb = json_decode(base64_decode($result[$i]['warenkorbjson']), true);
              }else{
                $isjson = false;
                $tmpwarenkorb = unserialize(base64_decode($result[$i]['warenkorb']));
              }
              if(!empty($tmpwarenkorb['projekt']) && $this->app->DB->Select("SELECT id FROM projekt WHERE id = '".(int)$tmpwarenkorb['projekt']."' LIMIT 1"))
              {
                $projekt = (int)$tmpwarenkorb['projekt'];
              }
              if(!empty($tmpwarenkorb['zeitstempel']))
              {
                $time = strtotime($tmpwarenkorb['zeitstempel']);
                if($time < 0)
                {
                  $time = 0;
                }
                if($maxtime === false)
                {
                  $maxtime = $time;
                }
                if($mintime === false)
                {
                  $mintime = $time;
                }
                if($time > $maxtime)
                {
                  $maxtime = $time;
                }
                if($time < $mintime)
                {
                  $mintime = $time;
                }
              }
              $onlinebestellnummer = $tmpwarenkorb['onlinebestellnummer'];
              if(!empty($tmpwarenkorb['useorderid']) ||
                (!is_numeric($onlinebestellnummer) && trim((String)$onlinebestellnummer) !== ''))
              {
                $onlinebestellnummer = $tmpwarenkorb['auftrag'];
              }

              if($holealle && $onlinebestellnummer)
              {
                $neue_nummer = (int)$onlinebestellnummer+1;
                $this->app->DB->Update("UPDATE shopexport SET ab_nummer = '$neue_nummer' WHERE id = '$id'");
              }
              $sessionid = isset($result[$i]['sessionid'])?$result[$i]['sessionid']:'';
              if($isjson)
              {
                $warenkorb = $result[$i]['warenkorbjson'];
              }else{
                $warenkorb = $result[$i]['warenkorb'];
              }
              $logdatei = isset($result[$i]['logdatei'])?$result[$i]['logdatei']:null;
              if(empty($logdatei))
              {
                $logdatei = date('Y-m-d H:i:s');
              }
              if(isset($tmpwarenkorb['subshop']) && $tmpwarenkorb['subshop'])
              {
                $subshopprojekt = $this->app->DB->Select("SELECT projekt FROM shopexport_subshop WHERE shop = '$id' AND aktiv = 1 AND subshopkennung = '".$this->app->DB->real_escape_string($tmpwarenkorb['subshop'])."' LIMIT 1");
                if($subshopprojekt)
                {
                  $projekt = $subshopprojekt;
                }
              }
              $letzteonlinebestellnummer = $tmpwarenkorb['onlinebestellnummer'];
              unset($tmpwarenkorb);
              
              //globalerauftragsnummernkreis
              $standardcheck = true;
              $modulename = $this->app->DB->Select(
                sprintf(
                  "SELECT modulename FROM shopexport WHERE id = %d AND modulename <> '' AND (shoptyp = 'intern')",
                  $id
                )
              );
              $shopIds = [$id];
              $otherModules= empty($modulename)?null:
                $this->app->DB->SelectFirstCols(
                  sprintf(
                    "SELECT id 
                  FROM shopexport 
                  WHERE modulename = '%s' AND id <> %d",
                    $this->app->DB->real_escape_string($modulename), $id
                  )
                );
              if(!empty($otherModules) && $this->app->erp->ModulVorhanden($modulename)) {
                $obj = $this->app->erp->LoadModul($modulename);
                if(!empty($obj) && method_exists($obj, 'EinstellungenStruktur')){
                  $konfiguration = $obj->EinstellungenStruktur();
                  if($konfiguration && isset($konfiguration['globalerauftragsnummernkreis']) && $konfiguration['globalerauftragsnummernkreis']) {
                    $shopIds = array_merge([$id], $otherModules);
                    $standardcheck = false;
                    /*$checkdoppeltimported = $this->app->DB->Select("SELECT id FROM shopimport_auftraege WHERE extid = '".$this->app->DB->real_escape_string($auftrag)."' and ((modulename = '".$this->app->DB->real_escape_string($modulename)."' AND shoptyp = 'intern') OR shopid = '$id') and warenkorb = '".$this->app->DB->real_escape_string($warenkorb)."' AND trash = 0
                                  AND (imported = 0 OR (imported = 1 AND DATE_SUB(NOW(),INTERVAL 10 MINUTE)>logdatei ))
                                  LIMIT 1");*/
                    /*$checkdoppeltimported = $this->app->DB->Select("SELECT id FROM shopimport_auftraege WHERE extid = '".$this->app->DB->real_escape_string($auftrag)."' and ((modulename = '".$this->app->DB->real_escape_string($modulename)."' AND shoptyp = 'intern') OR shopid = '$id') AND trash = 0
                                  AND (imported = 0 OR (imported = 1 AND DATE_SUB(NOW(),INTERVAL 10 MINUTE)>logdatei ))
                                  LIMIT 1");*/
                  }
                }
              }
              $checkdoppeltimported = $this->app->DB->Select(
                sprintf(
                  "SELECT id 
                  FROM shopimport_auftraege 
                  WHERE extid = '%s' and shopid IN (%s) AND trash = 0
                  AND (imported = 0 OR (imported = 1 AND DATE_SUB(NOW(),INTERVAL 10 MINUTE)>logdatei ))
                  LIMIT 1",
                  $this->app->DB->real_escape_string($auftrag), implode(',', $shopIds)
                )
              );
              /*if($standardcheck)
              {*/
                /*$checkdoppeltimported = $this->app->DB->Select("SELECT id FROM shopimport_auftraege WHERE extid = '".$this->app->DB->real_escape_string($auftrag)."' and shopid = '$id' and warenkorb = '".$this->app->DB->real_escape_string($warenkorb)."' AND trash = 0
              AND (imported = 0 OR (imported = 1 AND DATE_SUB(NOW(),INTERVAL 10 MINUTE)>logdatei ))
              LIMIT 1");*/
                /*$checkdoppeltimported = $this->app->DB->Select("SELECT id FROM shopimport_auftraege WHERE extid = '".$this->app->DB->real_escape_string($auftrag)."' and shopid = '$id' AND trash = 0
              AND (imported = 0 OR (imported = 1 AND DATE_SUB(NOW(),INTERVAL 10 MINUTE)>logdatei ))
              LIMIT 1");
              }*/
              $insid = null;
              if(empty($checkdoppeltimported))
              {
                $this->app->DB->Insert("INSERT INTO shopimport_auftraege (id,extid,sessionid,warenkorb,imported,projekt,bearbeiter,logdatei) 
                    VALUES('','".$this->app->DB->real_escape_string($auftrag)."','".$this->app->DB->real_escape_string($sessionid)."','".$this->app->DB->real_escape_string($warenkorb)."','0','$projekt','".$this->app->DB->real_escape_string($this->app->User->GetName())."','".$this->app->DB->real_escape_string($logdatei)."')");
                $insid = $this->app->DB->GetInsertID();
                if($insid)
                {
                  if($isjson)
                  {
                    $this->app->DB->Update("UPDATE shopimport_auftraege set jsonencoded = 1 where id = '$insid'");
                  }
                  $this->app->DB->Update("UPDATE shopimport_auftraege set shopid = '$id' where id = '$insid'");
                  $this->app->DB->Update("UPDATE shopimport_auftraege set bestellnummer = '".$this->app->DB->real_escape_string($letzteonlinebestellnummer)."' where id = '$insid'");
                }
              }
              if($demomodus!='1')
              {
                $this->app->remote->RemoteDeleteAuftrag($id,$auftrag,$letzteonlinebestellnummer);
              }
              elseif($demomodus == '1')
              {
                break;
              }
              unset($letzteonlinebestellnummer);

            }
            if(!$demomodus)
            {
              if(empty($maxtime))
              {
                $maxtime = strtotime(date('Y-m-d H:i:s'));
              }
              $datumvon = strtotime($zeitraum['datumvon']);
              $datumbis = strtotime($zeitraum['datumbis']);
              $tmpdatumvon = strtotime($zeitraum['tmpdatumvon']);
              $tmpdatumbis = strtotime($zeitraum['tmpdatumbis']);
              if($datumvon < 0){
                $datumvon = 0;
              }
              if($datumbis < 0){
                $datumbis = 0;
              }
              if($tmpdatumvon < 0){
                $tmpdatumvon = 0;
              }
              if($tmpdatumbis < 0)
              {
                $tmpdatumbis = 0;
              }
              $this->app->DB->Update("UPDATE shopexport SET datumvon = '".date('Y-m-d H:i:s',$maxtime)."', tmpdatumbis = '0000-00-00' WHERE id = '$id' LIMIT 1");
            }
          }else{
            if(!$demomodus)
            {
              if(is_array($result) && !empty($result['zeitstempel']))
              {
                $this->app->DB->Update("UPDATE shopexport SET datumvon = '".date('Y-m-d H:i:s',strtotime($result['zeitstempel']))."', tmpdatumbis = '0000-00-00' WHERE id = '$id' AND datumvon < '".date('Y-m-d H:i:s',strtotime($result['zeitstempel']))."' LIMIT 1");
              }
              if(empty($maxtime))
              {
                $maxtime = strtotime(date('Y-m-d H:i:s'));
              }
              $datumvon = strtotime($zeitraum['datumvon']);
              $datumbis = strtotime($zeitraum['datumbis']);
              $tmpdatumvon = strtotime($zeitraum['tmpdatumvon']);
              $tmpdatumbis = strtotime($zeitraum['tmpdatumbis']);
              if($datumvon < 0){
                $datumvon = 0;
              }
              if($datumbis < 0){
                $datumbis = 0;
              }
              if($tmpdatumvon < 0){
                $tmpdatumvon = 0;
              }
              if($tmpdatumbis < 0){
                $tmpdatumbis = 0;
              }
              if($tmpdatumbis)
              {
                $this->app->DB->Update("UPDATE shopexport SET tmpdatumbis = '0000-00-00' WHERE id = '$id' LIMIT 1");
              }
            }
          }
        }else{
          $gesamtanzahl = $this->app->remote->RemoteGetAuftraegeAnzahl($id);
          $maxmanuell = (int)$this->app->DB->Select("SELECT maxmanuell FROM shopexport WHERE id = '$id' LIMIT 1");
          if($maxmanuell <= 0){
            $maxmanuell = 100;
          }
          if($gesamtanzahl > $maxmanuell){
            $gesamtanzahl = $maxmanuell;
          }
          if($einzelsync=='1' && $gesamtanzahl > 1 && $maxmanuell <= 1){
            $gesamtanzahl = 1;
          }
          if($gesamtanzahl > 0)
          {
            for($i=0;$i<$gesamtanzahl;$i++)
            {
              //import au
              $result = $this->app->remote->RemoteGetAuftrag($id);

              if(is_array($result))
              {
                $auftrag = $result[0]['id'];
                if(isset($result[0]['warenkorbjson']))
                {
                  $isjson = true;
                  $tmpwarenkorb = json_decode(base64_decode($result[0]['warenkorbjson']), true);
                }else{
                  $isjson = false;
                  $tmpwarenkorb = unserialize(base64_decode($result[0]['warenkorb']));
                }
                $onlinebestellnummer = $tmpwarenkorb['onlinebestellnummer'];
                if(!empty($tmpwarenkorb['useorderid']) || (!is_numeric($onlinebestellnummer) && trim((String)$onlinebestellnummer) !== ''))
                {
                  $onlinebestellnummer = $tmpwarenkorb['auftrag'];
                }
                if($holealle && $onlinebestellnummer)
                {
                  $neue_nummer = (int)$onlinebestellnummer+1;
                  $this->app->DB->Update("UPDATE shopexport SET ab_nummer = '$neue_nummer' WHERE id = '$id'");
                }
                $sessionid = $result[0]['sessionid'];
                if($isjson)
                {
                  $warenkorb = $result[0]['warenkorbjson'];
                }else{
                  $warenkorb = $result[0]['warenkorb'];
                }
                $logdatei = $result[0]['logdatei'];
                if(empty($logdatei))
                {
                  $logdatei = date('Y-m-d H:i:s');
                }
                $projekt = $this->app->DB->Select("SELECT projekt FROM shopexport WHERE id = '$id' LIMIT 1");
                if(!empty($tmpwarenkorb['projekt']) && $this->app->DB->Select("SELECT id FROM projekt WHERE id = '".(int)$tmpwarenkorb['projekt']."' LIMIT 1"))
                {
                  $projekt = (int)$tmpwarenkorb['projekt'];
                }
                if(isset($tmpwarenkorb['subshop']) && $tmpwarenkorb['subshop'])
                {
                  $subshopprojekt = $this->app->DB->Select("SELECT projekt FROM shopexport_subshop WHERE shop = '$id' AND aktiv = 1 AND subshopkennung = '".$this->app->DB->real_escape_string($tmpwarenkorb['subshop'])."' LIMIT 1");
                  if($subshopprojekt)
                  {
                    $projekt = $subshopprojekt;
                  }
                }
                unset($tmpwarenkorb);

                $standardcheck = true;
                $modulename = $this->app->DB->Select(
                  sprintf(
                    "SELECT modulename FROM shopexport WHERE id = %d AND modulename <> '' AND (shoptyp = 'intern')",
                    $id
                  )
                );
                $shopIds = [$id];
                $otherModules= empty($modulename)?null:
                  $this->app->DB->SelectFirstCols(
                    sprintf(
                      "SELECT id 
                  FROM shopexport 
                  WHERE modulename = '%s' AND id <> %d",
                      $this->app->DB->real_escape_string($modulename), $id
                    )
                  );
                if(!empty($otherModules) && $this->app->erp->ModulVorhanden($modulename)) {
                  $obj = $this->app->erp->LoadModul($modulename);
                  if(!empty($obj) && method_exists($obj, 'EinstellungenStruktur')){
                    $konfiguration = $obj->EinstellungenStruktur();
                    if($konfiguration && isset($konfiguration['globalerauftragsnummernkreis']) && $konfiguration['globalerauftragsnummernkreis']) {
                      $shopIds = array_merge([$id], $otherModules);
                      $standardcheck = false;
                      /*$checkdoppeltimported = $this->app->DB->Select("SELECT id FROM shopimport_auftraege WHERE extid = '".$this->app->DB->real_escape_string($auftrag)."' and ((modulename = '".$this->app->DB->real_escape_string($modulename)."' AND shoptyp = 'intern') OR shopid = '$id') and warenkorb = '".$this->app->DB->real_escape_string($warenkorb)."' AND trash = 0
                                    AND (imported = 0 OR (imported = 1 AND DATE_SUB(NOW(),INTERVAL 10 MINUTE)>logdatei ))
                                    LIMIT 1");*/
                      /*$checkdoppeltimported = $this->app->DB->Select("SELECT id FROM shopimport_auftraege WHERE extid = '".$this->app->DB->real_escape_string($auftrag)."' and ((modulename = '".$this->app->DB->real_escape_string($modulename)."' AND shoptyp = 'intern') OR shopid = '$id') AND trash = 0
                                    AND (imported = 0 OR (imported = 1 AND DATE_SUB(NOW(),INTERVAL 10 MINUTE)>logdatei ))
                                    LIMIT 1");*/
                    }
                  }
                }
                $checkdoppeltimported = $this->app->DB->Select(
                  sprintf(
                    "SELECT id 
                  FROM shopimport_auftraege 
                  WHERE extid = '%s' and shopid IN (%s) AND trash = 0
                  AND (imported = 0 OR (imported = 1 AND DATE_SUB(NOW(),INTERVAL 10 MINUTE)>logdatei ))
                  LIMIT 1",
                    $this->app->DB->real_escape_string($auftrag), implode(',', $shopIds)
                  )
                );

                /*if($standardcheck){*/
                  /*$checkdoppeltimported = $this->app->DB->Select("SELECT id FROM shopimport_auftraege WHERE extid = '" . $this->app->DB->real_escape_string($auftrag) . "' and shopid = '$id' and warenkorb = '" . $this->app->DB->real_escape_string($warenkorb) . "' AND trash = 0
                AND (imported = 0 OR (imported = 1 AND DATE_SUB(NOW(),INTERVAL 10 MINUTE)>logdatei ))
                LIMIT 1");*/
                  /*$checkdoppeltimported = $this->app->DB->Select("SELECT id FROM shopimport_auftraege WHERE extid = '" . $this->app->DB->real_escape_string($auftrag) . "' and shopid = '$id' AND trash = 0
                AND (imported = 0 OR (imported = 1 AND DATE_SUB(NOW(),INTERVAL 10 MINUTE)>logdatei ))
                LIMIT 1");
                }*/

                $insid = null;
                if($demomodus == '1')
                {
                  $checkdoppeltimported = null;
                }
                if(!$checkdoppeltimported)
                {
                  $this->app->DB->Insert("INSERT INTO shopimport_auftraege (id,extid,sessionid,warenkorb,imported,projekt,bearbeiter,logdatei) 
                      VALUES('','$auftrag','$sessionid','$warenkorb','0','$projekt','".$this->app->User->GetName()."','$logdatei')");
                  $insid = $this->app->DB->GetInsertID();
                  if($insid){
                    $this->app->DB->Update("UPDATE shopimport_auftraege set shopid = '$id' where id = '$insid'");
                    $this->app->DB->Update("UPDATE shopimport_auftraege set logdatei = now() where id = '$insid' AND logdatei = '0000-00-00' OR logdatei > now()");
                    if($isjson){
                      $this->app->DB->Update("UPDATE shopimport_auftraege set jsonencoded = 1 where id = '$insid'");
                    }
                  }
                }

                if($demomodus!='1')
                {
                  $this->app->remote->RemoteDeleteAuftrag($id,$auftrag);
                }
                elseif($demomodus == '1')
                {
                  $i=$gesamtanzahl;
                }
              }
            }
          }
        }
      } else {
        if(!$returncount)
        {
          $this->app->Tpl->Set('IMPORT',"<div class=\"error\">Verbindungsprobleme! Bitte Administrator kontaktieren! ($pageContents)</div>");
        }else {
          $this->error = "<div class=\"error\">Verbindungsprobleme! Bitte Administrator kontaktieren! ($pageContents)</div>";
        }
      }
    }

    if(!$returncount)
    {
      $this->drawShopOrderTable($deletedRows);
    } else
    {
      return $count+(isset($gesamtanzahl)?$gesamtanzahl:0);
    }
  }

  /**
   * @param array $arr
   *
   * @return array
   */
  public function getCustomerNumberFromShopCart($arr)
  {
    $validkundennummer = '';
    if(!empty($arr['jsonencoded']))
    {
      $warenkorb = json_decode(base64_decode($arr['warenkorb']),true);
    }else{
      $warenkorb = unserialize(base64_decode($arr['warenkorb']));
    }
    foreach($warenkorb as $key=>$value) {
      if(is_string($warenkorb[$key])){
        $warenkorb[$key] = trim($warenkorb[$key]);
      }
    }
    foreach($warenkorb as $k => $v) {
      $warenkorb[$k] = $this->app->erp->fixeUmlaute($v);
    }

    $kundenurvonprojekt = $this->app->DB->Select("SELECT kundenurvonprojekt FROM shopexport WHERE id = '".$arr['shopid']."' LIMIT 1");
    $adresseprojekt = '';
    if($kundenurvonprojekt)
    {
      $adresseprojekt = $this->app->DB->Select("SELECT projekt FROM shopexport WHERE id = '".$arr['shopid']."' LIMIT 1");
    }
    if(!empty($warenkorb['kundennummer'])) {
      $validkundennummer = $this->app->DB->Select(
        "SELECT kundennummer 
        FROM adresse 
        WHERE kundennummer='".$warenkorb['kundennummer']."' and email <> '' $adresseprojekt  AND geloescht!=1 AND kundennummer <> '' 
        LIMIT 1"
      );
    }
    if(isset($warenkorb['subshop']) && $warenkorb['subshop'])
    {
      $subshopprojekt = $this->app->DB->Select("SELECT projekt FROM shopexport_subshop WHERE shop = '".$arr['shopid']."' AND aktiv = 1 AND subshopkennung = '".$this->app->DB->real_escape_string($warenkorb['subshop'])."' LIMIT 1");
      if($subshopprojekt)
      {
        if(!$kundenurvonprojekt)
        {
          $adresseprojekt = $subshopprojekt;
        }
        $arr['abkuerzung'] = $this->app->DB->Select("SELECT abkuerzung FROM projekt WHERE id = '$adresseprojekt' LIMIT 1");
      }
    }
    if($kundenurvonprojekt)
    {
      $adresseprojekt = " AND projekt = '".$adresseprojekt."' ";
    }else {
      $adresseprojekt = '';
    }

    $checkid = $this->app->DB->Select("SELECT kundennummer FROM adresse WHERE `name`='".$this->app->erp->ReadyForPDF($warenkorb['name'])."' AND abteilung='".$this->app->erp->ReadyForPDF($warenkorb['abteilung'])."'
              AND strasse='".$this->app->erp->ReadyForPDF($warenkorb['strasse'])."' AND plz='".$this->app->erp->ReadyForPDF($warenkorb['plz'])."' AND ort='".$this->app->erp->ReadyForPDF($warenkorb['ort'])."' AND kundennummer <> '' AND geloescht!=1 $adresseprojekt 
              ORDER BY email='".$this->app->erp->ReadyForPDF($warenkorb['email'])."' DESC
              LIMIT 1");


    if($warenkorb['email'] != '')
    {
      if($warenkorb['email']!=='amazon_import_bounce@nfxmedia.de')
      {
        $checkidemail = $this->app->DB->Select("SELECT kundennummer FROM adresse WHERE email='".$warenkorb['email']."' and email <> '' $adresseprojekt  AND geloescht!=1 AND kundennummer <> '' LIMIT 1");
      }
      if((String)$checkidemail === ''){
        $checkidemail = $this->app->DB->Select("SELECT kundennummer FROM adresse WHERE name LIKE '" . $warenkorb['name'] . "' AND ort LIKE '" . $warenkorb['ort'] . "'  AND geloescht!=1 $adresseprojekt  AND kundennummer <> '' LIMIT 1");
      }
    }else{
      $checkidemail = $this->app->DB->Select("SELECT kundennummer FROM adresse WHERE name='".$this->app->erp->ReadyForPDF($warenkorb['name'])."' AND strasse='".$this->app->erp->ReadyForPDF($warenkorb['strasse'])."' AND plz='".$this->app->erp->ReadyForPDF($warenkorb['plz'])."' AND ort='".$this->app->erp->ReadyForPDF($warenkorb['ort'])."'     $adresseprojekt  AND geloescht!=1 AND kundennummer <> '' LIMIT 1");
    }

    if($warenkorb['kundennummer']!='' && !empty($validkundennummer) && $validkundennummer==$warenkorb['kundennummer'])
    {
      $kdrnummer = $warenkorb['kundennummer'];
    }
    elseif ($checkid!='')
    {
      $kdrnummer = $checkid;
    }
    elseif ($checkidemail!='')
    {
      $kdrnummer = $checkidemail;
    }
    else {
      $kdrnummer='';
      $checkidemail='';
    }

    return [$checkidemail, $kdrnummer];
  }

  public function drawShopOrderTable($deletedRows) {
    $checkglobal = null;
    $htmltable = new HTMLTable(0,'100%','',3,1,'font-size:85%');
    $htmltable->AddRowAsHeading(array('Import','M&uuml;ll','Sp&auml;ter','Projekt','Internet','Name','Bemerkung','Strasse','PLZ','Ort','Kd.Nr.','vorhanden','Land','Betrag','Offen','Zahlung','Partner'));
    $htmltable->ChangingRowColors('#e0e0e0','#fff');

    $shopid = $this->app->Secure->GetGET('shopid');
    $where = '';
    if(!empty($shopid)){
      $where = 'AND sa.shopid='.(int)$shopid;
    }

    $bestellnummer = $this->app->Secure->GetGET('bestellnummer');
    if(!empty($bestellnummer)){
      $bestellnummer =  preg_replace('/[^\w-]/', '', $bestellnummer);
      $where .= " AND sa.bestellnummer='$bestellnummer'";
    }

    $arr = $this->app->DB->SelectArr("SELECT sa.*, p.abkuerzung FROM shopimport_auftraege sa left join projekt p on sa.projekt = p.id WHERE sa.imported='0' AND sa.trash='0' $where ORDER BY sa.logdatei LIMIT 100");
    if(is_array($arr) && (!empty($arr)?count($arr):0) > 0)
    {

      //Alte Auftraege prüfen
      $alteauftraegeohnebestellnummer = $this->app->DB->Query("SELECT sa.* FROM shopimport_auftraege sa WHERE isnull(bestellnummer) AND sa.trash='0' LIMIT 100");
      while($row = $this->app->DB->Fetch_Assoc($alteauftraegeohnebestellnummer))
      {
        if($row['warenkorb'] != '')
        {
          if(!empty($row['jsonencoded']))
          {
            $warenkorb = json_decode(base64_decode($row['warenkorb']),true);
          }else{
            $warenkorb = unserialize(base64_decode($row['warenkorb']));
          }
          $this->app->DB->Update("UPDATE shopimport_auftraege set bestellnummer = '".(isset($warenkorb['onlinebestellnummer'])?$warenkorb['onlinebestellnummer']:'')."' where id = '".$row['id']."'");
        }else{
          $this->app->DB->Update("UPDATE shopimport_auftraege set bestellnummer = '' where id = '".$row['id']."'");
        }
      }
      $this->app->DB->free($alteauftraegeohnebestellnummer);

      $unbekanntezahlungsweisen = null;
      $enthaeltdoppeltenummern = false;
      $carr = $arr?count($arr):0;
      for($i=0;$i<$carr;$i++)
      {
        if(empty($checkglobal) || !isset($checkglobal[$arr[$i]['shopid']]))
        {
          $checkglobal[$arr[$i]['shopid']] = null;

          if(($modulename = $this->app->DB->Select("SELECT modulename FROM shopexport WHERE id = '".$arr[$i]['shopid']."' AND modulename <> '' AND shoptyp = 'intern'"))
            && $this->app->DB->Select("SELECT id FROM shopexport WHERE modulename = '".$this->app->DB->real_escape_string($modulename)."' AND id <> '".$arr[$i]['shopid']."' LIMIT 1")
          )
          {
            $shopsintern = $this->app->DB->SelectArr("SELECT id FROM shopexport WHERE id = '".$arr[$i]['shopid']."' OR (modulename = '".$this->app->DB->real_escape_string($modulename)."' AND shoptyp = 'intern')");
            if($shopsintern)
            {
              foreach($shopsintern as $vs)
              {
                $checkglobal[$arr[$i]['shopid']][] = " shopid = '". $vs['id']."' ";
              }
              if($this->app->erp->ModulVorhanden($modulename))
              {
                /** @var ShopimporterBase $obj */
                $obj = $this->app->erp->LoadModul($modulename);
                if($obj && method_exists($obj, 'EinstellungenStruktur')){
                  $konfiguration = $obj->EinstellungenStruktur();
                  if($konfiguration && isset($konfiguration['globalerauftragsnummernkreis']) && $konfiguration['globalerauftragsnummernkreis'])
                  {

                  }else
                  {
                    $checkglobal[$arr[$i]['shopid']] = null;
                  }
                }else {
                  $checkglobal[$arr[$i]['shopid']] = null;
                }
              }else {
                $checkglobal[$arr[$i]['shopid']] = null;
              }
            }
          }
        }
      }

      $carr = $arr?count($arr):0;
      for($i=0;$i<$carr;$i++)
      {
        $projekt = $this->app->DB->Select("SELECT projekt FROM shopexport WHERE id = '".$arr[$i]['shopid']."' LIMIT 1");
        $auftraegeaufspaeter = $this->app->DB->Select("SELECT auftraegeaufspaeter FROM shopexport WHERE id='".$arr[$i]['shopid']."'");
        if(!empty($arr[$i]['jsonencoded']))
        {
          $warenkorb = json_decode(base64_decode($arr[$i]['warenkorb']),true);
        }else{
          $warenkorb = unserialize(base64_decode($arr[$i]['warenkorb']));
        }
        foreach($warenkorb as $key=>$value) {
          if(is_string($warenkorb[$key])){
            $warenkorb[$key] = trim($warenkorb[$key]);
          }
        }
        foreach($warenkorb as $k => $v) {
          $warenkorb[$k] = $this->app->erp->fixeUmlaute($v);
        }
        $kundenurvonprojekt = $this->app->DB->Select("SELECT kundenurvonprojekt FROM shopexport WHERE id = '".$arr[$i]['shopid']."' LIMIT 1");
        $adresseprojekt = '';
        if($kundenurvonprojekt)
        {
          $adresseprojekt = $this->app->DB->Select("SELECT projekt FROM shopexport WHERE id = '".$arr[$i]['shopid']."' LIMIT 1");
        }
        if(isset($warenkorb['subshop']) && $warenkorb['subshop'])
        {
          $subshopprojekt = $this->app->DB->Select("SELECT projekt FROM shopexport_subshop WHERE shop = '".$arr[$i]['shopid']."' AND aktiv = 1 AND subshopkennung = '".$this->app->DB->real_escape_string($warenkorb['subshop'])."' LIMIT 1");
          if($subshopprojekt)
          {
            if(!$kundenurvonprojekt)
            {
              $adresseprojekt = $subshopprojekt;
            }
            $arr[$i]['abkuerzung'] = $this->app->DB->Select("SELECT abkuerzung FROM projekt WHERE id = '$adresseprojekt' LIMIT 1");
          }
        }
        if($kundenurvonprojekt)
        {
          $adresseprojekt = " AND projekt = '".$adresseprojekt."' ";
        }else {
          $adresseprojekt = '';
        }

        $checkid = $this->app->DB->Select("SELECT kundennummer FROM adresse WHERE `name`='".$this->app->erp->ReadyForPDF($warenkorb['name'])."' AND abteilung='".$this->app->erp->ReadyForPDF($warenkorb['abteilung'])."'
              AND strasse='".$this->app->erp->ReadyForPDF($warenkorb['strasse'])."' AND plz='".$this->app->erp->ReadyForPDF($warenkorb['plz'])."' AND ort='".$this->app->erp->ReadyForPDF($warenkorb['ort'])."' AND kundennummer <> '' AND geloescht!=1 $adresseprojekt 
              ORDER BY email='".$this->app->erp->ReadyForPDF($warenkorb['email'])."' DESC
              LIMIT 1");


        if($warenkorb['email'] != '')
        {
          if($warenkorb['email']!=='amazon_import_bounce@nfxmedia.de')
          {
            $checkidemail = $this->app->DB->Select("SELECT kundennummer FROM adresse WHERE email='".$warenkorb['email']."' and email <> '' $adresseprojekt  AND geloescht!=1 AND kundennummer <> '' LIMIT 1");
          }
          if((String)$checkidemail === ''){
            $checkidemail = $this->app->DB->Select("SELECT kundennummer FROM adresse WHERE name LIKE '" . $warenkorb['name'] . "' AND ort LIKE '" . $warenkorb['ort'] . "'  AND geloescht!=1 $adresseprojekt  AND kundennummer <> '' LIMIT 1");
          }
        }else{
          $checkidemail = $this->app->DB->Select("SELECT kundennummer FROM adresse WHERE name='".$this->app->erp->ReadyForPDF($warenkorb['name'])."' AND strasse='".$this->app->erp->ReadyForPDF($warenkorb['strasse'])."' AND plz='".$this->app->erp->ReadyForPDF($warenkorb['plz'])."' AND ort='".$this->app->erp->ReadyForPDF($warenkorb['ort'])."'     $adresseprojekt  AND geloescht!=1 AND kundennummer <> '' LIMIT 1");
        }

        if($warenkorb['kundennummer']!='' && !empty($validkundennummer) && $validkundennummer==$warenkorb['kundennummer'])
        {
          $kdrnummer = $warenkorb['kundennummer'];
          $kdr_name = $this->app->DB->Select("SELECT name FROM adresse WHERE kundennummer='$kdrnummer' $adresseprojekt AND geloescht!=1 LIMIT 1");
          $email = $this->app->DB->Select("SELECT email FROM adresse WHERE kundennummer='$kdrnummer' $adresseprojekt AND geloescht!=1 LIMIT 1");
          $parts= explode("\n", wordwrap($kdr_name, 20, "\n"));
          $kdr_name = $parts[0];
          $kdr_name = '<br><i style="color:red">'.$kdr_name.'</i>';
          $email = '<br><i style="color:red">'.$email.'</i>';

          $kdr_strasse = $this->app->DB->Select("SELECT strasse FROM adresse WHERE kundennummer='$kdrnummer' AND geloescht!=1 $adresseprojekt LIMIT 1");
          $parts= explode("\n", wordwrap($kdr_strasse, 20, "\n"));
          $kdr_strasse = $parts[0];
          $kdr_strasse = '<br><i style="color:red">'.$kdr_strasse.'</i>';

          $kdr_plz = '<br><i style="color:red">'.$this->app->DB->Select("SELECT plz FROM adresse WHERE kundennummer='$kdrnummer' AND geloescht!=1 $adresseprojekt LIMIT 1").'</i>';
          $kdr_ort = '<br><i style="color:red">'.$this->app->DB->Select("SELECT ort FROM adresse WHERE kundennummer='$kdrnummer' AND geloescht!=1 $adresseprojekt LIMIT 1").'</i>';
          $checked='';
        }
        elseif ($checkid!='')
        {
          $checked='checked';
          $kdrnummer = $checkid;
          //$kdr_name = "<br><i style=\"color:purple\">".$this->app->DB->Select("SELECT name FROM adresse WHERE kundennummer='$kdrnummer' AND firma='".$this->app->User->GetFirma()."' LIMIT 1")."</i>";
          $kdrArr = $this->app->DB->SelectRow("SELECT name, email, strasse, ort, plz FROM adresse WHERE kundennummer='$kdrnummer' AND geloescht!=1 $adresseprojekt LIMIT 1");
          $kdr_name = $kdrArr['name'];
          $email = $kdrArr['email'];
          $parts= explode("\n", wordwrap($kdr_name, 20, "\n"));
          $kdr_name = $parts[0];
          $kdr_name = '<br><i style="color:green">'.$kdr_name.'</i>';
          $email = '<br><i style="color:green">'.$email.'</i>';

          $kdr_strasse = $kdrArr['strasse'];
          $parts= explode("\n", wordwrap($kdr_strasse, 20, "\n"));
          $kdr_strasse = $parts[0];
          $kdr_strasse = '<br><i style="color:green">'.$kdr_strasse.'</i>';

          $kdr_plz = '<br><i style="color:green">'.$kdrArr['plz'].'</i>';
          $kdr_ort = '<br><i style="color:green">'.$kdrArr['or'].'</i>';

        }
        elseif ($checkidemail!='')
        {
          $checked='checked';
          $kdrnummer = $checkidemail;
          $warenkorb['kundennummer'] = $kdrnummer;
          //$kdr_name = "<br><i style=\"color:purple\">".$this->app->DB->Select("SELECT name FROM adresse WHERE kundennummer='$kdrnummer' AND firma='".$this->app->User->GetFirma()."' LIMIT 1")."</i>";
          $kdrArr = $this->app->DB->SelectRow("SELECT name, email, strasse, ort, plz FROM adresse WHERE kundennummer='$kdrnummer' AND geloescht!=1 $adresseprojekt LIMIT 1");
          $kdr_name = $kdrArr['name'];
          $email = $kdrArr['email'];
          $parts= explode("\n", wordwrap($kdr_name, 20, "\n"));
          $kdr_name = $parts[0];
          $kdr_name = '<br><i style="color:purple">'.$kdr_name.'</i>';
          $email = '<br><i style="color:purple">'.$email.'</i>';

          $kdr_strasse = $kdrArr['strasse'];
          $parts= explode("\n", wordwrap($kdr_strasse, 40, "\n"));
          $kdr_strasse = $parts[0];
          $kdr_strasse = '<br><i style="color:purple">'.$kdr_strasse.'</i>';

          $kdr_plz = '<br><i style="color:purple">'.$kdrArr['plz'].'</i>';
          $kdr_ort = '<br><i style="color:purple">'.$kdrArr['ort'].'</i>';
        }


        else {
          $checked='';
          $checkid='';
          $kdrnummer='';
          $checkidemail='';
          $kdr_name='';
          $kdr_strasse='';
          $kdr_plz='';
          $kdr_ort='';
          $email='';
        }
        if($kdrnummer != ''){
          $kdr_addresse_id = $this->app->DB->Select("SELECT id FROM adresse WHERE kundennummer='$kdrnummer' AND geloescht!=1 $adresseprojekt LIMIT 1");
        }
        else {
          $kdr_addresse_id = '';
        }

        $warenkorb['name']  = $this->app->erp->LimitWord($warenkorb['name'],20);
        $warenkorb['strasse']  = $this->app->erp->LimitWord($warenkorb['strasse'],20);

        $htmltable->NewRow();

        $doppelteonlinebestellnummer = false;
        if(!empty($warenkorb['onlinebestellnummer']))
        {
          $check = $this->app->DB->Select("SELECT id from shopimport_auftraege where id <> '".$arr[$i]['id']."' and shopid = '".$arr[$i]['shopid']."' and bestellnummer = '".$warenkorb['onlinebestellnummer']."' and trash = '0' LIMIT 1");
          if($check)
          {
            $doppelteonlinebestellnummer = true;
            $enthaeltdoppeltenummern = true;
          }elseif(!empty($checkglobal) && isset($checkglobal[$arr[$i]['shopid']]) && $checkglobal[$arr[$i]['shopid']])
          {
            $check = $this->app->DB->Select("SELECT id from shopimport_auftraege where id <> '".$arr[$i]['id']."' and (shopid = '".$arr[$i]['shopid']."' OR ".(implode( " OR ", $checkglobal[$arr[$i]['shopid']])).") and bestellnummer = '".$warenkorb['onlinebestellnummer']."' and trash = '0' LIMIT 1");
            if($check)
            {
              $doppelteonlinebestellnummer = true;
              $enthaeltdoppeltenummern = true;
            }
          }
        }

        $htmltable->AddCol('<input type="hidden" name="auftrag[]" value="'.$arr[$i]['id'].'"><input type="radio" name="import['.$arr[$i]['id'].']" value="import" '.(($doppelteonlinebestellnummer || $auftraegeaufspaeter)?'':' checked="checked" ').'>');
        $htmltable->AddCol('<input type="radio" name="import['.$arr[$i]['id'].']" value="muell">');
        $htmltable->AddCol('<input type="radio" name="import['.$arr[$i]['id'].']" value="warten"'.(($doppelteonlinebestellnummer || $auftraegeaufspaeter)?' checked="checked" ':'').'>');
        $htmltable->AddCol($arr[$i]['abkuerzung']);


        $htmltable->AddCol(($doppelteonlinebestellnummer?'<b style="color:red">':'').$warenkorb['onlinebestellnummer'].($doppelteonlinebestellnummer?'</b>':''));
        $htmltable->AddCol($warenkorb['name'].$kdr_name.'<br>'.$warenkorb['email'].$email);
        $htmltable->AddCol($warenkorb['internebezeichnung']);

        $htmltable->AddCol($warenkorb['strasse'].$kdr_strasse);
        $htmltable->AddCol($warenkorb['plz'].$kdr_plz);
        $htmltable->AddCol($warenkorb['ort'].$kdr_ort);
        if($checkid!=''){
          $htmltable->AddCol('<input type="text" size="10" value="' . $kdrnummer . '" name="import_kundennummer[' . $arr[$i]['id'] . ']">');
        }
        else{
          $htmltable->AddCol('<input type="text" size="10" value="' . $warenkorb['kundennummer'] . '" name="import_kundennummer[' . $arr[$i]['id'] . ']">');
        }

        $htmltable->AddCol('<input type="checkbox" '.$checked.' name="kundennummer['.$arr[$i]['id'].']" value="1">');
        //$htmltable->AddCol('<input type="text" size="8" value="'.$warenkorb[kundennummer].'">&nbsp;<img src="./themes/[THEME]/images/zoom_in.png" border="0">');
        $htmltable->AddCol($warenkorb['land']);
        $htmltable->AddCol(number_format($warenkorb['gesamtsumme'],2,',','.'));
        $saldo_kunde = round($this->app->erp->SaldoAdresse($kdr_addresse_id),2);
        if($saldo_kunde > 0){
          $saldo_kunde = '<b style="color:red">' . number_format($saldo_kunde, 2, ',','.') . '</b>';
        }
        else{
          $saldo_kunde = '-';
        }
        $htmltable->AddCol($saldo_kunde);
        $htmltable->AddCol($warenkorb['zahlungsweise']);


        $htmltable->AddCol($warenkorb['affiliate_ref']);
        //$htmltable->AddCol('<a href="">Einzelimport</a>&nbsp;<a href="">verwerfen</a>');
        //$warenkorb[gesamtsumme] = str_replace(".","",$warenkorb[gesamtsumme]);
        $gesamtsumme = (isset($gesamtsumme)?$gesamtsumme:0) + $warenkorb['gesamtsumme'];
        $checkid = '';
        $checkidemail = '';
        $validkundennummer = '';
        //$this->app->Tpl->Add('INHALT',"<tr><td><input type=\"checkbox\" name=\"\" value=\"1\" checked></td><td>{$warenkorb[onlinebestellnummer]}</td><td>{$warenkorb[name]}</td><td>{$warenkorb[land]}</td><td>{$warenkorb[gesamtsumme]}</td></tr>");
      }


    } else {
      if($deletedRows > 0){
        $msg = $this->app->erp->base64_url_encode('<div class="info">Es wurden ' . $deletedRows . ' bereits importierte Datens&auml;tze entfernt.</div>');
      }else{
        $msg = $this->app->erp->base64_url_encode('<div class="error2">Aktuell sind keine Auftr&auml;ge in den Online-Shops vorhanden!</div>  ');
      }
      $this->app->Location->execute('Location: index.php?module=shopimport&action=list&msg='.$msg);
    }


    $htmltable->NewRow();
    $htmltable->AddCol('<input type="radio" value="import" id="import" name="auswahl" checked>');
    $htmltable->AddCol('<input type="radio" value="muell" id="muell" name="auswahl">');
    $htmltable->AddCol('<input type="radio" value="spaeter" id="spaeter" name="auswahl">');
    $htmltable->AddCol('');
    $htmltable->AddCol('');
    $htmltable->AddCol('');
    $htmltable->AddCol('');
    $htmltable->AddCol('');
    $htmltable->AddCol('');
    $htmltable->AddCol('');
    $htmltable->AddCol('');
    $htmltable->AddCol('');
    $htmltable->AddCol('');
    $htmltable->AddCol(number_format($gesamtsumme,2,',','.'));
    $htmltable->AddCol('');
    $htmltable->AddCol('');

    if($enthaeltdoppeltenummern)
    {
      $this->app->Tpl->Add('INHALT','<div class="error">Es wurde ein Auftrag aus einem Shop geholt, der bereits importiert wurde!</div>');
    }
    $this->app->Tpl->Add('INHALT',$htmltable->Get());

    $this->app->Tpl->Add('INHALT',"<br><br>Bedeutung: <ul>
          <li style=\"color:red\">Kundennummer von Kunde angegeben, eventuell ist diese falsch!</li>
          <li style=\"color:red\">Doppelte Internetbestellnummer!</li>
          <li style=\"color:purple\">Kundennummer bitte manuell pr&uuml;fen!</li>
          <li style=\"color:green\">Kundennummer aufgrund Felder Ort, Strasse, Name, Abteilung und E-Mail eindeutig gefunden!</li>
          </ul>");

    $this->app->Tpl->Set('EXTEND','<input type="submit" value="Auftr&auml;ge importieren" id="submit" name="submit">');
    $this->app->Tpl->Parse('IMPORT','rahmen70.tpl');


    $this->app->Tpl->Parse('PAGE','shopimport_import.tpl');
  }

  public function ShopimportNavigation()
  {
    $id = $this->app->Secure->GetGET('id');
    $tmp = new Navigation($this->app, $id);
    $this->app->Tpl->Set('ID',$id);
    $this->app->Tpl->Set('PAGE',$tmp->Get());
    $this->app->BuildNavigation=false;
  }

}