diff --git a/queue_message/appointmentrequestsender.py b/queue_message/appointmentrequestsender.py index 5b45265..b7e0849 100644 --- a/queue_message/appointmentrequestsender.py +++ b/queue_message/appointmentrequestsender.py @@ -70,6 +70,7 @@ class AppointmentRequestSender(threading.Thread): self.contact_list = sub_contact_list self.queue_name = queue_name self.proxy_to_use_list = proxy_to_use_list + self.already_read_emails = False def set_up_connection(self): self.connection = pika.BlockingConnection( @@ -193,12 +194,16 @@ class AppointmentRequestSender(threading.Thread): self.channel.start_consuming() def retreive_invalidate_urls(self): - self.logger.info("will retreive_invalidate_urls") - _mail_list = MONGO_STORE_MANAGER.get_destination_emails() - _mail_list_filtred = [] - for mail in _mail_list: - for _contact in self.list_to_retrieve_mails: - if _contact.mail == mail.mail: - _mail_list_filtred.append(mail) - self.logger.info("will call find_links_to_validate_from_mail_list, size = " + str(len(_mail_list_filtred))) - find_links_to_validate_from_mail_list(_mail_list_filtred) + if not self.already_read_emails: + self.logger.info("will retreive_invalidate_urls") + _mail_list = MONGO_STORE_MANAGER.get_destination_emails() + _mail_list_filtred = [] + for mail in _mail_list: + for _contact in self.list_to_retrieve_mails: + if _contact.mail == mail.mail: + _mail_list_filtred.append(mail) + self.logger.info("will call find_links_to_validate_from_mail_list, size = " + str(len(_mail_list_filtred))) + find_links_to_validate_from_mail_list(_mail_list_filtred) + self.already_read_emails = True + else: + self.logger.info("already read emails, will not retreive_invalidate_urls") diff --git a/request_sender.py b/request_sender.py index 0017c8e..dac772e 100644 --- a/request_sender.py +++ b/request_sender.py @@ -64,10 +64,10 @@ def send_appointment_request(message_queue_name, _contact_list): if __name__ == '__main__': - contacts_file_path = '~/Desktop/contact_list_2024-03-20.xlsx' + contacts_file_path = '~/Desktop/contact_list_2024-03-19.xlsx' _contact_list = read_contacts(contacts_file_path) _contact_list_to_book = filter_contacts(_contact_list) - _segment_number = 2 + _segment_number = 1 logger.info("{} contacts to book".format(len(_contact_list_to_book))) last_thread = None for i in range(0, _segment_number): diff --git a/workers/sender.py b/workers/sender.py index 1f59f89..99b0ec1 100644 --- a/workers/sender.py +++ b/workers/sender.py @@ -94,6 +94,7 @@ class Sender: self.logger.info("body in json:{}".format(json.dumps(self.received_dict))) self.cookiesPublisher.publish_body(json.dumps(self.received_dict)) # self.cookie_str = new_coolies_str + self.logger.info("successful request, mail:{}".format(contact.mail)) return RequestResult.SUCCESS else: print(response.text)