correcao nas ferramentas de upload

Edmar Moretti
1 parent fd2e6af1
Showing 5 changed files with 79 additions and 30 deletions Show diff stats
admin/php/estat_mapa_upload.php
admin/php/metaestat_mapa_uploadimagem.php
admin/php/metaestat_uploadcsv_submit.php
admin/php/metaestat_uploaddados_submit.php
admin/php/uploadgvp.php
@@ -8,6 +8,7 @@ error_reporting(0);
 ?>
 <html>
 <head>
+<link rel="stylesheet" type="text/css" href="../../css/input.css" />
 <link rel="stylesheet" type="text/css" href="../../css/geral.css" />
 <title></title>
 </head>
@@ -27,7 +28,7 @@ if (isset($_FILES[&#39;uploadimagem&#39;][&#39;name&#39;])){
 	//sobe arquivo
 	$Arquivo = $_FILES['uploadimagem']['tmp_name'];
 	//echo $Arquivo;
-	$status =  move_uploaded_file($Arquivo,$arq);
+	$status =  move_uploaded_file($Arquivo,str_replace(".png","",$arq).".png");
 	if($status != 1)
 	{echo "<p class='paragrafo' >Ocorreu um erro no envio do arquivo. Verifique as permissoes de escrita";exit;}
 	if($status == 1){
@@ -12,6 +12,7 @@ error_reporting(0);
 ?>
 <html>
 <head>
+<link rel="stylesheet" type="text/css" href="../../css/input.css" />
 <link rel="stylesheet" type="text/css" href="../../css/geral.css" />
 <title></title>
 </head>
@@ -31,12 +32,11 @@ if (isset($_FILES[&#39;uploadimagem&#39;][&#39;name&#39;])){
 	//sobe arquivo
 	$Arquivo = $_FILES['uploadimagem']['tmp_name'];
 	//echo $Arquivo;
-	$status =  move_uploaded_file($Arquivo,$arq);
+	$status =  move_uploaded_file($Arquivo,str_replace(".png","",$arq).".png");
 	if($status != 1)
 	{echo "<p class='paragrafo' >Ocorreu um erro no envio do arquivo. Verifique as permissoes de escrita";exit;}
 	if($status == 1){
 		echo "<p class='paragrafo' >Arquivo enviado.</p>";
-		chmod($arq,0777);
 	}
 	else{
 		echo "<p class='paragrafo' >Erro ao enviar o arquivo.</p>";
@@ -15,6 +15,7 @@ if (ob_get_level() == 0) ob_start();
 <html>
 <head>
 <meta http-equiv="content-type" content="text/html; charset=ISO-8859-1">
+<link rel="stylesheet" type="text/css" href="../../css/input.css" />
 <link rel="stylesheet" type="text/css" href="../../css/geral.css" />
 <title></title>
 </head>
@@ -37,7 +38,7 @@ if (ob_get_level() == 0) ob_start();
 			sleep(1);
 			$arqcsv = $_FILES['i3GEOuploadcsv']['tmp_name'];
 			$nomePrefixo = str_replace(" ","_",removeAcentos($_FILES['i3GEOuploadcsv']['name']));
-			$nomePrefixo = $nomePrefixo."_".(nomeRandomico(4));
+			$nomePrefixo = $nomePrefixo."_".(nomeRandomico(4)).".csv";
 			$Arquivo = $_FILES['i3GEOuploadcsv']['tmp_name'];
 			$status =  move_uploaded_file($Arquivo,$dir_tmp."/".$nomePrefixo);
@@ -65,7 +66,8 @@ if (ob_get_level() == 0) ob_start();
 				$colunas = explode(",",$buffer);
 				$separador = ",";
 			}
-			//var_dump($colunas);
+			echo "<p class='paragrafo' >Separador de colunas identificado: <b>".$separador."</b></p>";
+			echo "<p class='paragrafo' >Total de colunas: <b>".count($colunas)."</b></p>";
 			fclose ($handle);
 			//le o csv em um array
 			$handle = fopen ($arqcsv, "r");
@@ -75,18 +77,26 @@ if (ob_get_level() == 0) ob_start();
 			while (!feof($handle)) {
 				$buffer = fgets($handle);
 				if($buffer != $cabecalho){
-					$buffer = str_replace('"','',$buffer);
+					//$buffer = str_replace('"','',$buffer);
 					$buffer = str_replace("'",'',$buffer);
 					$buffer = str_replace("\n",'',$buffer);
 					$buffer = str_replace("\r",'',$buffer);
-					$temp = explode($separador,$buffer);
-					if(count($temp) == $ncolunas)
-						$linhas[] = $temp;
+					if($buffer != ""){
+						$temp = explode($separador,$buffer);
+						if(count($temp) == $ncolunas){
+							$linhas[] = $temp;
+						}
+						else{
+							echo "<p class='paragrafo' >A linha abaixo apresentou um erro - n&uacute;mero de colunas n&atilde;o bate com o cabe&ccedil;alho</p>";
+							var_dump($temp);
+							exit;
+						}
+					}
 				}
 			}
 			fclose ($handle);
 			//decobre o tipo de coluna
-			$testar = 10;
+			$testar = 50;
 			if(count($linhas) < $testar){
 				$testar = count($linhas);
 			}
@@ -112,7 +122,7 @@ if (ob_get_level() == 0) ob_start();
 			try {
 				$dbh = new PDO('pgsql:dbname='.$conexao["bancodedados"].';user='.$conexao["usuario"].';password='.$conexao["senha"].';host='.$conexao["host"].';port='.$conexao["porta"]);
 			} catch (PDOException $e) {
-				echo 'Connection failed: ' . $e->getMessage();
+				echo 'Connection failed: ' . " ";
 			}
 			//encoding do banco de dados
 			$sql = "SELECT pg_encoding_to_char(encoding) FROM pg_database WHERE datname = '".$conexao["bancodedados"]."'";
@@ -126,6 +136,8 @@ if (ob_get_level() == 0) ob_start();
 			if($encodingdb == "LATIN1"){
 				$encodingdb = "ISO-8859-1";
 			}
+			echo "<p class='paragrafo' >Codifica&ccedil;&atilde;o do banco: <b>".$encodingdb."</b></p>";
+
 			//gera o script para criar a tabela e verifica se ja existe
 			$sql = "SELECT table_name FROM information_schema.tables where table_schema = '".$_POST["i3GEOuploadcsvesquema"]."' AND table_name = '".$_POST["tabelaDestinocsv"]."'";
 			$res = $dbh->query($sql,PDO::FETCH_ASSOC);
@@ -149,6 +161,11 @@ if (ob_get_level() == 0) ob_start();
 				$sql .= implode(",",$temp).") WITH(OIDS=FALSE)";
 				$sqltabela[] = $sql;
 				$sqltabela[] = "ALTER TABLE ".$_POST["i3GEOuploadcsvesquema"].".".$_POST["tabelaDestinocsv"]." OWNER TO ".$conexao["usuario"];
+				if(!empty($_POST["comentarioCsv"])){
+					$enc = mb_detect_encoding($texto);
+					$_POST["comentarioCsv"] = mb_convert_encoding($_POST["comentarioCsv"],$encodingdb,$enc);
+					$sqltabela[] = "COMMENT ON TABLE ".$_POST["i3GEOuploadcsvesquema"].".".$_POST["tabelaDestinocsv"]." IS '".addcslashes($_POST["comentarioCsv"])."'";
+				}
 				echo "<br>Sql tabela: <pre>";
 				var_dump($sqltabela);
 				echo "</pre>";
@@ -178,29 +195,39 @@ if (ob_get_level() == 0) ob_start();
 			$nlinhas = count($linhas);
 			$valorX = 0;
 			$valorY = 0;
+			$escapar = "',<,>,%,#,@,(,)";
 			for ($i=0; $i<$nlinhas;$i++){
 				$s = $linhas[$i];
+				$s = str_replace('"','',$s);
+				$enc = mb_detect_encoding($s);
+				if($enc != ""){
+					$s = mb_convert_encoding($s,$encodingdb,$enc);
+				}
 				$vs = array();
 				for ($j=0; $j<$ncolunas;$j++){
-					if($tipoColuna[$colunas[$j]] == "varchar"){
+					$escape = "";
+					if($tipoColuna[$coluna] == "varchar"){
 						$texto = $s[$j];
-						$texto = str_replace("'","",$texto);
 						$enc = mb_detect_encoding($texto);
-						if(enc != ""){
-							$texto = "'".mb_convert_encoding($texto,$encodingdb,$enc)."'";
+						$textosl = addcslashes($texto,$escapar);
+						if($textosl != $texto){
+							$escape = "E";
+						}
+						if($enc != "" && $enc != $encodingdb){
+							$textosl = "$escape'".mb_convert_encoding($textosl,$encodingdb,$enc)."'";
 						}
 						else{
-							$texto = "'".$texto."'";
+							$textosl = "$escape'".$textosl."'";
 						}
-						if($texto == "''"){
-							$texto = 'null';
+						if($textosl == "''"){
+							$textosl = 'null';
 						}
-						$vs[] = $texto;
+						$vs[] = $textosl;
 					}
 					else{
 						$valor = $s[$j];
-						if($valor == ""){
-							$valor = "nulo";
+						if($valor == "" || (empty($valor) && $valor != 0)){
+							$valor = 'nulo';
 						}
 						$vs[] = $valor;
 					}
@@ -234,23 +261,42 @@ if (ob_get_level() == 0) ob_start();
 				try {
 					$dbh->query($linha);
 				} catch (PDOException $e) {
-					echo 'Erro: ' . $e->getMessage();
+					echo 'Erro: ' . " ";
 				}
 			}
+			$bdcon = pg_connect('dbname='.$conexao["bancodedados"].' user='.$conexao["usuario"].' password='.$conexao["senha"].' host='.$conexao["host"].' port='.$conexao["porta"]."options='-c client_encoding=LATIN1'");
+
 			foreach($linhasql as $linha){
 				try {
 					$res = $dbh->query($linha);
 					if($res == false){
-						echo "<br><br><span style=color:red >Erro em: </span>".$linha;
+						$res = pg_query($bdcon,$linha);
+						if($res == false){
+							$linha = remove_accents($linha);
+							$res = $dbh->query($linha);
+							if($res == false){
+								$res = pg_query($bdcon,$linha);
+								if($res == false){
+									echo "<br><br><span style=color:red >Erro em: </span>".$linha;
+								}
+							}
+							else{
+								echo "<br><br><span style=color:red >Linha com acentos removidos: </span>".$linha;
+							}
+						}
 					}
 				} catch (PDOException $e) {
-					echo 'Erro: ' . $e->getMessage();
+					echo 'Erro: ' . " ";
 				}
 			}
-			echo "<br>Registros existentes no CSV: ". $nlinhas;
 			$sql = "select * from ".$_POST["i3GEOuploadcsvesquema"].".".$_POST["tabelaDestinocsv"];
 			$q = $dbh->query($sql,PDO::FETCH_ASSOC);
 			$r = $q->fetchAll();
+			if($nlinhas != count($r)){
+				echo "<span style='color:red'>";
+			}
+			echo "<br>Registros existentes no CSV: ". $nlinhas;
+
 			echo "<br>Registros na tabela final: ". count($r);
 			echo "<b><br>Feito!!!<br>Fa&ccedil;a o reload da p&aacute;gina";
 		}
@@ -258,8 +304,8 @@ if (ob_get_level() == 0) ob_start();
 			echo "<p class='paragrafo' >Erro ao enviar o arquivo. Talvez o tamanho do arquivo seja maior do que o permitido.</p>";
 		}
-	?>
-	<script>window.scrollTo(0,10000);</script>
+		?>
+		<script>window.scrollTo(0,10000);</script>
 </body>
 </html>
@@ -7,7 +7,7 @@ if (isset($_FILES[&#39;i3GEOuploadArquivo&#39;][&#39;name&#39;]))
 {
 	require_once (dirname(__FILE__)."/../../ms_configura.php");
 	$Arquivoup = $_FILES['i3GEOuploadArquivo']['tmp_name'];
-	$nomearquivoserv = $dir_tmp."/upload".basename($Arquivoup);
+	$nomearquivoserv = $dir_tmp."/upload".basename($Arquivoup).".csv";
 	//echo $nomearquivoserv;
 	if(file_exists($nomearquivoserv)){
 		unlink($nomearquivoserv);
@@ -9,6 +9,7 @@ if (ob_get_level() == 0) ob_start();
 ?>
 <html>
 <head>
+<link rel="stylesheet" type="text/css" href="../../css/input.css" />
 <link rel="stylesheet" type="text/css" href="../../css/geral.css" />
 <title></title>
 </head>
@@ -21,9 +22,10 @@ if (isset($_FILES[&#39;i3GEOuploadgvp&#39;][&#39;name&#39;])){
 	ob_flush();
 	flush();
 	sleep(1);
-	$arq = $locaplic."/temas/".$_FILES['i3GEOuploadgvp']['name'];
-	//verifica nomes
 	verificaNome($_FILES['i3GEOuploadgvp']['name']);
+	$ArquivoDest = $_FILES['i3GEOuploadgvp']['name'];
+	$ArquivoDest = str_replace(".gvp","",$ArquivoDest).".gvp";
+	$arq = $locaplic."/temas/".$ArquivoDest;
 	if(file_exists($arq)){
 		unlink($arq);
 	}
	@@ -7,7 +7,7 @@ if (isset($_FILES['i3GEOuploadArquivo']['name']))		@@ -7,7 +7,7 @@ if (isset($_FILES['i3GEOuploadArquivo']['name']))
7	{	7	{
8	require_once (dirname(__FILE__)."/../../ms_configura.php");	8	require_once (dirname(__FILE__)."/../../ms_configura.php");
9	$Arquivoup = $_FILES['i3GEOuploadArquivo']['tmp_name'];	9	$Arquivoup = $_FILES['i3GEOuploadArquivo']['tmp_name'];
10	- $nomearquivoserv = $dir_tmp."/upload".basename($Arquivoup);	10	+ $nomearquivoserv = $dir_tmp."/upload".basename($Arquivoup).".csv";
11	//echo $nomearquivoserv;	11	//echo $nomearquivoserv;
12	if(file_exists($nomearquivoserv)){	12	if(file_exists($nomearquivoserv)){
13	unlink($nomearquivoserv);	13	unlink($nomearquivoserv);