234 lines
8.6 KiB
Python
Executable File
234 lines
8.6 KiB
Python
Executable File
#!/usr/bin/python3
|
|
|
|
# Libre en Communs's mecene control program
|
|
# Copyright (C) 2022-2024 Libre en Communs
|
|
|
|
# This program is free software: you can redistribute it and/or modify
|
|
# it under the terms of the GNU Affero General Public License as
|
|
# published by the Free Software Foundation, either version 3 of the
|
|
# License, or (at your option) any later version.
|
|
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU Affero General Public License for more details.
|
|
|
|
# You should have received a copy of the GNU Affero General Public License
|
|
# along with this program. If not, see <https://www.gnu.org/licenses/>.
|
|
|
|
import os
|
|
import requests
|
|
import datetime
|
|
import smtplib
|
|
from email.mime.multipart import MIMEMultipart
|
|
from email.mime.text import MIMEText
|
|
from email.mime.base import MIMEBase
|
|
from email import encoders
|
|
from requests.auth import HTTPBasicAuth
|
|
|
|
VERSION = "1.0.0"
|
|
GESTION_SECRET_FILE = "/home/tresorier/.secret/gestion_api_password"
|
|
WORKDIR = "/srv/validation_don.d"
|
|
MODALITY_MAIL = "mail_instructions.txt"
|
|
MODALITY_MAIL_HEADERS = "mail_instructions_headers.txt"
|
|
RECEPT_MAIL = "mail_recu.txt"
|
|
RECEPT_MAIL_HEADERS = "mail_recu_headers.txt"
|
|
RECEPT_MAIL_ATTACHMENT = "mail_recu_attachment.txt"
|
|
SUMMARY_MAIL = "mail_recap_header.txt"
|
|
|
|
# SMTP settings (adjust as necessary)
|
|
SMTP_SERVER = 'mail.a-lec.org'
|
|
SMTP_PORT = 587
|
|
SMTP_USER = 'tresorier@a-lec.org'
|
|
SMTP_SECRET_FILE = "/home/tresorier/.secret/smtp_api_password"
|
|
|
|
BUF = []
|
|
|
|
# Utility functions
|
|
def gestion_get_secret():
|
|
with open(GESTION_SECRET_FILE) as sfile:
|
|
return sfile.readline().strip()
|
|
|
|
def smtp_get_secret():
|
|
with open(SMTP_SECRET_FILE) as sfile:
|
|
return sfile.readline().strip()
|
|
|
|
def get_file_content(filename):
|
|
with open(filename) as sfile:
|
|
return sfile.readlines()
|
|
|
|
def get_file_content_all(filename):
|
|
with open(filename) as sfile:
|
|
return sfile.read()
|
|
|
|
def set_file_content(filename, lines):
|
|
with open(filename, "x") as sfile:
|
|
return sfile.writelines(lines)
|
|
|
|
def gestion_read(req):
|
|
response = requests.post('https://gestion.a-lec.org/api/sql/',
|
|
auth=HTTPBasicAuth('api666', gestion_get_secret()),
|
|
data=req)
|
|
return response.json()
|
|
|
|
def setup_workdir():
|
|
for subdir in ['transition', 'nouveau', 'validé']:
|
|
path = os.path.join(WORKDIR, subdir)
|
|
if not os.path.exists(path):
|
|
os.makedirs(path)
|
|
|
|
# Send email with attachment via SMTP, password fetched from file
|
|
def sendmail_with_attachment(headers, data, attachment_path=None, filename=None):
|
|
# Create a multipart message
|
|
msg = MIMEMultipart()
|
|
|
|
# Add the headers without manually setting Content-Type or MIME-Version
|
|
for header in headers.split("\n"):
|
|
if ": " in header and "Content-Type" not in header and "Mime-Version" not in header:
|
|
key, value = header.split(": ", 1)
|
|
msg[key] = value.strip()
|
|
|
|
# Add the email body
|
|
body = MIMEText(data, 'plain', 'utf-8')
|
|
msg.attach(body)
|
|
|
|
# Add the attachment only if attachment_path is provided
|
|
if attachment_path and filename:
|
|
with open(attachment_path, "rb") as attach_file:
|
|
attachment = MIMEBase('application', 'octet-stream')
|
|
attachment.set_payload(attach_file.read())
|
|
encoders.encode_base64(attachment)
|
|
attachment.add_header('Content-Disposition', f'attachment; filename={filename}')
|
|
msg.attach(attachment)
|
|
|
|
# Send the email
|
|
try:
|
|
with smtplib.SMTP(SMTP_SERVER, SMTP_PORT) as server:
|
|
server.starttls() # Start TLS encryption
|
|
server.login(SMTP_USER, smtp_get_secret())
|
|
server.sendmail(SMTP_USER, msg['To'], msg.as_string())
|
|
print("Email sent successfully")
|
|
except Exception as e:
|
|
print(f"Failed to send email: {e}")
|
|
|
|
# Notify unpaid donors
|
|
def notify_unpaid(record):
|
|
content = get_file_content_all(os.path.join(WORKDIR, "transition", record)).split("\n")
|
|
if len(content) > 8 and "notified" in content[8]:
|
|
return # Already notified
|
|
|
|
# Parse donor information
|
|
name, surname, address, postal_code, city, email, amount, mode = content[:8]
|
|
|
|
BUF.append(f"* {record} {name}, {amount} €")
|
|
BUF.append(" NOTIFICATION DONATEUR")
|
|
BUF.append("")
|
|
|
|
mailtext = get_file_content_all(MODALITY_MAIL)
|
|
mailtext = mailtext.replace("NOM_DONNEUR", f"{surname} {name}")
|
|
mailtext = mailtext.replace("NUMERO_DON", str(record))
|
|
mailtext = mailtext.replace("MONTANT_DON", amount)
|
|
mailtext = mailtext.replace("MODE_DON", mode)
|
|
|
|
mailheaders = get_file_content_all(MODALITY_MAIL_HEADERS)
|
|
mailheaders = mailheaders.replace("COURRIEL_DONNEUR", email)
|
|
|
|
# Notify
|
|
sendmail_with_attachment(mailheaders, mailtext, None, None)
|
|
|
|
# Mark as notified
|
|
with open(os.path.join(WORKDIR, "transition", record), "a") as sfile:
|
|
sfile.write("notified\n")
|
|
|
|
# Validate donation records
|
|
def validate(record):
|
|
request = f"SELECT * FROM acc_transactions tr INNER JOIN acc_transactions_lines l " \
|
|
f"ON tr.id = l.id_transaction WHERE tr.notes LIKE '%{record}%' AND id_account = 469"
|
|
|
|
try:
|
|
answer = gestion_read(request)["results"][-1]
|
|
except IndexError:
|
|
return False # If no result, donation not validated
|
|
|
|
# Parse donor information
|
|
name, surname, address, postal_code, city, email, amount, mode = \
|
|
get_file_content_all(os.path.join(WORKDIR, "transition", record)).split("\n")[:8]
|
|
|
|
date = datetime.datetime.strptime(answer["date"], '%Y-%m-%d').strftime("%d/%m/%Y")
|
|
filename = f"{name}_reçu_{record}_{date.replace('/', '.')}"
|
|
|
|
BUF.append(f"* {record} {name}, {amount} €")
|
|
BUF.append(" VALIDATION DON")
|
|
BUF.append("")
|
|
|
|
# Generate receipt
|
|
latexfile = get_file_content_all("RECU_FISCAL.tex")
|
|
latexfile = latexfile.replace("NUMERO-DON", record)
|
|
latexfile = latexfile.replace("ANNEE-CIVILE", answer["date"][:4])
|
|
latexfile = latexfile.replace("NOM-DONATEUR", name)
|
|
latexfile = latexfile.replace("STATUT-DONATEUR", "Personne physique")
|
|
latexfile = latexfile.replace("ADRESSE-DONATEUR", f"{address}, {postal_code} {city}")
|
|
latexfile = latexfile.replace("SOMME", f"{str(answer['credit'])[:-2]},{str(answer['credit'])[-2:]}")
|
|
latexfile = latexfile.replace("DATE-VERSEMENT", date)
|
|
latexfile = latexfile.replace("MODE-VERSEMENT", answer["reference"])
|
|
latexfile = latexfile.replace("FORME-DON", "Déclaration de don manuel")
|
|
latexfile = latexfile.replace("NATURE-DON", "Numéraire")
|
|
|
|
# Save the LaTeX file and generate the PDF
|
|
tex_file_path = os.path.join(WORKDIR, "validé", f"{filename}.tex")
|
|
set_file_content(tex_file_path, latexfile)
|
|
os.system(f"cd {WORKDIR}/validé/ && pdflatex {filename}.tex")
|
|
|
|
# Prepare and send email with attachment
|
|
mailheaders = get_file_content_all(RECEPT_MAIL_HEADERS).replace("COURRIEL-DON", email)
|
|
mailtext = get_file_content_all(RECEPT_MAIL).replace("DATE-DON", date)
|
|
mailtattach = get_file_content_all(RECEPT_MAIL_ATTACHMENT).replace("DATE-DON", f"{record}_{date.replace('/', '.')}")
|
|
pdf_path = os.path.join(WORKDIR, "validé", f"{filename}.pdf")
|
|
|
|
sendmail_with_attachment(mailheaders, mailtext, pdf_path, f"{filename}.pdf")
|
|
|
|
# Clean up
|
|
os.remove(os.path.join(WORKDIR, "transition", record))
|
|
return True
|
|
|
|
# Process new donation records
|
|
def check_record(intent):
|
|
numero, content = get_file_content_all(intent).split("|")
|
|
name, surname, address, postal_code, city, email, amount, mode = content.split(";")[:8]
|
|
|
|
BUF.append(f"* {numero} {name} {surname}, {amount} €")
|
|
BUF.append(" NOUVEAU DON")
|
|
BUF.append("")
|
|
|
|
lines = [f"{name}\n{surname}\n{address}\n{postal_code}\n{city}\n{email}\n{amount}\n{mode}\n"]
|
|
set_file_content(os.path.join(WORKDIR, "transition", numero), lines)
|
|
os.remove(intent) # Clean up processed intent file
|
|
|
|
# Main donation validation workflow
|
|
def validate_donors():
|
|
# Process new donation intents
|
|
for new_intent in os.listdir(os.path.join(WORKDIR, "nouveau")):
|
|
check_record(os.path.join(WORKDIR, "nouveau", new_intent))
|
|
|
|
# Validate existing records or notify unpaid
|
|
for record in os.listdir(os.path.join(WORKDIR, "transition")):
|
|
if not validate(record):
|
|
notify_unpaid(record)
|
|
|
|
# Main function
|
|
def main():
|
|
setup_workdir()
|
|
validate_donors()
|
|
|
|
# Send summary email
|
|
mailheaders = get_file_content_all(SUMMARY_MAIL) + "\n"
|
|
mailtext = ""
|
|
|
|
if BUF:
|
|
mailtext = "\n".join(BUF)
|
|
sendmail_with_attachment(mailheaders, mailtext, None, None)
|
|
|
|
if __name__ == '__main__':
|
|
main()
|
|
|