codice:
foreach($data as $value ){
if(substr($value->wbs, 0,3)=="WBS"){
$query = "SELECT * FROM tb_pianifica WHERE wbs ='".substr($value->wbs,3)."'";
$result = mysqli_query($connect, $query);
if ($result === false) {
echo "ERRORE CONNESSIONE DATABASE: " . mysqli_error($connect);
}
if (mysqli_num_rows($result)>0)
{ //AGGIORNA RECORD ESISTENTE
$sql=UpdateData($value);
if($connect->query($sql) == TRUE)
{
$CountUpdata=$CountUpdata+1;
}
else
{
$ErrUpdateData=$ErrUpdateData+1;
}
}
else
{ //INSERISCI NUOVO RECORD
$sql=InsertData($value);
if($connect->query($sql) === TRUE)
{
$CountIndata=$CountIndata+1;
}
else
{
$ErrInsertData=$ErrInsertData+1;
}
}
}
};
echo '<pre>';
echo "Record Aggiornati = " .$CountUpdata."</br>Record Inseriti = ".$CountIndata."</br>Errore Aggiornamento = " .$ErrUpdateData."</br>Errore Inserimento = ".$ErrInsertData;
echo '</pre>';
//FUNZIONE AGGIUNGI NUOVO RECORD
function InsertData($data){
$sql="INSERT INTO tb_pianifica (wbs,cons_eff,pianificato,budget,eff_tot,residuo_oda,disposto,disponibile,npp,anno,id_Status) VALUES ('".substr($data->wbs,3)."','" .str_replace(',','.',str_replace('.','',$data->cons_eff)). "','" .str_replace(',','.',str_replace('.','',$data->pianificato)). "','" .str_replace(',','.',str_replace('.','',$data->budget))."','".str_replace(',','.',str_replace('.','',$data->eff_tot))."','".str_replace(',','.',str_replace('.','',$data->residuo_oda))."','".str_replace(',','.',str_replace('.','',$data->disposto))."','".str_replace(',','.',str_replace('.','',$data->disponibile))."','".substr($data->wbs, 3,4)."','".substr($data->wbs, 8,4)."','1')";
return $sql;
};
//FUNZIONE AGGIORNA RECORD
function UpdateData($data){
$sql = "UPDATE tb_pianifica SET cons_eff='".$data->cons_eff."', pianificato='".$data->pianificato. "' WHERE wbs=".$data->wbs;
return $sql;
};