mirror of
https://github.com/6dylan6/jdpro.git
synced 2026-05-06 05:16:15 +08:00
Compare commits
6 Commits
7a5452906c
...
6d4c3e5bba
| Author | SHA1 | Date | |
|---|---|---|---|
 dylan
|
6d4c3e5bba | ||
|
dylan
|
b21e1e39e7 | ||
|
dylan
|
06dd221784 | ||
|
dylan
|
bcd2e60558 | ||
|
dylan
|
5b0842125b | ||
|
dylan
|
7ccc83b20d |
@@ -1,399 +0,0 @@
|
||||
import axios from "axios"
|
||||
import {Md5} from "ts-md5"
|
||||
import * as dotenv from "dotenv"
|
||||
import {existsSync, readFileSync} from "fs"
|
||||
import {sendNotify} from './sendNotify'
|
||||
|
||||
dotenv.config()
|
||||
|
||||
let fingerprint: string | number, token: string = '', enCryptMethodJD: any
|
||||
|
||||
const USER_AGENTS: Array<string> = [
|
||||
"jdapp;android;10.0.2;10;network/wifi;Mozilla/5.0 (Linux; Android 10; ONEPLUS A5010 Build/QKQ1.191014.012; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/77.0.3865.120 MQQBrowser/6.2 TBS/045230 Mobile Safari/537.36",
|
||||
"jdapp;iPhone;10.0.2;14.3;network/4g;Mozilla/5.0 (iPhone; CPU iPhone OS 14_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;android;10.0.2;9;network/4g;Mozilla/5.0 (Linux; Android 9; Mi Note 3 Build/PKQ1.181007.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/66.0.3359.126 MQQBrowser/6.2 TBS/045131 Mobile Safari/537.36",
|
||||
"jdapp;android;10.0.2;10;network/wifi;Mozilla/5.0 (Linux; Android 10; GM1910 Build/QKQ1.190716.003; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/77.0.3865.120 MQQBrowser/6.2 TBS/045230 Mobile Safari/537.36",
|
||||
"jdapp;android;10.0.2;9;network/wifi;Mozilla/5.0 (Linux; Android 9; 16T Build/PKQ1.190616.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/66.0.3359.126 MQQBrowser/6.2 TBS/044942 Mobile Safari/537.36",
|
||||
"jdapp;iPhone;10.0.2;13.6;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 13_6 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;iPhone;10.0.2;13.6;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 13_6 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;iPhone;10.0.2;13.5;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 13_5 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;iPhone;10.0.2;14.1;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 14_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;iPhone;10.0.2;13.3;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 13_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;iPhone;10.0.2;13.7;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 13_7 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;iPhone;10.0.2;14.1;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 14_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;iPhone;10.0.2;13.3;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 13_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;iPhone;10.0.2;13.4;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 13_4 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;iPhone;10.0.2;14.3;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 14_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;android;10.0.2;9;network/wifi;Mozilla/5.0 (Linux; Android 9; MI 6 Build/PKQ1.190118.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/66.0.3359.126 MQQBrowser/6.2 TBS/044942 Mobile Safari/537.36",
|
||||
"jdapp;android;10.0.2;11;network/wifi;Mozilla/5.0 (Linux; Android 11; Redmi K30 5G Build/RKQ1.200826.002; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/77.0.3865.120 MQQBrowser/6.2 TBS/045511 Mobile Safari/537.36",
|
||||
"jdapp;iPhone;10.0.2;11.4;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 11_4 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15F79",
|
||||
"jdapp;android;10.0.2;10;;network/wifi;Mozilla/5.0 (Linux; Android 10; M2006J10C Build/QP1A.190711.020; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/77.0.3865.120 MQQBrowser/6.2 TBS/045230 Mobile Safari/537.36",
|
||||
"jdapp;android;10.0.2;10;network/wifi;Mozilla/5.0 (Linux; Android 10; M2006J10C Build/QP1A.190711.020; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/77.0.3865.120 MQQBrowser/6.2 TBS/045230 Mobile Safari/537.36",
|
||||
"jdapp;android;10.0.2;10;network/wifi;Mozilla/5.0 (Linux; Android 10; ONEPLUS A6000 Build/QKQ1.190716.003; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/77.0.3865.120 MQQBrowser/6.2 TBS/045224 Mobile Safari/537.36",
|
||||
"jdapp;android;10.0.2;9;network/wifi;Mozilla/5.0 (Linux; Android 9; MHA-AL00 Build/HUAWEIMHA-AL00; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/66.0.3359.126 MQQBrowser/6.2 TBS/044942 Mobile Safari/537.36",
|
||||
"jdapp;android;10.0.2;8.1.0;network/wifi;Mozilla/5.0 (Linux; Android 8.1.0; 16 X Build/OPM1.171019.026; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/66.0.3359.126 MQQBrowser/6.2 TBS/044942 Mobile Safari/537.36",
|
||||
"jdapp;android;10.0.2;8.0.0;network/wifi;Mozilla/5.0 (Linux; Android 8.0.0; HTC U-3w Build/OPR6.170623.013; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/66.0.3359.126 MQQBrowser/6.2 TBS/044942 Mobile Safari/537.36",
|
||||
"jdapp;iPhone;10.0.2;14.0.1;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 14_0_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;android;10.0.2;10;network/wifi;Mozilla/5.0 (Linux; Android 10; LYA-AL00 Build/HUAWEILYA-AL00L; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/77.0.3865.120 MQQBrowser/6.2 TBS/045230 Mobile Safari/537.36",
|
||||
"jdapp;iPhone;10.0.2;14.2;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 14_2 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;iPhone;10.0.2;14.3;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 14_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;iPhone;10.0.2;14.2;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 14_2 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;android;10.0.2;8.1.0;network/wifi;Mozilla/5.0 (Linux; Android 8.1.0; MI 8 Build/OPM1.171019.026; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/66.0.3359.126 MQQBrowser/6.2 TBS/045131 Mobile Safari/537.36",
|
||||
"jdapp;android;10.0.2;10;network/wifi;Mozilla/5.0 (Linux; Android 10; Redmi K20 Pro Premium Edition Build/QKQ1.190825.002; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/77.0.3865.120 MQQBrowser/6.2 TBS/045227 Mobile Safari/537.36",
|
||||
"jdapp;iPhone;10.0.2;14.3;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 14_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;iPhone;10.0.2;14.3;network/4g;Mozilla/5.0 (iPhone; CPU iPhone OS 14_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
"jdapp;android;10.0.2;11;network/wifi;Mozilla/5.0 (Linux; Android 11; Redmi K20 Pro Premium Edition Build/RKQ1.200826.002; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/77.0.3865.120 MQQBrowser/6.2 TBS/045513 Mobile Safari/537.36",
|
||||
"jdapp;android;10.0.2;10;network/wifi;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/045227 Mobile Safari/537.36",
|
||||
"jdapp;iPhone;10.0.2;14.1;network/wifi;Mozilla/5.0 (iPhone; CPU iPhone OS 14_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1",
|
||||
]
|
||||
|
||||
function TotalBean(cookie: string) {
|
||||
return {
|
||||
cookie: cookie,
|
||||
isLogin: true,
|
||||
nickName: ''
|
||||
}
|
||||
}
|
||||
|
||||
function getRandomNumberByRange(start: number, end: number) {
|
||||
end <= start && (end = start + 100)
|
||||
return Math.floor(Math.random() * (end - start) + start)
|
||||
}
|
||||
|
||||
let USER_AGENT = USER_AGENTS[getRandomNumberByRange(0, USER_AGENTS.length)]
|
||||
|
||||
async function getBeanShareCode(cookie: string) {
|
||||
let {data}: any = await axios.post('https://api.m.jd.com/client.action',
|
||||
`functionId=plantBeanIndex&body=${encodeURIComponent(
|
||||
JSON.stringify({version: "9.0.0.1", "monitor_source": "plant_app_plant_index", "monitor_refer": ""})
|
||||
)}&appid=ld&client=apple&area=5_274_49707_49973&build=167283&clientVersion=9.1.0`, {
|
||||
headers: {
|
||||
Cookie: cookie,
|
||||
Host: "api.m.jd.com",
|
||||
Accept: "*/*",
|
||||
Connection: "keep-alive",
|
||||
"User-Agent": USER_AGENT
|
||||
}
|
||||
})
|
||||
if (data.data?.jwordShareInfo?.shareUrl)
|
||||
return data.data.jwordShareInfo.shareUrl.split('Uuid=')![1]
|
||||
else
|
||||
return ''
|
||||
}
|
||||
|
||||
async function getFarmShareCode(cookie: string) {
|
||||
let {data}: any = await axios.post('https://api.m.jd.com/client.action?functionId=initForFarm', `body=${encodeURIComponent(JSON.stringify({"version": 4}))}&appid=wh5&clientVersion=9.1.0`, {
|
||||
headers: {
|
||||
"cookie": cookie,
|
||||
"origin": "https://home.m.jd.com",
|
||||
"referer": "https://home.m.jd.com/myJd/newhome.action",
|
||||
"User-Agent": USER_AGENT,
|
||||
"Content-Type": "application/x-www-form-urlencoded"
|
||||
}
|
||||
})
|
||||
|
||||
if (data.farmUserPro)
|
||||
return data.farmUserPro.shareCode
|
||||
else
|
||||
return ''
|
||||
}
|
||||
|
||||
async function requireConfig(check: boolean = false): Promise<string[]> {
|
||||
let cookiesArr: string[] = []
|
||||
const jdCookieNode = require('./jdCookie.js')
|
||||
let keys: string[] = Object.keys(jdCookieNode)
|
||||
for (let i = 0; i < keys.length; i++) {
|
||||
let cookie = jdCookieNode[keys[i]]
|
||||
if (!check) {
|
||||
cookiesArr.push(cookie)
|
||||
} else {
|
||||
if (await checkCookie(cookie)) {
|
||||
cookiesArr.push(cookie)
|
||||
} else {
|
||||
let username = decodeURIComponent(jdCookieNode[keys[i]].match(/pt_pin=([^;]*)/)![1])
|
||||
console.log('Cookie失效', username)
|
||||
await sendNotify('Cookie失效', '【京东账号】' + username)
|
||||
}
|
||||
}
|
||||
}
|
||||
console.log(`共${cookiesArr.length}个京东账号\n`)
|
||||
return cookiesArr
|
||||
}
|
||||
|
||||
async function checkCookie(cookie: string) {
|
||||
await wait(3000)
|
||||
try {
|
||||
let {data}: any = await axios.get(`https://api.m.jd.com/client.action?functionId=GetJDUserInfoUnion&appid=jd-cphdeveloper-m&body=${encodeURIComponent(JSON.stringify({"orgFlag": "JD_PinGou_New", "callSource": "mainorder", "channel": 4, "isHomewhite": 0, "sceneval": 2}))}&loginType=2&_=${Date.now()}&sceneval=2&g_login_type=1&callback=GetJDUserInfoUnion&g_ty=ls`, {
|
||||
headers: {
|
||||
'authority': 'api.m.jd.com',
|
||||
'user-agent': 'Mozilla/5.0 (iPhone; CPU iPhone OS 10_3_1 like Mac OS X) AppleWebKit/603.1.30 (KHTML, like Gecko) Version/10.0 Mobile/14E304 Safari/602.1',
|
||||
'referer': 'https://home.m.jd.com/',
|
||||
'cookie': cookie
|
||||
}
|
||||
})
|
||||
data = JSON.parse(data.match(/GetJDUserInfoUnion\((.*)\)/)[1])
|
||||
return data.retcode === '0';
|
||||
} catch (e) {
|
||||
return false
|
||||
}
|
||||
}
|
||||
|
||||
function wait(timeout: number) {
|
||||
return new Promise(resolve => {
|
||||
setTimeout(resolve, timeout)
|
||||
})
|
||||
}
|
||||
|
||||
async function requestAlgo(appId: number = 10032) {
|
||||
fingerprint = generateFp()
|
||||
return new Promise<void>(async resolve => {
|
||||
let {data}: any = await axios.post('https://cactus.jd.com/request_algo?g_ty=ajax', {
|
||||
"version": "1.0",
|
||||
"fp": fingerprint,
|
||||
"appId": appId,
|
||||
"timestamp": Date.now(),
|
||||
"platform": "web",
|
||||
"expandParams": ""
|
||||
}, {
|
||||
"headers": {
|
||||
'Authority': 'cactus.jd.com',
|
||||
'Pragma': 'no-cache',
|
||||
'Cache-Control': 'no-cache',
|
||||
'Accept': 'application/json',
|
||||
'User-Agent': USER_AGENT,
|
||||
'Content-Type': 'application/json',
|
||||
'Origin': 'https://st.jingxi.com',
|
||||
'Sec-Fetch-Site': 'cross-site',
|
||||
'Sec-Fetch-Mode': 'cors',
|
||||
'Sec-Fetch-Dest': 'empty',
|
||||
'Referer': 'https://st.jingxi.com/',
|
||||
'Accept-Language': 'zh-CN,zh;q=0.9,zh-TW;q=0.8,en;q=0.7'
|
||||
},
|
||||
})
|
||||
if (data['status'] === 200) {
|
||||
token = data.data.result.tk
|
||||
let enCryptMethodJDString = data.data.result.algo
|
||||
if (enCryptMethodJDString) enCryptMethodJD = new Function(`return ${enCryptMethodJDString}`)()
|
||||
} else {
|
||||
console.log(`fp: ${fingerprint}`)
|
||||
console.log('request_algo 签名参数API请求失败:')
|
||||
}
|
||||
resolve()
|
||||
})
|
||||
}
|
||||
|
||||
function generateFp() {
|
||||
let e = "0123456789"
|
||||
let a = 13
|
||||
let i = ''
|
||||
for (; a--;)
|
||||
i += e[Math.random() * e.length | 0]
|
||||
return (i + Date.now()).slice(0, 16)
|
||||
}
|
||||
|
||||
function getJxToken(cookie: string, phoneId: string = '') {
|
||||
function generateStr(input: number) {
|
||||
let src = 'abcdefghijklmnopqrstuvwxyz1234567890'
|
||||
let res = ''
|
||||
for (let i = 0; i < input; i++) {
|
||||
res += src[Math.floor(src.length * Math.random())]
|
||||
}
|
||||
return res
|
||||
}
|
||||
|
||||
if (!phoneId)
|
||||
phoneId = generateStr(40)
|
||||
let timestamp = Date.now().toString()
|
||||
let nickname = cookie.match(/pt_pin=([^;]*)/)![1]
|
||||
let jstoken = Md5.hashStr('' + decodeURIComponent(nickname) + timestamp + phoneId + 'tPOamqCuk9NLgVPAljUyIHcPRmKlVxDy')
|
||||
return {
|
||||
'strPgtimestamp': timestamp,
|
||||
'strPhoneID': phoneId,
|
||||
'strPgUUNum': jstoken
|
||||
}
|
||||
}
|
||||
|
||||
function exceptCookie(filename: string = 'x.ts') {
|
||||
let except: any = []
|
||||
if (existsSync('./utils/exceptCookie.json')) {
|
||||
try {
|
||||
except = JSON.parse(readFileSync('./utils/exceptCookie.json').toString() || '{}')[filename] || []
|
||||
} catch (e) {
|
||||
console.log('./utils/exceptCookie.json JSON格式错误')
|
||||
}
|
||||
}
|
||||
return except
|
||||
}
|
||||
|
||||
function randomString(e: number, word?: number) {
|
||||
e = e || 32
|
||||
let t = word === 26 ? "012345678abcdefghijklmnopqrstuvwxyz" : "0123456789abcdef", a = t.length, n = ""
|
||||
for (let i = 0; i < e; i++)
|
||||
n += t.charAt(Math.floor(Math.random() * a))
|
||||
return n
|
||||
}
|
||||
|
||||
function o2s(arr: object, title: string = '') {
|
||||
title ? console.log(title, JSON.stringify(arr)) : console.log(JSON.stringify(arr))
|
||||
}
|
||||
|
||||
function randomNumString(e: number) {
|
||||
e = e || 32
|
||||
let t = '0123456789', a = t.length, n = ""
|
||||
for (let i = 0; i < e; i++)
|
||||
n += t.charAt(Math.floor(Math.random() * a))
|
||||
return n
|
||||
}
|
||||
|
||||
function randomWord(n: number = 1) {
|
||||
let t = 'ABCDEFGHIJKLMNOPQRSTUVWXYZ', a = t.length
|
||||
let rnd: string = ''
|
||||
for (let i = 0; i < n; i++) {
|
||||
rnd += t.charAt(Math.floor(Math.random() * a))
|
||||
}
|
||||
return rnd
|
||||
}
|
||||
|
||||
async function getshareCodeHW(key: string) {
|
||||
let shareCodeHW: string[] = []
|
||||
for (let i = 0; i < 5; i++) {
|
||||
try {
|
||||
let {data}: any = await axios.get('https://api.jdsharecode.xyz/api/HW_CODES')
|
||||
shareCodeHW = data[key] || []
|
||||
if (shareCodeHW.length !== 0) {
|
||||
break
|
||||
}
|
||||
} catch (e) {
|
||||
console.log("getshareCodeHW Error, Retry...")
|
||||
await wait(getRandomNumberByRange(2000, 6000))
|
||||
}
|
||||
}
|
||||
return shareCodeHW
|
||||
}
|
||||
|
||||
async function getShareCodePool(key: string, num: number) {
|
||||
let shareCode: string[] = []
|
||||
for (let i = 0; i < 2; i++) {
|
||||
try {
|
||||
let {data}: any = await axios.get(`https://api.jdsharecode.xyz/api/${key}/${num}`)
|
||||
shareCode = data.data || []
|
||||
console.log(`随机获取${num}个${key}成功：${JSON.stringify(shareCode)}`)
|
||||
if (shareCode.length !== 0) {
|
||||
break
|
||||
}
|
||||
} catch (e) {
|
||||
console.log("getShareCodePool Error, Retry...")
|
||||
await wait(getRandomNumberByRange(2000, 6000))
|
||||
}
|
||||
}
|
||||
return shareCode
|
||||
}
|
||||
|
||||
/*async function wechat_app_msg(title: string, content: string, user: string) {
|
||||
let corpid: string = "", corpsecret: string = ""
|
||||
let {data: gettoken} = await axios.get(`https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=${corpid}&corpsecret=${corpsecret}`)
|
||||
let access_token: string = gettoken.access_token
|
||||
|
||||
let {data: send} = await axios.post(`https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=${access_token}`, {
|
||||
"touser": user,
|
||||
"msgtype": "text",
|
||||
"agentid": 1000002,
|
||||
"text": {
|
||||
"content": `${title}\n\n${content}`
|
||||
},
|
||||
"safe": 0
|
||||
})
|
||||
if (send.errcode === 0) {
|
||||
console.log('企业微信应用消息发送成功')
|
||||
} else {
|
||||
console.log('企业微信应用消息发送失败', send)
|
||||
}
|
||||
}*/
|
||||
|
||||
function obj2str(obj: object) {
|
||||
return JSON.stringify(obj)
|
||||
}
|
||||
|
||||
async function getDevice() {
|
||||
let {data} = await axios.get('https://betahub.cn/api/apple/devices/iPhone', {
|
||||
headers: {
|
||||
'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/97.0.4692.71 Safari/537.36'
|
||||
}
|
||||
})
|
||||
data = data[getRandomNumberByRange(0, 16)]
|
||||
return data.identifier
|
||||
}
|
||||
|
||||
async function getVersion(device: string) {
|
||||
let {data} = await axios.get(`https://betahub.cn/api/apple/firmwares/${device}`, {
|
||||
headers: {
|
||||
'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/97.0.4692.71 Safari/537.36'
|
||||
}
|
||||
})
|
||||
data = data[getRandomNumberByRange(0, data.length)]
|
||||
return data.firmware_info.version
|
||||
}
|
||||
|
||||
async function jdpingou() {
|
||||
let device: string, version: string;
|
||||
device = await getDevice();
|
||||
version = await getVersion(device);
|
||||
return `jdpingou;iPhone;5.19.0;${version};${randomString(40)};network/wifi;model/${device};appBuild/100833;ADID/;supportApplePay/1;hasUPPay/0;pushNoticeIsOpen/0;hasOCPay/0;supportBestPay/0;session/${getRandomNumberByRange(10, 90)};pap/JA2019_3111789;brand/apple;supportJDSHWK/1;Mozilla/5.0 (iPhone; CPU iPhone OS 14_6 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148`
|
||||
}
|
||||
|
||||
function get(url: string, headers?: any): Promise<any> {
|
||||
return new Promise((resolve, reject) => {
|
||||
axios.get(url, {
|
||||
headers: headers
|
||||
}).then(res => {
|
||||
if (typeof res.data === 'string' && res.data.includes('jsonpCBK')) {
|
||||
resolve(JSON.parse(res.data.match(/jsonpCBK.?\(([\w\W]*)\);?/)[1]))
|
||||
} else {
|
||||
resolve(res.data)
|
||||
}
|
||||
}).catch(err => {
|
||||
reject({
|
||||
code: err?.response?.status || -1,
|
||||
msg: err?.response?.statusText || err.message || 'error'
|
||||
})
|
||||
})
|
||||
})
|
||||
}
|
||||
|
||||
function post(url: string, prarms?: string | object, headers?: any): Promise<any> {
|
||||
return new Promise((resolve, reject) => {
|
||||
axios.post(url, prarms, {
|
||||
headers: headers
|
||||
}).then(res => {
|
||||
resolve(res.data)
|
||||
}).catch(err => {
|
||||
reject({
|
||||
code: err?.response?.status || -1,
|
||||
msg: err?.response?.statusText || err.message || 'error'
|
||||
})
|
||||
})
|
||||
})
|
||||
}
|
||||
|
||||
export default USER_AGENT
|
||||
export {
|
||||
TotalBean,
|
||||
getBeanShareCode,
|
||||
getFarmShareCode,
|
||||
requireConfig,
|
||||
wait,
|
||||
getRandomNumberByRange,
|
||||
requestAlgo,
|
||||
getJxToken,
|
||||
exceptCookie,
|
||||
randomString,
|
||||
o2s,
|
||||
randomNumString,
|
||||
getshareCodeHW,
|
||||
getShareCodePool,
|
||||
randomWord,
|
||||
obj2str,
|
||||
jdpingou,
|
||||
get,
|
||||
post
|
||||
}
|
||||
+4
-3
@@ -154,14 +154,15 @@ async function usersign() {
|
||||
console.log(`${$.name} API请求失败，请检查网路重试`)
|
||||
} else {
|
||||
data = JSON.parse(data);
|
||||
JSON.stringify(data);
|
||||
if (data) {
|
||||
if (data.code === 200) {
|
||||
console.log(`签到成功：获得积分${data.data.signInfo.signNum}`);
|
||||
$.log(`总积分：${data.data.totalNum}\n`);
|
||||
} else {
|
||||
} else if(data.code === 302){
|
||||
console.log("已完成签到！！！\n");
|
||||
}
|
||||
} else {
|
||||
$.log(JSON.stringify(data));
|
||||
}
|
||||
}
|
||||
}
|
||||
} catch (e) {
|
||||
|
||||
@@ -1,443 +0,0 @@
|
||||
#!/bin/env python3
|
||||
# -*- coding: utf-8 -*
|
||||
'''
|
||||
Date: 2022-03-04
|
||||
cron: 5 0 0 * * * jd_health_exchange.py
|
||||
new Env('健康社区兑换京豆');
|
||||
'''
|
||||
#如果不想兑换京豆，ENV设置： export heath_noexchage='x'
|
||||
# x填写数字，x对应cookies中第几个账号，如果中间有黑号，黑号不算。多个账号不兑换用&隔开，例如2&3&4
|
||||
heath_noexchage=''
|
||||
|
||||
##############默认保留20W积分，18W积分才兑换20京豆############
|
||||
###想保留其他分数，ENV设置： export least='xxx'
|
||||
least = 200000
|
||||
|
||||
# 20京豆id为4
|
||||
id = '4'
|
||||
|
||||
|
||||
#每秒点击兑换次数...适当调整，手机会发烫
|
||||
#ENV设置： export dd_thread=30
|
||||
dd_thread = '10'
|
||||
|
||||
UserAgent = ''
|
||||
|
||||
import requests
|
||||
import time,datetime
|
||||
import requests,re,os,sys,random,json
|
||||
from urllib.parse import quote, unquote
|
||||
import threading
|
||||
import urllib3
|
||||
#urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
|
||||
|
||||
requests.packages.urllib3.disable_warnings()
|
||||
|
||||
|
||||
|
||||
|
||||
today = datetime.datetime.now().strftime('%Y-%m-%d')
|
||||
tomorrow=(datetime.datetime.now() + datetime.timedelta(days=1)).strftime('%Y-%m-%d')
|
||||
starttime = '23:59:58.00000000'
|
||||
|
||||
pwd = os.path.dirname(os.path.abspath(__file__)) + os.sep
|
||||
path = pwd + "env.sh"
|
||||
|
||||
script_name = '健康社区兑换-Python'
|
||||
|
||||
jd_host='https://api.m.jd.com/'
|
||||
|
||||
functionId=''
|
||||
|
||||
body = '{}'
|
||||
|
||||
uuid = ''
|
||||
|
||||
|
||||
def printT(s):
|
||||
print("[{0}]: {1}".format(datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S"), s))
|
||||
sys.stdout.flush()
|
||||
|
||||
def getEnvs(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(object):
|
||||
|
||||
|
||||
# 检测cookie格式是否正确
|
||||
def getUserInfo(self, ck, pinName, userNum):
|
||||
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=GetJDUserInfoUnion'
|
||||
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, verify=False, headers=headers, timeout=60).text
|
||||
r = re.compile(r'GetJDUserInfoUnion.*?\((.*?)\)')
|
||||
result = r.findall(resp)
|
||||
userInfo = json.loads(result[0])
|
||||
nickname = userInfo['data']['userInfo']['baseInfo']['nickname']
|
||||
return ck, nickname
|
||||
except Exception:
|
||||
context = f"账号{userNum}【{pinName}】Cookie 已失效！请重新获取。"
|
||||
printT(context)
|
||||
return ck, False
|
||||
|
||||
def iscookie(self):
|
||||
"""
|
||||
:return: cookiesList,userNameList,pinNameList
|
||||
"""
|
||||
cookiesList = []
|
||||
userNameList = []
|
||||
pinNameList = []
|
||||
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)))
|
||||
u = 1
|
||||
for i in result:
|
||||
r = re.compile(r"pt_pin=(.*?);")
|
||||
pinName = r.findall(i)
|
||||
pinName = unquote(pinName[0])
|
||||
# 获取账号名
|
||||
#ck, nickname = self.getUserInfo(i, pinName, u)
|
||||
#if nickname != False:
|
||||
cookiesList.append(i)
|
||||
#userNameList.append(nickname)
|
||||
pinNameList.append(pinName)
|
||||
#else:
|
||||
# u += 1
|
||||
# continue
|
||||
#u += 1
|
||||
if len(cookiesList) > 0:
|
||||
return cookiesList, userNameList, pinNameList
|
||||
else:
|
||||
printT("没有可用Cookie，已退出")
|
||||
exit(3)
|
||||
else:
|
||||
printT("cookie 格式错误！...本次操作已退出")
|
||||
exit(4)
|
||||
else:
|
||||
printT("cookie 格式错误！...本次操作已退出")
|
||||
exit(4)
|
||||
getCk = getJDCookie()
|
||||
#getCk.getCookie()
|
||||
|
||||
# 获取v4环境 特殊处理
|
||||
try:
|
||||
with open(v4f, 'r', encoding='utf-8') as v4f:
|
||||
v4Env = v4f.read()
|
||||
r = re.compile(r'^export\s(.*?)=[\'\"]?([\w\.\-@#&=_,\[\]\{\}\(\)]{1,})+[\'\"]{0,1}$',
|
||||
re.M | re.S | re.I)
|
||||
r = r.findall(v4Env)
|
||||
curenv = locals()
|
||||
for i in r:
|
||||
if i[0] != 'JD_COOKIE':
|
||||
curenv[i[0]] = getEnvs(i[1])
|
||||
except:
|
||||
pass
|
||||
|
||||
############## 在pycharm测试ql环境用，实际用下面的代码运行 #########
|
||||
# with open(path, "r+", encoding="utf-8") as f:
|
||||
# ck = f.read()
|
||||
# if "JD_COOKIE" in ck:
|
||||
# # r = re.compile (r"pt_key=.*?pt_pin=.*?;", re.M | re.S | re.I)
|
||||
# # cookies = r.findall (ck)
|
||||
# # cookies = cookies[0]
|
||||
# # print(cookies)
|
||||
# cookies = ck
|
||||
# printT ("已获取并使用ck环境 Cookie")
|
||||
########################################################################
|
||||
|
||||
|
||||
if "JD_COOKIE" in os.environ:
|
||||
if len (os.environ["JD_COOKIE"]) > 1:
|
||||
cookies = os.environ["JD_COOKIE"]
|
||||
# temporary = cookies.split ('&')
|
||||
# cookies = temporary[0]
|
||||
printT ("已获取并使用Env环境 Cookie")
|
||||
|
||||
if "heath_noexchage" in os.environ:
|
||||
heath_noexchage = os.environ["heath_noexchage"]
|
||||
printT(f"已获取并使用Env环境 heath_noexchage:{heath_noexchage}")
|
||||
|
||||
if "least" in os.environ:
|
||||
least = getEnvs(os.environ["least"])
|
||||
printT(f"已获取并使用Env环境 least:{least}")
|
||||
|
||||
|
||||
heath_noexchage_list = heath_noexchage.split('&')
|
||||
|
||||
def userAgent():
|
||||
"""
|
||||
随机生成一个UA
|
||||
:return: jdapp;iPhone;9.4.8;14.3;xxxx;network/wifi;ADID/201EDE7F-5111-49E8-9F0D-CCF9677CD6FE;supportApplePay/0;hasUPPay/0;hasOCPay/0;model/iPhone13,4;addressid/2455696156;supportBestPay/0;appBuild/167629;jdSupportDarkMode/0;Mozilla/5.0 (iPhone; CPU iPhone OS 14_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1
|
||||
"""
|
||||
if not UserAgent:
|
||||
uuid = ''.join(random.sample('123456789abcdef123456789abcdef123456789abcdef123456789abcdef', 40))
|
||||
addressid = ''.join(random.sample('1234567898647', 10))
|
||||
iosVer = ''.join(
|
||||
random.sample(["14.5.1", "14.4", "14.3", "14.2", "14.1", "14.0.1", "13.7", "13.1.2", "13.1.1"], 1))
|
||||
iosV = iosVer.replace('.', '_')
|
||||
iPhone = ''.join(random.sample(["8", "9", "10", "11", "12", "13"], 1))
|
||||
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))
|
||||
return f'jdapp;iPhone;10.0.4;{iosVer};{uuid};network/wifi;ADID/{ADID};supportApplePay/0;hasUPPay/0;hasOCPay/0;model/iPhone{iPhone},1;addressid/{addressid};supportBestPay/0;appBuild/167629;jdSupportDarkMode/0;Mozilla/5.0 (iPhone; CPU iPhone OS {iosV} like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148;supportJDSHWK/1'
|
||||
else:
|
||||
return UserAgent
|
||||
def difftime():
|
||||
heard={
|
||||
'User-Agent':'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/108.0.0.0 Safari/537.36',
|
||||
}
|
||||
url="https://wq.jd.com/mcoss/servertime/getservertime?_=1664872855968&sceneval=2&g_login_type=1&callback=cb8216634&g_ty=ls&appCode=msc588d6d5"
|
||||
resp=requests.get(url,headers=heard).text
|
||||
res=re.match('.*\"serverTime\":\"(.*)\".*',resp).group(1)
|
||||
sertime=int(time.mktime(time.strptime(res, '%Y/%m/%d %H:%M:%S'))*1000)
|
||||
loctime=int(time.time()*1000)
|
||||
return loctime-sertime
|
||||
## 获取通知服务
|
||||
class msg(object):
|
||||
def __init__(self, m=''):
|
||||
self.str_msg = m
|
||||
self.message()
|
||||
def message(self):
|
||||
global msg_info
|
||||
printT(self.str_msg)
|
||||
try:
|
||||
msg_info = "{}\n{}".format(msg_info, self.str_msg)
|
||||
except:
|
||||
msg_info = "{}".format(self.str_msg)
|
||||
sys.stdout.flush() #这代码的作用就是刷新缓冲区。
|
||||
# 当我们打印一些字符时，并不是调用print函数后就立即打印的。一般会先将字符送到缓冲区，然后再打印。
|
||||
# 这就存在一个问题，如果你想等时间间隔的打印一些字符，但由于缓冲区没满，不会打印。就需要采取一些手段。如每次打印后强行刷新缓冲区。
|
||||
def getsendNotify(self, a=0):
|
||||
if a == 0:
|
||||
a += 1
|
||||
try:
|
||||
url = 'https://gitee.com/curtinlv/Public/raw/master/sendNotify.py'
|
||||
response = requests.get(url)
|
||||
if 'curtinlv' in response.text:
|
||||
with open('sendNotify.py', "w+", encoding="utf-8") as f:
|
||||
f.write(response.text)
|
||||
else:
|
||||
if a < 5:
|
||||
a += 1
|
||||
return self.getsendNotify(a)
|
||||
else:
|
||||
pass
|
||||
except:
|
||||
if a < 5:
|
||||
a += 1
|
||||
return self.getsendNotify(a)
|
||||
else:
|
||||
pass
|
||||
def main(self):
|
||||
global send
|
||||
cur_path = os.path.abspath(os.path.dirname(__file__))
|
||||
sys.path.append(cur_path)
|
||||
if os.path.exists(cur_path + "/sendNotify.py"):
|
||||
try:
|
||||
from sendNotify import send
|
||||
except:
|
||||
self.getsendNotify()
|
||||
try:
|
||||
from sendNotify import send
|
||||
except:
|
||||
printT("加载通知服务失败~")
|
||||
else:
|
||||
self.getsendNotify()
|
||||
try:
|
||||
from sendNotify import send
|
||||
except:
|
||||
printT("加载通知服务失败~")
|
||||
###################
|
||||
msg().main()
|
||||
|
||||
|
||||
def listcookie(): #将JDCookies.txt的cookies变成list[]
|
||||
if 'pt_key=' in cookies and 'pt_pin=' in cookies:
|
||||
r = re.compile(r"pt_key=.*?pt_pin=.*?;" , re.M | re.S | re.I) #r"" 的作用是去除转义字符.
|
||||
result = r.findall(cookies) #输出为list列表
|
||||
if len(result) == 1:
|
||||
return result
|
||||
elif len(result)>1:
|
||||
return result
|
||||
else:
|
||||
print("cookie 格式错误！...本次操作已退出")
|
||||
exit(1)
|
||||
else:
|
||||
print("cookie 格式错误！...本次操作已退出")
|
||||
exit(9)
|
||||
|
||||
def setHeaders(cookie):
|
||||
try:
|
||||
r = re.compile(r"pt_pin=(.*?);") #指定一个规则：查找pt_pin=与;之前的所有字符,但pt_pin=与;不复制。r"" 的作用是去除转义字符.
|
||||
userName = r.findall(cookie) #查找pt_pin=与;之前的所有字符，并复制给r，其中pt_pin=与;不复制。
|
||||
#print (userName)
|
||||
userName = unquote(userName[0]) #r.findall(cookie)赋值是list列表，这个赋值为字符串
|
||||
#print(userName)
|
||||
except Exception as e:
|
||||
print(e,"cookie格式有误！")
|
||||
exit(2)
|
||||
headers = {
|
||||
'Origin': 'https://h5.m.jd.com',
|
||||
'Cookie': cookie,
|
||||
'Connection': 'keep-alive',
|
||||
'Accept': 'application/json, text/plain, */*',
|
||||
'Referer': 'https://h5.m.jd.com/',
|
||||
'Content-Type': 'application/x-www-form-urlencoded',
|
||||
'User-Agent': userAgent(),
|
||||
'Accept-Encoding': 'gzip, deflate',
|
||||
'Accept-Language': 'zh-cn'
|
||||
}
|
||||
return headers,userName
|
||||
|
||||
#返回符合条件的ck list
|
||||
def checkUser(cookies):
|
||||
global goodsid, mid_time,afternoon_time
|
||||
if isinstance(cookies,list): #isinstance() 函数来判断一个对象是否是一个已知的类型，类似 type()。此方法为：判断cookies是否为list[]列表，是返回True，否返回False
|
||||
pass
|
||||
elif isinstance(cookies,str): #判断cookies是否为str字符串，是返回True，否返回False
|
||||
cookies = listcookie()
|
||||
else:
|
||||
print("cookie 类型有误")
|
||||
exit(2)
|
||||
cookieList=[]
|
||||
#print(cookies)
|
||||
user_num=1
|
||||
for i in cookies:
|
||||
headers,userName = setHeaders(i)
|
||||
try:
|
||||
total_exchangePoints = cheak_points('jdhealth_getHomeData','{}',headers)
|
||||
title,exchangePoints,bizMsg,bizCode = jdhealth_getCommodities('jdhealth_getCommodities','',headers)
|
||||
if user_num == 1:
|
||||
printT("您已设置兑换的商品：【{0}豆】 需要{1}积分".format(title, exchangePoints))
|
||||
print("********** 检测符合兑换要求的账号 ********** ")
|
||||
if int(total_exchangePoints) > least:
|
||||
total_exchangePoints = int(total_exchangePoints)
|
||||
if not str(user_num) in heath_noexchage_list:
|
||||
cookieList.append(i) #将够钱兑换的账号保存下来给cookieList[]，其余不够钱的账号剔除在外，不执行兑换
|
||||
printT(f"账号{user_num}:【{userName}】积分:{total_exchangePoints}...yes")
|
||||
else:
|
||||
total_exchangePoints = int (total_exchangePoints)
|
||||
printT(f"账号{user_num}:【{userName}】积分:{total_exchangePoints}...no")
|
||||
except Exception as e:
|
||||
#printT(f"账号{user_num}:【{userName}】，该用户异常，查不到商品关键词【{Coupon}】，或者cookies已过期")
|
||||
msg(f"账号{user_num}:【{userName}】，该用户异常，查不到商品id【{id}】")
|
||||
# if '异常' in msg_info:
|
||||
# send (script_name, msg_info)
|
||||
# if len (cookies) == 1:
|
||||
#exit (0)
|
||||
user_num+=1
|
||||
if len (cookieList) > 0:
|
||||
printT ("共有{0}个账号符合兑换条件".format (len (cookieList)))
|
||||
return cookieList
|
||||
else:
|
||||
printT ("没有账号符合兑换要求，退出执行")
|
||||
exit(0)
|
||||
#查询总分
|
||||
def cheak_points(functionId,body,headers):
|
||||
url = jd_host + '?' +'functionId=' + functionId + '&body=' + body + '&client=wh5&clientVersion=1.0.0&' + 'uuid=' + uuid
|
||||
try:
|
||||
respon = requests.post(url=url, verify=False, headers=headers)
|
||||
result=respon.json()
|
||||
#print(result)
|
||||
total_exchangePoints = result['data']['result']['userScore'] #兑换所需分数
|
||||
return float(total_exchangePoints)
|
||||
except Exception as e:
|
||||
print(e)
|
||||
|
||||
#查询
|
||||
def jdhealth_getCommodities(functionId,body,headers):
|
||||
url = jd_host + '?' +'functionId=' + functionId + '&body=' + body + '&client=wh5&clientVersion=1.0.0&' + 'uuid=' + uuid
|
||||
try:
|
||||
respon = requests.post(url=url, verify=False, headers=headers)
|
||||
result=respon.json()
|
||||
title = result['data']['result']['jBeans'][3]['title']
|
||||
exchangePoints = result['data']['result']['jBeans'][3]['exchangePoints'] #兑换所需分数
|
||||
bizMsg = result['data']['bizMsg']
|
||||
bizCode = result['data']['bizCode']
|
||||
return title,exchangePoints,bizMsg,bizCode
|
||||
except Exception as e:
|
||||
print(e)
|
||||
|
||||
#兑换
|
||||
def jdhealth_exchange(functionId,body,headers):
|
||||
url = jd_host + '?' +'functionId=' + functionId + '&body=' + body + '&client=wh5&clientVersion=1.0.0&' + 'uuid=' + uuid
|
||||
try:
|
||||
respon = requests.post(url=url, verify=False, headers=headers)
|
||||
result=respon.json()
|
||||
#title = result['data']['result']['jingBeanNum']
|
||||
#userScore = result['data']['result']['userScore'] #剩余积分
|
||||
bizMsg = result['data']['bizMsg']
|
||||
bizCode = result['data']['bizCode']
|
||||
success = result['data']['success']
|
||||
if bizMsg == 'success' or bizCode == '0' :
|
||||
printT("{0}...恭喜兑换成功！".format(bizMsg))
|
||||
return 0
|
||||
else:
|
||||
printT(f"\t{bizMsg}" + ',兑换失败') #f 表达式----可以解析任意的数据类型。 \t表示空4格，相当于tab。
|
||||
return 999
|
||||
except Exception as e:
|
||||
print(e)
|
||||
|
||||
def start():
|
||||
print (f"############# 开始############ ")
|
||||
cookiesList, userNameList, pinNameList = getCk.iscookie ()
|
||||
cookies1 = checkUser (cookiesList) # 将够钱兑换的账号保存下来给cookies，其余不够钱的账号剔除在外，不执行兑换
|
||||
final = 1
|
||||
diff=difftime()
|
||||
tomorrow=datetime.date.today() + datetime.timedelta(days=1)
|
||||
tomorrow=int(time.mktime(time.strptime(str(tomorrow), '%Y-%m-%d'))*1000)
|
||||
print((tomorrow - int(time.time()*1000) + diff)/1000)
|
||||
time.sleep((tomorrow - int(time.time()*1000) + diff)/1000)
|
||||
while True:
|
||||
print (f"\n【准备开始...】\n")
|
||||
user_num = 1
|
||||
for i in cookies1:
|
||||
headers, userName = setHeaders (i)
|
||||
final = jdhealth_exchange ('jdhealth_exchange','{"commodityType":2,"commodityId":"4"}',headers)
|
||||
user_num += 1
|
||||
if final == 0:
|
||||
last_points = cheak_points ('jdhealth_getHomeData','',headers)
|
||||
title, exchangePoints, bizMsg, bizCode = jdhealth_getCommodities ('jdhealth_getCommodities', '{}',headers)
|
||||
# printT (f"账号{user_num}:【{userName}】剩余积分:{last_integration}...")
|
||||
msg (f"账号{user_num}:【{userName}】成功兑换【{title}豆】，剩余积分:{last_points}...")
|
||||
|
||||
elif final == 999:
|
||||
pass
|
||||
if user_num > len(cookies1):
|
||||
break
|
||||
if __name__ == '__main__':
|
||||
print("脚本默认兑换20豆，18W分以上才兑换，具体修改教程可看脚本开头注释")
|
||||
print ("\t\t【{}】".format (script_name))
|
||||
start ()
|
||||
if '成功兑换' in msg_info:
|
||||
send (script_name, msg_info)
|
||||
@@ -1,90 +0,0 @@
|
||||
/**
|
||||
汪汪赛跑-提现10元,周五9点
|
||||
59 59 8 * * 5 jd_joy_run_reward.ts
|
||||
new Env('汪汪赛跑提现')
|
||||
updateTime：2022-07-09
|
||||
**/
|
||||
|
||||
import { get, post, requireConfig, wait } from './TS_USER_AGENTS'
|
||||
import { H5ST } from "./function/h5st"
|
||||
|
||||
let cookie: string = '', res: any = '', UserName: string = '', fp_448de: string = '' || process.env.FP_448DE, fp_b6ac3: string = '' || process.env.FP_B6AC3
|
||||
let h5stTool: H5ST = null
|
||||
|
||||
!(async () => {
|
||||
let cookiesArr: string[] = await requireConfig()
|
||||
for (let [index, value] of cookiesArr.entries()) {
|
||||
cookie = value
|
||||
UserName = decodeURIComponent(cookie.match(/pt_pin=([^;]*)/)![1])
|
||||
console.log(`\n开始【京东账号${index + 1}】${UserName}\n`)
|
||||
let rewardAmount: number = 0
|
||||
try {
|
||||
h5stTool = new H5ST('448de', 'jdltapp;', fp_448de)
|
||||
await h5stTool.__genAlgo()
|
||||
res = await team('runningMyPrize', { "linkId": "L-sOanK_5RJCz7I314FpnQ", "pageSize": 20, "time": null, "ids": null })
|
||||
rewardAmount = res.data.rewardAmount
|
||||
if (res.data.runningCashStatus.currentEndTime) {
|
||||
console.log('可提现', rewardAmount)
|
||||
res = await api('runningPrizeDraw', { "linkId": "L-sOanK_5RJCz7I314FpnQ", "type": 2, "level": 3 })
|
||||
if (res.errMsg.indexOf("不足") > -1) {
|
||||
res = await api('runningPrizeDraw', { "linkId": "L-sOanK_5RJCz7I314FpnQ", "type": 2, "level": 2 })
|
||||
}
|
||||
await wait(1000)
|
||||
if (res.success) {
|
||||
console.log(res.data.message)
|
||||
} else {
|
||||
console.log('提现失败：', res.errMsg)
|
||||
}
|
||||
} else {
|
||||
console.log('还未到提现时间')
|
||||
}
|
||||
} catch (e) {
|
||||
console.log('Error', e)
|
||||
await wait(1000)
|
||||
}
|
||||
}
|
||||
})()
|
||||
|
||||
async function api(fn: string, body: object) {
|
||||
let timestamp: number = Date.now(), h5st: string = ''
|
||||
if (fn === 'runningOpenBox') {
|
||||
h5st = h5stTool.__genH5st({
|
||||
appid: "activities_platform",
|
||||
body: JSON.stringify(body),
|
||||
client: "ios",
|
||||
clientVersion: "3.1.0",
|
||||
functionId: "runningOpenBox",
|
||||
t: timestamp.toString()
|
||||
})
|
||||
}
|
||||
let params: string = `functionId=${fn}&body=${JSON.stringify(body)}&t=${timestamp}&appid=activities_platform&client=ios&clientVersion=3.1.0&cthr=1`
|
||||
h5st && (params += `&h5st=${h5st}`)
|
||||
return await post('https://api.m.jd.com/', params, {
|
||||
'authority': 'api.m.jd.com',
|
||||
'content-type': 'application/x-www-form-urlencoded',
|
||||
'cookie': cookie,
|
||||
'origin': 'https://h5platform.jd.com',
|
||||
'referer': 'https://h5platform.jd.com/',
|
||||
'user-agent': 'jdltapp;'
|
||||
})
|
||||
}
|
||||
|
||||
async function team(fn: string, body: object) {
|
||||
let timestamp: number = Date.now(), h5st: string
|
||||
h5st = h5stTool.__genH5st({
|
||||
appid: "activities_platform",
|
||||
body: JSON.stringify(body),
|
||||
client: "ios",
|
||||
clientVersion: "3.1.0",
|
||||
functionId: fn,
|
||||
t: timestamp.toString()
|
||||
})
|
||||
return await get(`https://api.m.jd.com/?functionId=${fn}&body=${encodeURIComponent(JSON.stringify(body))}&t=${timestamp}&appid=activities_platform&client=ios&clientVersion=3.1.0&cthr=1&h5st=${h5st}`, {
|
||||
'Host': 'api.m.jd.com',
|
||||
'User-Agent': 'jdltapp;',
|
||||
'Origin': 'https://h5platform.jd.com',
|
||||
'X-Requested-With': 'com.jd.jdlite',
|
||||
'Referer': 'https://h5platform.jd.com/',
|
||||
'Cookie': cookie
|
||||
})
|
||||
}
|
||||
+258
-320
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
Reference in New Issue
Block a user