correction sur l'envoi de mail

This commit is contained in:
2022-08-24 20:47:28 +02:00
parent 91b46472c2
commit 013db2e4ec
+4 -8
View File
@@ -1,22 +1,18 @@
import datetime import datetime
import email import email
import imaplib import imaplib
import re
from concurrent.futures import ThreadPoolExecutor from concurrent.futures import ThreadPoolExecutor
from email.header import decode_header from email.header import decode_header
from email.message import Message from email.message import Message
from builtins import list from builtins import list
from src import params
from src.db.mirgration.migration_tools import migre_accepted_appointment from src.db.mirgration.migration_tools import migre_accepted_appointment
from src.db.mongo_manager import MONGO_STORE_MANAGER from src.db.mongo_manager import MONGO_STORE_MANAGER
from src.notification.AcceptedResultPojo import get_accepted_result_from, AcceptedResultPojo from src.notification.AcceptedResultPojo import get_accepted_result_from
from src.notification.mailer import Mailer from src.notification.mailer import Mailer
from src.pojo.ResultEnum import ResultEnum from src.pojo.ResultEnum import ResultEnum
from src.pojo.mail.mail_pojo import MailPojo, MailAddress from src.pojo.mail.mail_pojo import MailPojo
from src.proxy.proxy_type import ProxyType
from src.workers.link_validator import LinkValidator
AOL_IMAP_SERVER = "imap.aol.com" AOL_IMAP_SERVER = "imap.aol.com"
IMAP_SERVER_163 = "imap.163.com" IMAP_SERVER_163 = "imap.163.com"
@@ -148,7 +144,7 @@ def read_mails_and_find_confirmation_contacts():
# mail_list = [mail_address3] # mail_list = [mail_address3]
mails_messages = [] mails_messages = []
# read all the emails # read all the emails
with ThreadPoolExecutor(max_workers=20) as executor: with ThreadPoolExecutor(max_workers=30) as executor:
for mail in mail_list: for mail in mail_list:
mail_reader = MailConfirmationReader(mail.mail, mail.password) mail_reader = MailConfirmationReader(mail.mail, mail.password)
executor.submit(mail_reader.read_emails, mails_messages) executor.submit(mail_reader.read_emails, mails_messages)
@@ -160,7 +156,7 @@ def read_mails_and_find_confirmation_contacts():
for item in successful_items: for item in successful_items:
if item.id in message_body: if item.id in message_body:
accepted_appointment_list.append(item) accepted_appointment_list.append(item)
elif "10:30" in message_body and item.email == mail.mail_address: elif "10:30" in message_body and (item.email == mail.mail_address or item.email in message_body):
accepted_appointment_list.append(item) accepted_appointment_list.append(item)
print(mail.mail_address) print(mail.mail_address)
print(mail.subject) print(mail.subject)