mirror of
https://github.com/KingJin-web/zy.git
synced 2025-12-16 23:19:32 +08:00
1236 lines
52 KiB
Python
1236 lines
52 KiB
Python
"""
|
||
* 胖乖生活
|
||
* 设置变量 PGSH_TOKEN,多号使用&隔开，青龙直接新建变量即可 ，网页获取ck：https://bigostk.github.io/pg/
|
||
* ck格式1:token#备注
|
||
* ck格式2: token
|
||
* 代理开关变量名：pg_dl，True为开启代理模式，False为关闭，默认为False
|
||
* 代理变量名：pg_dlurl，代理地址是动态代理api接口，一次性提取一个，选择txt格式，\r\n或者\n模式都可以
|
||
* 并发开关变量名：pg_bf，True为开启并发模式，False为关闭，默认为False
|
||
* 并发数量变量名：pg_bfsum，并发几个就写几个，默认为3
|
||
* 推送开关变量名：pg_ts，True为开启推送，False为关闭，默认为False
|
||
* 推送变量名1：WxPusher：pg_WxPusher_token是你的WxPusher的推送组的token，pg_WxPusher_uid是你的WxPusher该推送组的用户uid，推送给谁就填写谁的，填写一个即可
|
||
* 推送变量名2：pushplus：pg_pushplus_token是你的pushplus的token
|
||
* Top: 上面两个推送配置哪个就使用哪个推送，两个都配置的话就两个都进行推送
|
||
* 数据库地址变量名：pg_ckurl，保证打开数据库里面是ck，并使用&隔开，或者ck#备注，并使用&隔开
|
||
* 不填备注默认使用隐私格式手机号作为用户名，否则使用填写的备注作为用户名
|
||
* 出现False就是任务已完成或者不可完成
|
||
* 推荐携趣，注册实名每天免费1k，地址：https://www.xiequ.cn/
|
||
* cron：0 06-20 * * *
|
||
"""
|
||
|
||
##############################
|
||
ck = ''
|
||
ckurl1 = "" # 数据库地址，适配部分群友要求
|
||
jh = False # 聚合ck模式，开启即所有环境模式ck都生效，都会合成为一个ck列表，关闭则优先处理环境变量，默认为True，False为关闭
|
||
|
||
#############################
|
||
# -----运行模式配置区，自行配置------
|
||
|
||
bf1 = True # True开启并发，False关闭并发
|
||
bfsum1 = 3 # 并发数,开启并发模式生效
|
||
lljf = 1 # 运行新版浏览任务，22金币,只有10天
|
||
|
||
# -------推送配置区，自行填写-------
|
||
|
||
ts1 = False # True开启推送，False关闭推送
|
||
|
||
# -------代理配置区，自行填写-------
|
||
|
||
dl1 = False # True开启代理，False关闭代理
|
||
dl_url = 'http://api.xiequ.cn/VAD/GetIp.aspx?act=getturn82&uid=150098&vkey=617AF361D1745BECBC40DD5707FF3C27&num=1&time=6&plat=1&re=0&type=7&so=1&group=51&ow=1&spl=4&addr=&db=1' # 代理池api
|
||
|
||
# -----代理时间配置区，秒为单位------
|
||
|
||
dl_sleep = 30 # 代理切换时间
|
||
qqtime = 6 # 请求超时时间
|
||
|
||
# -----时间配置区，默认即可------
|
||
|
||
a = "1"
|
||
b = "23" # 表示6-22点之间才执行任务
|
||
|
||
#############################
|
||
# ---------勿动区----------
|
||
|
||
# 已隐藏乾坤于此区域
|
||
|
||
###########################
|
||
# ---------代码块---------
|
||
|
||
import requests
|
||
import time
|
||
import random
|
||
import string
|
||
import os
|
||
import json
|
||
import hashlib
|
||
import threading
|
||
from functools import partial
|
||
from urllib.parse import urlparse
|
||
from datetime import datetime, timedelta
|
||
from concurrent.futures import ThreadPoolExecutor, as_completed
|
||
from urllib3.exceptions import InsecureRequestWarning
|
||
from requests_toolbelt import MultipartEncoder
|
||
|
||
dl = os.environ.get('pg_dl', dl1)
|
||
proxy_api_url = os.environ.get('pg_dlurl', dl_url)
|
||
bf = os.environ.get('pg_bf', bf1)
|
||
bfsum = os.environ.get('pg_bfsum', bfsum1)
|
||
ts = os.environ.get('pg_ts', ts1)
|
||
ckurl = os.environ.get('pg_ckurl', ckurl1)
|
||
WxPusher_uid = os.environ.get('pg_WxPusher_uid')
|
||
WxPusher_token = os.environ.get('pg_WxPusher_token')
|
||
pushplus_token = os.environ.get('pg_pushplus_token')
|
||
|
||
# def check_yl():
|
||
# lb = ['requests', 'urllib3']
|
||
# for yl in lb:
|
||
# try:
|
||
# subprocess.check_call(["pip", "show", yl], stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
|
||
# except subprocess.CalledProcessError:
|
||
# print(f"{yl} 未安装，开始安装...")
|
||
# subprocess.check_call(["pip", "install", yl, "-i", "https://pypi.tuna.tsinghua.edu.cn/simple"], stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
|
||
# print(f"{yl} 安装完成")
|
||
# check_yl()
|
||
|
||
v = '6.6.6'
|
||
|
||
global_proxy = {
|
||
'http': None,
|
||
'https': None
|
||
}
|
||
|
||
|
||
def start_dlapi():
|
||
dlstart = threading.Thread(target=get_proxy, args=(stop_event,))
|
||
dlstart.start()
|
||
|
||
|
||
stop_event = threading.Event()
|
||
|
||
|
||
def get_proxy(stop_event):
|
||
global global_proxy, ipp
|
||
a = 0
|
||
while not stop_event.is_set():
|
||
a += 1
|
||
response = requests.get(proxy_api_url)
|
||
if response.status_code == 200:
|
||
proxy1 = response.text.strip()
|
||
if "白名单" not in proxy1:
|
||
print(f'✅第{a}次获取代理成功: {proxy1}')
|
||
ipp = proxy1.split(':')[0]
|
||
global_proxy = {
|
||
'http': proxy1,
|
||
'https': proxy1,
|
||
}
|
||
start_time = time.time()
|
||
while time.time() - start_time < dl_sleep:
|
||
if ip():
|
||
print("✅代理检测通过,可以使用")
|
||
time.sleep(2)
|
||
else:
|
||
print(f'❎当前ip不可用，第{a}次重新获取！')
|
||
break
|
||
continue
|
||
else:
|
||
print(f"请求代理池: {proxy1}")
|
||
print("响应中存在白名单字样，结束运行")
|
||
os._exit(0)
|
||
else:
|
||
print(f'❎第{a}次获取代理失败！重新获取！')
|
||
time.sleep(dl_sleep)
|
||
continue
|
||
|
||
|
||
def ip():
|
||
try:
|
||
if global_proxy:
|
||
r = requests.get('http://httpbin.org/ip', proxies=global_proxy, timeout=10, verify=False)
|
||
else:
|
||
r = requests.get('http://httpbin.org/ip')
|
||
if r.status_code == 200:
|
||
ip = r.json()["origin"]
|
||
print(f"当前IP: {ip}")
|
||
return ip
|
||
else:
|
||
print(f"❎查询ip失败")
|
||
return None
|
||
except requests.RequestException as e:
|
||
print(f"❎查询ip错误")
|
||
return None
|
||
except Exception as e:
|
||
print(f"❎查询ip错误")
|
||
return None
|
||
|
||
|
||
def p(p):
|
||
if len(p) == 11:
|
||
return p[:3] + '****' + p[7:]
|
||
else:
|
||
return p
|
||
|
||
|
||
class PGSH:
|
||
def __init__(self, cki):
|
||
self.msg = None
|
||
self.messages = []
|
||
self.title = None
|
||
self.phone = None
|
||
self.token = cki.split('#')[0]
|
||
self.cook = cki
|
||
self.total_amount = 0
|
||
self.id = None
|
||
self.hd = {
|
||
'User-Agent': "okhttp/3.14.9",
|
||
'Accept': 'application/json, text/plain, */*',
|
||
'Version': "1.57.2",
|
||
'Content-Type': "application/x-www-form-urlencoded;charset=UTF-8",
|
||
'Authorization': self.token,
|
||
'channel': "android_app"
|
||
}
|
||
self.hd1 = {
|
||
'User-Agent': "okhttp/3.14.9",
|
||
'Connection': "Keep-Alive",
|
||
'Accept-Encoding': "gzip",
|
||
'Authorization': self.token,
|
||
'Version': "1.57.2",
|
||
'channel': "android_app",
|
||
'phoneBrand': "Redmi",
|
||
'Content-Type': "application/x-www-form-urlencoded;charset=UTF-8"
|
||
}
|
||
self.listUrl = 'https://userapi.qiekj.com/task/list'
|
||
self.phone_url = 'https://userapi.qiekj.com/user/info'
|
||
self.check_url = 'https://userapi.qiekj.com/user/balance'
|
||
self.rcrw_url = 'https://userapi.qiekj.com/task/completed'
|
||
self.sign_url = 'https://userapi.qiekj.com/signin/doUserSignIn'
|
||
self.jrjf_url = "https://userapi.qiekj.com/integralRecord/pageList"
|
||
self.dkbm_url = 'https://userapi.qiekj.com/markActivity/doApplyTask'
|
||
self.dkbm_url1 = 'https://userapi.qiekj.com/markActivity/doMarkTask'
|
||
self.shop_url = 'https://userapi.qiekj.com/integralUmp/rewardIntegral'
|
||
self.jtjl_url = 'https://userapi.qiekj.com/ladderTask/applyLadderReward'
|
||
self.dkbm_url2 = "https://userapi.qiekj.com/markActivity/markTaskReward"
|
||
self.bmcodeurl = 'https://userapi.qiekj.com/markActivity/queryMarkTaskByStartTime'
|
||
|
||
# 签名
|
||
def sg(self, y):
|
||
timestamp = str(int(time.time() * 1000))
|
||
parsed_url = urlparse(y)
|
||
path = parsed_url.path
|
||
data = f"appSecret=nFU9pbG8YQoAe1kFh+E7eyrdlSLglwEJeA0wwHB1j5o=&channel=android_app×tamp={timestamp}&token={self.token}&version=1.57.2&{path}"
|
||
data1 = f"appSecret=Ew+ZSuppXZoA9YzBHgHmRvzt0Bw1CpwlQQtSl49QNhY=&channel=alipay×tamp={timestamp}&token={self.token}&{path}"
|
||
sign = hashlib.sha256(data.encode()).hexdigest()
|
||
sign1 = hashlib.sha256(data1.encode()).hexdigest()
|
||
return sign, sign1, timestamp
|
||
|
||
|
||
# 检测token有效性
|
||
def name(self,source):
|
||
try:
|
||
data = {'token': self.token}
|
||
if dl:
|
||
re = requests.post(self.phone_url, data=data, headers=self.hd, proxies=global_proxy, timeout=10,
|
||
verify=False).json()
|
||
else:
|
||
re = requests.post(self.phone_url, data=data, headers=self.hd).json()
|
||
code = re['code']
|
||
if code == 0:
|
||
try:
|
||
if "#" in self.cook:
|
||
self.phone = self.cook.split('#')[1]
|
||
else:
|
||
self.phone = p(re['data']['phone'])
|
||
except:
|
||
print(f'[账号{i + 1}] Cookie异常')
|
||
exit(0)
|
||
self.id = re["data"]["id"]
|
||
sign, sign1, timestamp = self.sg(self.check_url)
|
||
self.hd['sign'] = sign
|
||
self.hd['timestamp'] = timestamp
|
||
if dl:
|
||
r = requests.post(self.check_url, data=data, headers=self.hd, proxies=global_proxy, timeout=10,
|
||
verify=False).json()
|
||
else:
|
||
r = requests.post(self.check_url, data=data, headers=self.hd).json()
|
||
coin_code = r['code']
|
||
balance = r['data']['integral'] if coin_code == 0 else 'N/A'
|
||
if source == 1:
|
||
print(f"[{self.phone}] ✅登录成功！积分余额: {balance}")
|
||
return self.phone
|
||
else:
|
||
msg = re["msg"]
|
||
print(f"[账号{i + 1}] ❎登录失败==> {msg}")
|
||
return False
|
||
except Exception as e:
|
||
print("❎请求出现错误")
|
||
return False
|
||
|
||
# 签到
|
||
def sign(self, max_retries=3):
|
||
retries = 0
|
||
while retries < max_retries:
|
||
try:
|
||
data = {'activityId': '600001', 'token': self.token}
|
||
sign, sign1, timestamp = self.sg(self.sign_url)
|
||
self.hd['sign'] = sign
|
||
self.hd['timestamp'] = timestamp
|
||
if dl:
|
||
re = requests.post(self.sign_url, data=data, headers=self.hd, proxies=global_proxy, timeout=10,
|
||
verify=False).json()
|
||
else:
|
||
re = requests.post(self.sign_url, data=data, headers=self.hd).json()
|
||
|
||
msg = re['msg']
|
||
print(f"[{self.phone}] ✅签到==> {msg}")
|
||
break
|
||
except Exception as e:
|
||
retries += 1
|
||
print(f"❎签到错误,重试次数: {retries}/{max_retries}")
|
||
if retries >= max_retries:
|
||
print("❎达到最大重试次数，跳过该任务")
|
||
break
|
||
time.sleep(1)
|
||
|
||
# 浏览商品
|
||
def shop(self):
|
||
for t in range(6):
|
||
try:
|
||
b1 = string.ascii_lowercase + string.digits
|
||
item_code = ''.join(random.choice(b1) for _ in range(6))
|
||
data = {'itemCode': item_code, 'token': self.token}
|
||
sign, sign1, timestamp = self.sg(self.shop_url)
|
||
self.hd['sign'] = sign
|
||
self.hd['timestamp'] = timestamp
|
||
if dl:
|
||
re = requests.post(self.shop_url, data=data, headers=self.hd, proxies=global_proxy, timeout=10,
|
||
verify=False).json()
|
||
else:
|
||
re = requests.post(self.shop_url, data=data, headers=self.hd).json()
|
||
q = re["data"]
|
||
if q is not None:
|
||
amount = re["data"]["rewardIntegral"]
|
||
print(f"[{self.phone}] ✅第{t + 1}次浏览商品成功,获得==> {amount}!")
|
||
else:
|
||
print(f"[{self.phone}] ❎第{t + 1}次浏览商品失败==> {q}")
|
||
break
|
||
except Exception as error:
|
||
print("❎浏览商品出现错误")
|
||
continue
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
|
||
# 支付宝广告任务
|
||
def zfbgg(self):
|
||
for t in range(11):
|
||
try:
|
||
data = {'taskType': "9", 'token': self.token}
|
||
sign, sign1, timestamp = self.sg(self.rcrw_url)
|
||
hd1 = {
|
||
'User-Agent': "Dalvik/2.1.0 (Linux; U; Android 13; MEIZU 20 Build/TKQ1.221114.001) Chrome/105.0.5195.148 MYWeb/0.11.0.240407200246 UWS/3.22.2.9999 UCBS/3.22.2.9999_220000000000 Mobile Safari/537.36 NebulaSDK/1.8.100112 Nebula AlipayDefined(nt:WIFI,ws:1080|1862|2.8125) AliApp(AP/10.5.88.8000) AlipayClient/10.5.88.8000 Language/zh-Hans useStatusBar/true isConcaveScreen/true NebulaX/1.0.0 DTN/2.0",
|
||
'Connection': "Keep-Alive",
|
||
'Accept-Encoding': "gzip",
|
||
'Content-Type': "application/x-www-form-urlencoded",
|
||
'Accept-Charset': "UTF-8",
|
||
'channel': "alipay",
|
||
'sign': sign1,
|
||
'x-release-type': "ONLINE",
|
||
'version': "",
|
||
'timestamp': timestamp
|
||
}
|
||
if dl:
|
||
response = requests.post(self.rcrw_url, data=data, headers=hd1, proxies=global_proxy, timeout=10,
|
||
verify=False).json()
|
||
else:
|
||
response = requests.post(self.rcrw_url, data=data, headers=hd1).json()
|
||
msg = response["data"]
|
||
if msg:
|
||
print(f"[{self.phone}] ✅第{t + 1}次支付宝广告==> {msg}")
|
||
else:
|
||
print(f"[{self.phone}] ❎第{t + 1}次支付宝广告失败==> {msg}")
|
||
break
|
||
except Exception as error:
|
||
print("❎支付宝广告出现错误")
|
||
continue
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
|
||
# 看视频赚积分
|
||
def kspzjf(self):
|
||
for t in range(6):
|
||
try:
|
||
data = {'taskType': "2", 'token': self.token}
|
||
sign, sign1, timestamp = self.sg(self.rcrw_url)
|
||
self.hd['sign'] = sign
|
||
self.hd['timestamp'] = timestamp
|
||
if dl:
|
||
response = requests.post(self.rcrw_url, data=data, headers=self.hd, proxies=global_proxy,
|
||
timeout=10, verify=False).json()
|
||
else:
|
||
response = requests.post(self.rcrw_url, data=data, headers=self.hd).json()
|
||
msg = response["data"]
|
||
if msg:
|
||
print(f"[{self.phone}] ✅第{t + 1}次看视频赚积分==> {msg}")
|
||
else:
|
||
print(f"[{self.phone}] ❎第{t + 1}次看视频赚积分失败==> {msg}")
|
||
break
|
||
except Exception as error:
|
||
print("❎看视频赚积分出现错误")
|
||
continue
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
|
||
# 看广告赚积分
|
||
def kggzjf(self):
|
||
for t in range(9):
|
||
try:
|
||
data = {'taskCode': '18893134-715b-4307-af1c-b5737c70f58d', 'token': self.token}
|
||
sign, sign1, timestamp = self.sg(self.rcrw_url)
|
||
self.hd['sign'] = sign
|
||
self.hd['timestamp'] = timestamp
|
||
if dl:
|
||
res = requests.post(self.rcrw_url, data=data, headers=self.hd, proxies=global_proxy, timeout=10,
|
||
verify=False).json()
|
||
else:
|
||
res = requests.post(self.rcrw_url, data=data, headers=self.hd).json()
|
||
msg = res['data']
|
||
if msg:
|
||
print(f'[{self.phone}] ✅第{t + 1}次看广告赚积分==> {msg}')
|
||
else:
|
||
print(f'[{self.phone}] ❎第{t + 1}次看广告赚积分失败==> {msg}')
|
||
break
|
||
except Exception as e:
|
||
print("❎看广告赚积分出现错误")
|
||
continue
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
|
||
# 不知名任务
|
||
def ycrw(self):
|
||
for t in range(9):
|
||
try:
|
||
data = {'taskCode': '15eb1357-b2d9-442f-a19f-dbd9cdc996cb', 'token': self.token}
|
||
sign, sign1, timestamp = self.sg(self.rcrw_url)
|
||
self.hd['sign'] = sign
|
||
self.hd['timestamp'] = timestamp
|
||
if dl:
|
||
re = requests.post(self.rcrw_url, data=data, headers=self.hd, proxies=global_proxy, timeout=10,
|
||
verify=False).json()
|
||
else:
|
||
re = requests.post(self.rcrw_url, data=data, headers=self.hd).json()
|
||
msg = re['data']
|
||
if msg:
|
||
print(f'[{self.phone}] ✅第{t + 1}次看广告赚积分==> {msg}')
|
||
else:
|
||
print(f'[{self.phone}] ❎第{t + 1}次看广告赚积分失败==> {msg}')
|
||
break
|
||
except Exception as e:
|
||
print("❎不知名任务出现错误")
|
||
continue
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
|
||
# 大鹅积分
|
||
def dejf(self):
|
||
for t in range(10):
|
||
try:
|
||
data = {'taskCode': '5', 'token': self.token}
|
||
sign, sign1, timestamp = self.sg(self.rcrw_url)
|
||
self.hd['sign'] = sign
|
||
self.hd['timestamp'] = timestamp
|
||
if dl:
|
||
re = requests.post(self.rcrw_url, data=data, headers=self.hd, proxies=global_proxy, timeout=10,
|
||
verify=False).json()
|
||
else:
|
||
re = requests.post(self.rcrw_url, data=data, headers=self.hd).json()
|
||
msg = re['data']
|
||
if msg:
|
||
print(f'[{self.phone}] ✅第{t + 1}次大鹅积分当钱花==> {msg}')
|
||
else:
|
||
print(f'[{self.phone}] ❎第{t + 1}次大鹅积分当钱花==> {msg}')
|
||
break
|
||
except Exception as e:
|
||
print("❎大鹅积分当钱花出现错误")
|
||
continue
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
|
||
# 遍历日常
|
||
def rcrw(self):
|
||
try:
|
||
data = {'token': self.token}
|
||
sign, sign1, timestamp = self.sg(self.listUrl)
|
||
self.hd['sign'] = sign
|
||
self.hd['timestamp'] = timestamp
|
||
response = requests.post(self.listUrl, data=data, headers=self.hd).json()
|
||
code = response.get('code', -1)
|
||
if code == 0:
|
||
tasks = response.get('data', {}).get('items', [])
|
||
if tasks:
|
||
print(f'[{self.phone}] ✅获取到{len(tasks)}个日常任务')
|
||
|
||
# 筛选排除不执行的任务
|
||
not_task_titles = ["免费权益领取", "完成任务赚现金", "支付宝花呗开通", "开通支付宝小荷包", "更多任务赚积分", "开通云闪付无感支付", "完善个人信息"]
|
||
# 只筛选任务状态为0 即未执行完毕的任务
|
||
tasks = [task for task in tasks if task['completedStatus'] == 0 and task['title'] not in not_task_titles]
|
||
# 筛选条件，即要匹配的title列表 需要执行多次的任务
|
||
target_titles = ["浏览广告赚积分", "来乖乖果园赚积分"]
|
||
# 筛选数据
|
||
filtered_tasks = [task for task in tasks if task['title'] in target_titles]
|
||
tasks = tasks + filtered_tasks
|
||
|
||
for item in tasks:
|
||
title = item["title"]
|
||
id1 = item["taskCode"]
|
||
data = {'taskCode': id1, 'token': self.token}
|
||
sign, sign1, timestamp = self.sg(self.rcrw_url)
|
||
self.hd['sign'] = sign
|
||
self.hd['timestamp'] = timestamp
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
if dl:
|
||
response1 = requests.post(self.rcrw_url, data=data, headers=self.hd, proxies=global_proxy,
|
||
timeout=10, verify=False).json()
|
||
else:
|
||
response1 = requests.post(self.rcrw_url, data=data, headers=self.hd).json()
|
||
data1 = response1.get("data", {})
|
||
if data1:
|
||
print(f'[{self.phone}] ✅完成日常任务[{title}]成功==> {data1}')
|
||
else:
|
||
print(f'[{self.phone}] ❎完成日常任务[{title}]失败==> {data1}')
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
else:
|
||
print("❎获取任务列表为空!")
|
||
else:
|
||
print("❎获取任务列表失败!")
|
||
except requests.RequestException as e:
|
||
print(f"❎网络请求错误: {e}")
|
||
except Exception as e:
|
||
print(f"❎遍历日常出现错误: {e}")
|
||
|
||
# 浏览任务
|
||
def lljf(self):
|
||
try:
|
||
data = f"taskCode=8b475b42-df8b-4039-b4c1-f9a0174a611a&token={self.token}"
|
||
sign, sign1, timestamp = self.sg("https://userapi.qiekj.com/task/queryByType")
|
||
self.hd['sign'] = sign
|
||
self.hd['timestamp'] = timestamp
|
||
response = requests.post("https://userapi.qiekj.com/task/queryByType", data=data, headers=self.hd).json()
|
||
code = response.get('code', -1)
|
||
if code == 0:
|
||
tasks = response.get('data', {}).get('subtaskList', [])
|
||
if tasks:
|
||
print(f'[{self.phone}] ✅获取到{len(tasks)}个浏览任务')
|
||
for item in tasks:
|
||
title = item["subtaskName"]
|
||
id1 = item["taskCode"]
|
||
id2 = item["subtaskCode"]
|
||
data = {'taskCode': id1, 'subtaskCode': id2, 'token': self.token}
|
||
sign, sign1, timestamp = self.sg(self.rcrw_url)
|
||
self.hd['sign'] = sign
|
||
self.hd['timestamp'] = timestamp
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
if dl:
|
||
response1 = requests.post(self.rcrw_url, data=data, headers=self.hd, proxies=global_proxy,
|
||
timeout=10, verify=False).json()
|
||
else:
|
||
response1 = requests.post(self.rcrw_url, data=data, headers=self.hd).json()
|
||
data1 = response1.get("data", {})
|
||
if data1:
|
||
print(f'[{self.phone}] ✅完成浏览任务[{title}]成功==> {data1}')
|
||
else:
|
||
print(f'[{self.phone}] ❎完成浏览任务[{title}]失败==> {data1}')
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
else:
|
||
print("❎获取任务列表为空!")
|
||
else:
|
||
print("❎获取任务列表失败!")
|
||
except requests.RequestException as e:
|
||
print(f"❎网络请求错误: {e}")
|
||
except Exception as e:
|
||
print(f"❎遍历浏览出现错误: {e}")
|
||
|
||
# 领取阶梯奖励
|
||
def jtjl(self):
|
||
try:
|
||
url = "https://userapi.qiekj.com/ladderTask/ladderTaskForDay"
|
||
params = {
|
||
'token': self.token
|
||
}
|
||
sign, sign1, timestamp = self.sg(url)
|
||
self.hd1['sign'] = sign
|
||
self.hd1['timestamp'] = timestamp
|
||
if dl:
|
||
r = requests.get(url, params=params, headers=self.hd1, proxies=global_proxy, timeout=10,
|
||
verify=False).json()
|
||
else:
|
||
r = requests.get(url, params=params, headers=self.hd1).json()
|
||
if r['code'] == 0:
|
||
reward_list = [item['rewardCode'] for item in r['data']['ladderRewardList']]
|
||
for rewar in reward_list:
|
||
try:
|
||
url1 = "https://userapi.qiekj.com/ladderTask/applyLadderReward"
|
||
data = {'rewardCode': rewar, 'token': self.token}
|
||
sign, sign1, timestamp = self.sg(url1)
|
||
self.hd1['sign'] = sign
|
||
self.hd1['timestamp'] = timestamp
|
||
if dl:
|
||
r1 = requests.post(url1, data=data, headers=self.hd1, proxies=global_proxy, timeout=10,
|
||
verify=False).json()
|
||
else:
|
||
r1 = requests.post(url1, data=data, headers=self.hd1).json()
|
||
if r1["code"] == 0:
|
||
reward = r1["data"]["reward"]
|
||
print(f'[{self.phone}] ✅领取任务id[{rewar}]成功==> {reward}')
|
||
else:
|
||
print(f'[{self.phone}] ❎领取任务id[{rewar}]失败==> {r1["msg"]}')
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
except Exception as e:
|
||
print("❎领取阶梯奖励出现错误")
|
||
continue
|
||
else:
|
||
print("获取任务列表失败!")
|
||
except Exception as e:
|
||
print("获取阶梯奖励列表出现错误")
|
||
|
||
# 时间段奖励
|
||
def timejl(self, max_retries=3):
|
||
retries = 0
|
||
while retries < max_retries:
|
||
try:
|
||
url = "https://userapi.qiekj.com/timedBenefit/applyRewardForTimeBenefit"
|
||
params = {
|
||
'token': self.token
|
||
}
|
||
sign, sign1, timestamp = self.sg(url)
|
||
self.hd1['sign'] = sign
|
||
self.hd1['timestamp'] = timestamp
|
||
|
||
if dl:
|
||
r = requests.get(url, params=params, headers=self.hd1, proxies=global_proxy, timeout=10,
|
||
verify=False).json()
|
||
else:
|
||
r = requests.get(url, params=params, headers=self.hd1).json()
|
||
if r["code"] == 0:
|
||
print(f'[{self.phone}] ✅领取时间段奖励成功==> {r["data"]["rewardNum"]}')
|
||
break
|
||
else:
|
||
print(f'[{self.phone}] ❎领取时间段奖励失败==> {r["msg"]}')
|
||
break
|
||
except Exception as e:
|
||
retries += 1
|
||
print(f"❎完成时间段任务出现错误: {e}. 重试次数: {retries}/{max_retries}")
|
||
if retries >= max_retries:
|
||
print("❎达到最大重试次数，跳过该任务")
|
||
break
|
||
time.sleep(1)
|
||
|
||
# 打卡报名
|
||
def dkbm(self):
|
||
try:
|
||
ti = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
|
||
data = {'startTime': ti, 'token': self.token}
|
||
sign, sign1, timestamp = self.sg(self.bmcodeurl)
|
||
self.hd1['sign'] = sign
|
||
self.hd1['timestamp'] = timestamp
|
||
if dl:
|
||
r = requests.post(self.bmcodeurl, data=data, headers=self.hd1, proxies=global_proxy, timeout=10,
|
||
verify=False).json()
|
||
else:
|
||
r = requests.post(self.bmcodeurl, data=data, headers=self.hd1).json()
|
||
code = r['code']
|
||
if code == 0:
|
||
try:
|
||
code1 = r['data']['taskCode']
|
||
data = {'taskCode': code1, 'token': self.token}
|
||
sign, sign1, timestamp = self.sg(self.dkbm_url)
|
||
self.hd1['sign'] = sign
|
||
self.hd1['timestamp'] = timestamp
|
||
time.sleep(2)
|
||
if dl:
|
||
r1 = requests.post(self.dkbm_url, data=data, headers=self.hd1, proxies=global_proxy, timeout=10,
|
||
verify=False).json()
|
||
else:
|
||
r1 = requests.post(self.dkbm_url, data=data, headers=self.hd1).json()
|
||
code2 = r1['code']
|
||
data1 = r1["data"]
|
||
msg = r1["msg"]
|
||
if code2 == 0:
|
||
print(f"[{self.phone}] ✅打卡报名成功==> {data1}")
|
||
else:
|
||
print(f"[{self.phone}] ❎打卡报名失败==> {msg}")
|
||
except Exception as e:
|
||
print("❎打卡报名出现错误")
|
||
else:
|
||
print(f"获取code失败!{r}")
|
||
except Exception as e:
|
||
print("获取打卡报名id出现错误")
|
||
|
||
# 领取瓜分资格
|
||
def gfjf(self):
|
||
try:
|
||
current_datetime = datetime.now()
|
||
yesterday_datetime = current_datetime - timedelta(days=1)
|
||
yesterday_now = yesterday_datetime.replace(hour=current_datetime.hour, minute=current_datetime.minute,
|
||
second=current_datetime.second,
|
||
microsecond=current_datetime.microsecond)
|
||
k = yesterday_now.strftime("%Y-%m-%d %H:%M:%S")
|
||
data = {"startTime": k, "token": self.token}
|
||
sign, sign1, timestamp = self.sg(self.bmcodeurl)
|
||
self.hd1['sign'] = sign
|
||
self.hd1['timestamp'] = timestamp
|
||
if dl:
|
||
r = requests.post(self.bmcodeurl, headers=self.hd1, data=data).json()
|
||
else:
|
||
r = requests.post(self.bmcodeurl, headers=self.hd1, data=data).json()
|
||
if r['code'] == 0:
|
||
code1 = r['data']['taskCode']
|
||
data1 = {'taskCode': code1, 'token': self.token}
|
||
sign, sign1, timestamp = self.sg(self.dkbm_url1)
|
||
self.hd1['sign'] = sign
|
||
self.hd1['timestamp'] = timestamp
|
||
time.sleep(2)
|
||
if dl:
|
||
r1 = requests.post(self.dkbm_url1, headers=self.hd1, data=data1).json()
|
||
else:
|
||
r1 = requests.post(self.dkbm_url1, headers=self.hd1, data=data1).json()
|
||
print(f"[{self.phone}] 领取瓜分资格==> {r1['msg']}")
|
||
return code1
|
||
else:
|
||
print(f"❎获取taskCode失败! {r}")
|
||
return None
|
||
except Exception as e:
|
||
print(f"领取瓜分资格出现错误")
|
||
|
||
# 瓜分积分
|
||
def gfjf1(self, max_retries=3):
|
||
retries = 0
|
||
while retries < max_retries:
|
||
try:
|
||
data1 = {'taskCode': self.gfjf(), 'token': self.token}
|
||
sign, sign1, timestamp = self.sg(self.dkbm_url2)
|
||
self.hd1['sign'] = sign
|
||
self.hd1['timestamp'] = timestamp
|
||
req = requests.post(self.dkbm_url2, headers=self.hd1, data=data1).json()
|
||
a1 = req['data']
|
||
print(f"[{self.phone}] ✅报名瓜分成功==> {a1}")
|
||
break
|
||
except Exception as e:
|
||
retries += 1
|
||
print(f"❎报名瓜分错误,重试次数: {retries}/{max_retries}")
|
||
if retries >= max_retries:
|
||
print("❎达到最大重试次数，跳过该任务")
|
||
break
|
||
time.sleep(1)
|
||
|
||
# 每日答题
|
||
def queryans(self):
|
||
# print("------开始每日答题------")
|
||
url = "https://userapi.qiekj.com/integralRecord/statisticsAnswer"
|
||
start_date = datetime(2024, 9, 1)
|
||
start_number = 13
|
||
current_date = datetime.now()
|
||
delta = current_date - start_date
|
||
days_since_start = delta.days
|
||
current_number = start_number + days_since_start
|
||
|
||
multipart_data = MultipartEncoder(
|
||
fields={
|
||
'number': str(current_number),
|
||
'isCorrect': 'true',
|
||
'token': self.token
|
||
}
|
||
)
|
||
sign, sign1, timestamp = self.sg(url)
|
||
|
||
headers = self.hd1;
|
||
headers['sign'] = sign
|
||
headers['timestamp'] = timestamp
|
||
headers.update({
|
||
'Content-Type': multipart_data.content_type,
|
||
'Origin': 'https://h5user.qiekj.com',
|
||
'Referer': 'https://h5user.qiekj.com/'
|
||
})
|
||
time.sleep(2)
|
||
r1 = ""
|
||
phone = ""
|
||
try:
|
||
if dl:
|
||
r1 = requests.post(url, headers=headers, proxies=global_proxy, data=multipart_data).json()
|
||
else:
|
||
r1 = requests.post(url, headers=headers, data=multipart_data).json()
|
||
result = r1
|
||
# 获取用户账号
|
||
hd1 = {
|
||
'User-Agent': "okhttp/3.14.9",
|
||
'Accept': 'application/json, text/plain, */*',
|
||
'Version': "1.57.2",
|
||
'Content-Type': "application/x-www-form-urlencoded;charset=UTF-8",
|
||
'Authorization': self.token,
|
||
'channel': "android_app"
|
||
}
|
||
data = {'token': self.token}
|
||
r = requests.post(self.phone_url, data=data, headers=hd1).json()
|
||
if r['code'] == 0:
|
||
phone = p(r['data']['phone'])
|
||
|
||
if result['code'] == 0:
|
||
if result['data']['isReward']:
|
||
reward = result['data']['rewardNum']
|
||
print(f"[{phone}]✅每日答题成功，获得奖励：{reward}")
|
||
else:
|
||
print(result)
|
||
print(f"[{phone}]❎每日答题已完成，今日无法再获得奖励")
|
||
else:
|
||
if result['msg'] == "版本过低，请升级APP后再使用":
|
||
print(f"[{phone}]❎每日答题失败：{result['msg']}")
|
||
print("重试")
|
||
self.queryans()
|
||
except Exception as e:
|
||
print(f"每日答题出错：{str(e)}")
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
|
||
def xieru(self, rw, dk, dt):
|
||
default_rw = 0
|
||
default_dk = 0
|
||
try:
|
||
new_data = {
|
||
"pgid": str(self.id)
|
||
}
|
||
if not os.path.exists("./pgsh.json"):
|
||
with open("./pgsh.json", "w") as file:
|
||
json.dump({}, file)
|
||
with open("./pgsh.json", "r") as file:
|
||
try:
|
||
data = json.load(file)
|
||
except json.decoder.JSONDecodeError:
|
||
data = {}
|
||
|
||
if rw == 1 and new_data["pgid"] in data and data[new_data["pgid"]]["rw"] == 1:
|
||
print("任务记录已存在。")
|
||
return False
|
||
elif dk == 1 and new_data["pgid"] in data and data[new_data["pgid"]]["dk"] == 1:
|
||
print("打卡记录已存在。")
|
||
return False
|
||
elif dt == 1 and new_data["pgid"] in data and data[new_data["pgid"]]["dt"] == 1:
|
||
print("答题记录已存在。")
|
||
return False
|
||
else:
|
||
if rw == 1:
|
||
data[new_data["pgid"]] = {"rw": 1, "dk": 0, "dt": 0}
|
||
elif dk == 1:
|
||
data[new_data["pgid"]] = {"rw": 1, "dk": 1, "dt": 1}
|
||
elif dt == 1:
|
||
data[new_data["pgid"]] = {"rw": 1, "dk": 0, "dt": 1}
|
||
with open("./pgsh.json", "w") as file:
|
||
json.dump(data, file)
|
||
print("✅写入记录文件成功。")
|
||
return True
|
||
except Exception as e:
|
||
print(f"❎写入记录文件出现错误，初始化文件内容")
|
||
with open("./pgsh.json", "w") as file:
|
||
json.dump({}, file)
|
||
|
||
# 读取指定值是否存在
|
||
def duqu(self, aa, rw, dk, dt):
|
||
try:
|
||
if not os.path.exists("./pgsh.json"):
|
||
with open("./pgsh.json", "w") as file:
|
||
json.dump({}, file)
|
||
|
||
with open("./pgsh.json", "r") as file:
|
||
try:
|
||
data = json.load(file)
|
||
except json.decoder.JSONDecodeError:
|
||
data = {}
|
||
if rw == 1:
|
||
if str(aa) in data:
|
||
return data[str(aa)]["rw"]
|
||
else:
|
||
return False
|
||
elif dk == 1:
|
||
if str(aa) in data:
|
||
return data[str(aa)]["dk"]
|
||
else:
|
||
return False
|
||
elif dt == 1:
|
||
if str(aa) in data:
|
||
return data[str(aa)]["dt"]
|
||
else:
|
||
return False
|
||
except Exception as e:
|
||
print(f"读取记录文件出现错误,初始化文件内容")
|
||
with open("./pgsh.json", "w") as file:
|
||
json.dump({}, file)
|
||
|
||
# 今日积分
|
||
def jrjf(self, i, token1 ,source):
|
||
token = token1.split('#')[0]
|
||
try:
|
||
hd1 = {
|
||
'User-Agent': "okhttp/3.14.9",
|
||
'Accept': 'application/json, text/plain, */*',
|
||
'Version': "1.57.2",
|
||
'Content-Type': "application/x-www-form-urlencoded;charset=UTF-8",
|
||
'Authorization': token,
|
||
'channel': "android_app"
|
||
}
|
||
data = {'token': token}
|
||
sign, sign1, timestamp = self.sg(self.phone_url)
|
||
self.hd['sign'] = sign
|
||
self.hd['timestamp'] = timestamp
|
||
r = requests.post(self.phone_url, data=data, headers=hd1).json()
|
||
if r['code'] == 0:
|
||
try:
|
||
sign, sign1, timestamp = self.sg(self.check_url)
|
||
self.hd['sign'] = sign
|
||
self.hd['timestamp'] = timestamp
|
||
r1 = requests.post(self.check_url, data=data, headers=hd1).json()
|
||
coin_code = r1['code']
|
||
balance = r1['data']['integral'] if coin_code == 0 else 'N/A'
|
||
except Exception as e:
|
||
print(f"获取积分失败: {e}")
|
||
balance = 'N/A'
|
||
|
||
try:
|
||
phone = p(r['data']['phone'])
|
||
data = {
|
||
'page': (None, '1'),
|
||
'pageSize': (None, '100'),
|
||
'type': (None, '100'),
|
||
'receivedStatus': (None, '1'),
|
||
'token': (None, token),
|
||
}
|
||
hd = {
|
||
'User-Agent': 'Mozilla/5.0 (Linux; Android 14; 23117RK66C Build/UKQ1.230804.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/118.0.0.0 Mobile Safari/537.36 AgentWeb/5.0.0 UCBrowser/11.6.4.950 com.qiekj.QEUser',
|
||
'Accept': 'application/json, text/plain, */*',
|
||
'channel': 'android_app',
|
||
}
|
||
re_response = requests.post(self.jrjf_url, headers=hd, files=data).json()
|
||
current_date = datetime.now().strftime('%Y-%m-%d')
|
||
total_amount = 0
|
||
xieru_tips = ''
|
||
default_num = 170
|
||
for item in re_response['data']['items']:
|
||
received_date = item['receivedTime'][:10]
|
||
if received_date == current_date:
|
||
total_amount += item['amount']
|
||
if source == 2:
|
||
if total_amount >= default_num and self.name(2):
|
||
print(f"写入日志状态：{self.xieru(1, 0, 0)}")
|
||
else:
|
||
print(f"写入日志状态：未达标写入目标{default_num}积分")
|
||
else:
|
||
print(f"[{phone}] ✅今日获得积分: {total_amount},账户总积分:{balance}")
|
||
return {
|
||
'序号': i + 1,
|
||
'用户': phone,
|
||
'arg1': balance,
|
||
'arg2': total_amount
|
||
}
|
||
except Exception as e:
|
||
print(f"[账号{i + 1}] ❎查询当日积分出现错误: {e}")
|
||
return {
|
||
'序号': i + 1,
|
||
'用户': i + 1,
|
||
'arg1': f"❎",
|
||
'arg2': f"❎"
|
||
}
|
||
else:
|
||
print(f"[账号{i + 1}] ❎登录失败: {r['msg']}")
|
||
return {
|
||
'序号': i + 1,
|
||
'用户': i + 1,
|
||
'arg1': f"{r['msg']}",
|
||
'arg2': f"{r['msg']}"
|
||
}
|
||
except requests.exceptions.RequestException as e:
|
||
print(f"[账号{i + 1}] ❎网络请求错误: {e}")
|
||
return {
|
||
'序号': i + 1,
|
||
'用户': i + 1,
|
||
'arg1': f"❎",
|
||
'arg2': f"❎"
|
||
}
|
||
except Exception as e:
|
||
print(f"[账号{i + 1}] ❎查询当日积分出现错误: {e}")
|
||
return {
|
||
'序号': i + 1,
|
||
'用户': i + 1,
|
||
'arg1': f"❎",
|
||
'arg2': f"❎"
|
||
}
|
||
|
||
def jf(self):
|
||
try:
|
||
msg_list = []
|
||
print(f"======开始查询所有账号当日收益======")
|
||
for n, yy in enumerate(cookies):
|
||
msg = self.jrjf(n, yy,1)
|
||
msg_list.append(msg)
|
||
sorted_data = sorted(msg_list, key=lambda x: x['序号'])
|
||
table_content = ''
|
||
for row in sorted_data:
|
||
table_content += f"<tr><td style='border: 1px solid #ccc; padding: 6px;'>{row['序号']}</td><td style='border: 1px solid #ccc; padding: 6px;'>{row['用户']}</td><td style='border: 1px solid #ccc; padding: 6px;'>{row['arg1']}</td><td style='border: 1px solid #ccc; padding: 6px;'>{row['arg2']}</td></tr>"
|
||
|
||
self.msg = f"<table style='border-collapse: collapse;'><tr style='background-color: #f2f2f2;'><th style='border: 1px solid #ccc; padding: 8px;'>🆔</th><th style='border: 1px solid #ccc; padding: 8px;'>用户名</th><th style='border: 1px solid #ccc; padding: 8px;'>总积分</th><th style='border: 1px solid #ccc; padding: 8px;'>今日积分</th></tr>{table_content}</table>"
|
||
if ts:
|
||
self.send_msg()
|
||
except Exception as e:
|
||
print(f"查询所有账号当日收益出现错误: {e}")
|
||
# if int(b) <= now_time or now_time <= 1:
|
||
# with open("./pgsh.json", "w") as file:
|
||
# json.dump({}, file)
|
||
# print("已重置文件内容")
|
||
|
||
def send_msg(self):
|
||
if 'WxPusher_token' in os.environ and os.environ['WxPusher_token'] is not None:
|
||
self.WxPusher_ts()
|
||
if 'PUSH_PLUS_TOKEN' in os.environ and os.environ['PUSH_PLUS_TOKEN'] is not None:
|
||
self.pushplus_ts()
|
||
else:
|
||
print("❎推送失败，未配置推送")
|
||
|
||
def WxPusher_ts(self):
|
||
try:
|
||
url = 'https://wxpusher.zjiecode.com/api/send/message'
|
||
params = {
|
||
'appToken': WxPusher_token,
|
||
'content': self.msg,
|
||
'summary': '胖乖生活',
|
||
'contentType': 3,
|
||
'uids': [WxPusher_uid]
|
||
}
|
||
re = requests.post(url, json=params)
|
||
msg = re.json().get('msg', None)
|
||
print(f'WxPusher推送结果：{msg}\\\n')
|
||
except Exception as e:
|
||
print(f"WxPusher推送出现错误: {e}")
|
||
|
||
def pushplus_ts(self):
|
||
try:
|
||
url = 'https://www.pushplus.plus/send/'
|
||
data = {
|
||
"token": pushplus_token,
|
||
"title": '胖乖生活',
|
||
"content": self.msg
|
||
}
|
||
re = requests.post(url, json=data)
|
||
msg = re.json().get('msg', None)
|
||
print(f'pushplus推送结果：{msg}\\\n')
|
||
except Exception as e:
|
||
print(f"pushplus推送出现错误: {e}")
|
||
|
||
def start(self):
|
||
if self.name(1):
|
||
# self.jrjf(i, self.token, 2)
|
||
print("-----执行领取时间段奖励-----")
|
||
self.timejl()
|
||
if int(a) <= now_time < int(b):
|
||
print("--------滴滴车发车，坐稳了--------\\\n")
|
||
if self.duqu(self.id, 1, 0, 0) == 0:
|
||
print("-----开始执行签到-----")
|
||
self.sign()
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
print("-----先遍历个日常，防止漏网之鱼-----")
|
||
self.rcrw()
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
print("-----开始执行支付宝看广告-----")
|
||
self.zfbgg()
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
print("-----开始执行赚大鹅积分-----")
|
||
self.dejf()
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
print("-----开始执行看视频赚积分-----")
|
||
self.kspzjf()
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
print("-----开始执行看广告赚积分-----")
|
||
self.kggzjf()
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
print("-----开始执行浏览商品赚积分-----")
|
||
self.shop()
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
print("-----开始执行隐藏任务-----")
|
||
self.ycrw()
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
print("-----开始执行打卡报名-----")
|
||
self.dkbm()
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
print("-----开始执行领取瓜分资格-----")
|
||
self.gfjf()
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
if lljf == 1:
|
||
print("-----开始执行浏览任务-----")
|
||
self.lljf()
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
print("-----执行领取阶梯奖励----")
|
||
self.jtjl()
|
||
if dl:
|
||
time.sleep(2)
|
||
else:
|
||
time.sleep(6)
|
||
print("-----任务执行完毕，记录id-----")
|
||
self.jrjf(i, self.token, 2)
|
||
# self.xieru(1, 0)
|
||
else:
|
||
print("当前账号已执行过任务，跳过执行")
|
||
else:
|
||
print(f"当前时间非{int(a)}-{int(b)}，跳过今日任务")
|
||
if 14 <= now_time <= 23:
|
||
print("-----开始执行瓜分打卡积分-----")
|
||
if self.duqu(self.id, 0, 1, 0) == 0:
|
||
self.gfjf1()
|
||
self.xieru(0, 1, 0)
|
||
else:
|
||
print("当前账号已执行过任务，跳过执行")
|
||
else:
|
||
print(f"当前时间非14-16，跳过瓜分打卡积分")
|
||
|
||
if self.duqu(self.id, 0, 0, 1) == 0:
|
||
print("-----开始每日答题-----")
|
||
self.queryans()
|
||
self.xieru(0, 0, 1)
|
||
else:
|
||
print("当前账号已执行过答题任务，跳过执行")
|
||
|
||
if __name__ == '__main__':
|
||
print(f"当前版本: {v}")
|
||
requests.packages.urllib3.disable_warnings(category=InsecureRequestWarning)
|
||
print = partial(print, flush=True)
|
||
if jh:
|
||
print("当前聚合ck模式，所有模式ck生效")
|
||
ck1 = []
|
||
if 'PGSH_TOKEN' in os.environ:
|
||
ck1.append(os.environ.get('PGSH_TOKEN'))
|
||
if ckurl != "":
|
||
r = requests.get(ckurl)
|
||
ck1.append(r.text.strip())
|
||
if ck != "":
|
||
ck1.append(ck)
|
||
if not ck1:
|
||
print("变量为空，请设置其中一个变量后再运行")
|
||
exit(-1)
|
||
cookie = '\n'.join(ck1)
|
||
else:
|
||
if 'PGSH_TOKEN' in os.environ:
|
||
cookie = os.environ.get('PGSH_TOKEN')
|
||
else:
|
||
print("环境变量中不存在[PGSH_TOKEN],启用本地或数据库地址模式")
|
||
if ckurl != "":
|
||
r = requests.get(ckurl)
|
||
cookie = r.text.strip()
|
||
else:
|
||
cookie = ck
|
||
if cookie == "":
|
||
print("本地及数据库地址变量为空，请设置其中一个变量后再运行")
|
||
exit(-1)
|
||
cookies = cookie.split("\n")
|
||
print(f"胖乖生活共获取到 {len(cookies)} 个账号")
|
||
now_time = datetime.now().hour
|
||
if dl:
|
||
start_dlapi()
|
||
i = 1
|
||
if bf:
|
||
print("✅开启并发模式")
|
||
if dl:
|
||
print("✅开启代理模式")
|
||
with ThreadPoolExecutor(max_workers=int(bfsum)) as executor:
|
||
futures = [executor.submit(PGSH(ck).start) for ck in cookies]
|
||
for i, future in enumerate(as_completed(futures)):
|
||
print(f"======执行第{i + 1}个账号======")
|
||
future.result()
|
||
stop_event.set()
|
||
time.sleep(2)
|
||
PGSH(ck).jf()
|
||
else:
|
||
print("❎未开启代理模式")
|
||
with ThreadPoolExecutor(max_workers=int(bfsum)) as executor:
|
||
futures = [executor.submit(PGSH(ck).start) for ck in cookies]
|
||
for i, future in enumerate(as_completed(futures)):
|
||
print(f"======执行第{i + 1}个账号======")
|
||
time.sleep(2)
|
||
PGSH(ck).jf()
|
||
else:
|
||
print("✅常规运行模式")
|
||
if dl:
|
||
print("✅开启代理模式")
|
||
for i, ck in enumerate(cookies):
|
||
print(f"======开始第{i + 1}个账号======")
|
||
now_time = datetime.now().hour
|
||
PGSH(ck).start()
|
||
print("2s后进行下一个账号")
|
||
time.sleep(2)
|
||
stop_event.set()
|
||
time.sleep(2)
|
||
PGSH(ck).jf()
|
||
else:
|
||
print("❎未开启代理模式")
|
||
for i, ck in enumerate(cookies):
|
||
print(f"======开始第{i + 1}个账号======")
|
||
now_time = datetime.now().hour
|
||
PGSH(ck).start()
|
||
print("2s后进行下一个账号")
|
||
time.sleep(2)
|
||
time.sleep(2)
|
||
PGSH(ck).jf() |