diff --git a/participatorio-utils/consultaoffline_src/consultaoffline/lib/opendata_json_class.py b/participatorio-utils/consultaoffline_src/consultaoffline/lib/opendata_json_class.py index d16f7e7454190cb57c712dbecd98ebd21a9c8441..02860b8e9a28d0b24e19a84aacae1e566d3b9eb4 100644 --- a/participatorio-utils/consultaoffline_src/consultaoffline/lib/opendata_json_class.py +++ b/participatorio-utils/consultaoffline_src/consultaoffline/lib/opendata_json_class.py @@ -37,14 +37,14 @@ class OpendataJSON: dir_results = None filename = None out_file = None - - #--------------------------------------------------------------------# + + #--------------------------------------------------------------------# def __init__ (self, database, dir_results, filename): self.database = database - + self.indentation_lvl = 0 self.indent = strf.lvl(self.indentation_lvl) - + self.dir_results = dir_results self.filename = filename #--------------------------------------------------------------------# @@ -54,10 +54,10 @@ class OpendataJSON: self.indentation_lvl=self.indentation_lvl+(increment) self.indent = strf.lvl(self.indentation_lvl) #--------------------------------------------------------------------# - + #--------------------------------------------------------------------# def open_file (self): - self.out_file=codecs.open(self.filename,'w',encoding='utf-8') + self.out_file=codecs.open(self.dir_results+self.filename,'w',encoding='utf-8') #--------------------------------------------------------------------# #--------------------------------------------------------------------# @@ -97,31 +97,31 @@ class OpendataJSON: def write_comments (self, post_guid): post_comments = self.database.cursor() post_comments.execute(qry.qry_post_comments, (post_guid,)) - + self.write_open_tag("comentarios","[") - + row=0 for (user_id, user_name, user_username, string, time)\ in post_comments: - + row=row+1 - + self.write_open_tag("","{") - + prefix='profile/' user_attr=strf.urlparticipa(prefix,user_username) - + self.write_open_tag("usuario","{") self.write_tag("uid",user_attr,",") self.write_tag("nome",user_name,"") self.write_close_tag("}",True) - + self.write_tag("data",strf.datestr(time),",") self.write_tag("mensagem",string,"") - + self.write_close_tag("}",(row < post_comments.rowcount)) - + self.write_close_tag("]",False) - + post_comments.close() #--------------------------------------------------------------------# diff --git a/participatorio-utils/consultaoffline_src/consultaoffline/opendata_json_version.py b/participatorio-utils/consultaoffline_src/consultaoffline/opendata_json_version.py index 927482ada9871df5efd3a8eaba5a1d590218676c..f8cb1c2b70f5778bcdabb6ffefb399700c4eb70f 100644 --- a/participatorio-utils/consultaoffline_src/consultaoffline/opendata_json_version.py +++ b/participatorio-utils/consultaoffline_src/consultaoffline/opendata_json_version.py @@ -24,31 +24,46 @@ import psycopg2 import datetime import shutil +import os from lib.json_program_section import write_singlefile_programs_section def main(): - + + ###################################################################### + # OPTIONS: + + # Output directory. + # Must be the directory "consultaoffline" located inside of "estacaojuventude" tomcat's webapp + #consultaoffline_output_dir="/var/lib/tomcat7/webapps/estacaojuventude/consultaoffline/" + consultaoffline_output_dir="/tmp/" + # Database options + db_host="localhost" + db_name="estacaojuventude" + db_user="estacaojuventude" + db_password="admin" + + ###################################################################### + # Filenames definitions - consultaoffline_zipfile="/var/lib/tomcat7/webapps/estacaojuventude/consultaoffline/consultaoffline_programas" - consultaoffline_rootdir="/home/cadastroweb/consultaoffline_cadastroweb/" + consultaoffline_rootdir=os.path.dirname(os.path.realpath(__file__))+"/" consultaoffline_basedir="consultaoffline_programas/" - consultaoffline_programa_json=consultaoffline_rootdir+consultaoffline_basedir+"programas.json" + consultaoffline_filename="programas.json" # Open connection to database - db = psycopg2.connect("host='localhost' dbname='estacaojuventude' user='estacaojuventude' password='devjuventude'") - + db = psycopg2.connect("host='"+db_host+"' dbname='"+db_name+"' user='"+db_user+"' password='"+db_password+"'") + # Call functions to write Single Dump JSON file - write_singlefile_programs_section(db, consultaoffline_rootdir, consultaoffline_basedir+'programas.json') - + write_singlefile_programs_section(db, consultaoffline_rootdir+consultaoffline_basedir,consultaoffline_filename) + # Close database connection - db.close() - + db.close() + # Create Zipfile containing all necessary files to visualize data - shutil.make_archive(consultaoffline_zipfile, 'zip', consultaoffline_rootdir, consultaoffline_basedir) - + shutil.make_archive(consultaoffline_output_dir+"consultaoffline_programas",'zip',\ + consultaoffline_rootdir, consultaoffline_basedir) + return 0 if __name__ == '__main__': main() -