139 lines
4.9 KiB
Python
139 lines
4.9 KiB
Python
from math import log
|
||
import random
|
||
from re import S
|
||
import time
|
||
from tkinter import N
|
||
from DrissionPage import Chromium
|
||
from loguru import logger
|
||
from work import get_random_canada_info
|
||
from mail_ import mail_
|
||
from bit_browser import bit_browser
|
||
from api import api
|
||
|
||
|
||
class Auto:
|
||
def __init__(self, http: str = None):
|
||
self.browser = Chromium(http)
|
||
self.tab = self.browser.latest_tab
|
||
pass
|
||
|
||
# cf打码
|
||
def solve_cloudflare(self, is_ok: bool = False):
|
||
tab = self.browser.latest_tab
|
||
for _ in range(5):
|
||
tab.wait(1)
|
||
res = tab.ele(
|
||
't:h1@text()=Sorry, you have been blocked', timeout=1)
|
||
if res:
|
||
logger.error("Cloudflare验证失败")
|
||
return False
|
||
|
||
try:
|
||
shadow1 = tab.ele(
|
||
'x://*[@name="cf-turnstile-response"]').parent().shadow_root
|
||
iframe = shadow1.get_frame(1)
|
||
if iframe:
|
||
logger.debug("找到Cloudflare iframe")
|
||
shadow2 = iframe.ele('x:/html/body').shadow_root
|
||
if shadow2:
|
||
logger.debug("找到Cloudflare iframe body shadow root")
|
||
status = shadow2.ele(
|
||
'x://span[text()="Verifying..."]', timeout=1.5)
|
||
if status:
|
||
logger.debug("Cloudflare验证中，等待3秒")
|
||
tab.wait(3)
|
||
status = shadow2.ele(
|
||
'x://span[text()="Success!"]', timeout=1.5)
|
||
if status:
|
||
logger.debug("Cloudflare验证成功")
|
||
return True
|
||
checkbox = shadow2.ele(
|
||
'x://input[@type="checkbox"]', timeout=1.5)
|
||
if checkbox:
|
||
logger.debug("点击Cloudflare复选框")
|
||
checkbox.click()
|
||
tab.wait(3)
|
||
logger.debug("重新获取状态")
|
||
# return False
|
||
except Exception as e:
|
||
# logger.error(f"处理Cloudflare异常: {e}")
|
||
if is_ok:
|
||
logger.debug(f"cloudflare处理通过: {e}")
|
||
return True
|
||
return self.solve_cloudflare(is_ok=True)
|
||
tab.wait(1)
|
||
return False
|
||
|
||
def wait_home(self):
|
||
logger.debug("等待进入首页")
|
||
jc = 0
|
||
while True:
|
||
if jc > 3:
|
||
logger.error("等待进入首页超过5次，未成功")
|
||
return False
|
||
self.tab.wait(1)
|
||
# 判断cf是否通过
|
||
bol = self.solve_cloudflare()
|
||
if not bol:
|
||
logger.debug("Cloudflare验证失败.")
|
||
# 刷新网页
|
||
self.tab.refresh()
|
||
self.tab.wait(1.5)
|
||
jc += 1
|
||
continue
|
||
else:
|
||
logger.debug("Cloudflare验证成功.")
|
||
self.tab.wait(1.5)
|
||
bol = self.tab.ele(
|
||
't:h1@text()=Sorry, you have been blocked', timeout=1)
|
||
if bol:
|
||
logger.debug("ip被ban秒")
|
||
return False
|
||
|
||
bol = self.tab.ele(
|
||
't:div@text():ERR_TIMED_OUT', timeout=1)
|
||
if bol:
|
||
logger.debug("刷新网页")
|
||
self.tab.refresh()
|
||
self.tab.wait(1.5)
|
||
bol = self.tab.ele(
|
||
't:div@text():ERR_SSL_PROTOCOL_ERROR', timeout=1)
|
||
if bol:
|
||
logger.debug("刷新网页")
|
||
self.tab.refresh()
|
||
self.tab.wait(1.5)
|
||
bol = self.tab.ele(
|
||
't:div@text():ERR_SOCKS_CONNECTION_FAILED', timeout=1)
|
||
if bol:
|
||
logger.debug("刷新网页")
|
||
self.tab.refresh()
|
||
self.tab.wait(1.5)
|
||
html = self.tab.url
|
||
logger.debug(f"当前URL: {html}")
|
||
if 'https://veritaconnect.ca/canadianbreadsettlement/en-us' == html:
|
||
logger.debug("成功进入首页")
|
||
return True
|
||
jc += 1
|
||
|
||
def open_url(self, url: str):
|
||
self.tab.get(url)
|
||
|
||
|
||
def main():
|
||
browser_id = bit_browser.bit_browser_create(
|
||
remark=f"us.novproxy.io:1000:ozua8623-region-CA-st-Ontario-city-Toronto:6wdcv4gq",
|
||
host="us.novproxy.io",
|
||
port=1000,
|
||
proxy_user="ozua8623-region-CA-st-Alberta-city-Calgary",
|
||
proxy_pwd="6wdcv4gq",
|
||
proxy_type='socks5'
|
||
)
|
||
http = bit_browser.bit_browser_open(browser_id)
|
||
logger.debug(f"打开浏览器 {browser_id}, http: {http}")
|
||
auto = Auto(http)
|
||
auto.open_url(
|
||
"https://veritaconnect.ca/canadianbreadsettlement/en-us/Claimant/UnknownClaimForm")
|
||
auto.wait_home()
|
||
|
||
if __name__ == '__main__':
|
||
main() |