panleicim/appointment_request
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

check mail list size before reading mails

Browse Source
This commit is contained in:
Lei PAN
2024-06-22 11:25:42 +02:00
parent e649532cea
commit 68888364b9
1 changed files with 26 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files
mail/mail_reader_all_contacts.py
+26 -25
View File
@@ -231,31 +231,32 @@ def need_to_check_email(mail: str, successful_items) -> bool:
def find_links_to_validate_from_mail_list(mail_list: list, logger): def find_links_to_validate_from_mail_list(mail_list: list, logger):
# check time before start checking emails # check time before start checking emails
contact_to_book_list = MONGO_STORE_MANAGER.get_all_contact_to_book_list() if len(mail_list) > 0:
successful_items = MONGO_STORE_MANAGER.get_all_successful_items_for_day() contact_to_book_list = MONGO_STORE_MANAGER.get_all_contact_to_book_list()
mails_messages = [] successful_items = MONGO_STORE_MANAGER.get_all_successful_items_for_day()
with ThreadPoolExecutor(max_workers=len(mail_list)) as executor: mails_messages = []
for mail in mail_list: with ThreadPoolExecutor(max_workers=len(mail_list)) as executor:
# check whether we need to read mail for mail in mail_list:
if need_to_check_email(mail.mail, successful_items): # check whether we need to read mail
mail_reader = MailReader(mail.mail, mail.password) if need_to_check_email(mail.mail, successful_items):
executor.submit(mail_reader.read_emails, mails_messages) mail_reader = MailReader(mail.mail, mail.password)
# for mail in mail_list: executor.submit(mail_reader.read_emails, mails_messages)
# # check whether we need to read mail # for mail in mail_list:
# if need_to_check_email(mail.mail, successful_items): # # check whether we need to read mail
# mail_reader = MailReader(mail.mail, mail.password) # if need_to_check_email(mail.mail, successful_items):
# mail_reader.read_emails(mails_messages) # mail_reader = MailReader(mail.mail, mail.password)
_refreshed_successful_items = MONGO_STORE_MANAGER.get_all_successful_items_for_day() # mail_reader.read_emails(mails_messages)
for mail in mails_messages: _refreshed_successful_items = MONGO_STORE_MANAGER.get_all_successful_items_for_day()
match = re.search(VALIDATION_URL_REGEX, mail.body) for mail in mails_messages:
if match: match = re.search(VALIDATION_URL_REGEX, mail.body)
url = match.group(0) if match:
if need_to_valid_url(url, _refreshed_successful_items): url = match.group(0)
logger.info("need to validate url: " + url) if need_to_valid_url(url, _refreshed_successful_items):
MONGO_STORE_MANAGER.save_links_to_validate(url, mail.to_address, logger.info("need to validate url: " + url)
_all_contact_list=contact_to_book_list) MONGO_STORE_MANAGER.save_links_to_validate(url, mail.to_address,
else: _all_contact_list=contact_to_book_list)
logger.info("do not need to click url --> {}".format(mail.mail_address)) else:
logger.info("do not need to click url --> {}".format(mail.mail_address))
if __name__ == '__main__': if __name__ == '__main__':