Bugfix zu 1421: Loeschen von Stornos bereitet eine Reihe von Problemen
[kivitendo-erp.git] / lxo-import / import_lib.php
1 <?php
2 /*
3 Funktionsbibliothek für den Datenimport in Lx-Office ERP
4
5 Copyright (C) 2005
6 Author: Holger Lindemann
7 Email: hli@lx-system.de
8 Web: http://lx-system.de
9
10 */
11
12 require_once "db.php";
13
14 $address = array(
15     "name" => "Firmenname",
16     "department_1" => "Abteilung",
17     "department_2" => "Abteilung",
18     "street" => "Strasse + Nr",
19     "zipcode" => "Plz",
20     "city" => "Ort",
21     "country" => "Land",
22     "contact" => "Ansprechpartner",
23     "phone" => "Telefon",
24     "fax" => "Fax",
25     "homepage" => "Homepage",
26     "email" => "eMail",
27     "notes" => "Bemerkungen",
28     "discount" => "Rabatt (nn.nn)",
29     "taxincluded" => "incl. Steuer? (t/f)",
30     "terms" => "Zahlungsziel (Tage)",
31     "customernumber" => "Kundennummer",
32     "vendornumber" => "Lieferantennummer",
33     "taxnumber" => "Steuernummer",
34     "ustid" => "Umsatzsteuer-ID",
35     "account_number" => "Kontonummer",
36     "bank_code" => "Bankleitzahl",
37     "bank" => "Bankname",
38     "branche" => "Branche",
39     "business_id" => "BranchenID",
40     "salesman_id" => "VerkäuferID",
41     //"language" => "Sprache (de,en,fr)",
42     "sw" => "Stichwort",
43     "creditlimit" => "Kreditlimit (nnnnnn.nn)"); /*,
44     "hierarchie" => "Hierarchie",
45     "potenzial" => "Potenzial",
46     "ar" => "Debitorenkonto",
47     "ap" => "Kreditorenkonto",
48     "matchcode" => "Matchcode",
49     "customernumber2" => "Kundennummer 2"); 
50     Kundenspezifisch */
51         
52 $shiptos = array(
53     "firma" => "Firmenname",
54     "shiptoname" => "Liefername",
55     "shiptodepartment_1" => "Abteilung",
56     "shiptodepartment_2" => "Abteilung",
57     "shiptostreet" => "Strasse + Nr",
58     "shiptozipcode" => "Plz",
59     "shiptocity" => "Ort",
60     "shiptocountry" => "Land",
61     "shiptocontact" => "Ansprechpartner",
62     "shiptophone" => "Telefon",
63     "shiptofax" => "Fax",
64     "shiptoemail" => "eMail",
65     "customernumber" => "Kundennummer",
66     "vendornumber" => "Lieferantennummer");
67
68 $parts = array( 
69     "partnumber" => "Artikelnummer",
70     "ean" => "Barcode",
71     "description" => "Artikeltext",
72     "unit" => "Einheit",
73     "weight" => "Gewicht in Benutzerdefinition",
74     "notes" => "Beschreibung",
75     "notes1" => "Beschreibung",
76     "formel" => "Formel",
77     "makemodel" => "Hersteller",
78     "model" => "Modellbezeichnung",
79     "image" => "Pfad/Dateiname",
80     "drawing" => "Pfad/Dateiname",
81     "microfiche" => "Pfad/Dateiname",
82     "listprice" => "Listenpreis",
83     "sellprice" => "Verkaufspreis",
84     "lastcost" => "letzter EK",
85     "art" => "Ware/Dienstleistung (*/d), mu&szlig; vor den Konten kommen",
86     "inventory_accno" => "Bestandskonto",
87     "income_accno" => "Erl&ouml;skonto",
88     "expense_accno" => "Konto Umsatzkosten",
89     "obsolete" => "Gesperrt (Y/N)",
90     "lastcost" => "letzer EK-Preis",
91     "rop" => "Mindestbestand",
92     "shop" => "Shopartikel (Y/N)",
93     "assembly" => "St&uuml;ckliste (Y/N); wird noch nicht unterst&uuml;tzt",
94     "partsgroup" => "Warengruppenbezeichnung",
95     "partsgroup1" => "2.Warengruppenbezeichnung",
96     "partsgroup2" => "3.Warengruppenbezeichnung",
97     "partsgroup3" => "4.Warengruppenbezeichnung",
98     "partsgroup4" => "5.Warengruppenbezeichnung",
99     "shop"  => "Shopexport vorghesehen",
100     );
101     
102 $contactscrm = array(
103     "customernumber" => "Kundennummer",
104     "vendornumber" => "Lieferantennummer",
105     "cp_cv_id" => "FirmenID in der db",
106     "firma" => "Firmenname",
107     "cp_abteilung" => "Abteilung",
108     "cp_position" => "Position/Hierarchie",
109     "cp_gender" => "Geschlecht (m/f)",
110     "cp_title" => "Titel",
111     "cp_givenname" => "Vorname",
112     "cp_name" => "Nachname",
113     "cp_email" => "eMail",
114     "cp_phone1" => "Telefon 1",
115     "cp_phone2" => "Telefon 2",
116     "cp_mobile1" => "Mobiltelefon 1",
117     "cp_mobile2" => "Mobiltelefon 2",
118     "cp_homepage" => "Homepage",
119     "cp_street" => "Strasse",
120     "cp_country" => "Land",
121     "cp_zipcode" => "PLZ",
122     "cp_city" => "Ort",
123     "cp_privatphone" => "Privattelefon",
124     "cp_privatemail" => "private eMail",
125     "cp_notes" => "Bemerkungen",
126     "cp_stichwort1" => "Stichwort(e)",
127     "cp_id" => "Kontakt ID"
128     );
129
130 $contacts = array(
131     "customernumber" => "Kundennummer",
132     "vendornumber" => "Lieferantennummer",
133     "cp_cv_id" => "FirmenID in der db",
134     "firma" => "Firmenname",
135     "cp_greeting" => "Anrede",
136     "cp_title" => "Titel",
137     "cp_givenname" => "Vorname",
138     "cp_greeting" => "Anrede",
139     "cp_name" => "Nachname",
140     "cp_email" => "eMail",
141     "cp_phone1" => "Telefon 1",
142     "cp_phone2" => "Telefon 2",
143     "cp_mobile1" => "Mobiltelefon 1",
144     "cp_mobile2" => "Mobiltelefon 2",
145     "cp_privatphone" => "Privattelefon",
146     "cp_privatemail" => "private eMail",
147     "cp_homepage" => "Homepage",
148     "cp_id" => "Kontakt ID"
149     );
150
151 function checkCRM() {
152     global $db;
153     $sql="select * from crm";
154     $rs=$db->getAll($sql);
155     if ($rs) {
156         return true;
157     } else {
158         return false;
159     }
160 }
161
162 function chkUsr($usr) {
163 // ist es ein gültiger ERP-Benutzer? Er muß mindestens 1 x angemeldet gewesen sein.
164     global $db;
165     $sql="select * from employee where login = '$usr'";
166     $rs=$db->getAll($sql);
167     if ($rs[0]["id"]) { return $rs[0]["id"]; } 
168     else { return false; };
169 }
170
171 function getKdId() {
172 // die nächste freie Kunden-/Lieferantennummer holen
173     global $db,$file,$test;
174     if ($test) { return "#####"; }
175     $sql1="select * from defaults";
176     $sql2="update defaults set ".$file."number = '%s'";
177     $db->begin();
178     $rs=$db->getAll($sql1);
179     $nr=$rs[0][$file."number"];
180     preg_match("/^([^0-9]*)([0-9]+)/",$nr,$hits);
181     if ($hits[2]) { $nr=$hits[2]+1; $nnr=$hits[1].$nr; }
182     else { $nr=$hits[1]+1; $nnr=$nr; };
183     $rc=$db->query(sprintf($sql2,$nnr));
184     if ($rc) { 
185         $db->commit(); 
186         return $nnr;
187     } else { 
188         $db->rollback(); 
189         return false;
190     };
191 }
192
193 function chkKdId($data) {
194 // gibt es die Nummer schon?
195     global $db,$file,$test;
196     $sql="select * from $file where ".$file."number = '$data'";
197     $rs=$db->getAll($sql);
198     if ($rs[0][$file."number"]==$data) {
199         // ja, eine neue holen
200         return getKdId();
201     } else {
202         return $data;
203     }
204 }
205
206 function chkContact($id) {
207     global $db;
208     $sql="select * from contact where cp_id = $id";
209     $rs=$db->getAll($sql);
210     if ($rs[0]["cp_id"]==$id) {
211         return true;
212     } else {
213         return false;
214     }
215 }
216
217 function getKdRefId($data) {
218 // gibt es die Nummer schon?
219     global $db,$file,$test;
220     if (empty($data) or !$data) {   
221         return false; 
222     } 
223     $sql="select * from $file where ".$file."number = '$data'";
224     $rs=$db->getAll($sql);
225     return $rs[0]["id"];
226 }
227
228 function suchFirma($tab,$data) {
229 // gibt die Firma ?
230     global $db;
231     if (empty($data) or !$data) {   
232         return false; 
233     }
234     $data=strtoupper($data);
235     $sql="select * from $tab where upper(name) like '%$data%'";
236     $rs=$db->getAll($sql);
237     if (!$rs) {
238         $org=$data;
239         while(strpos($data,"  ")>0) {
240             $data=ereg_replace("  "," ",$data);
241         }
242          $data=preg_replace("/[^A-Z0-9]/ ",".*",trim($data));
243         $sql="select * from $tab where upper(name) ~ '$data'"; 
244         $rs=$db->getAll($sql);
245         if (count($rs)==1) {
246             return array("cp_cv_id"=>$rs[0]["id"],"Firma"=>$rs[0]["name"]);
247         }
248         return false;
249     } else {
250         return array("cp_cv_id"=>$rs[0]["id"],"Firma"=>$rs[0]["name"]);
251     }
252 }
253
254
255 //Suche Nach Kunden-/Lieferantenummer
256 function getFirma($nummer,$tabelle) {
257     global $db;
258     $nummer=strtoupper($nummer);
259     $sql="select id from $tabelle where upper(".$tabelle."number) = '$nummer'";
260     $rs=$db->getAll($sql);
261     if (!$rs) {
262         $nr=ereg_replace(" ","%",$nummer);
263         $sql="select id,".$tabelle."number from $tabelle where upper(".$tabelle."number) like '$nr'";
264         $rs=$db->getAll($sql);
265         if ($rs) {
266             $nr=ereg_replace(" ","",$nummer);
267             foreach ($rs as $row) {
268                 $tmp=ereg_replace(" ","",$row[$tabelle."number"]);
269                 if ($tmp==$nr) return $row["id"];
270             }
271         } else { 
272             return false;
273         }
274     } else {
275         return $rs[0]["id"];
276     }
277 }
278
279 function getAllBG($db) {
280     $sql  = "select * from buchungsgruppen order by description";
281     $rs=$db->getAll($sql);
282     return $rs;
283 }
284
285 function getAllUnits($db,$type) {
286     $sql  = "select * from units where type = '$type' order by sortkey";
287     $rs=$db->getAll($sql);
288     return $rs;
289 }
290
291 function anmelden($login=false,$pwd=false) {
292     ini_set("gc_maxlifetime","3600");
293     $tmp = @file_get_contents("../config/authentication.pl");
294     preg_match("/'db'[ ]*=> '(.+)'/",$tmp,$hits);
295     $dbname=$hits[1];
296     preg_match("/'password'[ ]*=> '(.+)'/",$tmp,$hits);
297     $dbpasswd=$hits[1];
298     preg_match("/'user'[ ]*=> '(.+)'/",$tmp,$hits);
299     $dbuser=$hits[1];
300     preg_match("/'host'[ ]*=> '(.+)'/",$tmp,$hits);
301     $dbhost=($hits[1])?$hits[1]:"localhost";
302     preg_match("/'port'[ ]*=> '?(.+)'?/",$tmp,$hits);
303     $dbport=($hits[1])?$hits[1]:"5432";
304     preg_match("/[ ]*\\\$self->\{cookie_name\}[ ]*=[ ]*'(.+)'/",$tmp,$hits);
305     $cookiename=$hits[1];
306     if (!$cookiename) $cookiename='lx_office_erp_session_id';
307     if ($login) {
308         $auth=authuser($dbhost,$dbport,$dbuser,$dbpasswd,$dbname,false,$login,$pwd);
309     } else {
310         $cookie=$_COOKIE[$cookiename];
311         if (!$cookie) header("location: ups.html");
312         $auth=authuser($dbhost,$dbport,$dbuser,$dbpasswd,$dbname,$cookie,false,false);
313     };
314     if (!$auth) { return false; };
315     $_SESSION["sessid"]=$cookie;
316     $_SESSION["cookie"]=$cookiename;
317     $_SESSION["employee"]=$auth["login"];
318     $_SESSION["mansel"]=$auth["dbname"];
319     $_SESSION["dbname"]=$auth["dbname"];
320     $_SESSION["dbhost"]=(!$auth["dbhost"])?"localhost":$auth["dbhost"];
321     $_SESSION["dbport"]=(!$auth["dbport"])?"5432":$auth["dbport"];
322     $_SESSION["dbuser"]=$auth["dbuser"];
323     $_SESSION["dbpasswd"]=$auth["dbpasswd"];
324     $_SESSION["db"]=new myDB($_SESSION["dbhost"],$_SESSION["dbuser"],$_SESSION["dbpasswd"],$_SESSION["dbname"],$_SESSION["dbport"],$showErr);
325     $_SESSION["authcookie"]=$authcookie;
326     $sql="select * from employee where login='".$auth["login"]."'";
327     $rs=$_SESSION["db"]->getAll($sql);
328     if(!$rs) {
329             return false;
330     } else {
331         if ($rs) {
332             $tmp=$rs[0];
333             $_SESSION["termbegin"]=(($tmp["termbegin"]>=0)?$tmp["termbegin"]:8);
334             $_SESSION["termend"]=($tmp["termend"])?$tmp["termend"]:19;
335             $_SESSION["Pre"]=$tmp["pre"];
336             $_SESSION["interv"]=($tmp["interv"]>0)?$tmp["interv"]:60;
337             $_SESSION["loginCRM"]=$tmp["id"];
338             $_SESSION["lang"]=$tmp["countrycode"]; //"de";
339             $_SESSION["kdview"]=$tmp["kdview"];
340             $sql="select * from defaults";
341             $rs=$_SESSION["db"]->getAll($sql);
342             $_SESSION["ERPver"]=$rs[0]["version"];
343             return true;$_SESSION;
344         } else {
345             return false;
346         }
347     }
348 }
349
350 function authuser($dbhost,$dbport,$dbuser,$dbpasswd,$dbname,$cookie,$login,$pwd) {
351     $db=new myDB($dbhost,$dbuser,$dbpasswd,$dbname,$dbport,true);
352     if ($cookie) {
353         $sql="select sc.session_id,u.id from auth.session_content sc left join auth.user u on ";
354         $sql.="u.login=sc.sess_value left join auth.session s on s.id=sc.session_id ";
355         $sql.="where session_id = '$cookie' and sc.sess_key='login'";// order by s.mtime desc";
356         $rs=$db->getAll($sql,"authuser_1");
357         if (!$rs) return false;
358         $stmp="";
359         if (count($rs)>1) {
360             foreach($rs as $row) {
361                     $stmp.=$row["session_id"].",";
362             }
363             $sql1="delete from session where id in (".substr($stmp,-1).")";
364             $sql2="delete from session_content where session_id in (".substr($stmp,-1).")";
365             $db->query($sql1,"authuser_A");
366             $db->query($sql2,"authuser_B");
367             header("location:../login.pl?action=logout");
368         };
369         $sql="update auth.session set mtime = '".date("Y-M-d H:i:s.100001")."' where id = '".$rs[0]["session_id"]."'";
370         $db->query($sql,"authuser_3");
371         $sql="select * from auth.user where id=".$rs[0]["id"];
372     } else {
373         $sql = "select * from auth.user where login = '$login' and password = '$pwd'";
374     }
375     $rs1=$db->getAll($sql,"authuser_1");
376     if (!$rs1) return false;
377     $auth=array();
378     $auth["login"]=$rs1[0]["login"];
379     $sql="select * from auth.user_config where user_id=".$rs1[0]["id"];
380     $rs1=$db->getAll($sql,"authuser_2");
381     $keys=array("dbname","dbpasswd","dbhost","dbport","dbuser");
382     foreach ($rs1 as $row) {
383         if (in_array($row["cfg_key"],$keys)) {
384                 $auth[$row["cfg_key"]]=$row["cfg_value"];
385         }
386     }
387     return $auth;
388 }
389
390 /**
391  * Zeichencode übersetzen
392  *
393  * @param String $txt
394  */
395 function translate(&$txt) {
396     if (Auto) {
397         $encoding = mb_detect_encoding($data,"UTF-8,ISO-8859-1,ISO-8859-15,Windows-1252,ASCII");
398         $txt = iconv("$encoding",ServerCode."//TRANSLIT",$txt);
399         //$txt = mb_convert_encoding($txt, ServerCode,"$encoding");
400     } else {
401         $txt = iconv(FileCode,ServerCode."//TRANSLIT",$txt);
402         //$txt = mb_convert_encoding($txt, ServerCode,FileCode);
403     }
404 }
405
406 ?>