Subversion Repositories Sigmater

<?php

function insert_TI11(&$file_blob) {
        
    global $conn, $ocierr, $progiscrizione, $periodo_da, $periodo_a, $keydett, $progiscrizioneass, $flag_ass, $idfile;
        
    $lob   = OCINewDescriptor($conn, OCI_D_LOB);
        
    $sql = "INSERT INTO S3_TI11_FILEINTERSCAMBIO ".
    $sql .= "(TI11_PROGISCRIZIONE, TI11_PERIODO_DA, TI11_PERIODO_A, TI11_FLAG_ASS, ";
    $sql .= "TI11_BLOB, TI11_KEYDETT, TI11_IDFILE, TI11_TIPODATO, TI11_PROGISCRIZIONEASS) values (";
    $sql .= "'$progiscrizione', to_date('$periodo_da', 'dd/mm/yyyy'), to_date('$periodo_a', 'dd/mm/yyyy'), ";
    $sql .= "$flag_ass, EMPTY_BLOB(), $keydett, $idfile, NULL, '$progiscrizioneass') ";
    $sql .= "returning TI11_BLOB into :doc";                          

    $stmt = OCIParse($conn, $sql);
    if ($stmt === false) {
        $msg = ' OCIParse fallita';
        $ocierr = array('message' => $msg, 'code' => 'OCIPARSE', 'sqltext' => $sql);
       return false;
    }
        
        OCIBindByName($stmt, ':doc', $lob, -1, OCI_B_BLOB);
         
    $ret = @OCIExecute($stmt, OCI_DEFAULT);
    
    if(!$ret) {
                                
        $ocierr = OCIError($stmt);
        return false;
    }    
    
    if (!$lob->save($file_blob)) {
        $msg = ' Salvataggio Blob fallito';
        $ocierr = array('message' => $msg, 'code' => 'SAVEBLOB', 'sqltext' => $sql);
       return false;    
    }   
   
    $lob->free(); 
    return true;
}

function update_servizidettaglio($opt, $keyerrore = 0, $autocommit = 1) {

        global $conn, $progiscrizione, $periodo_da, $periodo_a, $keydett, $flag_ass;
        global $idfile, $n_file_tot, $presenza_file;
        
        $up_TI04 = 1;
        
        $sql = "update S3_TI04_SERVIZIDETTAGLIO set ";
        
        if ($opt == 'LOG') {
                
                $up_TI04 = 0;
                        
                $riavviabile = select_catalogoerrori($keyerrore);
                
                if ($riavviabile === false) {
                        wlog(20025, 1);
                        $codstato = 2;
                }
                elseif ($riavviabile == '1') {
                        $codstato = 3;
                }
                else {
                        $codstato = 2;
                }
                 
                $sql .= "TI04_CODSTATO = $codstato, TI04_N_FILE = $idfile, ";
                if((!empty($n_file_tot))&& ($n_file_tot <>'')) 
                        $sql .= "TI04_N_FILE_TOT = $n_file_tot, TI04_PRESENZA_FILE = $presenza_file ";
                else
                        $sql .= "TI04_N_FILE_TOT = NULL, TI04_PRESENZA_FILE = $presenza_file ";
                $err = 20004;
        }
        elseif ($opt == 'NFILE') {
                $sql .= "TI04_N_FILE = $idfile, TI04_PRESENZA_FILE = 1 ";
                $err = 20021;
        }
        elseif ($opt == 'RIAVVIO') {
                $sql .= "TI04_PRESENZA_FILE = 0 ";
                $err = 20024;
        }       
        elseif ($opt == 'NFILETOT') {
                $sql .= "TI04_N_FILE_TOT = $n_file_tot ";
                $err = 20022;
        }
        
        $sql .= "where TI04_PROGISCRIZIONE = '$progiscrizione' and ";
        $sql .= "to_char(TI04_PERIODO_DA, 'dd/mm/yyyy') = '$periodo_da' and ";
        $sql .= "to_char(TI04_PERIODO_A, 'dd/mm/yyyy') = '$periodo_a' and ";
        $sql .= "TI04_KEYDETT = $keydett and TI04_FLAG_ASS = $flag_ass";
        
        if (!exec_sql($conn, $sql, $autocommit)) {
                
                OCIRollback($conn);
                wlog($err, 1, '', $up_TI04);
                return false;
        }
        else {
        
                return true;    
        }       
}

function select_dati_servizio($progiscrizione) {
        
        global $conn;
        
        $sql = "select distinct TI03_KEYSERVIZIO, TI02_NOME_XSD ";
        $sql .= ", (select TI02_NOME_XSD from S3_TI02_SERVIZI where TI02_KEYSERVIZIO = 8) INC_TER_XSD ";
        $sql .= ", TI03_PERIODICITA from S3_TI04_SERVIZIDETTAGLIO, S3_TI03_SERVIZIRICHIESTI, S3_TI02_SERVIZI ";
        $sql .= "where TI03_PROGISCRIZIONE = TI04_PROGISCRIZIONE and TI02_KEYSERVIZIO = TI03_KEYSERVIZIO ";
        $sql .= "and TI03_PROGISCRIZIONE = '$progiscrizione'";
                        
        $r_ks = exec_select_format($conn, $sql, 1);
        
        if (!$r_ks || $r_ks == 'NODATA') {
                
                return false;
        }
        else {
                
                return array($r_ks[0]['TI03_KEYSERVIZIO'], $r_ks[0]['TI02_NOME_XSD'], $r_ks[0]['INC_TER_XSD'], $r_ks[0]['TI03_PERIODICITA']);
        }       
}               

function select_catalogoerrori($keyerrore) {
        
        global $conn;
        
        $sql = "select TI08_RIAVVIO from S3_TI08_CATALOGOERRORI ";
        $sql .= "where TI08_KEYERRORE = $keyerrore";
                        
        $r = exec_select_format($conn, $sql, 1);
        
        if (!$r || $r == 'NODATA') {
                
                return false;
        }
        else {
                
                return $r[0]['TI08_RIAVVIO'];
        }       
}       

function delete_TI11($T11_file) {
        
        global $conn, $progiscrizione, $periodo_da, $periodo_a, $keydett, $flag_ass;
        
        $sql = "delete S3_TI11_FILEINTERSCAMBIO ";
        $sql .= "where TI11_PROGISCRIZIONE = '$progiscrizione' and ";
        $sql .= "to_char(TI11_PERIODO_DA, 'dd/mm/yyyy') = '$periodo_da' and ";
        $sql .= "to_char(TI11_PERIODO_A, 'dd/mm/yyyy') = '$periodo_a' and ";
        $sql .= "TI11_KEYDETT = $keydett and TI11_FLAG_ASS = $flag_ass and ";
        $sql .= "TI11_IDFILE = $T11_file";
        
        // NO AUTOCOMMIT                
        if (!exec_sql($conn, $sql, 0)) {
                
                return false;
        }       
        
        return true;

}       
?>