codice:
<?phpinclude "db_connect.php";
$connect = OpenCon();
$data= $_POST["pTableData"];
//$data = '';
$data = json_decode($data);
$CountUpdata=0;
$CountIndata=0;
$ErrUpdateData=0;
$ErrInsertData=0;
foreach($data as $value ){
if(substr($value->wbs, 0,3)=="WBS" && strlen($value->wbs)>16){
$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,$connect);
//Controllo se andata a buon fine aggiornamento
if($connect->query($sql) == TRUE)
{
$CountUpdata=$CountUpdata+1;
}
else
{
$ErrUpdateData=$ErrUpdateData+1;
}
}
else
{ //INSERISCI NUOVO RECORD
$sql=InsertData($value,$connect);
//Controllo se andata a buon fine inserimento
if($connect->query($sql) === TRUE)
{
$CountIndata=$CountIndata+1;
}
else
{ echo $sql;
$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,$connect){
$wbs = substr($data->wbs,3);
$cons_eff = str_replace(',','.',str_replace('.','',$data->cons_eff));
$pianificato = str_replace(',','.',str_replace('.','',$data->pianificato));
$budget = str_replace(',','.',str_replace('.','',$data->budget));
$eff_tot = str_replace(',','.',str_replace('.','',$data->eff_tot));
$residuo_oda = str_replace(',','.',str_replace('.','',$data->residuo_oda));
$disposto = str_replace(',','.',str_replace('.','',$data->disposto));
$disponibile = str_replace(',','.',str_replace('.','',$data->disponibile));
$npp = substr($data->wbs, 3,4);
// cerca id nnp
$query = "SELECT * FROM tb_npp WHERE codice ='".$npp."'";
$result = mysqli_query($connect, $query);
if ($result === false) {
echo "ERRORE CONNESSIONE DATABASE: " . mysqli_error($connect);
}
if (mysqli_num_rows($result)>0){
//NPP TROVATA
while($row = $result->fetch_assoc()) {
$id_npp= $row["id"];
}
//$id_npp = $data->id;
}
else {
//NPP NON TROVATA
echo "NPP NON TROVATA : ";
}
$sql="INSERT INTO tb_pianifica (wbs,cons_eff,pianificato,budget,eff_tot,residuo_oda,disposto,disponibile,id_npp,id_Status) VALUES ('".$wbs."','" .$cons_eff. "','" .$pianificato. "','" .$budget."','".$eff_tot."','".$residuo_oda."','".$disposto."','".$disponibile."','".$id_npp."','1')";
return $sql;
};
//FUNZIONE AGGIORNA RECORD
function UpdateData($data,$connect){
$wbs = substr($data->wbs,3);
$cons_eff = str_replace(',','.',str_replace('.','',$data->cons_eff));
$pianificato = str_replace(',','.',str_replace('.','',$data->pianificato));
$budget = str_replace(',','.',str_replace('.','',$data->budget));
$eff_tot = str_replace(',','.',str_replace('.','',$data->eff_tot));
$residuo_oda = str_replace(',','.',str_replace('.','',$data->residuo_oda));
$disposto = str_replace(',','.',str_replace('.','',$data->disposto));
$disponibile = str_replace(',','.',str_replace('.','',$data->disponibile));
$npp = substr($data->wbs, 3,4);
// cerca id nnp
$query = "SELECT * FROM tb_npp WHERE codice ='".$npp."'";
$result = mysqli_query($connect, $query);
if ($result === false) {
echo "ERRORE CONNESSIONE DATABASE: " . mysqli_error($connect);
}
if (mysqli_num_rows($result)>0){
//NPP TROVATA
while($row = $result->fetch_assoc()) {
$id_npp= $row["id"];
}
//$id_npp = $data->id;
}
else {
//NPP NON TROVATA
echo "NPP NON TROVATA : ";
}
$sql = "UPDATE tb_pianifica SET cons_eff='".$cons_eff."', pianificato='".$pianificato. "', budget='".$budget. "',eff_tot='".$eff_tot. "',residuo_oda='".$residuo_oda. "',disposto='".$disposto. "',disponibile='".$disponibile. "',id_npp='".$id_npp. "' WHERE wbs=".$wbs;
return $sql;
};
?>