fwefwf

bit_tools.py

@@ -242,21 +242,21 @@ if __name__ == '__main__':
 
     # print(browser_detail(id="532651f5330e4caa917e644f9b676b"))
 
-    # 批量修改代理
-    for i in Xstart.select():
-        update_proxy_Browser(id=i.bit_id, proxyType="http", host="104.168.59.92", port=random.randint(20001, 25000), )
+    # # 批量修改代理
+    # for i in Xstart.select():
+    #     update_proxy_Browser(id=i.bit_id, proxyType="http", host="104.168.59.92", port=random.randint(20001, 25000), )
 
-    # fz_datas = get_group_lists()
-    # print(fz_datas)
-    # bit_id_list = []
-    # for i in XToken.select().where(XToken.start.is_null(False)):
-    #     sql_info = Xstart.get_or_none(
-    #         Xstart.x_id == i.id
-    #     )
-    #
-    #     bit_id_list.append(sql_info.bit_id)
-    #
-    # print(len(bit_id_list))
-    # print(bit_id_list)
-    #
-    # print(group_update(fz_datas["英语"], bit_id_list))
+    fz_datas = get_group_lists()
+    print(fz_datas)
+    bit_id_list = []
+    for i in XToken.select().where(XToken.account_start == 2):
+        sql_info = Xstart.get_or_none(
+            Xstart.x_id == i.id
+        )
+
+        bit_id_list.append(sql_info.bit_id)
+
+    print(len(bit_id_list))
+    print(bit_id_list)
+
+    print(group_update(fz_datas["西班牙语"], bit_id_list))

交易/bitmart_交易.py

@@ -378,6 +378,12 @@ class WeexTransaction:
                 time.sleep(10)
                 continue
 
+            if self.get_token():  # 获取token
+                logger.info("获取token成功!!!")
+            else:
+                logger.info("获取token失败！！！")
+                self.send_dingtalk_message(message_content=f"获取token失败！！！", type=0)
+                continue
             new_price_datas = self.get_price()
             if not new_price_datas:
                 logger.info("获取最新价格有问题！！！")
@@ -400,12 +406,7 @@ class WeexTransaction:
 
             self.time_start = self.get_now_time()
 
-            if self.get_token():  # 获取token
-                logger.info("获取token成功!!!")
-            else:
-                logger.info("获取token失败！！！")
-                self.send_dingtalk_message(message_content=f"获取token失败！！！", type=0)
-                continue
+
 
             if self.get_position_status():
                 logger.info("获取仓位信息成功!!!")

交易/websea_交易.py

@@ -333,7 +333,7 @@ class WeexTransaction:
                 self.pbar.refresh()
 
             if current_minute not in [0, 1, 2, 3, 4, 5, 30, 31, 32, 33, 34, ]:  # 判断是否是 新的30分钟了
-                # if current_minute not in range(60):  # 判断是否是 新的30分钟了
+            # if current_minute not in range(60):  # 判断是否是 新的30分钟了
                 time.sleep(10)
                 continue
 

交易/weex_交易.py

@@ -336,7 +336,7 @@ class WeexTransaction:
                 self.pbar.refresh()
 
             if current_minute not in [0, 1, 2, 3, 4, 5, 30, 31, 32, 33, 34, ]:  # 判断是否是 新的30分钟了
-                # if current_minute not in range(60):  # 判断是否是 新的30分钟了
+            # if current_minute not in range(60):  # 判断是否是 新的30分钟了
                 time.sleep(10)
                 continue
 

推特/main.py

@@ -709,7 +709,7 @@ if __name__ == '__main__':
     #         time.sleep(random.randint(15, 60))
 
     # 同时运行
-    max_threads = 8
+    max_threads = 3
     delay_between_start = 15  # 每次启动线程之间的延迟时间（秒）
 
     with ThreadPoolExecutor(max_workers=max_threads) as executor: