# -*- 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_last_emailing(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_orphans_DE(request, societe):
    
    query = "SELECT * FROM devis WHERE societe = '%s' AND nochantier = 0 ORDER BY date desc LIMIT 50 ;" % (societe)
    results = request.dbsession.execute(query).first()
    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 update_nochantier(request, societe, nodossier, nochantier):
    x = nodossier.split('-')
    type = x[0] 
    no_id = int(x[1])
    
    if type == 'DE':
        query = "UPDATE devis SET nochantier = :nochantier WHERE societe = :societe and no_id = :no_id;"
    else:
        query = "UPDATE facture SET nochantier = :nochantier WHERE societe = :societe and no_id = :no_id;"
    execute_query(request, query, {'societe': societe, 'no_id': no_id, 'nochantier': nochantier})