# -*- coding: utf8 -*-
from zope.sqlalchemy import (
    mark_changed
)

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_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 update_societe(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)

    new_values['societe'] = code
    query = "UPDATE p_societe SET %s WHERE societe = :societe;" % s
    execute_query(request, query, new_values)

def update_tarif(request, ref, 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 ref == '0':
        query = "INSERT INTO tarifs SET %s" % s
    else:
        new_values['ref'] = ref
        query = "UPDATE tarifs SET %s WHERE ref = :ref;" % s
    execute_query(request, query, new_values)

def delete_tarif(request, ref):
    query = "DELETE FROM tarifs WHERE ref = :ref ;"
    execute_query(request, query, {'ref': ref})

def get_tarifs_byGroupe(request, groupe):
    query = "SELECT * FROM tarifs WHERE groupe = :groupe;"
    results = request.dbsession.execute(query, {'groupe': groupe}).fetchall()           
    return results

def get_tarif(request, groupe, ref):
    query = "SELECT * FROM tarifs WHERE groupe = :groupe and ref = :ref;"
    results = request.dbsession.execute(query, {'groupe': groupe, 'ref': ref}).first()
    return results

def get_p_acces(request):
    query = """SELECT * FROM p_acces ORDER BY code;"""
    results = request.dbsession.execute(query).fetchall()
    return results