收集更多信息

b6/src/jetblue.py

@@ -73,7 +73,8 @@ while True:
         try:
             # selectId = '55a8fe24a752595e774341d6'
             proxy = f'http://unfflcc:76cc14-47b8dd-1f8ace-827836-0c740e@usa.rotating.proxyrack.net:{int(random.randint(10000, 11149))}'
-            proxy = requests.post('http://ymx-lcc.unififi.com/proxy/get-proxy', json={'name':"B6", 'type':'shopping'}).json()['url']
+            proxy = random.choice(['http://unfflcc:76cc14-47b8dd-1f8ace-827836-0c740e@usa.rotating.proxyrack.net:9000', proxy])
+            # proxy = requests.post('http://ymx-lcc.unififi.com/proxy/get-proxy', json={'name':"B6", 'type':'shopping'}).json()['url']
 
             # proxy = f'http://ynfflcc2023.hotmail.com:gdcfh9@69.30.227.194:{random.randint(20001, 20250)}'
             # proxy = f'http://user-uni003-region-us-sessid-${random.randint(1000,5000)}-sesstime-5-keep-true:q39CEBTs5A5YQXor@pr.roxlabs.cn:4600'
@@ -86,29 +87,31 @@ while True:
                 'http': proxy,
                 'https': proxy,
             }
-            if platform.uname().system == 'Darwin':
-                session.proxies = {
-                    'http': 'http://127.0.0.1:7890',
-                    'https': 'http://127.0.0.1:7890',
-                }
+            # if platform.uname().system == 'Darwin':
+            #     session.proxies = {
+            #         'http': 'http://127.0.0.1:7890',
+            #         'https': 'http://127.0.0.1:7890',
+            #     }
 
 
             selectId = random.choice(list(envs))
             # selectId = 'a74b38e7115cf4d1b1f6976c'
-            c = session.get('https://www.jetblue.com/js/src/jb-74873.js', insecure_skip_verify=True).text
-            m5 = md5(c)
-            if m5 != lastHash and usedTime > 5:
-                lastHash = m5
-                usedTime = 0
-                logger.debug('js变化')
-                token = re.findall('nt"\),\["(.+?)",', c)[0]
-                db.token_shape.insert_one({
-                    '_id': token,
-                    'update_time': int(time.time() * 1000)
-                })
-                code = open('src.js', 'r', encoding='utf-8').read()
-                with open('src_run1.js', 'w', encoding='utf-8') as f:
-                    f.write(code + '\n\n' + c)
+
+            if  usedTime > 5:
+                c = session.get('https://www.jetblue.com/js/src/jb-74873.js', insecure_skip_verify=True).text
+                m5 = md5(c)
+                if m5 != lastHash:
+                    lastHash = m5
+                    usedTime = 0
+                    logger.debug('js变化')
+                    token = re.findall('nt"\),\["(.+?)",', c)[0]
+                    db.token_shape.insert_one({
+                        '_id': token,
+                        'update_time': int(time.time() * 1000)
+                    })
+                    code = open('src.js', 'r', encoding='utf-8').read()
+                    with open('src_run1.js', 'w', encoding='utf-8') as f:
+                        f.write(code + '\n\n' + c)
             #     # with open('js_dom_run1.js', 'w', encoding='utf-8') as f:
             #     #     f.write(code1 + '\n\n' + c)`
             t1 = time.time()
@@ -171,30 +174,32 @@ while True:
             logger.info(f'tls:{tlsV} proxy:{proxy}  res:: {response.status_code}')
             # total += 1
             # # print(response.text)
-            if response.status_code != 403:
-                res = db.env_shape.update_one(
-                    {'_id': ObjectId(selectId)},
-                    {"$inc": {"success": 1}}
-                )
+            # if response.status_code != 403:
+            #     res = db.env_shape.update_one(
+            #         {'_id': ObjectId(selectId)},
+            #         {"$inc": {"success": 1}}
+            #     )
+
                 # proxy = requests.post('http://ymx-lcc.unififi.com/proxy/get-proxy', json={
                 #     'type':'headerB6'
                 # })
-                uri = 'http://ymx-lcc.unififi.com/header/add'
-                # uri = 'http://52.52.23.116/header/add'
-                # proxy = f'http://unfflcc:76cc14-47b8dd-1f8ace-827836-0c740e@usa.rotating.proxyrack.net:{int(random.randint(10000, 11149))}'
-                # proxy = 'http://unfflcc:76cc14-47b8dd-1f8ace-827836-0c740e@usa.rotating.proxyrack.net:10042'
-                # proxy = 'http://user-unifflcc-region-us:q39CEBTs5A5YQXor@pr.roxlabs.cn:4600'
-                r = requests.post(uri, json={
-                    'brush_fromto': 'LAS-BOS',
-                    'brush_fromdate': '2023-05-26',
-                    'brush_header': headers,
-                    'brush_proxy': proxy,
-                    'brush_mode': 'shopping',
-                    'brush_name': 'js2',
-                    'brush_type': 'headerB6',
-                })
-                success += 1
-                logger.success(f'添加成功 {success}')
+            uri = 'http://ymx-lcc.unififi.com/header/add'
+            # uri = 'http://52.52.23.116/header/add'
+            # proxy = f'http://unfflcc:76cc14-47b8dd-1f8ace-827836-0c740e@usa.rotating.proxyrack.net:{int(random.randint(10000, 11149))}'
+            # proxy = 'http://unfflcc:76cc14-47b8dd-1f8ace-827836-0c740e@usa.rotating.proxyrack.net:10042'
+            # proxy = 'http://user-unifflcc-region-us:q39CEBTs5A5YQXor@pr.roxlabs.cn:4600'
+            print(headers)
+            r = requests.post(uri, json={
+                'brush_fromto': 'LAS-BOS',
+                'brush_fromdate': '2023-05-26',
+                'brush_header': headers,
+                'brush_proxy': proxy,
+                'brush_mode': 'shopping',
+                'brush_name': 'js2',
+                'brush_type': 'headerB6',
+            })
+            success += 1
+            logger.success(f'添加成功 {success}')
             # time.sleep(3)
         except Exception as e:
             print(e)