264 lines
9.7 KiB
Python
264 lines
9.7 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_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_dd_restant(request):
|
|
query = """SELECT SUM(IF(societe='PE',1,0)) AS nb_PE,
|
|
SUM(IF(societe='ME',1,0)) AS nb_ME,
|
|
SUM(IF(societe='PL',1,0)) AS nb_PL
|
|
FROM dem_devis WHERE STATUS=0;"""
|
|
results = request.dbsession.execute(query).first()
|
|
return results
|
|
|
|
def get_de_restant(request):
|
|
query = """SELECT SUM(IF(societe='PE',1,0)) AS nb_PE,
|
|
SUM(IF(societe='ME',1,0)) AS nb_ME,
|
|
SUM(IF(societe='PL',1,0)) AS nb_PL
|
|
FROM devis WHERE STATUS<4;"""
|
|
results = request.dbsession.execute(query).first()
|
|
return results
|
|
|
|
def get_fa_restant(request):
|
|
query = """SELECT SUM(IF(societe='PE',1,0)) AS nb_PE,
|
|
SUM(IF(societe='ME',1,0)) AS nb_ME,
|
|
SUM(IF(societe='PL',1,0)) AS nb_PL
|
|
FROM facture WHERE STATUS<8;"""
|
|
results = request.dbsession.execute(query).first()
|
|
return results
|
|
|
|
def get_rdv_by_date(request, date, agenda):
|
|
query = """SELECT COUNT(*) AS nb_rdv FROM bddevfac.dem_lig WHERE DATEVI=:date AND LISTE=:agenda;"""
|
|
results = request.dbsession.execute(query, {'date': date, 'agenda': agenda}).first()
|
|
return results
|
|
|
|
def get_rdf_null(request):
|
|
query = """SELECT COUNT(*) AS nb_rdf FROM bddevfac.dem_rdf WHERE date_relu IS NULL;"""
|
|
results = request.dbsession.execute(query).first()
|
|
return results
|