<?php
$select = "SELECT * FROM sav.type_visite";
$result = $connPostgre->query($select)->fetchAll();
$typeVisite = [];
foreach ($result as $value){
    $typeVisite[$value['code']] = $value['id'];
}

$select = "SELECT tmp.*, e.idadresse FROM sav.tmp_correspondance_equipement tmp LEFT JOIN sav.equipement e ON e.id = tmp.idequipement ";
$result = $connPostgre->query($select)->fetchAll();
$correspondanceIdEquip = [];
foreach ($result as $value){
    $correspondanceIdEquip[$value['idsite']][$value['idchaudiere_oracle']]['idequipement'] = $value['idequipement'];
    $correspondanceIdEquip[$value['idsite']][$value['idchaudiere_oracle']]['idclient'] = $value['idclient'];
    $correspondanceIdEquip[$value['idsite']][$value['idchaudiere_oracle']]['idadresse'] = $value['idadresse'];
}

$select = "SELECT * FROM sav.tmp_correspondance_moment_passage";
$result = $connPostgre->query($select)->fetchAll();
$correspondanceMomentPassage = [];
foreach ($result as $value){
    $correspondanceMomentPassage[$value['idsite']][$value['moment_passage_oracle']] = $value['idmoment_passage'];
}

foreach($sites as $cle => $site){
    $stid = oci_parse($connOracle[$site['nom']], "SELECT * FROM INTERV_LOG");
    oci_execute($stid);
    $nbResult = oci_fetch_all($stid, $result,  0, -1, OCI_ASSOC + OCI_FETCHSTATEMENT_BY_ROW);
    if($nbResult == 0){
        continue;
    }
    $insertPlanningHistoriqueModification = "INSERT INTO sav.planning_historique_modification(id, idplanning, idplanning_action, idequipement, idutilisateur_agent, idtype_plannification, date, memo, idmoment_passage, idplanning_initiative_type, idplanning_initiative_detail, date_action, idutilisateur, avis_passage, avis_passage_mail) VALUES ";
    $idPlanningHistoriqueModification = 1;
    $count = 0;
    //TO DO !
//    foreach($result as $cle => $row){
//        $idProduit++;
//        $insertProduit .= "('".$idProduit."','".$row['CODE_ARTICLE']."','".str_replace("'","''", $row['DESIGNATION'])."',null,null,null,'".$idProduitType."','".$site['id']."')";
//        $insertProduitStockSite .= "('".$site['id']."','".$idProduit."','".($row['TARIF'] == 'N' ? 0 : 1)."','".($row['STOCK_MINI'] == '' ? 0 : $row['STOCK_MINI'])."','".($row['STOCK_REEL'] == '' ? 0 : $row['STOCK_REEL'])."','".($row['STOCK_INITIAL'] == '' ? 0 : $row['STOCK_INITIAL'])."','".($row['INCLURE_COMMANDE'] == '' ? 0 : $row['INCLURE_COMMANDE'])."','".($row['STOCK_REAPPRO'] == '' ? 0 : $row['STOCK_REAPPRO'])."')";
//        $count++;
//        if(($count) != $nbResult){
//            $insertProduit .= ",";
//            $insertProduitStockSite .= ",";
//        }
//    }
//    $connPostgre->query($insertProduit);
//    $connPostgre->query($insertProduitStockSite);
}