1

src/main.py

@@ -19,6 +19,11 @@ root_logger.handlers = []
 if not pathlib.Path('nacos-data/snapshot/').exists():
     pathlib.Path('nacos-data/snapshot/').mkdir(parents=True)
 
+
+def check_pull():
+    get_url = 'https://ymx-lcc.unififi.com/header/task/pull/cookieY4?brush_name=test'
+    r = requests.get(get_url)
+    return r.json()
 def get_proxy():
     get_proxy_url = 'http://ymx-lcc.unififi.com/proxy/get-proxy'
     r = requests.post(get_proxy_url, json={
@@ -61,6 +66,10 @@ def run():
     while True:
 
         print(f'本次并发数 {brush_thread}')
+        pull = check_pull()
+        if pull.get('status') == 1:
+            time.sleep(10)
+            continue
         # pool = ThreadPoolExecutor(max_workers=brush_thread)
         # all_task = [pool.submit(exec, (i)) for i in range(brush_group)]
         # brush_check = CONFIG['internal']['reverse']['making']['brush_check']
@@ -81,6 +90,7 @@ def run():
                         objs[n] = task
 
 
+
 if __name__ == '__main__':
 
     run()