<?
class CsvImporter{
   
   var $id = "import";
   //un identificatore
   
   var $column_count = false;
   //numero di colonne del cvs, se settato serve per controllare che sia il file giusto
   
   var $start_row = false;
   //la prima riga da inserire
   
   var $row_function_name = false;
   //nome di una funzione che controllo e edita ogni riga. deve accettare in ingresso il riferrer dell'array riga e restituire true per confermare l'elaborazione, altrimenti la riga viene skippata 
   
   var $after_update_func = false;
   //nome di una funzione chiamata dopo qualsiasi update, ritorna true se ha fatto modifiche
	
	var $after_create_func = false;
   //nome di una funzione chiamata dopo un create andato a buon fine
   
   //LE QUERY USANO ALL'INTERNO $row[0], $row[1], ecc... DEVONO ESSERE DELIMITATE DA APICI SINGOLI! 
   //LE VARIABILI $row[n] STRINGA DEVONO ESSERE DELIMITATE CON APICI DOPPI (VENGONO QUOTATI NEL CONTENUTO DEL CAMPO)
   //es. 'update webuser set  email="$row[9]",  firstname="$row[1]",  address="$row[2]",  city="$row[3]",  zip="$row[4]",  state="$row[5]",  country="$row[6]",  cod_lingua="$row[7]",  sconto="$row[8]"  where uid="$row[0]"'
   
   var $find_query = false;
   //se settato serve per controllare se un record esiste ed eventualmente aggiornarlo (settare update_query) altrimenti settare $truncate_query 
   
	var $allow_multiple_rows_update = false;
   //se settato si prevede che find query ritorni più record per ogni id e che questi vengano aggiornati tutti contemporaneamente 
   
   var $truncate_query = false;
   //query per preparare la tabella all'inserimento di tutti i record del file senza controlli
   
   var $update_query = false;
   //necessaria in caso di find_query
   
   var $insert_query = false;
   //query di inserimento nuovo record
   
   var $file;
   
   var $delimiter = ";";
   
   var $log;//errors, updated, deleted, inserted...
   
   function CsvImporter($id){
      $this->id = $id;
      $this->log["insert_req"] = 0;
      $this->log["inserted"] = 0;
      $this->log["update_req"] = 0;
      $this->log["updated"] = 0;
      $this->log["skipped"] = 0;
      $this->log["deleted"] = 0;
   }
   
   function check(){
      if(!$this->file) $this->log["errors"][] = "Non è stato settato il file da cui importare";
//       if(!$this->insert_query) $this->log["errors"][] = "Non è stato la query per fare l'inserimento";
      if($this->find_query && !$this->update_query) $this->log["errors"][] = "E' stata settata la query per verificare l'esistenza di un record ma non quella per aggiornarlo se viene trovato";

      return !$this->log["errors"];
   }
   
   function import($file=null){
      if($file) $this->file = $file;
      
      if($this->check()){
        if($this->truncate_query){
            $this->eval_query($this->truncate_query);
            if(mysql_affected_rows() != -1) $this->log["deleted"] += mysql_affected_rows();
        }
        
        $counter = 0;
        $handle = fopen($this->file,"r");
        while (($row = fgetcsv($handle, 100000, $this->delimiter)) !== FALSE){
            $counter++;
            
            $func = $this->row_function_name;
            if($this->row_function_name && !$func($row)){//funzione custom di controllo e manipolazione
               $this->log["skipped"]++;
				// $this->log["skippedId"][] = $row[0];
            }
            else if($this->column_count && $this->column_count != count($row)){
               $this->log["errors"][] = "numero di colonne errato nella riga: ".var_export($row, true);
            }
            else if(!$this->start_row || $counter >= $this->start_row){
               
               if($this->find_query){
                  $r = $this->eval_query($this->find_query, $row);
                  $esistenti = mysql_num_rows($r);
               }
               else{
                  $esistenti = 0;
               }

            
               if($esistenti == 1 || ($esistenti > 1 && $this->allow_multiple_rows_update)){//aggiorno
                  $this->log["update_req"]++;
                  $this->eval_query($this->update_query, $row);
                  
                  $modifiche = mysql_affected_rows();
                  if($this->after_update_func && call_user_func($this->after_update_func, $row)){
                  	if(!$modifiche) $modifiche = 1;
                  }
                  if($modifiche){
							$this->log["updated"] += $modifiche?$modifiche:1;
							$this->log["updatedId"][] = $row[0];
						}
               }
               else if($esistenti === 0){//inserisco
                  $this->log["insert_req"]++;
                  if($this->insert_query){
	                  $this->eval_query($this->insert_query, $row);
	                  if(mysql_affected_rows() != -1){
	                  	if($this->after_insert_func) call_user_func($this->after_insert_func, $row);
								$this->log["inserted"] += mysql_affected_rows();
							}
	               }
               }
               else{//ci sono più righe con lo stesso id
                  $this->log["errors"][] = "sono state rilevate più righe con lo stesso identificativo. riga: ".var_export($row, true);
               }
            }
        }
        fclose($handle);
      }
      
      return $this->log;
   }
   
   function eval_query($query, &$row = null){//quoto e faccio la sostituzione
     if($row) foreach($row as $i=>$data){
         $query = str_replace('$row['.$i.']', str_replace('"', '\"', $data), $query);
     }

     
     $r = mysql_query($query);
     if(mysql_error()) $this->log["errors"][] = mysql_error() . "<br />" . $query;
     return $r;
   }
   
   
   function basicUsage($file = null){
	  
	  $src = $file ? $file : $_FILES['file_source']['tmp_name'];
      
	  if(!$file) $out = $this->getSimpleForm();
	  
      if(($file||$_POST["go_$this->id"]) && $src){
         $log = $this->import($src);  
         $out .= "<h3>Log importazione $this->id (cambiamenti effettivi/richieste):</h3>";
         $out .= "<ul>";
         if($log["deleted"]) $out .= "<li>cancellati: $log[deleted]</li>";
         if($log["update_req"]) $out .= "<li>aggiornati: $log[updated]/$log[update_req]</li>";
         // if($log["updatedId"]) $out .= "<li>aggiornatiId: ".implode(", ", $log['updatedId'])."</li>";
         if($log["insert_req"]) $out .= "<li>inseriti: $log[inserted]/$log[insert_req]</li>";
         if($log["skipped"]) $out .= "<li>saltati: $log[skipped]</li>";
         // if($log["skippedId"]) $out .= "<li>saltatiId: ".implode(", ", $log['skippedId'])."</li>";
         $out .= "<li>errori: ".count($log[errors])."</li>";
         $out .= "</ul>";
         unlink($src);
      }
	  
      $this->check();
      if($log["errors"]){
        $out .= "<h3>Errori importazione $this->id:</h3>";
        $out .= "<ul>";
        foreach($log["errors"] as $e) $out .= "<li>$e</li>";
        $out .= "</ul>";
      }
      return $out;   
   }
   
   function getSimpleForm(){
      return '
        <table border="0" align="center">
           <tr>
              <form method="post" enctype="multipart/form-data">
               	<td>File &quot;'.ucfirst($this->id).'.csv&quot;:</td>
               	<td><input type="file" name="file_source" id="file_source" class="edt" value=""></td>
               	<td><td colspan="3" align="center"><input type="Submit" name="go_'.$this->id.'" value="Importa '.$this->id.'"></td></td>
              </form>
           </tr>
        </table>';
   }
   
   
}
?>