ajout filtre json ; systeme de template dans .py a part

[restcoda.git] / fournisseur.py

#!/usr/bin/python
# -*- coding: utf-8 -*-

#
# Classe pour un fournisseur
# (export de la vue auf_v_acces_fournisseur)

from objet import Objet, ObjetInconnu
from utils import dict_fetchone

class fournisseur(Objet):
    """objet fournisseur CODA"""

    accept_like_filters = [ 'code', 'nom', 'createur', 'nom_complet', 'categorie', 'adresse_pays' ]

    def _get_index(self):
        """renvoie une liste de fournisseurs"""
	# connexion a la base de données
	cursor = self.cursor()
	# finition sur le where : si aucune categorie d'adresse n'est demandee, on envoie celle par defaut
	if not 'categorie' in self.filters:
	    if self.sqlwhere != '':
	        self.sqlwhere += ' and (adresse_defaut = 1) '
	    else:
	        self.sqlwhere = ' (adresse_defaut = 1) '
	if self.sqlwhere != '':
	    self.sqlwhere = ' where ' + self.sqlwhere
	request = "select top %d * from auf_v_acces_fournisseurs %s order by date_creation desc" % ( self.sqllimit, self.sqlwhere )
	cursor.execute( request )
	items = []
	while 1:
	    item = dict_fetchone( cursor )
	    if item == None: break
	    items.append(item)
	index = {}
	index['fournisseurs'] = items
	index['nombre_fournisseurs'] = len(items)
	index['limite_fournisseurs'] = self.sqllimit,
	index['filtres'] = self.filters
	index['requete_sql'] = request
	return index

    def _get_fournisseur(self,code):
        """renvoie un fournisseur"""
	# note : renvoie aussi la liste des adresses et pas seulement la premiere iteration trouvée
	cursor = self.cursor()
	request = "select * from auf_v_acces_fournisseurs where (code = '%s') order by adresse_defaut desc" % code
	cursor.execute( request )
	# le premier resultat est normalement l'adresse par defaut
        fournisseur = dict_fetchone(cursor)
	if fournisseur == None:
	    raise ObjetInconnu('fournisseur')
	autres_adresses = []
	while 1:
	    # les resultats suivant contiennent les autres adresses
	    adr = dict_fetchone( cursor )
	    if adr == None: break
	    adr_extraite = { 'categorie': adr['categorie'] ,
	                     'adresse1': adr['adresse1'],
	                     'adresse2': adr['adresse2'],
	                     'adresse3': adr['adresse3'],
	                     'adresse4': adr['adresse4'],
	                     'adresse5': adr['adresse5'],
	                     'adresse6': adr['adresse6'],
			     'adresse_code_postal': adr['adresse_code_postal'],
			     'adresse_pays': adr['adresse_pays'],
			     'adresse_telephone': adr['adresse_telephone'],
			     'adresse_telecopie': adr['adresse_telecopie'],
			     } 
	    autres_adresses.append(adr_extraite)
        fournisseur['autres_adresses'] = autres_adresses
	fournisseur['requete_sql'] = request
        return fournisseur

    def index(self):
        """renvoie une liste de fournisseurs formatée"""
        template = self.template('fournisseur-index') # préparation du modèle
	index = self._get_index( )                    # extraction des documents concernés
	output = template.render( index )             # formattage via le modèle
	return self.outputformat, output

    def show(self):
        """renvoie un fournisseur formaté"""
        code = self.environ['wsgiorg.routing_args'][1]['id'].upper()
        template = self.template( 'fournisseur' )
        fournisseur = self._get_fournisseur( code )
        output = template.render( fournisseur )
	return self.outputformat, output