app.py

# encoding: utf-8
from bottle import *
from datetime import datetime
import os
import bcrypt
from beaker.middleware import SessionMiddleware

from model.usuario import Usuario
from model.conta import Conta
from model.evento import Evento
from model.carrinho import Carrinho
from model.ingresso import Ingresso
from model.categoria import Categoria
from model.ibge import IBGE
from model.servico import Servico
from model.venda import Venda

TEMPLATE_PATH.insert(0,"view")
_session_opts = {'session.type':'memory','_session.cookie_expires':600,'_session.auto': True}

app = SessionMiddleware(app(), _session_opts)
def has_session():
	_session = request.environ.get('beaker.session')
	if not _session or 'usuario_id' not in _session:
		return redirect('/login')

def set_session(key,value):
	_session = request.environ['beaker.session']
	_session[key] = value
	_session.save()
def del_session():
	_session = request.environ['beaker.session']
	_session.delete()

def get_session():
	try:
		_session = request.environ['beaker.session']
		return _session['usuario_id']
	except Exception:
		return 0

def check_password(passw,passwh):
	if bcrypt.hashpw(passw.encode(),passwh.encode()) == passwh:
		return True
	return False
def set_passwh(passw):
	return bcrypt.hashpw(passw.encode(),bcrypt.gensalt())

@route('/logout')
def logout_get():
	del_session()
	return redirect("/")

@route('/',method='GET')
def main_page():
	usuario_id = get_session()
	return template('view/index',usuario_id=usuario_id)

@route('/message_err/<msg>',method='GET')
def message_page(msg):
	usuario_id = get_session()
	return template('view/message',msg=msg,usuario_id=usuario_id)

@route('/static/<filename:path>')
def static_routes(filename):
	return static_file(filename, root='static')

@route('/Eventos/<filename:path>')
def static_routes(filename):
	return static_file(filename, root='Eventos')
@error(404)
def error404(error):
	return template('view/404',usuario_id = get_session())

# Usuario Begin
@route('/usuario/profile',method='GET')
def usuario_profile_get(): 
	has_session()
	usuario_id = get_session()
	dado = Conta().find(usuario_id)
	return template('view/usuario/profile',dado=dado,usuario_id=usuario_id)

@route('/usuario/register',method='POST')
def usuario_register_post():		
	nome = request.POST.nome
	email = request.POST.email
	senha = request.POST.senha
	senha2 = request.POST.senha2	
	cpf = request.POST.cpf
	telefone = request.POST.telefone
	data_criacao = str(datetime.now())[0:19]

	if senha != senha2:
		return redirect('/message_err/Senhas diferentes!')

	senha = set_passwh(senha)
	
	if Usuario().has_email(email)[0] > 0:
		return redirect('/message_err/Email em uso!')

	if Usuario().add(email,senha):
		usuario_id = Usuario().find_by_email(email)[0]
		if Conta().add(usuario_id,nome,cpf,telefone,data_criacao):
			set_session('usuario_id',usuario_id)
	
	return redirect("/")



@route('/usuario/register',method='GET')
def usuario_register_get():
	usuario_id = get_session()
	return template('view/usuario/register',usuario_id=usuario_id)

@route('/usuario/edit',method='POST')
def usuario_edit_post():
	has_session()
	nome = request.POST.nome
	email = request.POST.email
	cpf = request.POST.cpf
	telefone = request.POST.telefone
	usuario_id  = get_session()
	data_alteracao = str(datetime.now())[0:19]
	dado = Usuario().find(usuario_id)[1]
	if dado != email:
		if Usuario().has_email(email)[0] > 0:
			return redirect('/message_err/Email em uso!')

	if Conta().update(nome,cpf,telefone,data_alteracao,usuario_id):
			return redirect("/usuario/profile")
	return redirect('/message_err/Ocorreu um erro!<br/>Não foi possivel realizar as alterações.')

@route('/usuario/edit',method='GET')
def usuario_edit_get():
	has_session()
	usuario_id = get_session()
	dado = Conta().find(get_session())
	return template('view/usuario/edit',dado=dado,usuario_id=usuario_id)

@route('/usuario/delete',method='POST')
def usuario_delete_post():
	has_session()
	usuario_id = get_session()
	if Conta().delete_by_usuario(usuario_id):
		print 'Conta deletada!'
	if Usuario().delete(usuario_id):
		print 'Usuario deletado!'
	if Evento().update_status_by_usuario(0,usuario_id):
		print 'Eventos inativos!'
	if Ingresso().update_status_by_usuario(0,usuario_id):
		print 'Ingressos inativos!'
	if Carrinho().delete_by_usuario(usuario_id):
		print 'Carrinho deletado!'

	del_session()			
	return redirect('/')

@route('/usuario/delete',method='GET')
def usuario_delete_get():
	has_session()
	usuario_id = get_session()
	dados = Conta().find(usuario_id)
	return template('view/usuario/delete', dados=dados,usuario_id=usuario_id)

@route('/login',method='POST')
def usuario_login_post():
	email = request.POST.email
	senha = request.POST.senha

	if Usuario().has_email(email)[0] <= 0:
		return redirect('/message_err/Conta não existe!')
	dado = Usuario().find_by_email(email)
	if check_password(senha,dado[2]):
		set_session('usuario_id',dado[0])
		return redirect('/')
	return redirect('/message_err/Senha errada!')

@route('/usuario/forgot_password',method=['GET','POST'])
def recovery_pw_get_post():
	if request.method == 'GET':
		usuario_id = get_session()
		return template('view/usuario/check_email.tpl',usuario_id=usuario_id)
	elif request.method == 'POST':	
		email = request.POST.email
		if Usuario().has_email(email)[0] > 0:

			usuario_id = Usuario().find_by_email(email)[0]

			emailh = set_passwh(email)
			if Usuario().update_orderRecPw(usuario_id,emailh):
				pass
			url = 'http://localhost:8080/usuario/reset_pw/%d/%s' % (usuario_id,emailh.encode('base64'))
			texto = 'Copie e cole em seu navegador o link: '+url
			Servico().sendEmail(email,'Esqueci minha senha',texto)
			return redirect('/message_err/Enviamos um link para seu email para você redefinir sua senha, Verifique na caixa de entrada ou na de spam.')
		return redirect('/message_err/Conta não existe!')

@route('/usuario/reset_pw/<_id>/<_hash>',method=['GET','POST'])
def reset_pw_get(_id,_hash): 
	usuario_id = get_session()
	if request.method == 'GET':

		if Usuario().has_usuario(_id)[0] <= 0:
			return redirect('/login')

		emailh = Usuario().find(_id)[3]

		if emailh == _hash.decode('base64'):
			return template('view/usuario/manage_password.tpl',_id=_id,_hash=_hash,usuario_id=usuario_id)
			
		return redirect('/login')
	elif request.method == 'POST':
		nova_senha = request.POST.nova_senha
		nova_senha2 = request.POST.nova_senha2
		if nova_senha != nova_senha2:
			return redirect('/message_err/Nova senha diferente da senha de confirmação!')
		
		emailh = Usuario().find(_id)[3]
		if emailh == _hash.decode('base64'):
			nova_senha = set_passwh(nova_senha)
			if Usuario().reset_password(nova_senha,_id) and Usuario().update_orderRecPw(_id,''):
				return redirect('/message_err/Senha alterada com sucesso!')


@route('/login',method='GET')
def usuario_login_get():
	usuario_id = get_session()
	return template('view/usuario/login',usuario_id=usuario_id)

@route('/usuario/reset',method='POST')
def reset_password_get():
	has_session()
	senha_atual = request.POST.senha_atual
	nova_senha = request.POST.nova_senha
	nova_senha2 = request.POST.nova_senha2
	if nova_senha != nova_senha2:
		return redirect('/message_err/Nova senha diferente da senha de confirmação!')

	usuario_id = get_session()
	dado = Usuario().find(usuario_id)
	if not check_password(senha_atual,dado[2]):
		return redirect('/message_err/Senha atual incorreta!')

	nova_senha = set_passwh(nova_senha)
	if Usuario().reset_password(nova_senha,get_session()):
		return redirect('/')

	return redirect(request.path)

@route('/usuario/reset',method='GET')
def reset_password_get():
	has_session()
	usuario_id = get_session()
	return template('view/usuario/reset_password',usuario_id=usuario_id)
# Usuario end
# Ingresso begin

@route('/ingresso',method='GET')
@route('/ingresso/index',method='GET')
def ingresso_index_get():
	has_session()
	usuario_id = get_session()
	dado = Ingresso().findAll(usuario_id,1)
	return template('view/ingresso/index',dado=dado,usuario_id=usuario_id)
@route('/ingresso/insert',method='POST')
def ingresso_insert_post():
	has_session()
	tipo = request.POST.tipo
	quantidade = request.POST.quantidade
	preco = request.POST.preco
	evento_id = request.POST.evento_id
	usuario_id = get_session()
	if Ingresso().add(tipo,quantidade,preco,usuario_id,evento_id):
		return redirect('/ingresso')
	return redirect('/message_err/Ocorreu um erro tente de novo!')

@route('/ingresso/insert',method='GET')
def ingresso_insert_get():
	has_session()
	usuario_id = get_session()
	evento = Evento().findAll(usuario_id,1)
	return template('view/ingresso/insert',evento=evento,usuario_id=usuario_id)

@route('/ingresso/edit/<_id>',method='POST')
def ingresso_edit_post(_id):
	has_session()
	evento_id = request.POST.evento_id
	tipo = request.POST.tipo
	quantidade = request.POST.quantidade
	preco = request.POST.preco
	usuario_id = get_session()
	if Ingresso().update(tipo,quantidade,preco,evento_id,usuario_id,_id):
		return redirect('/ingresso')
	return redirect('/message_err/Ocorreu um erro!<br/>Não foi possivel realizar as alterações.')

@route('/ingresso/edit/<_id>',method='GET')
def ingresso_edit_get(_id):
	has_session()
	usuario_id = get_session()
	evento = Evento().findAll(usuario_id,1)
	dado = Ingresso().find(usuario_id,_id)
	return template('view/ingresso/edit',evento=evento,dado=dado,usuario_id=usuario_id)

@route('/ingresso/delete/<_id>',method='GET')
def ingresso_delete_get(_id):
	has_session()
	usuario_id = get_session()
	if Ingresso().update_status(0,usuario_id,_id):
		return redirect('/ingresso')
	return redirect('/message_err/Ocorreu um erro!<br/>Não foi possivel deletar o ingresso.')
@route('/ingresso/mysales',method='GET')
def ingresso_mysales_get():
	has_session()
	usuario_id = get_session()
	dado = Venda().mysales(usuario_id)
	return template('view/ingresso/mysales',dado=dado)
#Ingresso end
#Evento begin
@route('/evento/upload/<evento_id>', method='POST')
def evento_upload_post(evento_id):
	has_session()
	save_path = "Eventos/"+str(evento_id)
	upload = request.files.get('upload')
	name, ext = os.path.splitext(upload.filename)
	file_path = save_path+"/banner" + str(ext) #Defini nome do arquivo.
	if ext not in ('.jpg'):
		return redirect(request.path)
	
	if not os.path.exists(save_path):
		os.makedirs(save_path)
	else:
		os.system("rm -f "+file_path)

	upload.save(file_path)	
	return redirect('/evento')

@route('/evento/upload/<evento_id>', method='GET')
def evento_upload_get(evento_id):
	has_session()
	usuario_id = get_session()
	return template('view/evento/upload',evento_id=evento_id,usuario_id=usuario_id)

@route('/evento/<_id>', method='GET')
def page_evento_get(_id):
	usuario_id = get_session()
	dado = Evento().find_by_evento_id(_id,1)
	ingresso = Ingresso().find_by_evento_id(_id,1)
	return template('view/evento/show',dado=dado,ingresso=ingresso,usuario_id=usuario_id)
	
@route('/list-event',method=['GET','POST'])
def evento_list_get():
	usuario_id = get_session()
	cidade = IBGE().findAll() 
	categoria = Categoria().findAll()
	if request.method == 'GET':
		evento = Evento().listAll(1)
	elif request.method == 'POST':
		categoria_id = request.POST.categoria_id
		cidade_id = request.POST.cidade_id
		evento = Evento().searchEvento(categoria_id,cidade_id)
	return template('view/evento/catalog',categoria=categoria,evento=evento,cidade=cidade,usuario_id=usuario_id)

@route('/evento', method='GET')
@route('/evento/index', method='GET')
def evento_index_get():
	has_session()
	usuario_id = get_session()
	dado = Evento().findAll(usuario_id,1) # Mostrar somente eventos ativos.
	return template('view/evento/index',dado=dado,usuario_id=usuario_id)

@route('/evento/insert', method='POST')
def evento_insert_post():
	has_session()
	usuario_id = get_session()
	titulo = request.POST.titulo
	categoria_id = request.POST.categoria_id
	descricao = request.POST.descricao
	endereco = request.POST.endereco
	numero = request.POST.numero
	cidade_id = request.POST.cidade_id
	bairro = request.POST.bairro
	telefone = request.POST.telefone
	if Evento().add(usuario_id,categoria_id,cidade_id,titulo,descricao,endereco,numero,bairro,telefone):
		return redirect('/evento')
	return redirect('/message_err/Ocorreu um erro!<br/>Não foi possivel adicionar o evento.')

@route('/evento/insert', method='GET')
def evento_insert_get():
	has_session()
	usuario_id = get_session()
	cidade = IBGE().findAll() 
	categoria = Categoria().findAll()
	return template('view/evento/insert',categoria=categoria,cidade=cidade,usuario_id=usuario_id)
@route('/evento/edit/<_id>', method='POST')
def evento_edit_post(_id):
	has_session()
	usuario_id = get_session()
	titulo = request.POST.titulo
	categoria_id = request.POST.categoria_id
	descricao = request.POST.descricao
	endereco = request.POST.endereco
	numero = request.POST.numero
	cidade_id = request.POST.cidade_id
	bairro = request.POST.bairro
	telefone = request.POST.telefone
	if Evento().update(_id,usuario_id,categoria_id,cidade_id,titulo,descricao,endereco,numero,bairro,telefone):
		return redirect('/evento')
	return redirect('/message_err/Ocorreu um erro!<br/>Não foi possivel realizar as alterações.')
@route('/evento/edit/<_id>',method='GET')
def evento_edit_get(_id):
	has_session()
	usuario_id = get_session()
	dado = Evento().find(usuario_id,_id)
	cidade = IBGE().findAll() 
	categoria = Categoria().findAll()
	return template('view/evento/edit',cidade=cidade,categoria=categoria,dado=dado,usuario_id=usuario_id)

@route('/evento/delete/<_id>',method='GET')
def evento_delete_get(_id):
	has_session()
	usuario_id = get_session()
	if Evento().update_status(0,usuario_id,_id):
		if Ingresso().update_status_by_evento(0,usuario_id,_id):
			return redirect('/evento')
	return redirect('/message_err/Ocorreu um erro!<br/>Não foi possivel realizar as alterações.')
#Evento end
#Shopping cart begin
@route('/carrinho/insert/<evento_id>/<ingresso_id>',method='POST')
def add_cart_get(evento_id,ingresso_id):
	has_session()
	usuario_id = get_session()
	quantidade = request.POST.quantidade
	if int(quantidade) <= 0:
		quantidade = 1
	if Carrinho().check_item_exists(usuario_id,ingresso_id)[0] != 0:
		dado = Carrinho().find(usuario_id,ingresso_id)[3]
		quantidade = dado + int(quantidade)
		if Carrinho().update_quantidade(usuario_id,ingresso_id,quantidade):
			print "UPDATE ITEM [OK]"
	else:
		if Carrinho().add(ingresso_id,usuario_id,quantidade):
			print 'ADICIONADO ITEM [OK]'	
	return redirect('/evento/%s' % evento_id)

@route('/carrinho/delete/<_id>',method='GET')
def carrinho_delete_get(_id):
	has_session()
	usuario_id = get_session()
	if Carrinho().delete(_id,usuario_id):
		print '[DELETADO ITEM]'
	return redirect('/carrinho')
	
@route('/carrinho',method='GET')
def carrinho_index_get():
	has_session()
	usuario_id = get_session()
	dado = Carrinho().findAll(usuario_id)
	return template('view/carrinho/index.tpl',dado=dado,usuario_id=usuario_id)
@route('/carrinho/myshopping',method="GET")
def myshopping_get():
	has_session()
	usuario_id = get_session()
	dado = Venda().myshopping(usuario_id)
	return template("view/carrinho/myshopping.tpl",dado=dado)

@route('/carrinho/pickupticket',method="GET")
def pickupticket_get():
	has_session()
	usuario_id = get_session()
	dado = Venda().pickupticket(usuario_id)
	return template("view/carrinho/pickupticket.tpl",dado=dado)

@route('/carrinho/finalizar',method="GET")
def finish():
	has_session()
	usuario_id = get_session()
	dado = Carrinho().findAll(usuario_id)
	for i in dado:
		if Ingresso().manage_inventory(i[1],i[3]):
			vendedor_id = Ingresso().find_by_usuario(i[1])
			_hash = Conta().find(vendedor_id)[0]
			_hash = set_passwh(_hash)
			print Venda().add(i[1],usuario_id,i[3],i[4],str(datetime.now())[0:19],vendedor_id,_hash)
		print Carrinho().delete_by_ingresso(i[1],usuario_id)
	return redirect('/carrinho')
#Shopping cart end
run(host='localhost',port='8080',debug=True,reloader=True,app=app)