Subversion Repositories Sigmater

<?php

function extract_blob($progiscrizione, $periodo_da, $periodo_a, $flag_ass, $keydett, $idfile) {
        
        global $conn;
        
        $sql = "select TI11_BLOB from 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_FLAG_ASS = $flag_ass and TI11_KEYDETT = $keydett and TI11_IDFILE = $idfile";
        $r_select = exec_select_format($conn, $sql, 0);
        
        if (!$r_select)
                return array(false, 30002, '');

        if ($r_select == 'NODATA')
                return array(false, 30003, 'Blob non trovato');
        
        $blob = $r_select[0][0]->load();
        
        if (strlen($blob) == 0)
                return array(false, 30004, 'Blob vuoto');
                
        return array(true, $blob, '');
}

function insert_protocollo_staging($keyservizio, $keycom, $keysez, $periodo_da, $periodo_a, $protocollo, $autocommit = 0) {
        
        global $conn;
        
        if ($keyservizio > 6 && $keyservizio < 11) {
                $tipo_dato = 'C';
        }else if($keyservizio == 6){
                $tipo_dato = 'A';
        }else if($keyservizio == 5){
                $tipo_dato = 'M'; 
        }
        else if($keyservizio == 3){
                $tipo_dato = 'E'; 
        }else { 
                $tipo_dato = 'G';
        }
                
        $sql = "select TI07_PROTOCOLLO_STAGING from S3_TI07_PROTOCOLLI ";
        $sql .= "where TI07_KEYCOM = '$keycom' and TI07_KEYSEZ = '$keysez' and ";
        $sql .= "to_char(TI07_PERIODO_DA, 'dd/mm/yyyy') = '$periodo_da' and ";
        $sql .= "to_char(TI07_PERIODO_A, 'dd/mm/yyyy') = '$periodo_a'";
        
        $r_select = exec_select_format($conn, $sql, 0);
        
        if (!$r_select)
                return array(false, 30010);

        if ($r_select == 'NODATA') {
                
                $sql = "select TI07_STAGING_SEQ.nextval from dual";
                
                $r_select = exec_select_format($conn, $sql, 0);
                
                if (!$r_select)
                        return array(false, 30011);
                
                $protocollo_staging = $r_select[0][0];
        }       
        else {
                
                $protocollo_staging = $r_select[0][0];
        }       
                
        $sql = "insert into S3_TI07_PROTOCOLLI (TI07_PROTOCOLLO, TI07_PROTOCOLLO_STAGING, ";
        $sql .= "TI07_KEYCOM, TI07_KEYSEZ, TI07_PERIODO_DA, TI07_PERIODO_A, TI07_TIPO_FORNITURA, TI07_TIPO_PROCESSO) ";
        $sql .= "values($protocollo, $protocollo_staging, ";
        $sql .= "'$keycom', '$keysez', to_date('$periodo_da', 'dd/mm/yyyy'), ";
        $sql .= "to_date('$periodo_a', 'dd/mm/yyyy'), 'I', '$tipo_dato')";
        
        if (!exec_sql($conn, $sql, $autocommit))
                return array(false, 30012);
        else    
                return array(true, $protocollo_staging);
}

function check_fornitura($progiscrizione, $periodo_da, $periodo_a, $flag_ass, $keydett, $stato) {
        
        global $conn;
          
        $sql = "select TI04_N_FILE_TOT, TI04_PROTOCOLLO,TI04_KEYDETT from S3_TI04_SERVIZIDETTAGLIO ";
        $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_FLAG_ASS = $flag_ass and TI04_KEYDETT = $keydett and TI04_CODSTATO = $stato";
        $sql .= "TI04_FLAG_ASS = $flag_ass and TI04_CODSTATO = $stato";
        
        
        $r_select = exec_select_format($conn, $sql, 1);
        
        
        if (!$r_select)
                return array(false, '', '','');

        if ($r_select == 'NODATA')
                return array('NODATA', '', '','');

        return array(true, $r_select[0]['TI04_N_FILE_TOT'], $r_select[0]['TI04_PROTOCOLLO'], $r_select[0]['TI04_KEYDETT']);
}

function insert_blob_cart($filename, $protocollo_fornitura, $protocollo_staging, $progressivo) {

        global $conn;
        
        $sql = "insert into TCW24_BLOB_CART ";
        $sql .= "values($protocollo_fornitura, $progressivo, EMPTY_BLOB(), $protocollo_staging)";
        
        $OCI_OPT = array('INS_BLOB' => 'TCW24_FILE_BLOB');
        
        $ret = exec_sql_blob_file($conn, $sql, 0, $OCI_OPT,$filename);
        
        if(!$ret)
                return array(false, 30028, '');
                
        unlink($filename);
        return array(true, '', '');
}

// MM funzione per Apache 2
function insert_blob_plan($filename,$arr_riga,$protocollo_staging) {

        global $conn;

        //comune 
        $comune = "'".$arr_riga[1]."'";

        // sezione 
        if(strlen($arr_riga[2]) == 0)
         $sezione =  "'".'@'."'";
        else   
         $sezione = "'".$arr_riga[2]."'";
        // uiu
        $uiu = $arr_riga[3];  
        // mutazione iniziale
        $mutazione_in = $arr_riga[4]; 

        // mutazione finale 
        if(strlen($arr_riga[5]) == 0)
          $mutazione_fn=-1; 
        else
          $mutazione_fn = $arr_riga[5]; 
        
        $tipo =  "'".$arr_riga[6]."'"; 
        $nome =  "'".$arr_riga[7]."'"; 
        $pagina = $arr_riga[8]; 

        $sql = "insert into TCW22_BLOB ";
        $sql .= "values($comune,$sezione,$uiu,$mutazione_in,$mutazione_fn,$tipo,$nome,$pagina,EMPTY_BLOB(),$protocollo_staging)";
        
        $OCI_OPT = array('INS_BLOB' => 'FILE_BLOB');

        $ret = exec_sql_blob_file($conn, $sql, 0, $OCI_OPT,$filename);

        if(!$ret)
                return array(false, 30028, '');

        unlink($filename);

        return array(true, '', '');
}


?>