ddrwode/lm_code
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bitmart优化完成

Browse Source
This commit is contained in:
Administrator
2026-01-15 15:06:37 +08:00
parent 4e1746f44b
commit 6513c42618
5 changed files with 53 additions and 54 deletions
Download Patch File Download Diff File Expand all files Collapse all files

BIN
telegram/8619211027341.session
View File

Binary file not shown.

BIN
telegram/bot_session.session
View File

Binary file not shown.

BIN
telegram/sign.db
View File

Binary file not shown.

105
推特/main.py
View File

@@ -1,3 +1,4 @@
import threading
import time
import pyotp
import random
@@ -29,16 +30,16 @@ class Hub_Web:
self.create_Browser() # 创建浏览器
if self.get_page():
logger.info(f"推特名字：{self.x_info.user_name}，浏览器打开成功")
logger.info(f"，浏览器打开成功")
else:
logger.error(f"推特名字：{self.x_info.user_name}，浏览器打开失败")
logger.error(f"，浏览器打开失败")
return
if self.login_x_main():
self.xstart_info.start = 1
self.xstart_info.save()
logger.success(f"推特名字：{self.x_info.user_name}，登录x成功！！！")
logger.success(f"，登录x成功！！！")
# time.sleep(25)
#
@@ -48,7 +49,7 @@ class Hub_Web:
# self.xstart_info.save()
else:
logger.error(f"推特名字：{self.x_info.user_name}，登录x失败！！！")
logger.error(f"，登录x失败！！！")
self.xstart_info.start = 0
self.xstart_info.save()
@@ -66,7 +67,7 @@ class Hub_Web:
fz_datas = get_group_lists()
bit_id = createBrowser(
name=self.x_info.user_name,
# name=self.x_info.user_name,
proxyType="http",
groupId=fz_datas['推特'],
host="104.168.59.92",
@@ -89,11 +90,12 @@ class Hub_Web:
'x://*[@id="react-root"]/div/div/div[2]/header/div/div/div/div[2]/div/button/div[2]/div/div/div/div[1]/span/span',
timeout=10,
)
return True
if user_name and self.x_info.user_name.lower() == user_name.text.split("@")[-1].lower():
return True
else:
return False
# if user_name and self.x_info.user_name.lower() == user_name.text.split("@")[-1].lower():
# return True
# else:
# return False
# self.x_tab.refresh()
# time.sleep(5)
@@ -175,7 +177,7 @@ class Hub_Web:
self.xstart_info.start = 1
self.xstart_info.save()
logger.success(f"推特名字：{self.x_info.user_name}，登录x成功！！！")
logger.success(f"，登录x成功！！！")
# time.sleep(25)
#
@@ -185,7 +187,7 @@ class Hub_Web:
# self.xstart_info.save()
else:
logger.error(f"推特名字：{self.x_info.user_name}，登录x失败！！！")
logger.error(f"，登录x失败！！！")
self.xstart_info.start = 0
self.xstart_info.save()
@@ -195,7 +197,7 @@ class Hub_Web:
if self.x_testing():
return True
else:
logger.info(f"推特名字：{self.x_info.user_name}，开始登录x。。。")
logger.info(f"，开始登录x。。。")
if self.login_x():
return True
@@ -737,7 +739,7 @@ def run_work(x_token_info, xstart_info):
# hun_web = Hub_Web(x_info=x_token_info, xstart_info=xstart_info)
# executor.submit(hun_web.to_do_tui)
with Hub_Web(x_info=x_token_info, xstart_info=xstart_info) as hub:
with Hub_Web(x_info=None, xstart_info=xstart_info) as hub:
try:
hub.account_nurturing() # 养号
except:
@@ -750,48 +752,45 @@ def run_work(x_token_info, xstart_info):
if __name__ == '__main__':
ensure_tables()
sync_xstart_from_bitbrowser(group_name="推特", max_pages=10)
fz_datas = get_group_lists()
for bit_data in get_browser_lists_Browser(id=fz_datas['推特']):
print(bit_data)
xstart_info, start = Xstart.get_or_create(
bit_id=bit_data["id"],
)
if xstart_info.x_id:
# continue
hun_web = Hub_Web(xstart_info=xstart_info)
# hun_web.action()
threading.Thread(target=hun_web.action).start()
time.sleep(random.randint(15, 60))
# # 同时运行
# max_threads = 5
# delay_between_start = 30 # 每次启动线程之间的延迟时间（秒）
# ensure_tables()
# sync_xstart_from_bitbrowser(group_name="推特", max_pages=10)
#
# with ThreadPoolExecutor(max_workers=max_threads) as executor:
# fz_datas = get_group_lists()
#
# # for x_token_info in XToken.select():
# for bit_data in get_browser_lists_Browser(id=fz_datas['推特']):
# print(bit_data)
# xstart_info, start = Xstart.get_or_create(
# bit_id=bit_data["id"],
# )
# if xstart_info.x_id:
# # continue
#
# # 查询数据并转换为列表
# random_x_infos = list(XToken.select())
# # 直接对原列表进行打乱操作
# random.shuffle(random_x_infos)
# hun_web = Hub_Web(xstart_info=xstart_info)
#
# # 遍历打乱顺序后的列表
# for x_token_info in random_x_infos:
# xstart_info, start = Xstart.get_or_create(
# x_id=x_token_info.id,
# )
# # hun_web.action()
#
# # if xstart_info.start:
# # continue
#
# executor.submit(run_work, x_token_info, xstart_info)
# # time.sleep(random.randint(60, 150))
# time.sleep(delay_between_start)
# threading.Thread(target=hun_web.action).start()
# time.sleep(random.randint(15, 60))
# 同时运行
max_threads = 5
delay_between_start = 30 # 每次启动线程之间的延迟时间（秒）
with ThreadPoolExecutor(max_workers=max_threads) as executor:
# for x_token_info in XToken.select():
# 查询数据并转换为列表
random_x_infos = list(Xstart.select())
# 直接对原列表进行打乱操作
random.shuffle(random_x_infos)
# 遍历打乱顺序后的列表
for x_token_info in random_x_infos:
# if xstart_info.start:
# continue
executor.submit(run_work, x_token_info, x_token_info)
# time.sleep(random.randint(60, 150))
time.sleep(delay_between_start)

2
推特/同步比特浏览器.py
View File

@@ -3,4 +3,4 @@ from db_init import ensure_tables, sync_xstart_from_bitbrowser
if __name__ == '__main__':
ensure_tables()
sync_xstart_from_bitbrowser(group_name="推特", max_pages=10)
sync_xstart_from_bitbrowser(group_name="西班牙语", max_pages=10)