source: seiven/api_client/services.py @ ca8b5aa

"""
Sistema Estadístico Integral de Venezuela - (SEIVEN)

Copyleft (@) 2015 CENDITEL nodo Mérida - https://mpv.cenditel.gob.ve/seiven
"""
## @namespace productivo.services
#
# Contiene los métodos para consumir servicios REST
# @author Ing. Roldan Vargas (rvargas at cenditel.gob.ve)
# @author <a href='http://www.cenditel.gob.ve'>Centro Nacional de Desarrollo e Investigación en Tecnologías Libres
# (CENDITEL) nodo Mérida - Venezuela</a>
# @copyright <a href='http://www.gnu.org/licenses/gpl-2.0.html'>GNU Public License versión 2 (GPLv2)</a>
from __future__ import unicode_literals

import json

from .models import AccessToken
import requests

consult_api = False
params = {}

def api_anho_registro():
    global consult_api
    access_credentials = AccessToken.objects.filter(activo=True)

    if access_credentials:
        token_type = access_credentials[0].token_type
        token = access_credentials[0].access_token
        url = access_credentials[0].url_access + "api/anhos"

        consult_api = requests.get(url=url, headers={'Authorization': '%s %s' % (token_type, token)})
    return json.loads(consult_api.text)

def api_estados():
    global consult_api
    access_credentials = AccessToken.objects.filter(activo=True)

    if access_credentials:
        token_type = access_credentials[0].token_type
        token = access_credentials[0].access_token
        url = access_credentials[0].url_access + "api/estados"

        consult_api = requests.get(url=url, headers={'Authorization': '%s %s' % (token_type, token)})

    return json.loads(consult_api.text)

def api_unidad_economica(rif=None, nombre=None, estado=None, anho=None, id_list=None):
    global consult_api
    access_credentials = AccessToken.objects.filter(activo=True)

    if access_credentials:
        token_type = access_credentials[0].token_type
        token = access_credentials[0].access_token
        url = access_credentials[0].url_access + "api/unidad-economica"

        ## Actualiza los datos de consulta por rif si se ha especificado
        params.update({'rif': rif} if rif else {})
        ## Actualiza los datos de consulta por nombre de la unidad económica si se ha especificado
        params.update({'nombre': nombre} if nombre else {})
        ## Actualiza los datos de consulta por estado si se ha especificado
        params.update({'estado': estado} if estado else {})
        ## Actualiza los datos de consulta por año de registro si se ha especificado
        params.update({'anho': anho} if anho else {})
        ## Actualiza los datos de consulta por lista de ids si se han especificado
        params.update({'id_list': id_list} if id_list else {})

        consult_api = requests.get(url=url, headers={'Authorization': '%s %s' % (token_type, token)}, params=params)

    return  json.loads(consult_api.text)