# -*- coding: utf8 -*- from sqlalchemy import text from sqlalchemy.ext.declarative import declarative_base from sqlalchemy.orm import ( scoped_session, sessionmaker, ) from zope.sqlalchemy import ( ZopeTransactionExtension, mark_changed ) from datetime import * import dateutil.relativedelta import transaction def execute_query(request, query, params): """Execute query and mark session as changed""" request.dbsession.execute(query, params) mark_changed(request.dbsession) transaction.commit() def get_log_nuit(request, ): # lire le log de nuit query = """SELECT * FROM t_log_nuit;""" results = request.dbsession.execute(query, ) return results.fetchall() def get_rappels_rdv(request): """Lire les 200 derniers envois d'emails""" query = "SELECT * FROM email_rappels ORDER BY no_id DESC LIMIT 400;" results = request.dbsession.execute(query, {}) return results.fetchall() def get_stats_dd(request, societe): query = """SELECT societe, year(date) as Annee, COUNT(*) as Total, SUM(IF(status = '', 1, 0)) AS Created, SUM(IF(status = 'Devis', 1, 0)) AS Devis, SUM(IF(status = 'Commandé', 1, 0)) AS Commande, SUM(IF(status = 'Facturé', 1, 0)) AS Facture, SUM(IF(status = 'Régl part.', 1, 0)) AS ReglePart, SUM(IF(status = 'Réglée', 1, 0)) AS Regle FROM dem_devis where societe=:societe group by societe, year(date);""" results = request.dbsession.execute(query, {'societe': societe}).fetchall() return results def get_dossiers_byChantier(request, societe, name): query = "CALL spGET_DOSSIERS_byChantier('%s','%s','%s');" % (societe, 'DE', name.replace("'","''")) results = request.dbsession.execute(query).fetchall() return results def get_cabinets_by_id(request, code): # lire les cabinets if code == '0': query = """SELECT * FROM P_CABINET ORDER BY nom;""" results = request.dbsession.execute(query).fetchall() else: query = """SELECT * FROM P_CABINET WHERE code=:code;""" results = request.dbsession.execute(query, {'code': code}).first() return results def get_experts_by_id(request, code_cab, code_exp): # lire les experts du cabinet if code_exp == '0': query = """SELECT * FROM P_EXPERTS WHERE code_cab=:code_cab ORDER BY nom;""" results = request.dbsession.execute(query, {'code_cab': code_cab}).fetchall() else: query = """SELECT * FROM P_EXPERTS WHERE code_cab=:code_cab AND code_exp=:code_exp;""" results = request.dbsession.execute(query, {'code_cab': code_cab, 'code_exp': code_exp}).first() return results def get_rdf_causes_by_id(request, code): # lire les rdf_causes if code == '0': query = """SELECT * FROM rdf_causes;""" results = request.dbsession.execute(query).fetchall() else: query = """SELECT * FROM rdf_causes WHERE code=:code;""" results = request.dbsession.execute(query, {'code': code}).first() return results def delete_rdf_cause(request, old_code): query = "DELETE FROM rdf_causes WHERE code = :old_code;" execute_query(request, query, {'old_code': old_code}) def update_rdf_cause(request, old_code, code, libelle): if old_code == '0': query = "INSERT rdf_causes (code, libelle) values (:code, :libelle);" else: query = "UPDATE rdf_causes SET code = :code, libelle = :libelle WHERE code = :old_code;" execute_query(request, query, {'old_code': old_code, 'code': code, 'libelle': libelle}) def get_texts(request, text_id): """Lire les textes""" if text_id == 0: query = "SELECT * FROM p_texts ORDER BY theme, intitule;" results = request.dbsession.execute(query).fetchall() elif text_id == -1: query = "SELECT * FROM p_texts where theme != 'INTERNE' ORDER BY theme, intitule;" results = request.dbsession.execute(query).fetchall() else: query = "SELECT * FROM p_texts where text_id = :text_id;" results = request.dbsession.execute(query, {'text_id': text_id}).first() return results def update_text(request, text_id, intitule, texte, theme): """créér ou modifier la text""" if text_id == '0': query = "INSERT INTO p_texts (intitule, texte, theme) VALUES(:intitule, :texte, :theme);" execute_query(request, query, {'intitule': intitule, 'texte': texte, 'theme': theme}) else: query = "update p_texts set intitule=:intitule, texte=:texte, theme=:theme where text_id = :text_id;" execute_query(request, query, {'text_id': text_id, 'intitule': intitule, 'texte': texte, 'theme': theme}) def delete_text(request, text_id): """supprimer la text""" query = "delete from p_texts where text_id = :text_id;" execute_query(request, query, {'text_id': text_id}) def get_articles_byFam(request, fam): if fam == 'T': query = "SELECT * FROM articles WHERE FAM = 'T';" else: query = "SELECT * FROM articles WHERE FAM != 'T';" results = request.dbsession.execute(query, ).fetchall() return results def update_article(request, ref, new_values): # formater les champs s = '' for param in new_values.keys(): if param == 'FAM': ' ne prend que 2 premiers caractères' new_values['FAM'] = new_values['FAM'][0:2].upper() if s: s += ",%s=:%s" % (param, param) else: s = "%s=:%s" % (param, param) if ref == '0': query = "INSERT INTO articles SET %s" % s else: new_values['ref'] = ref query = "UPDATE articles SET %s WHERE ref = :ref;" % s execute_query(request, query, new_values) def delete_article(request, ref): query = "DELETE FROM articles WHERE ref = :ref ;" execute_query(request, query, {'ref': ref}) def update_cabinet(request, code, new_values): # formater les champs s = '' for param in new_values.keys(): if s: s += ",%s=:%s" % (param, param) else: s = "%s=:%s" % (param, param) if code == '0': query = "CALL spINS_P_CABINET(:nom);" results = request.dbsession.execute(query, {'nom': new_values['NOM']}).first() # recupère lenouveau code créé code = results.newligne new_values['code'] = code query = "UPDATE p_cabinet SET %s WHERE code = :code;" % s execute_query(request, query, new_values) def delete_cabinet(request, code): query = "DELETE FROM p_cabinet WHERE code = :code ;" execute_query(request, query, {'code': code}) def update_expert(request, code_cab, code_exp, new_values): # formater les champs s = '' for param in new_values.keys(): if s: s += ",%s=:%s" % (param, param) else: s = "%s=:%s" % (param, param) if code_exp == '0': query = "CALL spINS_P_EXPERT(:code_cab, :nom);" results = request.dbsession.execute(query, {'code_cab': code_cab, 'nom': new_values['NOM']}).first() # recupère lenouveau code créé code_exp = results.newligne new_values['code_cab'] = code_cab new_values['code_exp'] = code_exp query = "UPDATE p_experts SET %s WHERE code_cab = :code_cab AND code_exp = :code_exp;" % s execute_query(request, query, new_values) def delete_expert(request, code_cab, code_exp): query = "DELETE FROM p_experts WHERE code_cab = :code_cab AND code_exp = :code_exp;" execute_query(request, query, {'code_cab': code_cab, 'code_exp': code_exp}) def get_stats_delai_groupe(request, societe, datedeb, datefin): query = """SELECT group2, group2_lib FROM stats_delais WHERE societe=:societe AND group1 >= :datedeb AND group1 < :datefin GROUP BY group2 ORDER BY group2_lib;""" results = request.dbsession.execute(query, {'societe': societe, 'datedeb': datedeb.strftime("%Y%m"), 'datefin': datefin.strftime("%Y%m")}) return results.fetchall() def get_stats_delais(request, societe, datedeb, datefin, groupe, id_chart): # lire les examens sur 12 mois glissants par moniteur query = """SELECT * FROM stats_delais WHERE societe=:societe AND id=:id_chart AND group1 >= :datedeb AND group1 < :datefin AND group2=:groupe order by group1;""" results = request.dbsession.execute(query, {'societe': societe, 'id_chart': id_chart, 'datedeb': datedeb.strftime("%Y%m"), 'datefin': datefin.strftime("%Y%m"), 'groupe': groupe}) return results.fetchall()