yydspure/邀请好友赢大礼.py

333 lines
15 KiB
Python
Raw Blame History

This file contains ambiguous Unicode characters!

This file contains ambiguous Unicode characters that may be confused with others in your current locale. If your use case is intentional and legitimate, you can safely ignore this warning. Use the Escape button to highlight these characters.

# 邀好友赢大礼 create by doubi 通用模板
# 17:/椋东送福利,邀请好友,争排行榜排位,大礼送不停,(E1Y7RAtC4b) ,升级新版猄·=·Dσσōngαpρ
# https://prodev.m.jd.com/mall/active/dVF7gQUVKyUcuSsVhuya5d2XD4F/index.html?code=7cfd02e34d6d41028286d6a95cdeea7e&invitePin=jd_5a2bee883014b
# 注意事项 pin 为助力pin 必须保证ck在里面
# by 逗比 https://t.me/jdsign2
import json
import requests,random,time,asyncio,re,os
from urllib.parse import quote_plus,unquote_plus
from functools import partial
print = partial(print, flush=True)
activatyname = '邀请赢大礼'
activityId = 'dVF7gQUVKyUcuSsVhuya5d2XD4F' # 活动类型
authorCode = '16dde1860f1b4f1b9a93db6612abf0b9' # 活动id
invitePin = '' # pin 填写cookie后面的pin
activityUrl = f'https://prodev.m.jd.com/mall/active/{activityId}/index.html?code={authorCode}&invitePin={invitePin}'
# 随机ua
def randomuserAgent():
global uuid, addressid, iosVer, iosV, clientVersion, iPhone, area, ADID, lng, lat
uuid = ''.join(random.sample(
['a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j', 'k', 'l', 'm', 'n', 'o', 'p', 'q', 'r', 's', 't', 'u', 'v',
'w', 'x', 'y', 'z', '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'z'], 40))
addressid = ''.join(random.sample('1234567898647', 10))
iosVer = ''.join(random.sample(["15.1.1", "14.5.1", "14.4", "14.3", "14.2", "14.1", "14.0.1"], 1))
iosV = iosVer.replace('.', '_')
clientVersion = ''.join(random.sample(["10.3.0", "10.2.7", "10.2.4"], 1))
iPhone = ''.join(random.sample(["8", "9", "10", "11", "12", "13"], 1))
area = ''.join(random.sample('0123456789', 2)) + '_' + ''.join(random.sample('0123456789', 4)) + '_' + ''.join(
random.sample('0123456789', 5)) + '_' + ''.join(random.sample('0123456789', 4))
ADID = ''.join(random.sample('0987654321ABCDEF', 8)) + '-' + ''.join(
random.sample('0987654321ABCDEF', 4)) + '-' + ''.join(random.sample('0987654321ABCDEF', 4)) + '-' + ''.join(
random.sample('0987654321ABCDEF', 4)) + '-' + ''.join(random.sample('0987654321ABCDEF', 12))
lng = '119.31991256596' + str(random.randint(100, 999))
lat = '26.1187118976' + str(random.randint(100, 999))
UserAgent = ''
if not UserAgent:
return f'jdapp;iPhone;10.0.4;{iosVer};{uuid};network/wifi;ADID/{ADID};model/iPhone{iPhone},1;addressid/{addressid};appBuild/167707;jdSupportDarkMode/0;Mozilla/5.0 (iPhone; CPU iPhone OS {iosV} like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/null;supportJDSHWK/1'
else:
return UserAgent
# 检测ck状态
async def check(ua, ck):
try:
url = 'https://me-api.jd.com/user_new/info/GetJDUserInfoUnion'
header = {
"Host": "me-api.jd.com",
"Accept": "*/*",
"Connection": "keep-alive",
"Cookie": ck,
"User-Agent": ua,
"Accept-Language": "zh-cn",
"Referer": "https://home.m.jd.com/myJd/newhome.action?sceneval=2&ufc=&",
"Accept-Encoding": "gzip, deflate",
}
result = requests.get(url=url, headers=header, timeout=2).text
codestate = json.loads(result)
if codestate['retcode'] == '1001':
msg = "当前ck已失效请检查"
return {'code': 1001, 'data': msg}
elif codestate['retcode'] == '0' and 'userInfo' in codestate['data']:
nickName = codestate['data']['userInfo']['baseInfo']['nickname']
return {'code': 200, 'name': nickName, 'ck': ck}
except Exception as e:
return {'code': 0, 'data': e}
# 获取当前时间
def get_time():
time_now = round(time.time()*1000)
return time_now
# 登录plogin
async def plogin(ua,cookie):
now = get_time()
url = f'https://plogin.m.jd.com/cgi-bin/ml/islogin?time={now}&callback=__jsonp{now-2}&_={now+2}'
header = {
'Accept':'*/*',
'Accept-Encoding': 'gzip, deflate, br',
'Accept-Language': 'zh-CN,zh-Hans;q=0.9',
'Connection': 'keep-alive',
'Cookie': cookie,
'Host': 'plogin.m.jd.com',
'Referer': 'https://prodev.m.jd.com/',
'User-Agent':ua
}
response = requests.get(url=url,headers=header,timeout=5).text
return response
# 活动接口
async def jdjoy(ua,cookie):
url = f'https://jdjoy.jd.com/member/bring/getActivityPage?code={authorCode}&invitePin={invitePin}&_t={get_time()}'
header = {
'Accept':'*/*',
'Accept-Encoding':'gzip, deflate',
'Accept-Language':'zh-Hans-US;q=1,en-US;q=0.9',
'Connection':'keep-alive',
'Content-Type':'application/json',
'Cookie':cookie,
"Host":'jdjoy.jd.com',
'Origin':'https://prodev.m.jd.com',
"Referer":'https://prodev.m.jd.com/',
'User-Agent':ua
}
response = requests.get(url=url,headers=header).text
return json.loads(response)
# go开卡
async def ruhui(ua,cookie):
url = f'https://jdjoy.jd.com/member/bring/joinMember?code={authorCode}&invitePin={invitePin}'
header = {
'Host': 'jdjoy.jd.com',
'Content-Type': 'application/json',
'Origin': 'https://prodev.m.jd.com',
'Accept-Encoding': 'gzip, deflate, br',
'Cookie': cookie,
'Connection': 'keep-alive',
'Accept': '*/*',
'User-Agent': ua,
'Referer': activityUrl,
'Accept-Language': 'zh-cn',
'request-from': 'native'
}
response = requests.get(url=url,headers=header).text
return json.loads(response)
# 检查开卡状态
async def check_ruhui(body,cookie,venderId,ua):
url = f'https://api.m.jd.com/client.action?appid=jd_shop_member&functionId=getShopOpenCardInfo&body={json.dumps(body)}&client=H5&clientVersion=9.2.0&uuid=88888'
headers = {
'Host': 'api.m.jd.com',
'Accept': '*/*',
'Connection': 'keep-alive',
'Cookie': cookie,
'User-Agent': ua,
'Accept-Language': 'zh-cn',
'Referer': f'https://shopmember.m.jd.com/shopcard/?venderId={venderId}&channel=801&returnUrl={json.dumps(activityUrl)}',
'Accept-Encoding': 'gzip, deflate'
}
response = requests.get(url=url,headers=headers,timeout=5).text
return json.loads(response)
# 领取奖励
async def getInviteReward(cookie,ua,number):
url = f'https://jdjoy.jd.com/member/bring/getInviteReward?code={authorCode}&stage={number}'
header = {
'Accept':'*/*',
'Accept-Encoding':'gzip, deflate',
'Accept-Language':'zh-Hans-US;q=1,en-US;q=0.9',
'Connection':'keep-alive',
'Content-Type':'application/json',
'Cookie':cookie,
"Host":'jdjoy.jd.com',
'Origin':'https://prodev.m.jd.com',
"Referer":'https://prodev.m.jd.com/',
'User-Agent':ua
}
response = requests.get(url=url,headers=header).text
return json.loads(response)
# 开启活动
async def firstInvite(cookie,ua):
url = f'https://jdjoy.jd.com/member/bring/firstInvite?code={authorCode}'
header = {
'Accept':'text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8',
'Accept-Encoding':'gzip, deflate',
'Accept-Language':'zh-Hans-US;q=1,en-US;q=0.9',
'Connection':'keep-alive',
'Cookie':cookie,
"Host":'jdjoy.jd.com',
'User-Agent':ua
}
response = requests.get(url=url,headers=header).text
print(response)
return json.loads(response)
async def get_ck(data):
cklist = []
if data['code']!=200:
return {'code': 0, 'data':data}
else:
env_data = data['data']
for ck in env_data:
if 'remarks' in ck and ck['name']=='JD_COOKIE':
cklist.append(ck['value'])
else:
pass
return cklist
# 检查pin
def checkpin(cks:list,pin):
for ck in cks:
if pin in ck:
return ck
else:
None
# 主程序
async def main():
try:
cks = os.environ["JD_COOKIE"].split("&")
except:
with open('cklist1.txt','r') as f:
cks = f.read().split('\n')
success = 0 # 计算成功数
inveteck = checkpin(cks,invitePin) # 根据设定的pin返回对应ck
needinviteNum = [] # 需要助力次数
needdel = []
need = []
if inveteck:
print(f'🔔{activatyname}', flush=True)
print(f'==================共{len(cks)}个京东账号Cookie==================')
print(f'==================脚本执行- 北京时间(UTC+8){get_time()}=====================\n')
print(f'您好!{invitePin},正在获取您的活动信息',)
ua = randomuserAgent() # 获取ua
result = await check(ua, inveteck) # 检测ck
if result['code'] == 200:
await plogin(ua,inveteck) # 获取登录状态
await asyncio.sleep(2)
result = await jdjoy(ua,inveteck) # 获取活动信息
await firstInvite(inveteck,ua) # 开启活动
if result['success']:
brandName = result['data']['brandName'] # 店铺名字
venderId = result['data']['venderId'] # 店铺入会id
rewardslist =[] # 奖品
successCount = result['data']['successCount'] # 当前成功数
success += successCount
result_data = result['data']['rewards'] # 奖品数据
print(f'您好!账号[{invitePin}],开启{brandName}邀请好友活动\n去开活动')
for i in result_data:
stage = i['stage']
inviteNum = i['inviteNum'] # 单次需要拉新人数
need.append(inviteNum)
rewardName = i['rewardName'] # 奖品名
rewardNum = i['rewardStock']
if rewardNum !=0:
needinviteNum.append(inviteNum)
needdel.append(inviteNum)
rewardslist.append(f'级别{stage}: 需助力{inviteNum}人,奖品: {rewardName},库存:{rewardNum}\n')
if len(rewardslist)!=0:
print('当前活动奖品如下: \n'+str('\n'.join(rewardslist))+f'\n当前已助力{successCount}\n')
for nmubers in needdel:
if success >= nmubers:
print("您当前助力已经满足了,可以去领奖励了")
print(f'\n这就去领取奖励{need.index(nmubers)+1}')
result = await getInviteReward(inveteck,ua,need.index(nmubers)+1)
print(result)
needinviteNum.remove(nmubers)
await asyncio.sleep(10)
needdel = needinviteNum
if needinviteNum == []:
print('奖励已经全部获取啦,退出程序')
return
for n,ck in enumerate(cks,1):
ua = randomuserAgent() # 获取ua
try:
pin = re.findall(r'(pt_pin=([^; ]+)(?=;))',str(ck))[0]
pin = (unquote_plus(pin[1]))
except IndexError:
pin = f'用户{n}'
print(f'******开始【京东账号{n}{pin} *********\n')
for n,nmubers in enumerate(needinviteNum,1):
for nmubers in needdel:
if success >= nmubers:
print(nmubers)
print("您当前助力已经满足了,可以去领奖励了")
print(f'\n这就去领取奖励{need.index(nmubers)+1}')
result = await getInviteReward(inveteck,ua,need.index(nmubers)+1)
print(result)
needinviteNum.remove(nmubers)
await asyncio.sleep(10)
needdel = needinviteNum
if needinviteNum == []:
print('奖励已经全部获取啦,退出程序')
return
await plogin(ua,ck) # 获取登录状态
result = await check(ua, ck) # 检测ck
if result['code'] == 200:
result = await jdjoy(ua,ck) # 调用ck
if result['success']:
print(f'账户[{pin}]已开启{brandName}邀请好友活动\n')
await asyncio.sleep(3)
result= await check_ruhui({"venderId":str(venderId), "channel": "401" },ck,venderId,ua) # 检查入会状态
try:
if result['result']['userInfo']['openCardStatus']==0: # 0 未开卡
await asyncio.sleep(2)
print(f'您还不是会员哦,这就去去助力{invitePin}\n')
result = await ruhui(ua,ck)
if result['success']:
success +=1
print(f'助力成功! 当前成功助力{success}\n')
if '交易失败' in str(result):
success +=1
print(f'助力成功! 当前成功助力{success}\n')
else:
print(result)
await asyncio.sleep(2)
else:
print('您已经是会员啦,不去请求了入会了\n')
continue
except TypeError as e:
print(e)
result = await ruhui(ua,ck)
if result['success']:
success +=1
print(f'助力成功! 当前成功助力{success}\n')
if '交易失败' in result:
success +=1
print(f'助力成功! 当前成功助力{success}\n')
else:
print(result['errorMessage'])
await asyncio.sleep(2)
else: # 没有获取到活动信息
print('未获取到活动参数信息\n')
break
else:
print(result['data'])
continue
else:
print('未能获取到活动信息\n')
return
else:
print(result['data'])
return
else:
print(f'pin填写有误请重试')
if __name__ == "__main__":
asyncio.run(main())