mirror of
https://github.com/okyyds/yyds.git
synced 2026-07-13 09:01:16 +08:00
first commit
This commit is contained in:
YYDS
310
backUp/jd_15.py
Normal file
310
backUp/jd_15.py
Normal file
@@ -0,0 +1,310 @@
|
||||
#!/bin/env python3
|
||||
# -*- coding: utf-8 -*
|
||||
|
||||
'''
|
||||
cron: 0 59 23 * * 0 jd_15.py
|
||||
new Env('Faker群友家电15周年助力');
|
||||
'''
|
||||
|
||||
# cron
|
||||
#不做浏览，只做助力 建议先运行jd_appliances.js 在运行此脚本
|
||||
# export jd15_pins=["pt_pin1","pt_pin2"]
|
||||
|
||||
from urllib.parse import unquote, quote
|
||||
import time, datetime, os, sys
|
||||
import requests, json, re, random
|
||||
import threading
|
||||
|
||||
UserAgent = ''
|
||||
script_name = '家电15周年助力'
|
||||
|
||||
|
||||
def printT(msg):
|
||||
print("[{}]: {}".format(datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S"), msg))
|
||||
sys.stdout.flush()
|
||||
|
||||
|
||||
def delEnvs(label):
|
||||
try:
|
||||
if label == 'True' or label == 'yes' or label == 'true' or label == 'Yes':
|
||||
return True
|
||||
elif label == 'False' or label == 'no' or label == 'false' or label == 'No':
|
||||
return False
|
||||
except:
|
||||
pass
|
||||
try:
|
||||
if '.' in label:
|
||||
return float(label)
|
||||
elif '&' in label:
|
||||
return label.split('&')
|
||||
elif '@' in label:
|
||||
return label.split('@')
|
||||
else:
|
||||
return int(label)
|
||||
except:
|
||||
return label
|
||||
|
||||
|
||||
class getJDCookie():
|
||||
# 适配青龙平台环境ck
|
||||
def getckfile(self):
|
||||
ql_new = '/ql/config/env.sh'
|
||||
ql_old = '/ql/config/cookie.sh'
|
||||
if os.path.exists(ql_new):
|
||||
printT("当前环境青龙面板新版")
|
||||
return ql_new
|
||||
elif os.path.exists(ql_old):
|
||||
printT("当前环境青龙面板旧版")
|
||||
return ql_old
|
||||
|
||||
# 获取cookie
|
||||
def getallCookie(self):
|
||||
cookies = ''
|
||||
ckfile = self.getckfile()
|
||||
try:
|
||||
if os.path.exists(ckfile):
|
||||
with open(ckfile, "r", encoding="utf-8") as f:
|
||||
cks_text = f.read()
|
||||
if 'pt_key=' in cks_text and 'pt_pin=' in cks_text:
|
||||
r = re.compile(r"pt_key=.*?pt_pin=.*?;", re.M | re.S | re.I)
|
||||
cks_list = r.findall(cks_text)
|
||||
if len(cks_list) > 0:
|
||||
for ck in cks_list:
|
||||
cookies += ck
|
||||
return cookies
|
||||
except Exception as e:
|
||||
printT(f"【getCookie Error】{e}")
|
||||
|
||||
# 检测cookie格式是否正确
|
||||
def getUserInfo(self, ck, user_order, pinName):
|
||||
url = 'https://me-api.jd.com/user_new/info/GetJDUserInfoUnion?orgFlag=JD_PinGou_New&callSource=mainorder&channel=4&isHomewhite=0&sceneval=2&sceneval=2&callback='
|
||||
headers = {
|
||||
'Cookie': ck,
|
||||
'Accept': '*/*',
|
||||
'Connection': 'close',
|
||||
'Referer': 'https://home.m.jd.com/myJd/home.action',
|
||||
'Accept-Encoding': 'gzip, deflate, br',
|
||||
'Host': 'me-api.jd.com',
|
||||
'User-Agent': 'Mozilla/5.0 (iPhone; CPU iPhone OS 14_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/14.0.2 Mobile/15E148 Safari/604.1',
|
||||
'Accept-Language': 'zh-cn'
|
||||
}
|
||||
try:
|
||||
resp = requests.get(url=url, headers=headers, timeout=60).json()
|
||||
if resp['retcode'] == "0":
|
||||
nickname = resp['data']['userInfo']['baseInfo']['nickname']
|
||||
return ck, nickname
|
||||
else:
|
||||
context = f"账号{user_order}【{pinName}】Cookie 已失效！请重新获取。"
|
||||
print(context)
|
||||
return ck, False
|
||||
except Exception:
|
||||
context = f"账号{user_order}【{pinName}】Cookie 已失效！请重新获取。"
|
||||
print(context)
|
||||
return ck, False
|
||||
|
||||
def getcookies(self):
|
||||
"""
|
||||
:return: cookiesList,userNameList,pinNameList
|
||||
"""
|
||||
cookiesList = []
|
||||
pinNameList = []
|
||||
nickNameList = []
|
||||
cookies = self.getallCookie()
|
||||
if 'pt_key=' in cookies and 'pt_pin=' in cookies:
|
||||
r = re.compile(r"pt_key=.*?pt_pin=.*?;", re.M | re.S | re.I)
|
||||
result = r.findall(cookies)
|
||||
if len(result) >= 1:
|
||||
printT("您已配置{}个账号".format(len(result)))
|
||||
user_order = 1
|
||||
for ck in result:
|
||||
r = re.compile(r"pt_pin=(.*?);")
|
||||
pinName = r.findall(ck)
|
||||
pinName = unquote(pinName[0])
|
||||
# 获取账号名
|
||||
ck, nickname = self.getUserInfo(ck, user_order, pinName)
|
||||
if nickname != False:
|
||||
cookiesList.append(ck)
|
||||
pinNameList.append(pinName)
|
||||
nickNameList.append(nickname)
|
||||
user_order += 1
|
||||
else:
|
||||
user_order += 1
|
||||
continue
|
||||
if len(cookiesList) > 0:
|
||||
return cookiesList, pinNameList, nickNameList
|
||||
else:
|
||||
printT("没有可用Cookie，已退出")
|
||||
exit(4)
|
||||
else:
|
||||
printT("没有可用Cookie，已退出")
|
||||
exit(4)
|
||||
|
||||
|
||||
def getPinEnvs():
|
||||
if "jd15_pins" in os.environ:
|
||||
if len(os.environ["jd15_pins"]) != 0:
|
||||
jd15_pins = os.environ["jd15_pins"]
|
||||
jd15_pins = jd15_pins.replace('[', '').replace(']', '').replace('\'', '').replace(' ', '').split(',')
|
||||
printT(f"已获取并使用Env环境 jd15_pins:{jd15_pins}")
|
||||
return jd15_pins
|
||||
else:
|
||||
printT('请先配置export jd15_pins=["pt_pin1","pt_pin2"]')
|
||||
exit(4)
|
||||
printT('请先配置export jd15_pins=["pt_pin1","pt_pin2"]')
|
||||
exit(4)
|
||||
|
||||
|
||||
def res_post(cookie, body):
|
||||
url = "https://api.m.jd.com/api"
|
||||
headers = {
|
||||
"Host": "api.m.jd.com",
|
||||
"content-length": "146",
|
||||
"accept": "application/json, text/plain, */*",
|
||||
"origin": "https://welfare.m.jd.com",
|
||||
"user-agent": "jdapp;android;10.1.0;10;4636532323835366-1683336356836626;network/UNKNOWN;model/MI 8;addressid/4608453733;aid/dc52285fa836e8fb;oaid/a28cc4ac8bda0bf6;osVer/29;appBuild/89568;partner/xiaomi001;eufv/1;jdSupportDarkMode/0;Mozilla/5.0 (Linux; Android 10; MI 8 Build/QKQ1.190828.002; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/77.0.3865.120 MQQBrowser/6.2 TBS/045715 Mobile Safari/537.36",
|
||||
"sec-fetch-mode": "cors",
|
||||
"content-type": "application/x-www-form-urlencoded",
|
||||
"x-requested-with": "com.jingdong.app.mall",
|
||||
"sec-fetch-site": "same-site",
|
||||
"referer": "https://welfare.m.jd.com/",
|
||||
"accept-encoding": "gzip, deflate, br",
|
||||
"accept-language": "zh-CN,zh;q\u003d0.9,en-US;q\u003d0.8,en;q\u003d0.7",
|
||||
"cookie": cookie
|
||||
}
|
||||
body = json.dumps(body)
|
||||
t = str(int(time.time() * 1000))
|
||||
data = {
|
||||
'appid': 'anniversary-celebra',
|
||||
'functionId': 'jd_interaction_prod',
|
||||
'body': body,
|
||||
't': t,
|
||||
'loginType': 2
|
||||
}
|
||||
res = requests.post(url=url, headers=headers, data=data).json()
|
||||
return res
|
||||
|
||||
|
||||
def get_share5(cookie):
|
||||
body = {"type": "99", "apiMapping": "/api/supportTask/getShareId"}
|
||||
res = res_post(cookie, body)
|
||||
# print(res)
|
||||
if '成功' in res['msg']:
|
||||
return res['data']
|
||||
|
||||
|
||||
def get_share50(cookie):
|
||||
body = {"type": "100", "apiMapping": "/api/supportTask/getShareId"}
|
||||
res = res_post(cookie, body)
|
||||
# print(res)
|
||||
|
||||
if '成功' in res['msg']:
|
||||
return res['data']
|
||||
|
||||
|
||||
def getprize1(cookie,nickname):
|
||||
body = {"apiMapping": "/api/prize/getCoupon"}
|
||||
res = res_post(cookie, body)
|
||||
# print(res)
|
||||
if res['code'] == 200:
|
||||
print('------【账号：' + nickname + '】------' + res['data']['name'])
|
||||
else:
|
||||
print('------【账号：' + nickname + '】------优惠券领过了')
|
||||
|
||||
|
||||
def getprize2(cookie,nickname):
|
||||
body = {"apiMapping": "/api/prize/doLottery"}
|
||||
res = res_post(cookie, body)
|
||||
# print(res)
|
||||
if res['code'] == 5011:
|
||||
print('------【账号：' + nickname + '】------未中奖e卡')
|
||||
else:
|
||||
print('------【账号：' + nickname + '】------不确定，手动确认')
|
||||
|
||||
|
||||
def help(mycookie, nickname, cookiesList, nickNameList):
|
||||
shareId5 = get_share5(mycookie)
|
||||
if shareId5 != None:
|
||||
# print('获取5助力码成功：', shareId5)
|
||||
# print('--------------------------------------开始5个助力-------------')
|
||||
body1 = {"shareId": shareId5, "apiMapping": "/api/supportTask/doSupport"}
|
||||
for i in range(len(cookiesList)):
|
||||
res = res_post(cookiesList[i], body1)
|
||||
# print(res)
|
||||
try:
|
||||
if res['code'] == 200 and res['data']['status'] == 7:
|
||||
print(nickNameList[i] + '助力' + nickname + '：' + '5助力成功')
|
||||
elif res['code'] == 200 and res['data']['status'] == 4:
|
||||
print(nickNameList[i]+'助力'+nickname+'：'+'5个助力完成啦----')
|
||||
getprize1(mycookie,nickname)
|
||||
getprize2(mycookie,nickname)
|
||||
break
|
||||
elif res['code'] == 200 and res['data']['status'] == 3:
|
||||
print(nickNameList[i]+'助力'+nickname+'：'+'5已经助力过了')
|
||||
except:
|
||||
pass
|
||||
else:
|
||||
print('【账号：' + nickname + '】请先手动执行下浏览任务')
|
||||
|
||||
shareId50 = get_share50(mycookie)
|
||||
if shareId50 != None:
|
||||
# print('获取50助力码成功：', shareId50)
|
||||
# print('-------------------------------开始50个助力-------------')
|
||||
body2 = {"shareId": shareId50, "apiMapping": "/api/supportTask/doSupport"}
|
||||
for ck in mycookie:
|
||||
res = res_post(ck, body2)
|
||||
# print(res)
|
||||
try:
|
||||
if res['code'] == 200 and res['data']['status'] == 7:
|
||||
print(nickNameList[i] + '助力' + nickname + '：' + '50助力成功')
|
||||
elif res['code'] == 200 and res['data']['status'] == 4:
|
||||
print(nickNameList[i] + '助力' + nickname + '：' + '50个助力完成啦----')
|
||||
getprize1(mycookie, nickname)
|
||||
getprize2(mycookie, nickname)
|
||||
break
|
||||
elif res['code'] == 200 and res['data']['status'] == 3:
|
||||
print(nickNameList[i] + '助力' + nickname + '：' + '50已经助力过了')
|
||||
except:
|
||||
pass
|
||||
else:
|
||||
print('【账号' + nickname + '】请先手动执行下浏览任务')
|
||||
|
||||
|
||||
def use_thread(jd15_cookies, nicks, cookiesList, nickNameList):
|
||||
threads = []
|
||||
for i in range(len(jd15_cookies)):
|
||||
threads.append(
|
||||
threading.Thread(target=help, args=(jd15_cookies[i], nicks[i], cookiesList, nickNameList))
|
||||
)
|
||||
for t in threads:
|
||||
t.start()
|
||||
for t in threads:
|
||||
t.join()
|
||||
|
||||
|
||||
def start():
|
||||
printT("############{}##########".format(script_name))
|
||||
jd15_pins = getPinEnvs()
|
||||
get_jd_cookie = getJDCookie()
|
||||
cookiesList, pinNameList, nickNameList = get_jd_cookie.getcookies()
|
||||
jd15_cookies = []
|
||||
nicks = []
|
||||
for ckname in jd15_pins:
|
||||
try:
|
||||
ckNum = pinNameList.index(ckname)
|
||||
jd15_cookies.append(cookiesList[ckNum])
|
||||
nicks.append(nickNameList[ckNum])
|
||||
except Exception as e:
|
||||
try:
|
||||
ckNum = pinNameList.index(unquote(ckname))
|
||||
jd15_cookies.append(cookiesList[ckNum])
|
||||
nicks.append(nickNameList[ckNum])
|
||||
except:
|
||||
print(f"请检查被助力账号【{ckname}】名称是否正确？ck是否存在？提示：助力名字可填pt_pin的值、也可以填账号名。")
|
||||
continue
|
||||
if len(jd15_cookies) == 0:
|
||||
exit(4)
|
||||
use_thread(jd15_cookies, nicks, cookiesList, nickNameList)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
start()
|
||||
Reference in New Issue
Block a user