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

save phone model

Browse Source
This commit is contained in:
Lei PAN
2025-07-01 15:01:46 +02:00
parent d35c667b5f
commit 1a9a88c49a
2 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
models/ReserveResultPojo.py
+2 -2
View File
@@ -29,6 +29,7 @@ class ReserveResultPojo:
slot_position = None slot_position = None
sim_position = None sim_position = None
ccid: str = "" ccid: str = ""
model: str = ""
source_from: str = socket.gethostname() source_from: str = socket.gethostname()
store_type = 0 store_type = 0
url_validated = None url_validated = None
@@ -122,8 +123,7 @@ class ReserveResultPojo:
u'email': self.email, u'email': self.email,
u'passport': self.passport, u'passport': self.passport,
u'url': self.url, u'url': self.url,
# u'sim_position': self.sim_position, u'model': self.model,
# u'slot_position': self.slot_position,
u'source_from': self.source_from, u'source_from': self.source_from,
u'hostName': self.source_from, u'hostName': self.source_from,
u'created_at': self.created_at, u'created_at': self.created_at,
workers/sender.py
+6 -4
View File
@@ -38,7 +38,8 @@ class Sender:
self.proxy_to_use = proxy_to_use self.proxy_to_use = proxy_to_use
self.cookie.load(self.cookie_str) self.cookie.load(self.cookie_str)
def publish_message_to_queue(self, contact: ContactPojo, status: PublishType, url: str, store_type: str): def publish_message_to_queue(self, contact: ContactPojo, status: PublishType, url: str, store_type: str,
model: str = ""):
# create the message # create the message
if url == "https://rendezvousparis.hermes.com/client/welcome": if url == "https://rendezvousparis.hermes.com/client/welcome":
return return
@@ -59,11 +60,12 @@ class Sender:
result.proxy = "data_impulse" result.proxy = "data_impulse"
result.id = id result.id = id
result.store_type = store_type result.store_type = store_type
result.model = model
result.created_at = time.strftime("%H:%M:%S", time.localtime()) result.created_at = time.strftime("%H:%M:%S", time.localtime())
collection_name = str(datetime.date.today()) collection_name = str(datetime.date.today())
MONGO_STORE_MANAGER.insert_reserve_result(collection_name=collection_name, reserve=result) MONGO_STORE_MANAGER.insert_reserve_result(collection_name=collection_name, reserve=result)
def apply_redirect(self, response, old_headers, contact, js_data, selected_store): def apply_redirect(self, response, old_headers, contact, js_data, selected_store, model=""):
# /client/register/5XD2E2 # /client/register/5XD2E2
_res_headers = response.headers _res_headers = response.headers
_location = _res_headers['location'] _location = _res_headers['location']
@@ -87,7 +89,7 @@ class Sender:
contact.current_ip = get_address_ip(proxy_to_use=self.proxy_to_use) contact.current_ip = get_address_ip(proxy_to_use=self.proxy_to_use)
_appointment_url = _redirect_url _appointment_url = _redirect_url
self.publish_message_to_queue(contact, status=PublishType.SUCCESS, url=_appointment_url, self.publish_message_to_queue(contact, status=PublishType.SUCCESS, url=_appointment_url,
store_type=selected_store) store_type=selected_store, model=model)
self.cookie.load(_cookies_to_set) self.cookie.load(_cookies_to_set)
new_cookies = {k: v.value for k, v in self.cookie.items()} new_cookies = {k: v.value for k, v in self.cookie.items()}
new_coolies_str = "" new_coolies_str = ""
@@ -175,7 +177,7 @@ class Sender:
# add to mongodb # add to mongodb
self.logger.info(response.text) self.logger.info(response.text)
self.apply_redirect(response=response, old_headers=headers, contact=contact, js_data=js_data, self.apply_redirect(response=response, old_headers=headers, contact=contact, js_data=js_data,
selected_store=_selected_store) selected_store=_selected_store, model=model)
# self.logger.info("{}:{}".format(contact.mail, response.url)) # self.logger.info("{}:{}".format(contact.mail, response.url))
# contact.ua = js_data.ua # contact.ua = js_data.ua
# contact.current_ip = get_address_ip(proxy_to_use=proxy_to_use) # contact.current_ip = get_address_ip(proxy_to_use=proxy_to_use)