Subversion Repositories Sigmater

Rev

Details | Last modification | View Log | RSS feed

Rev Author Line No. Line
6 Andrea 1 
<?php
2 
 
3 
function extract_blob($progiscrizione, $periodo_da, $periodo_a, $flag_ass, $keydett, $idfile) {
4 
 
5 
	global $conn;
6 
 
7 
	$sql = "select TI11_BLOB from S3_TI11_FILEINTERSCAMBIO ";
8 
	$sql .= "where TI11_PROGISCRIZIONE = '$progiscrizione' and ";
9 
	$sql .= "to_char(TI11_PERIODO_DA, 'dd/mm/yyyy') = '$periodo_da' and ";
10 
	$sql .= "to_char(TI11_PERIODO_A, 'dd/mm/yyyy') = '$periodo_a' and ";
11 
	$sql .= "TI11_FLAG_ASS = $flag_ass and TI11_KEYDETT = $keydett and TI11_IDFILE = $idfile";
12 
	$r_select = exec_select_format($conn, $sql, 0);
13 
 
14 
	if (!$r_select)
15 
		return array(false, 30002, '');
16 
 
17 
	if ($r_select == 'NODATA')
18 
		return array(false, 30003, 'Blob non trovato');
19 
 
20 
	$blob = $r_select[0][0]->load();
21 
 
22 
	if (strlen($blob) == 0)
23 
		return array(false, 30004, 'Blob vuoto');
24 
 
25 
	return array(true, $blob, '');
26 
}
27 
 
28 
function insert_protocollo_staging($keyservizio, $keycom, $keysez, $periodo_da, $periodo_a, $protocollo, $autocommit = 0) {
29 
 
30 
	global $conn;
31 
 
32 
	if ($keyservizio > 6 && $keyservizio < 11) {
33 
		$tipo_dato = 'C';
34 
	}else if($keyservizio == 6){
35 
		$tipo_dato = 'A';
36 
        }else if($keyservizio == 5){
37 
                $tipo_dato = 'M';
38 
        }
39 
        else if($keyservizio == 3){
40 
                $tipo_dato = 'E';
41 
        }else {
42 
		$tipo_dato = 'G';
43 
	}
44 
 
45 
	$sql = "select TI07_PROTOCOLLO_STAGING from S3_TI07_PROTOCOLLI ";
46 
	$sql .= "where TI07_KEYCOM = '$keycom' and TI07_KEYSEZ = '$keysez' and ";
47 
	$sql .= "to_char(TI07_PERIODO_DA, 'dd/mm/yyyy') = '$periodo_da' and ";
48 
	$sql .= "to_char(TI07_PERIODO_A, 'dd/mm/yyyy') = '$periodo_a'";
49 
 
50 
	$r_select = exec_select_format($conn, $sql, 0);
51 
 
52 
	if (!$r_select)
53 
		return array(false, 30010);
54 
 
55 
	if ($r_select == 'NODATA') {
56 
 
57 
		$sql = "select TI07_STAGING_SEQ.nextval from dual";
58 
 
59 
		$r_select = exec_select_format($conn, $sql, 0);
60 
 
61 
		if (!$r_select)
62 
			return array(false, 30011);
63 
 
64 
		$protocollo_staging = $r_select[0][0];
65 
	}
66 
	else {
67 
 
68 
		$protocollo_staging = $r_select[0][0];
69 
	}
70 
 
71 
	$sql = "insert into S3_TI07_PROTOCOLLI (TI07_PROTOCOLLO, TI07_PROTOCOLLO_STAGING, ";
72 
	$sql .= "TI07_KEYCOM, TI07_KEYSEZ, TI07_PERIODO_DA, TI07_PERIODO_A, TI07_TIPO_FORNITURA, TI07_TIPO_PROCESSO) ";
73 
	$sql .= "values($protocollo, $protocollo_staging, ";
74 
	$sql .= "'$keycom', '$keysez', to_date('$periodo_da', 'dd/mm/yyyy'), ";
75 
	$sql .= "to_date('$periodo_a', 'dd/mm/yyyy'), 'I', '$tipo_dato')";
76 
 
77 
	if (!exec_sql($conn, $sql, $autocommit))
78 
		return array(false, 30012);
79 
	else
80 
		return array(true, $protocollo_staging);
81 
}
82 
 
83 
function check_fornitura($progiscrizione, $periodo_da, $periodo_a, $flag_ass, $keydett, $stato) {
84 
 
85 
	global $conn;
86 
 
87 
	$sql = "select TI04_N_FILE_TOT, TI04_PROTOCOLLO,TI04_KEYDETT from S3_TI04_SERVIZIDETTAGLIO ";
88 
	$sql .= "where TI04_PROGISCRIZIONE = '$progiscrizione' and ";
89 
	$sql .= "to_char(TI04_PERIODO_DA, 'dd/mm/yyyy') = '$periodo_da' and ";
90 
	$sql .= "to_char(TI04_PERIODO_A, 'dd/mm/yyyy') = '$periodo_a' and ";
91 
	//$sql .= "TI04_FLAG_ASS = $flag_ass and TI04_KEYDETT = $keydett and TI04_CODSTATO = $stato";
92 
	$sql .= "TI04_FLAG_ASS = $flag_ass and TI04_CODSTATO = $stato";
93 
 
94 
 
95 
	$r_select = exec_select_format($conn, $sql, 1);
96 
 
97 
 
98 
	if (!$r_select)
99 
		return array(false, '', '','');
100 
 
101 
	if ($r_select == 'NODATA')
102 
		return array('NODATA', '', '','');
103 
 
104 
	return array(true, $r_select[0]['TI04_N_FILE_TOT'], $r_select[0]['TI04_PROTOCOLLO'], $r_select[0]['TI04_KEYDETT']);
105 
}
106 
 
107 
function insert_blob_cart($filename, $protocollo_fornitura, $protocollo_staging, $progressivo) {
108 
 
109 
	global $conn;
110 
 
111 
	$sql = "insert into TCW24_BLOB_CART ";
112 
	$sql .= "values($protocollo_fornitura, $progressivo, EMPTY_BLOB(), $protocollo_staging)";
113 
 
114 
	$OCI_OPT = array('INS_BLOB' => 'TCW24_FILE_BLOB');
115 
 
116 
	$ret = exec_sql_blob_file($conn, $sql, 0, $OCI_OPT,$filename);
117 
 
118 
	if(!$ret)
119 
		return array(false, 30028, '');
120 
 
121 
        unlink($filename);
122 
        return array(true, '', '');
123 
}
124 
 
125 
// MM funzione per Apache 2
126 
function insert_blob_plan($filename,$arr_riga,$protocollo_staging) {
127 
 
128 
        global $conn;
129 
 
130 
        //comune
131 
        $comune = "'".$arr_riga[1]."'";
132 
 
133 
        // sezione
134 
        if(strlen($arr_riga[2]) == 0)
135 
         $sezione =  "'".'@'."'";
136 
        else
137 
         $sezione = "'".$arr_riga[2]."'";
138 
        // uiu
139 
        $uiu = $arr_riga[3];
140 
        // mutazione iniziale
141 
        $mutazione_in = $arr_riga[4];
142 
 
143 
        // mutazione finale
144 
        if(strlen($arr_riga[5]) == 0)
145 
          $mutazione_fn=-1;
146 
        else
147 
          $mutazione_fn = $arr_riga[5];
148 
 
149 
        $tipo =  "'".$arr_riga[6]."'";
150 
        $nome =  "'".$arr_riga[7]."'";
151 
        $pagina = $arr_riga[8];
152 
 
153 
        $sql = "insert into TCW22_BLOB ";
154 
        $sql .= "values($comune,$sezione,$uiu,$mutazione_in,$mutazione_fn,$tipo,$nome,$pagina,EMPTY_BLOB(),$protocollo_staging)";
155 
 
156 
        $OCI_OPT = array('INS_BLOB' => 'FILE_BLOB');
157 
 
158 
        $ret = exec_sql_blob_file($conn, $sql, 0, $OCI_OPT,$filename);
159 
 
160 
        if(!$ret)
161 
                return array(false, 30028, '');
162 
 
163 
        unlink($filename);
164 
 
165 
        return array(true, '', '');
166 
}
167 
 
168 
 
169 
?>