This commit is contained in:
2025-11-25 00:50:09 +08:00
parent d72ce4cc28
commit 47fe57ef49
3 changed files with 18 additions and 8 deletions

View File

@@ -1,3 +1,5 @@
# 0.1.5
- 新增status字段
# 0.1.4 # 0.1.4
- 修复自动化bug - 修复自动化bug
# 0.1.3 # 0.1.3

View File

@@ -111,9 +111,7 @@ class DomainManager:
"emaing.pw", "emaing.pw",
"emaing.xyz", "emaing.xyz",
"qydkjgs.asia", "qydkjgs.asia",
"qydgs.autos",
"qydkj.homes", "qydkj.homes",
"qydkjgs.baby",
"qydkj.baby", "qydkj.baby",
"qydkj.cyou", "qydkj.cyou",
"qydkjgs.autos", "qydkjgs.autos",
@@ -122,9 +120,7 @@ class DomainManager:
"qydkjgs.homes", "qydkjgs.homes",
"qydgs.asia", "qydgs.asia",
"qydkj.asia", "qydkj.asia",
"qydgs.baby",
"qydgs.cyou", "qydgs.cyou",
"qydgs.homes",
"lulanjing.asia", "lulanjing.asia",
"lisihan.asia", "lisihan.asia",
"mmwan.asia", "mmwan.asia",

View File

@@ -452,6 +452,15 @@ class Auto:
't:h2@text()=CLAIM SUBMISSION CONFIRMATION', timeout=3) 't:h2@text()=CLAIM SUBMISSION CONFIRMATION', timeout=3)
if res: if res:
logger.info("提交问卷成功") logger.info("提交问卷成功")
res = self.tab.ele('@text():Your claim number: ')
if res:
logger.info(f"反馈地址: {res.text()}")
text =f"{text}----{res.text()}"
status = True
else:
status=False
api.create_info( api.create_info(
first_name=first_name, first_name=first_name,
last_name=last_name, last_name=last_name,
@@ -462,7 +471,8 @@ class Auto:
postal_code=postal_code, postal_code=postal_code,
province=province, province=province,
email=email, email=email,
text=text text=text,
status=status
) )
return True return True
@@ -524,6 +534,7 @@ def get_random_proxy() -> list[str] | None:
except Exception: except Exception:
return None return None
def get_all_proxies() -> list[list[str]]: def get_all_proxies() -> list[list[str]]:
""" """
返回固定代理列表(与提供的代理一一对应) 返回固定代理列表(与提供的代理一一对应)
@@ -752,7 +763,8 @@ def run_all_proxies_concurrently():
return return
threads = [] threads = []
for i, proxy in enumerate(proxies): for i, proxy in enumerate(proxies):
t = threading.Thread(target=run_proxies_forever, args=(proxy,), name=f"proxy-thread-{i}") t = threading.Thread(target=run_proxies_forever,
args=(proxy,), name=f"proxy-thread-{i}")
t.start() t.start()
threads.append(t) threads.append(t)
logger.info(f"固定代理线程 {i} 已启动: {proxy[0]}:{proxy[1]} @ {proxy[2]}") logger.info(f"固定代理线程 {i} 已启动: {proxy[0]}:{proxy[1]} @ {proxy[2]}")