scripts-pde/mails_rappel_ctrl.py

'''
    Script d'envoi automatique de mails de rappel aux maitres d'oeuvre,
    lorsqu'un chantier de contrôle est en état A1 (attente d'intervention)
    depuis plus de X jours (X est défini par la variable SEUIL_DUREE)

    Les données sont issues de la base Contrôles.

@author: olivier.massot, oct. 2017
'''
import logging

from path import Path  # @UnusedImport

from core import logconf
from core.mail import Mail
from core.pde import ControlesDb, RSCDIR
from core.pde import mk_workdir  # @UnusedImport


logger = logging.getLogger("mails_rappel_ctrl")
logconf.start("mails_rappel_ctrl", logging.DEBUG)

DEBUG = False
wrkdir = ""

# # POUR TESTER, décommenter les lignes suivantes
##-----------------------------------------------

# logger.warning("Mode TEST")
# ControlesDb._path = Path(r"\\h2o\local\4-transversal\BDD\mdb_test\cg67Parc_data.mdb")
# DEBUG = True
# wrkdir = mk_workdir("mails_rappel_ctrl")

##-----------------------------------------------

# #     CONFIG

# Nombre de jours à partir duquel les mails sont envoyés
SEUIL_DUREE = 15

# Demarrer la requete de sélection à partir du chantier:
CHANTIER_DEPART = 175000

# Adresse mail depuis laquelle les mails sont envoyés
SENDER = "ne-pas-repondre@bas-rhin.fr"

# Objet des mails automatiques
SUBJECT = "Mail automatique - Rappel"

# Contact
CONTACT = "jacky.klein@bas-rhin.fr"

# Contenu des mails automatiques
#   NB: variables optionelles utilisables dans CONTENT: {chantier_id}, {date_status}, {contact}
with open(RSCDIR / "mail.html", encoding="utf-8") as f:
    content = f.read()

# #     INITIALISATION

db = ControlesDb()

# Sous requête: liste les chantiers compactage/étanchéite/video.
# si le chantier est en état A1, a1_status est Vrai
subsql = """SELECT tblCompactageBases.lngChantierId,
                (tblCompactageBases.bytStatus=45 Or tblCompactageBases.bytStatus=46 Or tblCompactageBases.bytStatus=47) AS a1_status,
                tblCompactageBases.dtmStatus AS since
            FROM tblCompactageBases
            UNION
            SELECT tblEtancheiteBases.lngChantierId,
                (tblEtancheiteBases.bytStatus=45 Or tblEtancheiteBases.bytStatus=46 Or tblEtancheiteBases.bytStatus=47) AS a1_status,
                tblEtancheiteBases.dtmStatus AS since
            FROM tblEtancheiteBases
            UNION
            SELECT tblVideoBases.lngChantierId,
                (tblVideoBases.bytStatus=45 Or tblVideoBases.bytStatus=46 Or tblVideoBases.bytStatus=47) AS a1_status,
                tblVideoBases.dtmStatus AS since
            FROM tblVideoBases
            """

# Selectionne les chantiers pour lesquels un mail doit être envoyé
sql = """SELECT tblChantiers.lngChantierId, tblChantiers.mailContact,
            tblChantiers.stopMails, statuts.a1_status, statuts.since
        FROM tblChantiers INNER JOIN ({subsql}) as statuts ON tblChantiers.lngChantierId = statuts.lngChantierId
        WHERE statuts.a1_status=True
            AND tblChantiers.lngChantierId>={depart}
            AND statuts.since<=(Date()-{seuil})
            ;
        """.format(subsql=subsql,
                   seuil=SEUIL_DUREE,
                   depart=CHANTIER_DEPART)

# #    PROCESS
logger.debug(sql)

qry = db.execute(sql)

for row in qry:
    chantier_id, mail_to, stop_mails, a1, since = row
    if DEBUG:
        mail_to = "olivier.massot@bas-rhin.fr"

    if stop_mails:
        logger.info("X Chantier %s: l'envoi de mail est bloqué", chantier_id)
        continue

    if not mail_to:
        logger.warning("X Chantier %s: pas d'adresse de contact", chantier_id)
        continue

    logger.info("> Chantier %s: envoi d'un mail à %s", chantier_id, mail_to)
    mail = Mail(SENDER,
                [mail_to],
                SUBJECT,
                content.format(
                               chantier_id=chantier_id,
                               date_status=since,
                               contact=CONTACT)
                               )
    mail.send()

    if DEBUG:
        break