xtcom/shoplib.php

   1 <?php
   2
   3
   4 $login=$_GET["login"];
   5 $debug=false;
   6 #require_once "DB.php";
   7 require_once "MDB2.php";
   8
   9 if (file_exists ("conf$login.php")) {
  10         require "conf$login.php";
  11 } else {
  12         require "conf.php";
  13 }
  14
  15 $landarray=array("DEUTSCHLAND"=>"D","STEREICH"=>"A","OESTEREICH"=>"A","SCHWEIZ"=>"CH");
  16 $taxarray=array("D"=>0,"A"=>1,"CH"=>2);
  17 $defaultland="D";
  18 $taxid=0;
  19 $log=false;
  20 $erp=false;
  21 $shop=false;
  22
  23 //$PGdns = "user='$ERPuser' password='$ERPpass' host='$ERPhost' dbname='$ERPdbname' port='$ERPport'";
  24
  25 $ERPdns= array('phptype'  => 'pgsql',
  26                'username' => $ERPuser,
  27                'password' => $ERPpass,
  28                'hostspec' => $ERPhost,
  29                'database' => $ERPdbname,
  30                'port'     => $ERPport);
  31
  32 $SHOPdns=array('phptype'  => 'mysql',
  33                'username' => $SHOPuser,
  34                'password' => $SHOPpass,
  35                'hostspec' => $SHOPhost,
  36                'database' => $SHOPdbname,
  37                'port'     => $SHOPport);
  38
  39 /****************************************************
  40 * Debugmeldungen in File schreiben
  41 ****************************************************/
  42 if ($debug) { $log=fopen("tmp/shop.log","a"); } // zum Debuggen
  43 else { $log=false; };
  44
  45
  46
  47 /****************************************************
  48 * Shopverbindung aufbauen
  49 ****************************************************/
  50 /*$shop=DB::connect($SHOPdns);
  51 if (!$shop) shopFehler("",$shop->getDebugInfo());
  52 if (DB::isError($shop)) {
  53         $nun=date("Y-m-d H:i:s");
  54         if ($log) fputs($log,$nun.": Shop-Connect\n");
  55         shopFehler("",$shop->getDebugInfo());
  56         die ($shop->getDebugInfo());
  57 };*/
  58 $options = array();
  59 //print_r($SHOPdns);
  60 $shop=MDB2::factory($SHOPdns,$options);
  61 //echo "<pre>"; print_r($shop); echo "</pre>";
  62 if (!$shop) shopFehler("",$shop->getMessage());
  63 if (PEAR::isError($shop)) {
  64         $nun=date("Y-m-d H:i:s");
  65         if ($log) fputs($log,$nun.": Shop-Connect\n");
  66         shopFehler("",$shop->getMessage());
  67         die ($shop->getMessage());
  68 };
  69 if (ExportMode == "1") $shop->setCharset('utf8');
  70 $shop->setFetchMode(MDB2_FETCHMODE_ASSOC);
  71
  72
  73 /****************************************************
  74 * ERPverbindung aufbauen
  75 ****************************************************/
  76 /*$erp=DB::connect($ERPdns);
  77 if (!$erp) shopFehler("",$erp->getDebugInfo());
  78 if (DB::isError($erp)) {
  79         $nun=date("Y-m-d H:i:s");
  80         if ($log) fputs($log,$nun.": ERP-Connect\n");
  81         shopFehler("",$erp->getDebugInfo());
  82         die ($erp->getDebugInfo());
  83 } else {
  84         $erp->autoCommit(true);
  85 };*/
  86 $options = array('result_buffering' => false,);
  87 $erp = MDB2::factory($ERPdns,$options);
  88 //echo "<pre>"; print_r($erp); echo "</pre>";
  89 if (!$erp) shopFehler("",$erp->getMessage());
  90 if (PEAR::isError($erp)) {
  91         $nun=date("Y-m-d H:i:s");
  92         if ($log) fputs($log,$nun.": ERP-Connect\n");
  93         shopFehler("",$erp->getMessage());
  94         die ($erp->getMessage());
  95 } else {
  96         if ($erp->autocommit) $erp->autocommit();
  97 };
  98
  99 if ($SHOPchar and ExportMode != "1") {
 100     $erp->setCharset($SHOPchar);
 101 }
 102 $erp->setFetchMode(MDB2_FETCHMODE_ASSOC);
 103
 104
 105
 106 /****************************************************
 107 * SQL-Befehle absetzen
 108 ****************************************************/
 109 function query($db,$sql,$function="--") {
 110         $nun=date("d.m.y H:i:s");
 111         //if ($db<>"shop") { echo "$sql!$db!<br>"; flush(); };
 112         if ($GLOBALS["log"]) fputs($GLOBALS["log"],$nun.": ".$function."\n".$sql."\n");
 113         $rc=$GLOBALS[$db]->query($sql);
 114         if ($GLOBALS["log"]) fputs($GLOBALS["log"],print_r($rc,true)."\n");
 115     if(PEAR::isError($rc)) {
 116         //if ($rc!==1) {
 117             return -99;
 118         } else {
 119             return true;
 120         }
 121 }
 122
 123 /****************************************************
 124 * Datenbank abfragen
 125 ****************************************************/
 126 function getAll($db,$sql,$function="--") {
 127         $nun=date("d.m.y H:i:s");
 128         if ($GLOBALS["log"]) fputs($GLOBALS["log"],$nun.": ".$function."\n".$sql."\n");
 129         //$rs=$GLOBALS[$db]->getAll($sql,DB_FETCHMODE_ASSOC);
 130         $rs=$GLOBALS[$db]->queryAll($sql);
 131         //if ($rs["message"]<>"") {
 132     if ($rs->message<>"") {
 133                 if ($GLOBALS["log"]) fputs($GLOBALS["log"],print_r($rs,true)."\n");
 134                 return false;
 135         } else {
 136                 return $rs;
 137         }
 138 }
 139
 140 /****************************************************
 141 * shopFehler
 142 * in: sql,err = string
 143 * out:
 144 * Fehlermeldungen ausgeben
 145 *****************************************************/
 146 function shopFehler($sql,$err) {
 147 global $showErr;
 148         if ($showErr)
 149                 echo "</td></tr></table><font color='red'>$sql : $err</font><br>";
 150 }
 151
 152 /****************************************************
 153 * Nächste Auftragsnummer (ERP) holen
 154 ****************************************************/
 155 function getNextAnr() {
 156         $sql="select * from defaults";
 157         $sql1="update defaults set sonumber=";
 158         $rs2=getAll("erp",$sql,"getNextAnr");
 159         if ($rs2[0]["sonumber"]) {
 160                 $auftrag=$rs2[0]["sonumber"]+1;
 161                 $rc=query("erp",$sql1.$auftrag,"getNextAnr");
 162                 if ($rc === -99) {
 163                         echo "Kann keine Auftragsnummer erzeugen - Abbruch";
 164                         exit();
 165                 }
 166                 return $auftrag;
 167         } else {
 168                 return false;
 169         }
 170 }
 171
 172 /****************************************************
 173 * Nächste Kundennummer (ERP) holen
 174 ****************************************************/
 175 function getNextKnr() {
 176         $sql="select * from defaults";
 177         $sql1="update defaults set customernumber='";
 178         $rs2=getAll("erp",$sql,"getNextKnr");
 179         if ($rs2[0]["customernumber"]) {
 180                 $kdnr=$rs2[0]["customernumber"]+1;
 181                 $rc=query("erp",$sql1.$kdnr."'","getNextKnr");
 182                 if ($rc === -99) {
 183                         echo "Kann keine Kundennummer erzeugen - Abbruch";
 184                         exit();
 185                 }
 186                 return $kdnr;
 187         } else {
 188                 return false;
 189         }
 190 }
 191
 192
 193 //$shopdata=array("firma"=>"","abteilung"=>"","vorname"=>"","nachname"=>"","strasse"=>"","plz"=>"","ort"=>"","telefon"=>"","email"=>"","land"=>"","fax"=>"","notiz"=>"","postfach"=>"")
 194 $shopdata=array(        "id"=>"customers_id","kdnr"=>"customers_cid","bid"=>"orders_id", "anrede"=>" customers_gender",
 195                         "firma"=>"customers_company", "nachname"=>"customers_lastname", "vorname"=>"customers_firstname",
 196                         "strasse"=>"customers_street_address","plz"=>"customers_postcode","ort"=>"customers_city","land"=>"customers_country",
 197                         "telefon"=>"customers_phone","email"=>"customers_email_address","fax"=>"Fax","notiz"=>"comments",
 198
 199                         "netto"=>"ot_subtotal","steuer"=>"ot_tax","datum"=>" date_purchased","bemerkung"=>"comments",
 200                         "artnr"=>"products_id","preis"=>"final_price","artikeltxt"=>" products_name","menge"=>" products_quantity");
 201
 202 $shopartikel=array(     "id"=>"Artikel_ID","artnr"=>"Artikel_Nr","arttxt"=>"Name","artbeschr"=>"Beschreibung","gruppe"=>"Kategorie_ID",
 203                         "preis"=>"Preis","preis2"=>"Haendlerpreis","preis3"=>"Aktionspreis","gewicht"=>"Gewicht",
 204                         "bild"=>"Bild_gross","bestand"=>"Lagerbestand","minbestand"=>"Mindestlagermenge","steuer"=>"MwSt_Satz");
 205
 206
 207 /****************************************************
 208 * Ab hier Artikelexport aus ERP
 209 ****************************************************/
 210 // Ab hier Artikelexport aus ERP nur eine Sprache
 211 function shopartikellang($lang,$alle) {
 212         $sql="SELECT P.partnumber,L.translation,P.description,L.longdescription,P.notes,PG.partsgroup ";
 213         $sql.="FROM parts P left join translation L on L.parts_id=P.id left join partsgroup PG on PG.id=P.partsgroup_id ";
 214         $sql.="WHERE P.shop='t' and (L.language_id = $lang";
 215         if ($alle) {
 216                 $sql.=" or L.language_id is Null)";
 217         } else { $sql.=")"; };
 218         $rs=getAll("erp",$sql,"shopartikellang");
 219         $data=array();
 220         if ($rs) foreach ($rs as $row) {
 221                 if (!$data[$row["partnumber"]]) $data[$row["partnumber"]]=$row;
 222         }
 223         return $data;
 224 }
 225 // Ab hier alle Artikelexport aus ERP Defaultsprache
 226 function shopartikel() {
 227 global $stdprice,$altprice;
 228         if ($stdprice>0) {
 229                 $sql="SELECT P.partnumber,P.description,P.weight,(t.rate * 100) as rate,G.price as sellprice,P.sellprice as stdprice, ";
 230                 $sql.="PG.partsgroup,P.notes,P.image,P.onhand,G.pricegroup_id,P.buchungsgruppen_id as bugru FROM ";
 231                 $sql.="chart c left join tax t on c.taxkey_id=t.taxkey, parts P left join partsgroup PG on ";
 232                 $sql.="PG.id=P.partsgroup_id left join prices G on G.parts_id=P.id ";
 233                 $sql.="left join buchungsgruppen B  on P.buchungsgruppen_id = B.id ";
 234                 $sql.="where P.shop='t' and c.id=B.income_accno_id_0  and ";
 235                 $sql.="(G.pricegroup_id=$stdprice or G.pricegroup_id=$altprice or G.pricegroup_id is null) ";
 236                 $sql.="order by P.partnumber";
 237         } else {
 238                 $sql="SELECT P.partnumber,P.description,P.weight,(t.rate * 100) as rate,P.sellprice,PG.partsgroup,";
 239                 $sql.="P.notes,P.image,P.onhand,P.buchungsgruppen_id as bugru FROM ";
 240                 $sql.="chart c left join tax t on c.taxkey_id=t.taxkey, parts P left join partsgroup PG on ";
 241                 $sql.="PG.id=P.partsgroup_id left join buchungsgruppen B  on P.buchungsgruppen_id = B.id ";
 242                 $sql.="WHERE P.shop='t'  and c.id=B.income_accno_id_0";
 243         }
 244         $rs=getAll("erp",$sql,"shopartikel");
 245         $i=0;
 246         $data=array();
 247         if ($rs) foreach ($rs as $row) {
 248                 if (!$data[$row["partnumber"]]) $data[$row["partnumber"]]=$row;
 249                 if ($row["pricegroup_id"]==$altprice) {
 250                         $data[$row["partnumber"]]["altprice"]=($row["sellprice"])?$row["sellprice"]:$row["stdprice"];
 251                 } else {
 252                         $data[$row["partnumber"]]["sellprice"]=($row["sellprice"])?$row["sellprice"]:$row["stdprice"];
 253                 }
 254                 $i++;
 255         }
 256
 257         return $data;
 258 }
 259
 260 /****************************************************
 261 * Artikelexport in ERP importieren
 262 ****************************************************/
 263 function insertArtikel($data) {
 264 global $shopartikel;
 265         foreach ($data as $row) {
 266                 $pg=$GLOBALS["warengruppen"][$row[$shopartikel["gruppe"]]]["partsgroup"];
 267                 $bg=$GLOBALS["buchungsgruppen"][sprintf("%0.2f",$row[$shopartikel["steuer"]])];
 268                 $artnr=($row[$shopartikel["artnr"]])?$row[$shopartikel["artnr"]]:getArtnr();
 269                 $sqltmp="insert into parts (partnumber,description,notes,weight,onhand,rop,image,sellprice,unit,partsgroup_id,buchungsgruppen_id) ";
 270                 $sqltmp.="values ('%s','%s','%s',%0.5f,%0.5f,%0.5f,'%s',%0.5f,'%s',%d,%d)";
 271                 $sql=sprintf($sqltmp,$artnr,$row[$shopartikel["arttxt"]],$row[$shopartikel["artbeschr"]],
 272                                 $row[$shopartikel["gewicht"]],$row[$shopartikel["bestand"]],$row[$shopartikel["minbestand"]],
 273                                 $row[$shopartikel["bild"]],$row[$shopartikel["preis"]],$row[$shopartikel["einheit"]],$pg,$bg);
 274                 $rc=query("erp",$sql,"insertArtikel");
 275                 if ($rc === -99) {
 276                         echo $row[$shopartikel["id"]]." ".$row[$shopartikel["arttxt"]]." nicht importiert<br>";
 277                 } else {
 278                         echo "";
 279                 }
 280                 echo $sql."<br>";
 281         }
 282 }
 283
 284 /****************************************************
 285 * Nächste Artikelnummer (ERP) holen
 286 ****************************************************/
 287 function getArtnr() {
 288         $sql="select * from defaults";
 289         $sql1="update defaults set articlenumber='";
 290         if ($rc === -99) {
 291                 echo "Kann keine Artikelnummer erzeugen - Abbruch";
 292                 exit();
 293         }
 294         $rs2=getAll("erp",$sql,"getArtnr");
 295         $artnr=$rs2[0]["articelnumber"]+1;
 296         $rc=query("erp",$sql1.$artnr."'","getArtnr");
 297         if ($rc === -99) {
 298                 echo "Kann keine Artikelnummer erzeugen - Abbruch";
 299                 $rc=query("erp","ROLLBACK","getArtnr");
 300                 exit();
 301         }
 302         return $artnr;
 303 }
 304
 305 $buchungsgruppen=array();
 306 $warengruppen=array();
 307
 308 function getBugru() {
 309         $sql ="select B.id,tax.rate from buchungsgruppen B left join chart on income_accno_id_0=chart.id left join taxkeys T on ";
 310         $sql.="T.chart_id=income_accno_id_0 left join tax on tax.id=T.tax_id where T.startdate<=now()";
 311         $rs=getAll("erp",$sql,"getBugru");
 312         if ($rs) foreach ($rs as $row) {
 313                 $steuer=sprintf("%0.2f",$row["rate"]*100);
 314                 $GLOBALS["buchungsgruppen"][$steuer]=$row["id"];
 315         }
 316 }
 317
 318 $wg=1000;
 319
 320 function insPartgroup($kat) {
 321         $sql="insert into partsgroup () value ()";
 322         $GLOBALS["wg"]++;
 323         //$rc=query("erp",$sql,"insPartgroup");
 324         if ($rc === -99) { return false; }
 325         else { return $GLOBALS["wg"]; }
 326 }
 327 getBugru();
 328 ?>