57 lines
1.9 KiB
Python
57 lines
1.9 KiB
Python
# -*- 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})
|