From 6513c42618d68558009a4581a30d7f62e283dd06 Mon Sep 17 00:00:00 2001 From: Administrator Date: Thu, 15 Jan 2026 15:06:37 +0800 Subject: [PATCH] =?UTF-8?q?bitmart=E4=BC=98=E5=8C=96=E5=AE=8C=E6=88=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- telegram/8619211027341.session | Bin 45056 -> 45056 bytes telegram/bot_session.session | Bin 65536 -> 65536 bytes telegram/sign.db | Bin 49152 -> 49152 bytes 推特/main.py | 105 ++++++++++++++++----------------- 推特/同步比特浏览器.py | 2 +- 5 files changed, 53 insertions(+), 54 deletions(-) diff --git a/telegram/8619211027341.session b/telegram/8619211027341.session index 6972a427fd97a53981a0c46b8080a5f9b54d0c1b..b4d77d2c08cfc007d10b1004a7e84cbb5e52933f 100644 GIT binary patch delta 64 zcmZp8z|`=7X@WH4t%)+ujJGx>EY0Q2bG#KLce}3JellO4GE;TtX5+jQEKJoooBtL~ UVq~h$-8`{G$r{L?ymh@d09o-GW&i*H delta 64 zcmZp8z|`=7X@WH4=7}=SjGH$mEY0PNcDxlO9Ur8yXEI-&GE;8FX5+jQEKIpIoBtL~ UVr0s#-8`{G$r{L?ymh@d052LDa{vGU diff --git a/telegram/bot_session.session b/telegram/bot_session.session index ece3268b5e22301eff2175b93f1069a86ea26689..d4cb136a7f2f8f766b185773de34d7d7cc3e5b34 100644 GIT binary patch delta 619 zcmXw%ZAepL6vyv#?{i;w?;TMjPMhgA(So!x!$~X^3M>^0BYIIWhpvW8^R3kGHm^DI zCG}*?X5T~>1SQuHLyaH{HAE;2(-0~@M5IuX3Q=8%&c}0paL(`W_j<9{i#wx`(iNSB zl))l!;NGcGtG4cFOER6xcz-5lVaF=9gu z81{4D=~Z|2YOcHYFT zaWh;$ca=NIC2>6ak$uc|vzOUyHi1$8Fq2G(sbTV&6lN>EM$gdq>1MisPN%oybv%!U zu!_&)1ZsnNOAS&1s+7v4tP~~}Nsa6vPm^|1Myu#03ZZJ0haz;Be`UTi{B0_WC74Je z0v8<5@2F>&LeA2PT9^BTr`T1lf9RS{MwwSCb%@ZRSD|;WuYYL>=Ulktbh{kW9__bU zi{P%$20dybRNrWY8GmedOD=r&#X)Y%C=~f^AOwoxqG|zm;21ph*|g!na|F$Pi&lTr zgdkb(+-}{8AncEa$%8g+zO5HQjn4{osTSzz7=uMM4kl7#!L9?0KLxJbYKJAS6;}Pb zAYb1j`Yc*x(@`W!`n83`GC?eJWx#cg!DMH2LR_%#(SlJIh#?~Jk%5Pw>`Py9g{QQn zeY3;AS547n_>h A1ONa4 delta 550 zcmXw$T}V@59EaccoOkEE=W|I#IZbnOV>Zy75v0@_T?keNLKkJ_Ffx;dVxLg7wYgk# z=P>&x%|f~ea@`d68fB&-hL;Pv5Hw{`U36toNJ%RiLBHDvp6B8h4wG=0q)M=Nuyh~x zjs?I+MrT)g*$-c`#@6CrJX&(nKQ~i^1cV9U%IkU?HlFDWUWSqGgHr2%%)WOo>s-)) z?YnD%4^42vt1unf8|v_Dm`Cj>hlqy=e2#y@-{f2PVyxi9+*g#dzO&x9p5p|r-r7Qz zthLs4`X_x-PwTz-qTZx$)xK$y+C8mDYu4;)UR_Yfxr};8?NJY?P9?7_Dle7WxJKzx zd`hvrD!-L8@)a&7ACc?iBI%3N{#5Fd+N3?w7MiEa^f`V_fu1E@w2`{0%mu_nk%`yD zX8c*K5)qdb-V0O0h;V@n;k$xQsIaVB<}Hsc5z8^lPV$FLqkr=Zo4+z{5eZJ@B;YbD zDG4C@Ak#)+$gG5H+y&=NJFE>jz>GNIQOpVRQ9GP6c7V@t!FZn&ZuL80L&628qZQC( zZetT>BbJGQ z1q*%ca3Z#!Wn*tJd)9BmY&BkvS$$#}Luv8@lo=H;Y#3Cdo#;5$5U8ms`~v1u diff --git a/telegram/sign.db b/telegram/sign.db index d15468b2a04ecb9b35e0a61e6a92a7aa49f0f930..81f30514d06d3e26efcbd11398284e3a40efe951 100644 GIT binary patch delta 196 zcmZo@U~Xt&o*>P*Zla7cz3wUid3p&W~niw`lvoWwTiuy7z rru|NJ<|@ui&qJ6MVqjopY-wd+re|qjW@&7yYhY?+V6eGh?*t|Q06R9S delta 87 zcmV-d0I2_ffCGSl1CSd5s*xN+0jjZJqz?mc1oV>!5FL{y5G1oq5OxHSkT$dQ6bows t+OmKIFd7RDZ~za?510>R4=@hy4y+Dp4k!)g4Wtclvk^d24YP2)kOJix99#eZ diff --git a/推特/main.py b/推特/main.py index 92da972..ff4deb2 100644 --- a/推特/main.py +++ b/推特/main.py @@ -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) diff --git a/推特/同步比特浏览器.py b/推特/同步比特浏览器.py index d17ca10..035a1fc 100644 --- a/推特/同步比特浏览器.py +++ b/推特/同步比特浏览器.py @@ -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)