# © 2019 Le Filament (<http://www.le-filament.com>) # License AGPL-3.0 or later (http://www.gnu.org/licenses/agpl.html). import requests import logging from odoo import models, exceptions, tools _logger = logging.getLogger(__name__) class ConnectorAlfresco(models.AbstractModel): """ Appelle l'API alfresco et implémente les fonctions suivantes : alfresco_list_docs : liste les documents """ _name = 'connector.alfresco' _description = 'Connecteur Alfresco' def alfresco_get_by_url(self, url, call_type, json=None): """ Création de la requête à Alfresco :param url: action API Alfresco :param call_type: post/get :param json: data to post @return response au format JSON """ _logger.info("Calling %s" % url) param = self.env['ir.config_parameter'].sudo() alfresco_url = param.get_param('alfresco.url') basicAuthCredentials = ( tools.config['alfresco_login'], tools.config['alfresco_password']) try: if call_type == 'get': response = requests.get( alfresco_url + url, auth=basicAuthCredentials, verify=False,) elif call_type == 'post': response = requests.post( alfresco_url + url, auth=basicAuthCredentials, verify=False, json=json) elif call_type == 'delete': response = requests.delete( alfresco_url + url, auth=basicAuthCredentials, verify=False, json=json) except Exception as err: _logger.warning( "Erreur de connexion. URL: %s", err.__str__(), ) if response.status_code not in [200, 201]: if 'Le dossier organisme est inexistant' in response.json().get('message'): print(response.json().get('message')) else: raise exceptions.Warning( "L'appel url '%s' a échoué\n" "- Code erreur : %d\n" "- Message : %s" % ( response.url, response.status_code, response.json().get('message'))) return response.json() # Get Methods def alfresco_list_docs(self, name): """ Liste les documents pour un organisme (raison sociale) :param name: raison sociale de la structure """ url = '/alfresco/s/erp/listedocuments?raisonSociale=' + name return self.alfresco_get_by_url(url=url, call_type='get') def alfresco_list_type(self): """ Liste le valeurs du formulaire de dépôt d'un nouveau document @return: dict des valeurs possibles pour période, validité, type """ url = '/alfresco/s/api/properties?nsp=crm&n=document' list_type = self.alfresco_get_by_url(url=url, call_type='get') return { 'periode': self.get_allowed_values( list_type=list_type, value='crm:periode'), 'validite': self.get_allowed_values( list_type=list_type, value='crm:validite'), 'type': self.get_allowed_values( list_type=list_type, value='crm:type'), } def alfresco_get_doc(self, nodeRef): """ Retourne le contenu d'un document en base64 :param nodeRef: id Alfresco """ url = '/alfresco/s/document/' + nodeRef return self.alfresco_get_by_url(url=url, call_type='get') # Post Methods def alfresco_create_organism(self, partner): """ Création d'un dossier Organisme :param partner: objet Odoo créé @return: id Alfresco (nodeRef) du dossier """ url = '/alfresco/s/erp/createdossierorganisme' json = { 'raisonSociale': partner.name, "id": partner.id, "siret": partner.siret, "numAdherent": partner.member_number } return self.get_nodeRef( self.alfresco_get_by_url(url=url, call_type='post', json=json)) def alfresco_upload(self, raisonSociale, type, periode, validite, filename, doc): """ Upload d'un document sur Alfresco :param doc: document encodé en base64 @return: id Alfresco (nodeRef) du fichier """ url = '/alfresco/s/erp/depotdocument' json = { 'raisonSociale': raisonSociale, 'periode': periode, 'type': type, 'nomOrigine': filename, 'mimeType': "application/octet-stream", 'validite': validite, 'contentBase64': doc, } return self.get_nodeRef( self.alfresco_get_by_url(url=url, call_type='post', json=json)) # Delete Methods def alfresco_remove(self, nodeRef): """ Supprime un document d'Alfresco :param id_doc: id du document Alfresco """ url = '/alfresco/s/document/' + nodeRef return self.alfresco_get_by_url(url=url, call_type='delete') # Others def get_allowed_values(self, list_type, value): """ Fonction qui itère dans l'objet retourné """ list_selected = list(filter( lambda i: i['name'] == value, list_type)) return list_selected[0].get( 'constraints')[0].get('parameters')[0].get('allowedValues') def get_nodeRef(self, result): """ Renvoie la référence Alfresco d'un JSON contenant au premier niveau la clé "nodeRef" puis supprime le chemin du workspace """ return result.get('nodeRef', '').replace( 'workspace://SpacesStore/', '')