mirror of
https://github.com/shufflewzc/faker2.git
synced 2025-04-20 12:48:05 +08:00
390 lines
14 KiB
Python
390 lines
14 KiB
Python
#!/usr/bin/env python3
|
||
# -*- coding: utf-8 -*-
|
||
'''
|
||
cron: 11 11 10 11 * jd_fcwb.py
|
||
new Env('发财挖宝');
|
||
活动入口: 京东极速版 > 我的 > 发财挖宝
|
||
最高可得总和为10元的微信零钱和红包
|
||
脚本功能为: 挖宝，提现，没有助力功能，当血量剩余 1 时停止挖宝，领取奖励并提现
|
||
|
||
目前需要完成逛一逛任务并且下单任务才能通关，不做的话大概可得1.5～2块的微信零钱
|
||
'''
|
||
import os,json,random,time,re,string,functools,asyncio
|
||
import sys
|
||
sys.path.append('../../tmp')
|
||
print('\n运行本脚本之前请手动进入游戏点击一个方块\n')
|
||
print('\n挖的如果都是0.01红包就是黑了，别挣扎了！\n')
|
||
print('\n默认关闭自动领取奖励，开启请在主函数最后调用的函数前面删除#号注释即可\n')
|
||
try:
|
||
import requests
|
||
except Exception as e:
|
||
print(str(e) + "\n缺少requests模块, 请执行命令：pip3 install requests\n")
|
||
requests.packages.urllib3.disable_warnings()
|
||
|
||
|
||
linkId="pTTvJeSTrpthgk9ASBVGsw"
|
||
|
||
|
||
# 获取pin
|
||
cookie_findall=re.compile(r'pt_pin=(.+?);')
|
||
def get_pin(cookie):
|
||
try:
|
||
return cookie_findall.findall(cookie)[0]
|
||
except:
|
||
print('ck格式不正确，请检查')
|
||
|
||
# 读取环境变量
|
||
def get_env(env):
|
||
try:
|
||
if env in os.environ:
|
||
a=os.environ[env]
|
||
elif '/ql' in os.path.abspath(os.path.dirname(__file__)):
|
||
try:
|
||
a=v4_env(env,'/ql/config/config.sh')
|
||
except:
|
||
a=eval(env)
|
||
elif '/jd' in os.path.abspath(os.path.dirname(__file__)):
|
||
try:
|
||
a=v4_env(env,'/jd/config/config.sh')
|
||
except:
|
||
a=eval(env)
|
||
else:
|
||
a=eval(env)
|
||
except:
|
||
a=''
|
||
return a
|
||
|
||
# v4
|
||
def v4_env(env,paths):
|
||
b=re.compile(r'(?:export )?'+env+r' ?= ?[\"\'](.*?)[\"\']', re.I)
|
||
with open(paths, 'r') as f:
|
||
for line in f.readlines():
|
||
try:
|
||
c=b.match(line).group(1)
|
||
break
|
||
except:
|
||
pass
|
||
return c
|
||
|
||
|
||
# 随机ua
|
||
def ua():
|
||
sys.path.append(os.path.abspath('.'))
|
||
try:
|
||
from jdEnv import USER_AGENTS as a
|
||
except:
|
||
a = 'jdltapp;iPhone;3.8.18;;;M/5.0;hasUPPay/0;pushNoticeIsOpen/0;lang/zh_CN;hasOCPay/0;appBuild/1157;supportBestPay/0;jdSupportDarkMode/0;ef/1;ep/%7B%22ciphertype%22%3A5%2C%22cipher%22%3A%7B%22ud%22%3A%22D2PtYzKmY2S5ENY0ZJqmDNTrDtrtZtrsCWPuDtSzY2DvYzq3Y2GzDm%3D%3D%22%2C%22sv%22%3A%22CJCkDm%3D%3D%22%2C%22iad%22%3A%22%22%7D%2C%22ts%22%3A1660017794%2C%22hdid%22%3A%22TQXsGHnakmmgYnwstgBuo1lumKk2DznsrnZM56ldiQM%22%2C%22version%22%3A%221.0.3%22%2C%22appname%22%3A%22com.jd.jdmobilelite%22%2C%22ridx%22%3A1%7D;Mozilla/5.0 (iPhone; CPU iPhone OS 13_7 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1;'
|
||
return a
|
||
|
||
# 13位时间戳
|
||
def gettimestamp():
|
||
return str(int(time.time() * 1000))
|
||
|
||
## 获取cooie
|
||
class Judge_env(object):
|
||
def main_run(self):
|
||
if '/jd' in os.path.abspath(os.path.dirname(__file__)):
|
||
cookie_list=self.v4_cookie()
|
||
else:
|
||
cookie_list=os.environ["JD_COOKIE"].split('&') # 获取cookie_list的合集
|
||
if len(cookie_list)<1:
|
||
print('请填写环境变量JD_COOKIE\n')
|
||
return cookie_list
|
||
|
||
def v4_cookie(self):
|
||
a=[]
|
||
b=re.compile(r'Cookie'+'.*?=\"(.*?)\"', re.I)
|
||
with open('/jd/config/config.sh', 'r') as f:
|
||
for line in f.readlines():
|
||
try:
|
||
regular=b.match(line).group(1)
|
||
a.append(regular)
|
||
except:
|
||
pass
|
||
return a
|
||
|
||
|
||
cookie_list = Judge_env().main_run()
|
||
async def taskGetUrl(functionId, body, cookie):
|
||
url = f'https://api.m.jd.com/?functionId={functionId}&body={json.dumps(body)}&t={gettimestamp()}&appid=activities_platform&client=H5&clientVersion=1.0.0'
|
||
headers = {
|
||
'Cookie': cookie,
|
||
'Host': 'api.m.jd.com',
|
||
'Connection': 'keep-alive',
|
||
'origin': 'https://bnzf.jd.com',
|
||
'Content-Type': 'application/x-www-form-urlencoded',
|
||
'accept': 'application/json, text/plain, */*',
|
||
"User-Agent": ua(),
|
||
'Accept-Language': 'zh-cn',
|
||
'Accept-Encoding': 'gzip, deflate, br',
|
||
}
|
||
for n in range(5):
|
||
time.sleep(1)
|
||
try:
|
||
res = requests.get(url, headers=headers, timeout=30).json()
|
||
return res
|
||
except Exception as e:
|
||
# errorMsg = f"❌ 第{e.__traceback__.tb_lineno}行：{e}"
|
||
# print(errorMsg)
|
||
if n == 4:
|
||
print('API请求失败，请检查网路重试❗\n')
|
||
|
||
|
||
# 剩余血量
|
||
async def xueliang(cookie):
|
||
body = {"linkId": linkId}
|
||
res = await taskGetUrl("happyDigHome", body, cookie)
|
||
if not res:
|
||
return
|
||
if res['code'] == 0:
|
||
if res['success']:
|
||
curRound = res['data']['curRound'] # 未知
|
||
blood = res['data']['blood'] # 剩余血量
|
||
return blood
|
||
|
||
|
||
async def jinge(cookie, i):
|
||
body = {"linkId": linkId}
|
||
res = await taskGetUrl("happyDigHome", body, cookie)
|
||
if not res:
|
||
return
|
||
if res['code'] == 0:
|
||
if res['success']:
|
||
curRound = res['data']['curRound'] # 未知
|
||
blood = res['data']['blood'] # 剩余血量
|
||
roundList = res['data']['roundList'] # 3个总池子
|
||
roundList_n = roundList[0]
|
||
redAmount = roundList_n['redAmount'] # 当前池已得京东红包
|
||
cashAmount = roundList_n['cashAmount'] # 当前池已得微信红包
|
||
|
||
return [blood, redAmount, cashAmount]
|
||
|
||
# 页面数据
|
||
async def happyDigHome(cookie):
|
||
body = {"linkId": linkId}
|
||
res = await taskGetUrl("happyDigHome", body, cookie)
|
||
exit_flag = "false"
|
||
if not res:
|
||
return
|
||
if res['code'] == 0:
|
||
if res['success']:
|
||
curRound = res['data']['curRound'] # 未知
|
||
incep_blood = res['data']['blood'] # 剩余血量
|
||
roundList = res['data']['roundList'] # 3个总池子
|
||
for e, roundList_n in enumerate(roundList): # 迭代每个池子
|
||
roundid = roundList_n['round'] # 池序号
|
||
state = roundList_n['state']
|
||
# 池规模，rows*rows
|
||
rows = roundList_n['rows']
|
||
# 当前池已得京东红包
|
||
redAmount = roundList_n['redAmount']
|
||
# 当前池已得微信红包
|
||
cashAmount = roundList_n['cashAmount']
|
||
leftAmount = roundList_n['leftAmount'] # 剩余红包？
|
||
# 当前池详情list
|
||
chunks = roundList_n['chunks']
|
||
a = await jinge(cookie, roundid)
|
||
if roundid == 1:
|
||
print(f'\n开始进行 "入门" 难度关卡，剩余血量 {a[0]}🩸\n')
|
||
elif roundid == 2:
|
||
print(f'\n开始进行 "挑战" 难度关卡，剩余血量 {a[0]}🩸\n')
|
||
elif roundid == 3:
|
||
print(f'\n开始进行 "终极" 难度关卡，剩余血量 {a[0]}🩸\n')
|
||
## print(f'当前池已得京东红包 {a[2]}\n当前池已得微信红包 {a[1]}\n')
|
||
_blood = await xueliang(cookie)
|
||
if _blood > 1:
|
||
# await happyDigDo(cookie, roundid, 0, 0)
|
||
if e == 0 or e == 1:
|
||
roundid_n = 4
|
||
else:
|
||
roundid_n = 5
|
||
for n in range(roundid_n):
|
||
for i in range(roundid_n):
|
||
_blood = await xueliang(cookie)
|
||
if _blood > 1:
|
||
## print(f'当前血量为 {_blood}')
|
||
await happyDigDo(cookie, roundid, n, i)
|
||
else:
|
||
a = await jinge(cookie, roundid)
|
||
print(f'没血了，溜了溜了\n')
|
||
exit_flag = "true"
|
||
## print(f'当前池已得京东红包 {a[2]}\n当前池已得微信红包 {a[1]}\n')
|
||
break
|
||
|
||
if exit_flag == "true":
|
||
break
|
||
if exit_flag == "true":
|
||
break
|
||
else:
|
||
print(f'获取数据失败\n{res}\n')
|
||
else:
|
||
print(f'获取数据失败\n{res}\n')
|
||
|
||
|
||
# 玩一玩
|
||
async def apDoTask(cookie):
|
||
print('开始做玩一玩任务')
|
||
body={"linkId":linkId,"taskType":"BROWSE_CHANNEL","taskId":962,"channel":4,"itemId":"https%3A%2F%2Fwqs.jd.com%2Fsns%2F202210%2F20%2Fmake-money-shop%2Findex.html%3FactiveId%3D63526d8f5fe613a6adb48f03","checkVersion":False}
|
||
res = await taskGetUrl('apDoTask', body, cookie)
|
||
if not res:
|
||
return
|
||
try:
|
||
if res['success']:
|
||
print('玩好了')
|
||
else:
|
||
print(f"{res['errMsg']}")
|
||
except:
|
||
print(f"错误\n{res}")
|
||
|
||
|
||
# 挖宝
|
||
async def happyDigDo(cookie, roundid, rowIdx, colIdx):
|
||
body = {"round": roundid, "rowIdx": rowIdx,
|
||
"colIdx": colIdx, "linkId": linkId}
|
||
res = await taskGetUrl("happyDigDo", body, cookie)
|
||
|
||
a = rowIdx + 1
|
||
b = colIdx + 1
|
||
coordinateText = f"坐标({a},{b}) ➜ "
|
||
if not res:
|
||
return
|
||
if res['code'] == 0:
|
||
if res['success']:
|
||
typeid = res['data']['chunk']['type']
|
||
if typeid == 2:
|
||
print(coordinateText + f"🧧 {res['data']['chunk']['value']}元极速版红包")
|
||
elif typeid == 3:
|
||
print(coordinateText + f"💰 {res['data']['chunk']['value']}元微信现金")
|
||
elif typeid == 4:
|
||
print(coordinateText + f"💣 炸弹")
|
||
elif typeid == 1:
|
||
print(coordinateText + f"🎟️ 优惠券")
|
||
else:
|
||
print(f'未知内容')
|
||
else:
|
||
print(coordinateText + f'挖宝失败（{res["errCode"]}）')
|
||
else:
|
||
print(coordinateText + f'挖宝失败（{res["errMsg"]}）')
|
||
|
||
|
||
# 领取奖励
|
||
async def happyDigExchange(cookie):
|
||
for n in range(1, 4):
|
||
await xueliang(cookie)
|
||
# print(f"\n开始领取第{n}场的奖励")
|
||
body = {"round": n, "linkId": linkId}
|
||
res = await taskGetUrl("happyDigExchange", body, cookie)
|
||
if not res:
|
||
return
|
||
# if res['code'] == 0:
|
||
# if res['success']:
|
||
# try:
|
||
# print(f"已领取极速版红包 {res['data']['redValue']} 🧧")
|
||
# except:
|
||
# print('')
|
||
# if res['data']['wxValue'] != "0":
|
||
# try:
|
||
# print(f"待提现微信现金 {res['data']['wxValue']} 💰")
|
||
# except:
|
||
# pass
|
||
# else:
|
||
# print(res['errMsg'])
|
||
|
||
|
||
# 微信现金id
|
||
async def spring_reward_list(cookie):
|
||
await happyDigExchange(cookie)
|
||
await xueliang(cookie)
|
||
|
||
body = {"linkId": linkId, "pageNum": 1, "pageSize": 6}
|
||
res = await taskGetUrl("spring_reward_list", body, cookie)
|
||
|
||
if res['code'] == 0:
|
||
if res['success']:
|
||
items = res['data']['items']
|
||
for _items in items:
|
||
amount = _items['amount'] # 金额
|
||
prizeDesc = _items['prizeDesc'] # 奖品描述
|
||
prizeType = _items['prizeType'] # 奖品类型（1券，2红包，4微信零钱）
|
||
amountid = _items['id'] # 金额id
|
||
poolBaseId = _items['poolBaseId']
|
||
prizeGroupId = _items['prizeGroupId']
|
||
prizeBaseId = _items['prizeBaseId']
|
||
if prizeType == 4:
|
||
print(f'开始提现 {amount} 微信现金💰')
|
||
for n in range(1, 3):
|
||
result = await WeChat(cookie, amountid, poolBaseId, prizeGroupId, prizeBaseId)
|
||
time.sleep(10) ## 上一比金额提现完才可以提现下一笔
|
||
if (result): break
|
||
else:
|
||
continue
|
||
else:
|
||
print(f'获取数据失败\n{res}\n')
|
||
else:
|
||
print(f'获取数据失败\n{res}\n')
|
||
|
||
# 微信提现
|
||
|
||
|
||
async def WeChat(cookie, amountid, poolBaseId, prizeGroupId, prizeBaseId):
|
||
await xueliang(cookie)
|
||
|
||
url = 'https://api.m.jd.com'
|
||
headers = {
|
||
'Cookie': cookie,
|
||
'Host': 'api.m.jd.com',
|
||
'Connection': 'keep-alive',
|
||
'origin': 'https://bnzf.jd.com',
|
||
'Content-Type': 'application/x-www-form-urlencoded',
|
||
"User-Agent": ua(),
|
||
'Accept-Language': 'zh-cn',
|
||
'Accept-Encoding': 'gzip, deflate, br',
|
||
}
|
||
body = {"businessSource": "happyDiggerH5Cash", "base": {"id": amountid, "business": "happyDigger", "poolBaseId": poolBaseId, "prizeGroupId": prizeGroupId, "prizeBaseId": prizeBaseId, "prizeType": 4}, "linkId": linkId}
|
||
data = f"functionId=apCashWithDraw&body={json.dumps(body)}&t={gettimestamp()}&appid=activities_platform&client=H5&clientVersion=1.0.0"
|
||
for n in range(3):
|
||
try:
|
||
res = requests.post(url, headers=headers, data=data, timeout=30).json()
|
||
break
|
||
except:
|
||
if n == 2:
|
||
print('API请求失败，请检查网路重试❗\n')
|
||
try:
|
||
if res['code'] == 0:
|
||
if res['success']:
|
||
print(res['data']['message']+'')
|
||
return True
|
||
except:
|
||
print(res)
|
||
return False
|
||
|
||
|
||
async def main():
|
||
print('🔔发财挖宝 - 挖宝，开始！\n')
|
||
|
||
# print('获取助力码\n')
|
||
# global inviteCode_1_list,inviteCode_2_list
|
||
# inviteCode_1_list=list()
|
||
# inviteCode_2_list=list()
|
||
# for cookie in cookie_list:
|
||
# inviteCode(cookie)
|
||
|
||
# print('互助\n')
|
||
# inviteCode_2_list=inviteCode_2_list[:2]
|
||
# for e,fcwbinviter in enumerate(inviteCode_2_list):
|
||
# fcwbinviteCode=inviteCode_1_list[e]
|
||
# for cookie in cookie_list:
|
||
# happyDigHelp(cookie,fcwbinviter,fcwbinviteCode)
|
||
|
||
print(f'================= 共{len(cookie_list)}个京东账号Cookie =================\n')
|
||
|
||
for e, cookie in enumerate(cookie_list, start=1):
|
||
print(f'******开始【京东账号{e}】{get_pin(cookie)}******\n')
|
||
await apDoTask(cookie)
|
||
await happyDigHome(cookie)
|
||
#await spring_reward_list(cookie)
|
||
|
||
|
||
if __name__ == '__main__':
|
||
asyncio.run(main())
|