can take appointment
This commit is contained in:
@@ -7,8 +7,6 @@ from logs.AppLogging import init_logger
|
||||
from utils.excel_reader import ExcelHelper
|
||||
from workers.commandor_page import CommandorPage
|
||||
|
||||
OTP_TIMEOUT = 240
|
||||
current_gsm_modem = None
|
||||
# used to save the current slot position
|
||||
|
||||
init_logger()
|
||||
@@ -19,11 +17,11 @@ logger.addHandler(logging.StreamHandler(stream=sys.stdout))
|
||||
def start_book(start_number, end_number, store=0):
|
||||
# read the contact, and contact the 2 objects together
|
||||
excel_reader = ExcelHelper()
|
||||
contacts = excel_reader.read_contacts()[start_number - 1: end_number - 1]
|
||||
contacts = excel_reader.read_contacts()[start_number - 1: end_number]
|
||||
print(contacts)
|
||||
with ThreadPoolExecutor(max_workers=10) as executor:
|
||||
with ThreadPoolExecutor(max_workers=1) as executor:
|
||||
for contact in contacts:
|
||||
proxy = get_proxy(contact.phone_number)
|
||||
proxy = get_proxy(contact.phone)
|
||||
commandor = CommandorPage(contact, store_type=store)
|
||||
# start the task in thread
|
||||
executor.submit(commandor.start_page, proxy)
|
||||
@@ -42,5 +40,5 @@ def get_proxy(phone_number):
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
# 修改起始行,结束行, 第三个参数store等于0的时候是随机,传入1的时候是总店
|
||||
start_book(2, 18, store=0)
|
||||
# 修改联系人行,结束联系人行 第三个参数store等于0的时候是随机,传入1的时候是总店
|
||||
start_book(1, 1, store=0)
|
||||
|
||||
Reference in New Issue
Block a user