$1

Edmar Moretti
1 parent 112cad2d
Showing 5 changed files with 253 additions and 1 deletions Show diff stats
admin/admin.db
admin/js/estat_editor.js
admin/php/metaestat_uploadcsv_submit.php
pacotes/atualiza.py
pacotes/proxy.db
@@ -533,7 +533,7 @@ i3GEOadmin.editor = {
 			'<option value=apagar >Apagar dados atuais e incluir do SHP</option>' +
 			'</select></p>' +
 			'<p class="paragrafo" >C&oacute;digo da proje&ccedil;&atilde;o (SRID) Assegure-se que o shapefile esteja na proje&ccedil;&atilde;o geogr&aacute;fica se voc&ecirc; for usar com o sistema de metadados estat&iacute;sticos :<br><input class=digitar type="text" value="4326" size=20 id="srid" name="srid" style="top:0px;left:0px;cursor:pointer;"></p>' +
-			'<p class="paragrafo" ><input type="checkbox" id="incluiserialshp" name="incluiserialshp" style="cursor:pointer;position:relative;top:2px;">&nbsp;Inclui uma coluna gid do tipo serial e chave prim&aacute;ria com c&oacute;digo &uacute;nico</p>' +			
+			'<p class="paragrafo" ><input type="checkbox" id="incluiserialshp" name="incluiserialshp" style="cursor:pointer;position:relative;top:2px;">&nbsp;Inclui uma coluna gid do tipo serial e chave prim&aacute;ria com c&oacute;digo &uacute;nico</p>' +
 			'<p class="paragrafo" ><input id=i3GEOuploadsubmit type="button" value="Enviar" size=12 />' +
 			'<input type="hidden" name="MAX_FILE_SIZE" value="1000000">' +
 			'<input type="hidden" id="i3GEOuploadcodigoconexao" name="i3GEOuploadcodigoconexao" value="">' +
@@ -564,6 +564,7 @@ i3GEOadmin.editor = {
 			$i("i3GEOuploadcodigoconexao").value = $i("i3GEOadmincodigo_estat_conexao").value;
 			$i("i3GEOuploadesquema").value = $i("i3GEOadminesquema").value;
 			$i("i3GEOuploadf").submit();
+			$i("tabelaDestino").value = "";
 		}
 	},
 	uploadcsv: {
@@ -584,6 +585,8 @@ i3GEOadmin.editor = {
 			var ins = '<fieldset><form id=i3GEOuploadcsvf target="i3GEOuploadcsviframe" action="../php/metaestat_uploadcsv_submit.php" method="post" ENCTYPE="multipart/form-data">' +
 			'<p class="paragrafo" >CSV (utilize ponto como separador de valores decimais ou a importa&ccedil;&atilde;o poder&aacute; n&atilde;o ocorrer): <br><input class=digitar type="file" size=22 name="i3GEOuploadcsv" style="top:0px;left:0px;cursor:pointer;"></p>' +
 			'<p class="paragrafo" >Nome da nova tabela (n&atilde;o utilize caracteres incompat&iacute;veis com o banco de dados, como -, acentos ou espa&ccedil;os em branco):<br><input class=digitar type="text" size=20 id="tabelaDestinocsv" name="tabelaDestinocsv" style="top:0px;left:0px;cursor:pointer;"></p>' +
+			'<p class="paragrafo" ><input type="checkbox" id="incluiserialcsv" name="incluiserialcsv" style="cursor:pointer;position:relative;top:2px;">&nbsp;Inclui uma coluna gid do tipo serial e chave prim&aacute;ria com c&oacute;digo &uacute;nico</p>' +
+
 			'<p class="paragrafo" ><input id=i3GEOuploadcsvsubmit type="button" value="Enviar" size=12 />' +
 			'<input type="hidden" name="MAX_FILE_SIZE" value="1000000">' +
 			'<input type="hidden" id="i3GEOuploadcsvcodigoconexao" name="i3GEOuploadcsvcodigoconexao" value="">' +
@@ -602,6 +605,7 @@ i3GEOadmin.editor = {
 			$i("i3GEOuploadcsvcodigoconexao").value = $i("i3GEOadmincodigo_estat_conexao").value;
 			$i("i3GEOuploadcsvesquema").value = $i("i3GEOadminesquema").value;
 			$i("i3GEOuploadcsvf").submit();
+			$i("tabelaDestinocsv").value = "";
 		}
 	},
 	esvaziaFormsUpload: function(){
@@ -162,6 +162,9 @@ if (ob_get_level() == 0) ob_start();
 	ob_flush();
 	flush();
 	sleep(1);
+	if($_POST["incluiserialcsv"] == "on"){
+		$linhasql[] = "alter table ".$_POST["i3GEOuploadcsvesquema"].".".$_POST["tabelaDestinocsv"]." add gid serial CONSTRAINT gid_pkey PRIMARY KEY";
+	}
 	foreach($sqltabela as $linha){
 		try {
 			$dbh->query($linha);
@@ -0,0 +1,245 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+"""
+Created on Fri Jan 11 17:26:01 2013
+
+@author: Diego
+"""
+import os, subprocess
+import sqlite3
+import os
+import time
+
+TABELA_ORIGINAL = 'tb_proxy'
+
+tables = {}
+tables[TABELA_ORIGINAL] =  [[u'id', u'INTEGER PRIMARY KEY'],
+                        [u'proxy', u'TEXT'],
+                        [u'port', u'TEXT'],
+                        [u'user', u'TEXT'],
+                        [u'password', u'TEXT'],
+                        [u'exceptions', u'TEXT']]   
+
+class ProxyDB():
+    def __init__(self, path, nome):
+        self.con = self.getDB(path, nome)      
+        if not self.isMetadadosDB(): 
+            self.createTables()
+
+    def getDB(self, path, nome):
+        banco = os.path.join(path,nome)
+        if os.path.exists(path):
+                try:
+                    con = sqlite3.connect(banco)
+                    return con
+                except:
+                    print 'Não foi possível criar uma conecção com o BD:{0}'\
+                    .format(banco)
+                    return None
+        else:
+            print 'Não foi possível encontrar o caminho especificado:{0}'\
+                    .format(banco)
+            return None
+        
+    
+    def isMetadadosDB(self):
+        cur = self.con.cursor() 
+        tablesNames = tables.keys()
+        for i in tablesNames:
+            teste = False
+            for j in cur.execute("select name from sqlite_master where type ='table'"):
+                teste = i ==  j[0]
+                if teste:
+                    break
+            if not teste:
+                return teste
+        return teste
+            
+    def createTables(self):
+        tablesName = tables.keys()
+        tablesName.reverse()
+        for table in tablesName :
+            sql = "CREATE TABLE {0}(".format(table)
+            columns = tables.get(table)
+            column = columns.pop(0)
+            sql = "{0} {1} {2}".format(sql, column[0], column[1])
+            for column in columns:
+                sql = "{0}, {1} {2}".format(sql, column[0], column[1])
+            sql = "{0});".format(sql)
+            cur = self.con.cursor()
+            cur.execute(sql)
+            self.con.commit()
+            
+    def inserirItem(self, nomeTabela, dicionario):
+        sql = "INSERT INTO {0}".format(nomeTabela)
+        columns = dicionario.keys()
+        values = []
+        for key in columns:
+            value = dicionario.get(key)
+            if type(value) == str:
+                values.append("'{0}'".format(value))
+            else:
+                values.append(str(value))
+       
+        sql = '{0} {1} VALUES {2}'.format(sql,  str(columns).replace("'", ''), \
+                 str(values).replace('"', '')).replace('[','(').replace(']',')')
+        cur = self.con.cursor()
+        cur.execute(sql)
+        self.con.commit()
+        
+    def obterProxyList(self):
+        cur = self.con.cursor()
+        proxyDict = {}
+        for e in cur.execute("SELECT id, proxy, port, user, password, exceptions FROM tb_proxy"):
+            proxyDict[e[0]] = {'proxy':e[1], 'port':e[2], 'user':e[3], 'password':e[4], 'exceptions':e[5] }
+        return proxyDict
+        
+  
+    def save(self):
+        self.con.commit()
+        
+    def close(self):
+        self.con.close()
+
+PROJECT_ROOT_PATH =  os.path.realpath(os.path.dirname(__file__))
+metadadosDB = ProxyDB(PROJECT_ROOT_PATH, 'proxy.db')
+    
+def validaEntradaSN(msg):
+    while True:
+        var = raw_input(msg)
+        if var.upper() == 'S':
+            return True
+        elif var.upper() == 'N':
+            return False
+
+def validaEntradaTexto(msg):
+    while True:
+        var = raw_input(msg)
+        if len(var) > 0:
+            return var
+        
+def validaEntradaNumero(msg):
+    while True:
+        var = raw_input(msg)
+        if len(var) > 0:
+            try:
+                int(var)
+                return var
+            except:
+                print 'O valor deve ser do tipo interio!'
+    return None
+
+def insertProxy():
+    continua = True
+    proxyDict = {}
+    while continua :
+        proxyDict['proxy'] = validaEntradaTexto("Informe o proxy: ") 
+        proxyDict['port'] = validaEntradaNumero("Informe a porta: ")
+        if validaEntradaSN("Seu proxy requer autenticação? (S ou N)\n>> "):
+            proxyDict['user'] = validaEntradaTexto("Informe o usuário: ")
+            proxyDict['password'] = validaEntradaTexto("Informe a senha: ")
+        if validaEntradaSN("Você quer cadastrar exceções? (S ou N)\n>> "):
+            proxyDict['exceptions'] = validaEntradaTexto("Informe as exceções: ")
+
+        for i in proxyDict:
+            print i, '\t- ', proxyDict[i]
+            
+        msg = "Esta é a configurção de proxy que será utilizada:\nEla está correta? (S ou N)\n>>"
+        if validaEntradaSN(msg):
+            continua = False
+            metadadosDB.inserirItem(TABELA_ORIGINAL, proxyDict)
+            '''serversPath = os.path.join(PROJECT_ROOT_PATH,'.subversion/servers')
+            serversFile = open(serversPath,'a+b')
+            serversFile.write("http-proxy-host = {0}\n".format(proxy))
+            serversFile.write("http-proxy-port = {0}\n".format(porta))
+            if usuario:
+                serversFile.write("http-proxy-username = {0}\n".format(usuario))
+                serversFile.write("http-proxy-password = {0}\n".format(senha)) 
+            serversFile.close()
+            atualiza_info_file = open(atualizaPath,'w')
+            atualiza_info_file.close()'''
+
+        else:
+            for i in proxyDict.keys():
+                proxyDict[i] = ''
+    return proxyDict
+
+def utilizarProxy(proxyDict):
+    serversPath = os.path.join(PROJECT_ROOT_PATH,'.subversion/servers')
+    serversFile = open(serversPath,'w')
+    serversFile.write("[global]\n")
+    
+    fileDict = {'proxy': 'http-proxy-host = ',
+    'port':'http-proxy-port = ',
+    'user': 'http-proxy-username = ',
+    'password':'http-proxy-username = ',
+    'exceptions':'http-proxy-password = '}
+    if proxyDict:
+        for k,v in proxyDict.items():
+            if v:
+                serversFile.write(fileDict[k] + v + '\n')
+    serversFile.close()
+    atualiza()
+    
+   
+def proxy():
+    
+    texto = "Se você utiliza um proxy para acessar a web é necessário que o proxy seja configurado para fazer o update.\
+    Caso você configure o proxy e o update não seja executado com sucesso, procure o seu administrador da rede e informe a ele o seguinte:\n\
+    1 - Arquivo local que armazena as configurações do proxy para o svn: {0}\n\
+    2 - É preciso que o servidor proxy suporte os seguintes métodos: PROPFIND, REPORT, MERGE, MKACTIVITY, CHECKOUT.\n\
+    3 - Mais informações: http://subversion.apache.org/faq.html#proxy\n\n".format(os.path.join(PROJECT_ROOT_PATH,'.subversion/servers'))
+
+    print texto    
+    
+   
+    a = metadadosDB.obterProxyList()
+    print 'Escolha o que fazer:'
+    print '-1 - para restaurar as configurações iniciais;'
+    print ' 0 - para cadastrar um proxy novo;'
+    print ' Ou Digite o numero de um proxy cadastrado, caso exista.\n'
+
+    if len(a): 
+	print 'Proxies disponíveis:'
+        for i in a:
+            print i,' - ', a[i]['proxy'],a[i]['port'],a[i]['user'],a[i]['password'],a[i]['exceptions']
+        metadadosDB.close() 
+    
+    var = int(validaEntradaNumero(">>"))
+    
+    proxyDict = None
+    if var == 0:
+        proxyDict = insertProxy()
+
+    elif var == -1:
+	proxyDict = None
+    else:
+        if var in a:
+            proxyDict = a[var]
+        else: 
+            print 'Opção inválida!'
+            return
+    utilizarProxy(proxyDict)           
+
+def atualiza():
+    os.chdir('/var/www')
+    subprocess.call(["svn","update"], stdout=0) 
+       
+if __name__ == '__main__':
+    continua = True
+    while continua :
+        print 'Opções:'
+        print '0 - Atualizar:'
+        print '1 - Configurar Proxy e Atualizar:'
+        print '2 - Sair:'
+        var = int(validaEntradaNumero("Escolha: "))
+        if var == 0:
+            atualiza()
+        elif var == 1:
+            proxy()
+        elif var == 2: 
+            continua = False
+        
+        continua = False
+    time.sleep(5)
+
@@ -0,0 +1,245 @@		@@ -0,0 +1,245 @@
	1	+#!/usr/bin/env python
	2	+# -- coding: utf-8 --
	3	+"""
	4	+Created on Fri Jan 11 17:26:01 2013
	5	+
	6	+@author: Diego
	7	+"""
	8	+import os, subprocess
	9	+import sqlite3
	10	+import os
	11	+import time
	12	+
	13	+TABELA_ORIGINAL = 'tb_proxy'
	14	+
	15	+tables = {}
	16	+tables[TABELA_ORIGINAL] = [[u'id', u'INTEGER PRIMARY KEY'],
	17	+ [u'proxy', u'TEXT'],
	18	+ [u'port', u'TEXT'],
	19	+ [u'user', u'TEXT'],
	20	+ [u'password', u'TEXT'],
	21	+ [u'exceptions', u'TEXT']]
	22	+
	23	+class ProxyDB():
	24	+ def __init__(self, path, nome):
	25	+ self.con = self.getDB(path, nome)
	26	+ if not self.isMetadadosDB():
	27	+ self.createTables()
	28	+
	29	+ def getDB(self, path, nome):
	30	+ banco = os.path.join(path,nome)
	31	+ if os.path.exists(path):
	32	+ try:
	33	+ con = sqlite3.connect(banco)
	34	+ return con
	35	+ except:
	36	+ print 'Não foi possível criar uma conecção com o BD:{0}'\
	37	+ .format(banco)
	38	+ return None
	39	+ else:
	40	+ print 'Não foi possível encontrar o caminho especificado:{0}'\
	41	+ .format(banco)
	42	+ return None
	43	+
	44	+
	45	+ def isMetadadosDB(self):
	46	+ cur = self.con.cursor()
	47	+ tablesNames = tables.keys()
	48	+ for i in tablesNames:
	49	+ teste = False
	50	+ for j in cur.execute("select name from sqlite_master where type ='table'"):
	51	+ teste = i == j[0]
	52	+ if teste:
	53	+ break
	54	+ if not teste:
	55	+ return teste
	56	+ return teste
	57	+
	58	+ def createTables(self):
	59	+ tablesName = tables.keys()
	60	+ tablesName.reverse()
	61	+ for table in tablesName :
	62	+ sql = "CREATE TABLE {0}(".format(table)
	63	+ columns = tables.get(table)
	64	+ column = columns.pop(0)
	65	+ sql = "{0} {1} {2}".format(sql, column[0], column[1])
	66	+ for column in columns:
	67	+ sql = "{0}, {1} {2}".format(sql, column[0], column[1])
	68	+ sql = "{0});".format(sql)
	69	+ cur = self.con.cursor()
	70	+ cur.execute(sql)
	71	+ self.con.commit()
	72	+
	73	+ def inserirItem(self, nomeTabela, dicionario):
	74	+ sql = "INSERT INTO {0}".format(nomeTabela)
	75	+ columns = dicionario.keys()
	76	+ values = []
	77	+ for key in columns:
	78	+ value = dicionario.get(key)
	79	+ if type(value) == str:
	80	+ values.append("'{0}'".format(value))
	81	+ else:
	82	+ values.append(str(value))
	83	+
	84	+ sql = '{0} {1} VALUES {2}'.format(sql, str(columns).replace("'", ''), \
	85	+ str(values).replace('"', '')).replace('[','(').replace(']',')')
	86	+ cur = self.con.cursor()
	87	+ cur.execute(sql)
	88	+ self.con.commit()
	89	+
	90	+ def obterProxyList(self):
	91	+ cur = self.con.cursor()
	92	+ proxyDict = {}
	93	+ for e in cur.execute("SELECT id, proxy, port, user, password, exceptions FROM tb_proxy"):
	94	+ proxyDict[e[0]] = {'proxy':e[1], 'port':e[2], 'user':e[3], 'password':e[4], 'exceptions':e[5] }
	95	+ return proxyDict
	96	+
	97	+
	98	+ def save(self):
	99	+ self.con.commit()
	100	+
	101	+ def close(self):
	102	+ self.con.close()
	103	+
	104	+PROJECT_ROOT_PATH = os.path.realpath(os.path.dirname(__file__))
	105	+metadadosDB = ProxyDB(PROJECT_ROOT_PATH, 'proxy.db')
	106	+
	107	+def validaEntradaSN(msg):
	108	+ while True:
	109	+ var = raw_input(msg)
	110	+ if var.upper() == 'S':
	111	+ return True
	112	+ elif var.upper() == 'N':
	113	+ return False
	114	+
	115	+def validaEntradaTexto(msg):
	116	+ while True:
	117	+ var = raw_input(msg)
	118	+ if len(var) > 0:
	119	+ return var
	120	+
	121	+def validaEntradaNumero(msg):
	122	+ while True:
	123	+ var = raw_input(msg)
	124	+ if len(var) > 0:
	125	+ try:
	126	+ int(var)
	127	+ return var
	128	+ except:
	129	+ print 'O valor deve ser do tipo interio!'
	130	+ return None
	131	+
	132	+def insertProxy():
	133	+ continua = True
	134	+ proxyDict = {}
	135	+ while continua :
	136	+ proxyDict['proxy'] = validaEntradaTexto("Informe o proxy: ")
	137	+ proxyDict['port'] = validaEntradaNumero("Informe a porta: ")
	138	+ if validaEntradaSN("Seu proxy requer autenticação? (S ou N)\n>> "):
	139	+ proxyDict['user'] = validaEntradaTexto("Informe o usuário: ")
	140	+ proxyDict['password'] = validaEntradaTexto("Informe a senha: ")
	141	+ if validaEntradaSN("Você quer cadastrar exceções? (S ou N)\n>> "):
	142	+ proxyDict['exceptions'] = validaEntradaTexto("Informe as exceções: ")
	143	+
	144	+ for i in proxyDict:
	145	+ print i, '\t- ', proxyDict[i]
	146	+
	147	+ msg = "Esta é a configurção de proxy que será utilizada:\nEla está correta? (S ou N)\n>>"
	148	+ if validaEntradaSN(msg):
	149	+ continua = False
	150	+ metadadosDB.inserirItem(TABELA_ORIGINAL, proxyDict)
	151	+ '''serversPath = os.path.join(PROJECT_ROOT_PATH,'.subversion/servers')
	152	+ serversFile = open(serversPath,'a+b')
	153	+ serversFile.write("http-proxy-host = {0}\n".format(proxy))
	154	+ serversFile.write("http-proxy-port = {0}\n".format(porta))
	155	+ if usuario:
	156	+ serversFile.write("http-proxy-username = {0}\n".format(usuario))
	157	+ serversFile.write("http-proxy-password = {0}\n".format(senha))
	158	+ serversFile.close()
	159	+ atualiza_info_file = open(atualizaPath,'w')
	160	+ atualiza_info_file.close()'''
	161	+
	162	+ else:
	163	+ for i in proxyDict.keys():
	164	+ proxyDict[i] = ''
	165	+ return proxyDict
	166	+
	167	+def utilizarProxy(proxyDict):
	168	+ serversPath = os.path.join(PROJECT_ROOT_PATH,'.subversion/servers')
	169	+ serversFile = open(serversPath,'w')
	170	+ serversFile.write("[global]\n")
	171	+
	172	+ fileDict = {'proxy': 'http-proxy-host = ',
	173	+ 'port':'http-proxy-port = ',
	174	+ 'user': 'http-proxy-username = ',
	175	+ 'password':'http-proxy-username = ',
	176	+ 'exceptions':'http-proxy-password = '}
	177	+ if proxyDict:
	178	+ for k,v in proxyDict.items():
	179	+ if v:
	180	+ serversFile.write(fileDict[k] + v + '\n')
	181	+ serversFile.close()
	182	+ atualiza()
	183	+
	184	+
	185	+def proxy():
	186	+
	187	+ texto = "Se você utiliza um proxy para acessar a web é necessário que o proxy seja configurado para fazer o update.\
	188	+ Caso você configure o proxy e o update não seja executado com sucesso, procure o seu administrador da rede e informe a ele o seguinte:\n\
	189	+ 1 - Arquivo local que armazena as configurações do proxy para o svn: {0}\n\
	190	+ 2 - É preciso que o servidor proxy suporte os seguintes métodos: PROPFIND, REPORT, MERGE, MKACTIVITY, CHECKOUT.\n\
	191	+ 3 - Mais informações: http://subversion.apache.org/faq.html#proxy\n\n".format(os.path.join(PROJECT_ROOT_PATH,'.subversion/servers'))
	192	+
	193	+ print texto
	194	+
	195	+
	196	+ a = metadadosDB.obterProxyList()
	197	+ print 'Escolha o que fazer:'
	198	+ print '-1 - para restaurar as configurações iniciais;'
	199	+ print ' 0 - para cadastrar um proxy novo;'
	200	+ print ' Ou Digite o numero de um proxy cadastrado, caso exista.\n'
	201	+
	202	+ if len(a):
	203	+ print 'Proxies disponíveis:'
	204	+ for i in a:
	205	+ print i,' - ', a[i]['proxy'],a[i]['port'],a[i]['user'],a[i]['password'],a[i]['exceptions']
	206	+ metadadosDB.close()
	207	+
	208	+ var = int(validaEntradaNumero(">>"))
	209	+
	210	+ proxyDict = None
	211	+ if var == 0:
	212	+ proxyDict = insertProxy()
	213	+
	214	+ elif var == -1:
	215	+ proxyDict = None
	216	+ else:
	217	+ if var in a:
	218	+ proxyDict = a[var]
	219	+ else:
	220	+ print 'Opção inválida!'
	221	+ return
	222	+ utilizarProxy(proxyDict)
	223	+
	224	+def atualiza():
	225	+ os.chdir('/var/www')
	226	+ subprocess.call(["svn","update"], stdout=0)
	227	+
	228	+if __name__ == '__main__':
	229	+ continua = True
	230	+ while continua :
	231	+ print 'Opções:'
	232	+ print '0 - Atualizar:'
	233	+ print '1 - Configurar Proxy e Atualizar:'
	234	+ print '2 - Sair:'
	235	+ var = int(validaEntradaNumero("Escolha: "))
	236	+ if var == 0:
	237	+ atualiza()
	238	+ elif var == 1:
	239	+ proxy()
	240	+ elif var == 2:
	241	+ continua = False
	242	+
	243	+ continua = False
	244	+ time.sleep(5)
	245	+