67 lines
2.3 KiB
Python
67 lines
2.3 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 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})
|