58 |
if (is_file($file.$xfile) && substr($xfile, -4) == ".csv") |
if (is_file($file.$xfile) && substr($xfile, -4) == ".csv") |
59 |
{ |
{ |
60 |
$files[$i] = $file.$xfile; |
$files[$i] = $file.$xfile; |
61 |
dolibarr_syslog($file.$xfile." ajouté"); |
dolibarr_syslog($xfile." ajouté"); |
62 |
$i++; |
$i++; |
63 |
} |
} |
64 |
else |
else |
65 |
{ |
{ |
66 |
dolibarr_syslog($file.$xfile." ignoré"); |
dolibarr_syslog($xfile." ignoré"); |
67 |
} |
} |
68 |
} |
} |
69 |
|
|
85 |
exit ; |
exit ; |
86 |
} |
} |
87 |
|
|
|
|
|
|
|
|
88 |
/* |
/* |
89 |
* Vérification du fournisseur |
* Vérification du fournisseur |
90 |
* |
* |
116 |
exit ; |
exit ; |
117 |
} |
} |
118 |
|
|
119 |
|
/* |
120 |
|
* Vérification des fichiers traités |
121 |
|
* |
122 |
|
*/ |
123 |
|
$fichiers = array(); |
124 |
|
$sql = "SELECT distinct(fichier_cdr)"; |
125 |
|
$sql .= " FROM ".MAIN_DB_PREFIX."telephonie_communications_details"; |
126 |
|
if ($db->query($sql)) |
127 |
|
{ |
128 |
|
while ($row = $db->fetch_row($resql)) |
129 |
|
{ |
130 |
|
array_push($fichiers, $row[0]); |
131 |
|
} |
132 |
|
$db->free($resql); |
133 |
|
} |
134 |
|
else |
135 |
|
{ |
136 |
|
dolibarr_syslog("Erreur recherche fournisseur"); |
137 |
|
} |
138 |
|
$sql = "SELECT distinct(fichier)"; |
139 |
|
$sql .= " FROM ".MAIN_DB_PREFIX."telephonie_import_cdr"; |
140 |
|
if ($db->query($sql)) |
141 |
|
{ |
142 |
|
while ($row = $db->fetch_row($resql)) |
143 |
|
{ |
144 |
|
array_push($fichiers, $row[0]); |
145 |
|
} |
146 |
|
$db->free($resql); |
147 |
|
} |
148 |
|
else |
149 |
|
{ |
150 |
|
dolibarr_syslog("Erreur recherche fournisseur"); |
151 |
|
exit ; |
152 |
|
} |
153 |
/* |
/* |
154 |
* Charge les ID de lignes |
* Charge les ID de lignes |
155 |
* |
* |
185 |
{ |
{ |
186 |
if (is_readable($xfile)) |
if (is_readable($xfile)) |
187 |
{ |
{ |
188 |
if ( _verif($db, $xfile) == 0) |
if ( _verif($db, $xfile, $fichiers) == 0) |
189 |
{ |
{ |
190 |
dolibarr_syslog("Lecture du fichier $xfile"); |
dolibarr_syslog("Lecture du fichier $xfile"); |
191 |
|
|
357 |
} |
} |
358 |
|
|
359 |
|
|
360 |
function _verif($db, $file) |
function _verif($db, $file, $fichiers) |
361 |
{ |
{ |
362 |
$result = 0; |
$result = 0; |
363 |
/* |
/* |
364 |
* Vérifie que le fichier n'a pas déjà été chargé |
* Vérifie que le fichier n'a pas déjà été chargé |
365 |
* |
* |
366 |
*/ |
*/ |
367 |
|
if (in_array (basename($file), $fichiers)) |
368 |
|
{ |
369 |
|
print "Trouvé Linux"; |
370 |
|
dolibarr_syslog ("Fichier ".basename($file)." déjà chargé/traité"); |
371 |
|
$result = -1; |
372 |
|
} |
373 |
|
|
374 |
|
|
375 |
|
/* |
376 |
$sql = "SELECT count(fichier)"; |
$sql = "SELECT count(fichier)"; |
377 |
$sql .= " FROM ".MAIN_DB_PREFIX."telephonie_import_cdr"; |
$sql .= " FROM ".MAIN_DB_PREFIX."telephonie_import_cdr"; |
378 |
$sql .= " WHERE fichier = '".basename($file)."'"; |
$sql .= " WHERE fichier = '".basename($file)."'"; |
401 |
dolibarr_syslog("Erreur SQL vérification du fichier"); |
dolibarr_syslog("Erreur SQL vérification du fichier"); |
402 |
$result = -1; |
$result = -1; |
403 |
} |
} |
404 |
|
|
|
/* |
|
|
* Vérifie que le fichier n'a pas déjà été traité |
|
|
* |
|
|
*/ |
|
|
|
|
405 |
$sql = "SELECT count(fichier_cdr)"; |
$sql = "SELECT count(fichier_cdr)"; |
406 |
$sql .= " FROM ".MAIN_DB_PREFIX."telephonie_communications_details"; |
$sql .= " FROM ".MAIN_DB_PREFIX."telephonie_communications_details"; |
407 |
$sql .= " WHERE fichier_cdr = '".basename($file)."'"; |
$sql .= " WHERE fichier_cdr = '".basename($file)."'"; |
431 |
dolibarr_syslog($sql); |
dolibarr_syslog($sql); |
432 |
$result = -1; |
$result = -1; |
433 |
} |
} |
434 |
|
*/ |
435 |
return $result; |
return $result; |
436 |
} |
} |
437 |
|
|
|
|
|
438 |
return $error; |
return $error; |