112 lines
4.3 KiB
Python
112 lines
4.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 get_emails_sent(request, societe, nolig):
|
|
d = datetime.now()
|
|
d = d - dateutil.relativedelta.relativedelta(months=1)
|
|
# début du mois M-3
|
|
datedeb = d.strftime('%Y-%m-%d')
|
|
|
|
if nolig == 0:
|
|
query = """SELECT CONCAT(l.societe,"-",l.no_id) as nodossier, l.datemaj, l.comment, l.nolig, l.usermaj, e.nomcli FROM dem_lig l
|
|
INNER JOIN dem_devis e ON l.societe=e.societe AND l.no_id=e.no_id
|
|
WHERE l.societe = :societe AND l.date >= :datedeb AND l.comment LIKE 'Envoi email -> %' ORDER BY l.datemaj LIMIT 250;"""
|
|
results = request.dbsession.execute(query, {'societe': societe, 'datedeb': datedeb}).fetchall()
|
|
else:
|
|
query = """SELECT * FROM dem_lig WHERE nolig=:nolig;"""
|
|
results = request.dbsession.execute(query, {'nolig': nolig}).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})
|