Compare commits
3 Commits
43774b4af7
...
bf39e8a8b9
Author | SHA1 | Date |
---|---|---|
Adrien Bourmault | bf39e8a8b9 | |
Adrien Bourmault | e7442c89aa | |
Adrien Bourmault | 652e7b1f20 |
|
@ -1,7 +1,7 @@
|
||||||
#!/usr/bin/python3
|
#!/usr/bin/python3
|
||||||
|
|
||||||
# Libre en Communs's adhesion control program
|
# Libre en Communs's adhesion control program
|
||||||
# Copyright (C) 2022 Libre en Communs
|
# Copyright (C) 2022-2024 Libre en Communs
|
||||||
|
|
||||||
# This program is free software: you can redistribute it and/or modify
|
# This program is free software: you can redistribute it and/or modify
|
||||||
# it under the terms of the GNU Affero General Public License as
|
# it under the terms of the GNU Affero General Public License as
|
||||||
|
@ -22,6 +22,9 @@ from typing import List
|
||||||
from requests.auth import HTTPBasicAuth
|
from requests.auth import HTTPBasicAuth
|
||||||
from requests.auth import HTTPDigestAuth
|
from requests.auth import HTTPDigestAuth
|
||||||
|
|
||||||
|
import smtplib
|
||||||
|
from email.mime.text import MIMEText
|
||||||
|
from email.mime.multipart import MIMEMultipart
|
||||||
|
|
||||||
VERSION="1.0.0"
|
VERSION="1.0.0"
|
||||||
GESTION_SECRET_FILE="/home/secretaire/.secret/gestion_api_password"
|
GESTION_SECRET_FILE="/home/secretaire/.secret/gestion_api_password"
|
||||||
|
@ -34,10 +37,27 @@ SENDMAIL_LOCATION = "/usr/sbin/sendmail" # sendmail location
|
||||||
BUF=[]
|
BUF=[]
|
||||||
GITEA_URL = "https://forge.a-lec.org"
|
GITEA_URL = "https://forge.a-lec.org"
|
||||||
|
|
||||||
|
# Update these with your SMTP server details
|
||||||
|
SMTP_SERVER = 'mail.a-lec.org'
|
||||||
|
SMTP_PORT = 587
|
||||||
|
SMTP_USER = 'secretaire@a-lec.org'
|
||||||
|
SMTP_SECRET_FILE = "/home/secretaire/.secret/smtp_api_password"
|
||||||
|
|
||||||
|
# gestion_read("SELECT * FROM services_users su \
|
||||||
|
# INNER JOIN membres m ON m.id = su.id_user \
|
||||||
|
# INNER JOIN services_fees sf ON sf.id = su.id_fee \
|
||||||
|
# LEFT JOIN acc_transactions_users tu ON tu.id_service_user = su.id \
|
||||||
|
# LEFT JOIN acc_transactions_lines l ON l.id_transaction = tu.id_transaction \
|
||||||
|
# WHERE m.id = 3 AND l.id_account = 481;")
|
||||||
|
|
||||||
def gestion_get_secret():
|
def gestion_get_secret():
|
||||||
with open(GESTION_SECRET_FILE) as sfile:
|
with open(GESTION_SECRET_FILE) as sfile:
|
||||||
return sfile.readline().replace("\n", "")
|
return sfile.readline().replace("\n", "")
|
||||||
|
|
||||||
|
def smtp_get_secret():
|
||||||
|
with open(SMTP_SECRET_FILE) as sfile:
|
||||||
|
return sfile.readline().replace("\n", "")
|
||||||
|
|
||||||
def git_get_secret():
|
def git_get_secret():
|
||||||
with open(GIT_SECRET_FILE) as sfile:
|
with open(GIT_SECRET_FILE) as sfile:
|
||||||
return sfile.readline().replace("\n", "")
|
return sfile.readline().replace("\n", "")
|
||||||
|
@ -86,10 +106,31 @@ def setup_workdir():
|
||||||
if not "refuse" in os.listdir(WORKDIR):
|
if not "refuse" in os.listdir(WORKDIR):
|
||||||
os.mkdir(WORKDIR+"/refuse")
|
os.mkdir(WORKDIR+"/refuse")
|
||||||
|
|
||||||
|
# def sendmail(headers, data):
|
||||||
|
# print("***\nHEADERS: {}\n***\n".format(headers))
|
||||||
|
# msg = bytes(headers + "\n", 'utf-8') + quopri.encodestring(bytes(data, 'utf-8'))
|
||||||
|
# subprocess.run([SENDMAIL_LOCATION, "-t", "-oi"], input=msg)
|
||||||
|
|
||||||
def sendmail(headers, data):
|
def sendmail(headers, data):
|
||||||
print("***\nHEADERS: {}\n***\n".format(headers))
|
print("***\nHEADERS: {}\n***\n".format(headers))
|
||||||
msg = bytes(headers + "\n", 'utf-8') + quopri.encodestring(bytes(data, 'utf-8'))
|
# Prepare the email
|
||||||
subprocess.run([SENDMAIL_LOCATION, "-t", "-oi"], input=msg)
|
msg = MIMEMultipart()
|
||||||
|
for header in headers.split("\n"):
|
||||||
|
if ": " in header:
|
||||||
|
key, value = header.split(": ", 1)
|
||||||
|
msg[key] = value
|
||||||
|
msg.attach(MIMEText(data, 'plain'))
|
||||||
|
|
||||||
|
# Connect to the SMTP server and send the email
|
||||||
|
try:
|
||||||
|
server = smtplib.SMTP(SMTP_SERVER, SMTP_PORT)
|
||||||
|
server.starttls() # Upgrade the connection to a secure TLS connection
|
||||||
|
server.login(SMTP_USER, smtp_get_secret())
|
||||||
|
server.sendmail(SMTP_USER, msg['To'], msg.as_string())
|
||||||
|
server.quit()
|
||||||
|
#print("Email sent successfully")
|
||||||
|
except Exception as e:
|
||||||
|
print(f"Failed to send email: {e}")
|
||||||
|
|
||||||
def new_registrations_worker():
|
def new_registrations_worker():
|
||||||
if (os.listdir(WORKDIR+"/nouveau") == []):
|
if (os.listdir(WORKDIR+"/nouveau") == []):
|
||||||
|
|
|
@ -1,7 +1,7 @@
|
||||||
#!/usr/bin/python3
|
#!/usr/bin/python3
|
||||||
|
|
||||||
# Libre en Communs's cotisation control program
|
# Libre en Communs's cotisation control program
|
||||||
# Copyright (C) 2022 Libre en Communs
|
# Copyright (C) 2022-2024 Libre en Communs
|
||||||
|
|
||||||
# This program is free software: you can redistribute it and/or modify
|
# This program is free software: you can redistribute it and/or modify
|
||||||
# it under the terms of the GNU Affero General Public License as
|
# it under the terms of the GNU Affero General Public License as
|
||||||
|
@ -19,7 +19,13 @@
|
||||||
import os, requests, json, datetime, shutil, quopri, subprocess, base64
|
import os, requests, json, datetime, shutil, quopri, subprocess, base64
|
||||||
from requests.auth import HTTPBasicAuth
|
from requests.auth import HTTPBasicAuth
|
||||||
from requests.auth import HTTPDigestAuth
|
from requests.auth import HTTPDigestAuth
|
||||||
|
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 email.utils import formataddr
|
||||||
|
from pathlib import Path
|
||||||
|
|
||||||
VERSION="1.0.0"
|
VERSION="1.0.0"
|
||||||
GESTION_SECRET_FILE="/home/tresorier/.secret/gestion_api_password"
|
GESTION_SECRET_FILE="/home/tresorier/.secret/gestion_api_password"
|
||||||
|
@ -35,6 +41,12 @@ SENDMAIL_LOCATION = "/usr/sbin/sendmail" # sendmail location
|
||||||
BUF=[]
|
BUF=[]
|
||||||
GITEA_URL = "https://forge.a-lec.org"
|
GITEA_URL = "https://forge.a-lec.org"
|
||||||
|
|
||||||
|
# Update these with your SMTP server details
|
||||||
|
SMTP_SERVER = 'mail.a-lec.org'
|
||||||
|
SMTP_PORT = 587
|
||||||
|
SMTP_USER = 'tresorier@a-lec.org'
|
||||||
|
SMTP_SECRET_FILE = "/home/tresorier/.secret/smtp_api_password"
|
||||||
|
|
||||||
# gestion_read("SELECT * FROM services_users su \
|
# gestion_read("SELECT * FROM services_users su \
|
||||||
# INNER JOIN membres m ON m.id = su.id_user \
|
# INNER JOIN membres m ON m.id = su.id_user \
|
||||||
# INNER JOIN services_fees sf ON sf.id = su.id_fee \
|
# INNER JOIN services_fees sf ON sf.id = su.id_fee \
|
||||||
|
@ -46,6 +58,10 @@ def gestion_get_secret():
|
||||||
with open(GESTION_SECRET_FILE) as sfile:
|
with open(GESTION_SECRET_FILE) as sfile:
|
||||||
return sfile.readline().replace("\n", "")
|
return sfile.readline().replace("\n", "")
|
||||||
|
|
||||||
|
def smtp_get_secret():
|
||||||
|
with open(SMTP_SECRET_FILE) as sfile:
|
||||||
|
return sfile.readline().replace("\n", "")
|
||||||
|
|
||||||
def git_get_secret():
|
def git_get_secret():
|
||||||
with open(GIT_SECRET_FILE) as sfile:
|
with open(GIT_SECRET_FILE) as sfile:
|
||||||
return sfile.readline().replace("\n", "")
|
return sfile.readline().replace("\n", "")
|
||||||
|
@ -84,18 +100,48 @@ def setup_workdir():
|
||||||
if not "transition" in os.listdir(WORKDIR):
|
if not "transition" in os.listdir(WORKDIR):
|
||||||
os.mkdir(WORKDIR+"/transition")
|
os.mkdir(WORKDIR+"/transition")
|
||||||
|
|
||||||
def sendmail(headers, data):
|
# def sendmail(headers, data):
|
||||||
msg = bytes(headers + "\n", 'utf-8') + quopri.encodestring(bytes(data, 'utf-8'))
|
# msg = bytes(headers + "\n", 'utf-8') + quopri.encodestring(bytes(data, 'utf-8'))
|
||||||
subprocess.run([SENDMAIL_LOCATION, "-t", "-oi"], input=msg)
|
# subprocess.run([SENDMAIL_LOCATION, "-t", "-oi"], input=msg)
|
||||||
|
|
||||||
def sendmail_with_attachment(headers, data, attachment_header, attachment, ending):
|
# def sendmail_with_attachment(headers, data, attachment_header, attachment, ending):
|
||||||
msg = bytes(headers + "\n", 'utf-8') \
|
# msg = bytes(headers + "\n", 'utf-8') \
|
||||||
+ quopri.encodestring(bytes(data, 'utf-8')) \
|
# + quopri.encodestring(bytes(data, 'utf-8')) \
|
||||||
+ bytes(attachment_header + "\n", 'utf-8') \
|
# + bytes(attachment_header + "\n", 'utf-8') \
|
||||||
+ base64.b64encode(attachment) \
|
# + base64.b64encode(attachment) \
|
||||||
+ bytes(ending, 'utf-8')
|
# + bytes(ending, 'utf-8')
|
||||||
|
|
||||||
subprocess.run([SENDMAIL_LOCATION, "-t", "-oi"], input=msg)
|
# subprocess.run([SENDMAIL_LOCATION, "-t", "-oi"], input=msg)
|
||||||
|
|
||||||
|
|
||||||
|
def sendmail_with_attachment(headers, data, attachment_path, filename):
|
||||||
|
# Parse headers
|
||||||
|
msg = MIMEMultipart()
|
||||||
|
for header in headers.split("\n"):
|
||||||
|
if ": " in header:
|
||||||
|
key, value = header.split(": ", 1)
|
||||||
|
msg[key] = value
|
||||||
|
|
||||||
|
# Add the email body
|
||||||
|
body = MIMEText(data, 'plain', 'utf-8')
|
||||||
|
msg.attach(body)
|
||||||
|
|
||||||
|
# Add the attachment
|
||||||
|
attachment = MIMEBase('application', 'octet-stream')
|
||||||
|
attachment.set_payload(Path(attachment_path).read_bytes())
|
||||||
|
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}")
|
||||||
|
|
||||||
def gestion_get_expired():
|
def gestion_get_expired():
|
||||||
request_expired = "SELECT id_user FROM services_users su " +\
|
request_expired = "SELECT id_user FROM services_users su " +\
|
||||||
|
@ -396,23 +442,15 @@ def validate(member):
|
||||||
set_file_content(WORKDIR+"/validé/"+filename+".tex", latexfile)
|
set_file_content(WORKDIR+"/validé/"+filename+".tex", latexfile)
|
||||||
os.system("cd {} && pdflatex {}".format(WORKDIR+"/validé/", filename+".tex"))
|
os.system("cd {} && pdflatex {}".format(WORKDIR+"/validé/", filename+".tex"))
|
||||||
|
|
||||||
# Preparing mail
|
# Preparing the email
|
||||||
mailheaders = get_file_content_all(RECEPT_MAIL_HEADERS).replace("COURRIEL-COTISANT",
|
mailheaders = get_file_content_all(RECEPT_MAIL_HEADERS).replace("COURRIEL-COTISANT", answer["email"]) + "\n"
|
||||||
answer["email"]) + "\n"
|
mailtext = get_file_content_all(RECEPT_MAIL).replace("ANNEE-CIVILE", answer["date"][:4]) + "\n"
|
||||||
mailtext = get_file_content_all(RECEPT_MAIL).replace("ANNEE-CIVILE",
|
|
||||||
answer["date"][:4]) + "\n"
|
|
||||||
mailtattach = get_file_content_all(RECEPT_MAIL_ATTACHMENT) + "\n"
|
|
||||||
|
|
||||||
# Opening PDF file as binary
|
# Sending the email with the attached PDF
|
||||||
attachment = open(WORKDIR+"/validé/"+filename+".pdf", "rb")
|
pdf_path = WORKDIR+"/validé/"+filename+".pdf"
|
||||||
data = attachment.read()
|
sendmail_with_attachment(mailheaders, mailtext, pdf_path, filename + ".pdf")
|
||||||
attachment.close()
|
|
||||||
|
|
||||||
ending = "--------------3yxkFgv0AINs5nd0i6BJrWaV--"
|
# Cleanup
|
||||||
|
|
||||||
sendmail_with_attachment(mailheaders, mailtext, mailtattach, data, ending)
|
|
||||||
|
|
||||||
# The end
|
|
||||||
os.remove(WORKDIR+"/transition/"+member)
|
os.remove(WORKDIR+"/transition/"+member)
|
||||||
|
|
||||||
def validate_members():
|
def validate_members():
|
||||||
|
|
|
@ -1,7 +1,7 @@
|
||||||
#!/usr/bin/python3
|
#!/usr/bin/python3
|
||||||
|
|
||||||
# Libre en Communs's mecene control program
|
# Libre en Communs's mecene control program
|
||||||
# Copyright (C) 2022 Libre en Communs
|
# Copyright (C) 2022-2024 Libre en Communs
|
||||||
|
|
||||||
# This program is free software: you can redistribute it and/or modify
|
# This program is free software: you can redistribute it and/or modify
|
||||||
# it under the terms of the GNU Affero General Public License as
|
# it under the terms of the GNU Affero General Public License as
|
||||||
|
@ -16,10 +16,15 @@
|
||||||
# You should have received a copy of the GNU Affero General Public License
|
# 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/>.
|
# along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||||
|
|
||||||
import os, requests, json, datetime, shutil, quopri, subprocess, base64
|
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
|
from requests.auth import HTTPBasicAuth
|
||||||
from requests.auth import HTTPDigestAuth
|
|
||||||
|
|
||||||
|
|
||||||
VERSION = "1.0.0"
|
VERSION = "1.0.0"
|
||||||
GESTION_SECRET_FILE = "/home/tresorier/.secret/gestion_api_password"
|
GESTION_SECRET_FILE = "/home/tresorier/.secret/gestion_api_password"
|
||||||
|
@ -30,19 +35,23 @@ RECEPT_MAIL="mail_recu.txt"
|
||||||
RECEPT_MAIL_HEADERS = "mail_recu_headers.txt"
|
RECEPT_MAIL_HEADERS = "mail_recu_headers.txt"
|
||||||
RECEPT_MAIL_ATTACHMENT = "mail_recu_attachment.txt"
|
RECEPT_MAIL_ATTACHMENT = "mail_recu_attachment.txt"
|
||||||
SUMMARY_MAIL = "mail_recap_header.txt"
|
SUMMARY_MAIL = "mail_recap_header.txt"
|
||||||
SENDMAIL_LOCATION = "/usr/sbin/sendmail" # sendmail location
|
|
||||||
|
# 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 = []
|
BUF = []
|
||||||
|
|
||||||
# gestion_read("SELECT * FROM services_users su \
|
# Utility functions
|
||||||
# INNER JOIN membres m ON m.id = su.id_user \
|
|
||||||
# INNER JOIN services_fees sf ON sf.id = su.id_fee \
|
|
||||||
# LEFT JOIN acc_transactions_users tu ON tu.id_service_user = su.id \
|
|
||||||
# LEFT JOIN acc_transactions_lines l ON l.id_transaction = tu.id_transaction \
|
|
||||||
# WHERE m.id = 3 AND l.id_account = 481;")
|
|
||||||
|
|
||||||
def gestion_get_secret():
|
def gestion_get_secret():
|
||||||
with open(GESTION_SECRET_FILE) as sfile:
|
with open(GESTION_SECRET_FILE) as sfile:
|
||||||
return sfile.readline().replace("\n", "")
|
return sfile.readline().strip()
|
||||||
|
|
||||||
|
def smtp_get_secret():
|
||||||
|
with open(SMTP_SECRET_FILE) as sfile:
|
||||||
|
return sfile.readline().strip()
|
||||||
|
|
||||||
def get_file_content(filename):
|
def get_file_content(filename):
|
||||||
with open(filename) as sfile:
|
with open(filename) as sfile:
|
||||||
|
@ -63,85 +72,90 @@ def gestion_read(req):
|
||||||
return response.json()
|
return response.json()
|
||||||
|
|
||||||
def setup_workdir():
|
def setup_workdir():
|
||||||
if not os.path.isdir(WORKDIR):
|
for subdir in ['transition', 'nouveau', 'validé']:
|
||||||
os.mkdir(WORKDIR)
|
path = os.path.join(WORKDIR, subdir)
|
||||||
if not "transition" in os.listdir(WORKDIR):
|
if not os.path.exists(path):
|
||||||
os.mkdir(WORKDIR+"/transition")
|
os.makedirs(path)
|
||||||
if not "nouveau" in os.listdir(WORKDIR):
|
|
||||||
os.mkdir(WORKDIR+"/nouveau")
|
|
||||||
if not "validé" in os.listdir(WORKDIR):
|
|
||||||
os.mkdir(WORKDIR+"/validé")
|
|
||||||
|
|
||||||
def sendmail(headers, data):
|
# Send email with attachment via SMTP, password fetched from file
|
||||||
msg = bytes(headers + "\n", 'utf-8') + quopri.encodestring(bytes(data, 'utf-8'))
|
def sendmail_with_attachment(headers, body, attachment_path, attachment_filename):
|
||||||
subprocess.run([SENDMAIL_LOCATION, "-t", "-oi"], input=msg)
|
msg = MIMEMultipart()
|
||||||
|
|
||||||
def sendmail_with_attachment(headers, data, attachment_header, attachment, ending):
|
# Add headers
|
||||||
msg = bytes(headers + "\n", 'utf-8') \
|
for header in headers.split("\n"):
|
||||||
+ quopri.encodestring(bytes(data, 'utf-8')) \
|
if ": " in header:
|
||||||
+ bytes(attachment_header + "\n", 'utf-8') \
|
key, value = header.split(": ", 1)
|
||||||
+ base64.b64encode(attachment) \
|
msg[key] = value.strip()
|
||||||
+ bytes(ending, 'utf-8')
|
|
||||||
|
|
||||||
subprocess.run([SENDMAIL_LOCATION, "-t", "-oi"], input=msg)
|
# Email body
|
||||||
|
msg.attach(MIMEText(body, 'plain', 'utf-8'))
|
||||||
|
|
||||||
|
# Attach PDF file
|
||||||
|
if attachment_path:
|
||||||
|
with open(attachment_path, "rb") as attachment:
|
||||||
|
part = MIMEBase('application', 'octet-stream')
|
||||||
|
part.set_payload(attachment.read())
|
||||||
|
encoders.encode_base64(part)
|
||||||
|
part.add_header('Content-Disposition', f'attachment; filename={attachment_filename}')
|
||||||
|
msg.attach(part)
|
||||||
|
|
||||||
|
# Send email
|
||||||
|
try:
|
||||||
|
with smtplib.SMTP(SMTP_SERVER, SMTP_PORT) as server:
|
||||||
|
server.starttls() # Secure the connection
|
||||||
|
server.login(SMTP_USER, smtp_get_secret()) # Fetch SMTP password from file
|
||||||
|
server.sendmail(SMTP_USER, msg['To'], msg.as_string())
|
||||||
|
#print(f"Email sent to {msg['To']}")
|
||||||
|
except Exception as e:
|
||||||
|
print(f"Error sending email: {e}")
|
||||||
|
|
||||||
|
# Notify unpaid donors
|
||||||
def notify_unpaid(record):
|
def notify_unpaid(record):
|
||||||
# Check if notified
|
content = get_file_content_all(os.path.join(WORKDIR, "transition", record)).split("\n")
|
||||||
content = get_file_content_all(WORKDIR+"/transition/"+record).split("\n")
|
|
||||||
if len(content) > 8 and "notified" in content[8]:
|
if len(content) > 8 and "notified" in content[8]:
|
||||||
return
|
return # Already notified
|
||||||
|
|
||||||
# Get infos
|
# Parse donor information
|
||||||
name, surname, address, postal_code, city, email, amount, mode = \
|
name, surname, address, postal_code, city, email, amount, mode = content[:8]
|
||||||
get_file_content_all(WORKDIR+"/transition/"+record).split("\n")[:8]
|
|
||||||
|
|
||||||
BUF.append("* {} {}, {} €".format(record, name, amount))
|
BUF.append(f"* {record} {name}, {amount} €")
|
||||||
BUF.append(" NOTIFICATION DONATEUR")
|
BUF.append(" NOTIFICATION DONATEUR")
|
||||||
BUF.append("")
|
BUF.append("")
|
||||||
|
|
||||||
mailtext = get_file_content_all(MODALITY_MAIL) + "\n"
|
mailtext = get_file_content_all(MODALITY_MAIL)
|
||||||
mailtext = mailtext.replace("NOM_DONNEUR", surname+" "+name)
|
mailtext = mailtext.replace("NOM_DONNEUR", f"{surname} {name}")
|
||||||
mailtext = mailtext.replace("NUMERO_DON", str(record))
|
mailtext = mailtext.replace("NUMERO_DON", str(record))
|
||||||
mailtext = mailtext.replace("MONTANT_DON", amount)
|
mailtext = mailtext.replace("MONTANT_DON", amount)
|
||||||
mailtext = mailtext.replace("MODE_DON", mode)
|
mailtext = mailtext.replace("MODE_DON", mode)
|
||||||
mailheaders = get_file_content_all(MODALITY_MAIL_HEADERS) + "\n"
|
|
||||||
|
mailheaders = get_file_content_all(MODALITY_MAIL_HEADERS)
|
||||||
mailheaders = mailheaders.replace("COURRIEL_DONNEUR", email)
|
mailheaders = mailheaders.replace("COURRIEL_DONNEUR", email)
|
||||||
|
|
||||||
# Notify
|
# Notify
|
||||||
sendmail(mailheaders, mailtext)
|
sendmail_with_attachment(mailheaders, mailtext, None, None)
|
||||||
|
|
||||||
# Indicate as notified
|
# Mark as notified
|
||||||
with open(WORKDIR+"/transition/"+record, "a") as sfile:
|
with open(os.path.join(WORKDIR, "transition", record), "a") as sfile:
|
||||||
sfile.write("notified")
|
sfile.write("notified\n")
|
||||||
|
|
||||||
|
# Validate donation records
|
||||||
def validate(record):
|
def validate(record):
|
||||||
|
request = f"SELECT * FROM acc_transactions tr INNER JOIN acc_transactions_lines l " \
|
||||||
# Get infos
|
f"ON tr.id = l.id_transaction WHERE tr.notes LIKE '%{record}%' AND id_account = 469"
|
||||||
request = "SELECT * FROM acc_transactions tr " +\
|
|
||||||
"INNER JOIN acc_transactions_lines l " +\
|
|
||||||
" ON tr.id = l.id_transaction " +\
|
|
||||||
"WHERE tr.notes LIKE '%{}%' and id_account = 469".format(record)
|
|
||||||
# Note: su.id_service = 1 parceque la cotisation correspond au service 1
|
|
||||||
|
|
||||||
try:
|
try:
|
||||||
answer = gestion_read(request)["results"][-1]
|
answer = gestion_read(request)["results"][-1]
|
||||||
except:
|
except IndexError:
|
||||||
return False
|
return False # If no result, donation not validated
|
||||||
|
|
||||||
|
# Parse donor information
|
||||||
name, surname, address, postal_code, city, email, amount, mode = \
|
name, surname, address, postal_code, city, email, amount, mode = \
|
||||||
get_file_content_all(WORKDIR+"/transition/"+record).split("\n")[:8]
|
get_file_content_all(os.path.join(WORKDIR, "transition", record)).split("\n")[:8]
|
||||||
|
|
||||||
date = datetime.datetime.strptime(
|
date = datetime.datetime.strptime(answer["date"], '%Y-%m-%d').strftime("%d/%m/%Y")
|
||||||
answer["date"],'%Y-%m-%d').strftime("%d/%m/%Y")
|
filename = f"{name}_reçu_{record}_{date.replace('/', '.')}"
|
||||||
|
|
||||||
filename = "{}_reçu_{}_{}".format(
|
BUF.append(f"* {record} {name}, {amount} €")
|
||||||
name,
|
|
||||||
record,
|
|
||||||
date.replace("/", "."))
|
|
||||||
|
|
||||||
BUF.append("* {} {}, {} €".format(record, name, "{},{}".format(
|
|
||||||
str(answer["credit"])[:-2],
|
|
||||||
str(answer["credit"])[-2:])))
|
|
||||||
BUF.append(" VALIDATION DON")
|
BUF.append(" VALIDATION DON")
|
||||||
BUF.append("")
|
BUF.append("")
|
||||||
|
|
||||||
|
@ -150,95 +164,68 @@ def validate(record):
|
||||||
latexfile = latexfile.replace("NUMERO-DON", record)
|
latexfile = latexfile.replace("NUMERO-DON", record)
|
||||||
latexfile = latexfile.replace("ANNEE-CIVILE", answer["date"][:4])
|
latexfile = latexfile.replace("ANNEE-CIVILE", answer["date"][:4])
|
||||||
latexfile = latexfile.replace("NOM-DONATEUR", name)
|
latexfile = latexfile.replace("NOM-DONATEUR", name)
|
||||||
latexfile = latexfile.replace("STATUT-DONATEUR", "Personne physique") # XXX
|
latexfile = latexfile.replace("STATUT-DONATEUR", "Personne physique")
|
||||||
latexfile = latexfile.replace("ADRESSE-DONATEUR", "{}, {} {}".format(
|
latexfile = latexfile.replace("ADRESSE-DONATEUR", f"{address}, {postal_code} {city}")
|
||||||
address,
|
latexfile = latexfile.replace("SOMME", f"{str(answer['credit'])[:-2]},{str(answer['credit'])[-2:]}")
|
||||||
postal_code,
|
|
||||||
city))
|
|
||||||
latexfile = latexfile.replace("SOMME", "{},{}".format(
|
|
||||||
str(answer["credit"])[:-2],
|
|
||||||
str(answer["credit"])[-2:]))
|
|
||||||
latexfile = latexfile.replace("DATE-VERSEMENT", date)
|
latexfile = latexfile.replace("DATE-VERSEMENT", date)
|
||||||
latexfile = latexfile.replace("MODE-VERSEMENT", answer["reference"])
|
latexfile = latexfile.replace("MODE-VERSEMENT", answer["reference"])
|
||||||
latexfile = latexfile.replace("FORME-DON", "Déclaration de don manuel") # XXX
|
latexfile = latexfile.replace("FORME-DON", "Déclaration de don manuel")
|
||||||
latexfile = latexfile.replace("NATURE-DON", "Numéraire") # XXX
|
latexfile = latexfile.replace("NATURE-DON", "Numéraire")
|
||||||
|
|
||||||
try:
|
# Save the LaTeX file and generate the PDF
|
||||||
os.remove(WORKDIR+"/validé/"+filename+".tex")
|
tex_file_path = os.path.join(WORKDIR, "validé", f"{filename}.tex")
|
||||||
except:
|
set_file_content(tex_file_path, latexfile)
|
||||||
pass
|
os.system(f"cd {WORKDIR}/validé/ && pdflatex {filename}.tex")
|
||||||
set_file_content(WORKDIR+"/validé/"+filename+".tex", latexfile)
|
|
||||||
os.system("cd {} && pdflatex {}".format(WORKDIR+"/validé/", filename+".tex"))
|
|
||||||
|
|
||||||
# Preparing mail
|
# Prepare and send email with attachment
|
||||||
mailheaders = get_file_content_all(RECEPT_MAIL_HEADERS).replace(
|
mailheaders = get_file_content_all(RECEPT_MAIL_HEADERS).replace("COURRIEL-DON", email)
|
||||||
"COURRIEL-DON",
|
mailtext = get_file_content_all(RECEPT_MAIL).replace("DATE-DON", date)
|
||||||
email) + "\n"
|
mailtattach = get_file_content_all(RECEPT_MAIL_ATTACHMENT).replace("DATE-DON", f"{record}_{date.replace('/', '.')}")
|
||||||
mailtext = get_file_content_all(RECEPT_MAIL).replace("DATE-DON", date) + "\n"
|
pdf_path = os.path.join(WORKDIR, "validé", f"{filename}.pdf")
|
||||||
mailtattach = get_file_content_all(RECEPT_MAIL_ATTACHMENT).replace(
|
|
||||||
"DATE-DON",
|
|
||||||
record + "_" + date.replace("/", ".")) + "\n"
|
|
||||||
|
|
||||||
# Opening PDF file as binary
|
sendmail_with_attachment(mailheaders, mailtext, pdf_path, f"{filename}.pdf")
|
||||||
attachment = open(WORKDIR+"/validé/"+filename+".pdf", "rb")
|
|
||||||
data = attachment.read()
|
|
||||||
attachment.close()
|
|
||||||
|
|
||||||
ending = "--------------3yxkFgv0AINs5nd0i6BJrWaV--"
|
|
||||||
|
|
||||||
sendmail_with_attachment(mailheaders, mailtext, mailtattach, data, ending)
|
|
||||||
|
|
||||||
# The end
|
|
||||||
os.remove(WORKDIR+"/transition/"+record)
|
|
||||||
|
|
||||||
|
# Clean up
|
||||||
|
os.remove(os.path.join(WORKDIR, "transition", record))
|
||||||
return True
|
return True
|
||||||
|
|
||||||
|
# Process new donation records
|
||||||
def check_record(intent):
|
def check_record(intent):
|
||||||
numero, content = get_file_content_all(intent).split("|")
|
numero, content = get_file_content_all(intent).split("|")
|
||||||
name, surname, address, postal_code, city, email, amount, mode = \
|
name, surname, address, postal_code, city, email, amount, mode = content.split(";")[:8]
|
||||||
content.split(";")[:8]
|
|
||||||
|
|
||||||
BUF.append("* {} {}, {} €".format(numero, name+" "+surname, amount))
|
BUF.append(f"* {numero} {name} {surname}, {amount} €")
|
||||||
BUF.append(" NOUVEAU DON")
|
BUF.append(" NOUVEAU DON")
|
||||||
BUF.append("")
|
BUF.append("")
|
||||||
|
|
||||||
lines = [ "{}\n{}\n{}\n{}\n{}\n{}\n{}\n{}\n".format(
|
lines = [f"{name}\n{surname}\n{address}\n{postal_code}\n{city}\n{email}\n{amount}\n{mode}\n"]
|
||||||
name, surname, address, postal_code, city, email, amount, mode
|
set_file_content(os.path.join(WORKDIR, "transition", numero), lines)
|
||||||
) ]
|
os.remove(intent) # Clean up processed intent file
|
||||||
set_file_content(WORKDIR+"/transition/"+numero, lines)
|
|
||||||
if numero in os.listdir(WORKDIR+"/transition/"):
|
|
||||||
os.remove(intent)
|
|
||||||
|
|
||||||
|
# Main donation validation workflow
|
||||||
def validate_donors():
|
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))
|
||||||
|
|
||||||
# Get new
|
# Validate existing records or notify unpaid
|
||||||
for new_intent in os.listdir(WORKDIR+"/nouveau"):
|
for record in os.listdir(os.path.join(WORKDIR, "transition")):
|
||||||
check_record(WORKDIR+"/nouveau/"+new_intent)
|
|
||||||
|
|
||||||
# Validate record
|
|
||||||
for record in os.listdir(WORKDIR+"/transition"):
|
|
||||||
if not validate(record):
|
if not validate(record):
|
||||||
notify_unpaid(record)
|
notify_unpaid(record)
|
||||||
|
|
||||||
|
# Main function
|
||||||
def main():
|
def main():
|
||||||
setup_workdir()
|
setup_workdir()
|
||||||
#GET DATA()
|
|
||||||
validate_donors()
|
validate_donors()
|
||||||
|
|
||||||
# End of work
|
# Send summary email
|
||||||
# Launch summary mail
|
|
||||||
mailheaders = get_file_content_all(SUMMARY_MAIL) + "\n"
|
mailheaders = get_file_content_all(SUMMARY_MAIL) + "\n"
|
||||||
mailtext = ""
|
mailtext = ""
|
||||||
|
|
||||||
is_sendable = False;
|
if BUF:
|
||||||
for line in BUF:
|
mailtext = "\n".join(BUF)
|
||||||
mailtext += line + "\n"
|
sendmail_with_attachment(mailheaders, mailtext, None, None)
|
||||||
is_sendable = True;
|
|
||||||
print(line)
|
|
||||||
|
|
||||||
if is_sendable:
|
|
||||||
sendmail(mailheaders, mailtext)
|
|
||||||
|
|
||||||
## Bootstrap
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
main()
|
main()
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue