-
Notifications
You must be signed in to change notification settings - Fork 217
/
jd_chinaJoy.js
195 lines (192 loc) · 16.3 KB
/
jd_chinaJoy.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
/*
* APP-》智能生活-》右侧浮窗
* 一天跑1次
* 9.28 - 10.28
* */
const $ = new Env('京东小家');
const jdCookieNode = $.isNode() ? require('./jdCookie.js') : '';
let cookiesArr = [];
if ($.isNode()) {
Object.keys(jdCookieNode).forEach((item) => {
cookiesArr.push(jdCookieNode[item])
})
if (process.env.JD_DEBUG && process.env.JD_DEBUG === 'false') console.log = () => {
};
} else {
cookiesArr = [
$.getdata("CookieJD"),
$.getdata("CookieJD2"),
...$.toObj($.getdata("CookiesJD") || "[]").map((item) => item.cookie)].filter((item) => !!item);
}
let shareList = [];
!(async () => {
if (!cookiesArr[0]) {
$.msg($.name, '【提示】请先获取京东账号一cookie\n直接使用NobyDa的京东签到获取', 'https://bean.m.jd.com/bean/signIndex.action', {"open-url": "https://bean.m.jd.com/bean/signIndex.action"});
return;
}
if(Date.now() > 1635436800000){
console.log(`活动结束`);
return;
}
const promiseArr = cookiesArr.map((ck, index) => main(ck));
await Promise.all(promiseArr);
if(shareList.length === 0){return;}
let allShareList = [];
for (let i = 0; i < cookiesArr.length; i++) {
let cookie = cookiesArr[i];
let userName = decodeURIComponent(cookie.match(/pt_pin=(.+?);/) && cookie.match(/pt_pin=(.+?);/)[1]);
for (let j = 0; j < shareList.length; j++) {
if(shareList[j].user === userName){
allShareList.push(shareList[j]);
break;
}
}
}
console.log(`========================================开始互助=============================================`);
cookiesArr = getRandomArrayElements(cookiesArr,cookiesArr.length);
for (let i = 0; i < cookiesArr.length; i++) {
let cookie = cookiesArr[i];
let userName = decodeURIComponent(cookie.match(/pt_pin=(.+?);/) && cookie.match(/pt_pin=(.+?);/)[1]);
let canHelp = true;
let time = 0;
for (let j = 0; j < allShareList.length && canHelp; j++) {
if(allShareList[j].user === userName || allShareList[j].max){
continue;
}
console.log(`\n${userName},去助力:${allShareList[j].user},助力码:${allShareList[j].code}`);
let doSupportInfo = await takeRequest(`{"shareId":"${allShareList[j].code}","apiMapping":"/api/supportTask/doSupport"}`,cookie);
if(doSupportInfo.status === 7){
console.log(`助力成功`);
time++;
}else if(doSupportInfo.status === 4){
console.log(`助力已满`);
allShareList[j].max = true;
}else if(doSupportInfo.status === 5){
console.log(`助力次数已用完`);
canHelp = false;
}
console.log(JSON.stringify(doSupportInfo));
await $.wait(2000);
if(time === 3){
canHelp = false;
}
}
}
console.log(`====================================账户内互助结束，开始领取助力奖励=============================================`)
const promiseArr2 = cookiesArr.map((ck, index) => main(ck));
await Promise.all(promiseArr2);
})()
.catch((e) => {
$.log('', `❌ ${$.name}, 失败! 原因: ${e}!`, '')
})
.finally(() => {
$.done();
})
function getRandomArrayElements(arr, count) {
var shuffled = arr.slice(0), i = arr.length, min = i - count, temp, index;
while (i-- > min) {
index = Math.floor((i + 1) * Math.random());
temp = shuffled[index];
shuffled[index] = shuffled[i];
shuffled[i] = temp;
}
return shuffled.slice(min);
}
async function main(cookie) {
let userName = decodeURIComponent(cookie.match(/pt_pin=(.+?);/) && cookie.match(/pt_pin=(.+?);/)[1])
let configInfo = await takeRequest(`{"apiMapping":"/api/front/config"}`,cookie);
let prizeInfo = await takeRequest(`{"apiMapping":"/api/prize/prizeInfo"}`,cookie);
let riskInfo = await takeRequest(`{"apiMapping":"/api/risk"}`,cookie);
let skuGroupListInfo = await takeRequest(`{"apiMapping":"/api/skuGroupList"}`,cookie);
if(JSON.stringify(configInfo) === '{}' || JSON.stringify(prizeInfo) === '{}' || JSON.stringify(riskInfo) === '{}' || JSON.stringify(skuGroupListInfo) === '{}'){
console.log(`${userName},初始化失败`);
return;
}
console.log(`${userName},去签到`);
let registInfo = await takeRequest(`{"apiMapping":"/api/regist"}`,cookie);
console.log(`${userName},签到完成，已签到天数：${registInfo.registDays}天，连续签到：${registInfo.serialRegistDays}天`)
await $.wait(2000);
let runFlag = false;
let runTime = 0;
do {
runFlag = false;
runTime ++;
riskInfo = await takeRequest(`{"apiMapping":"/api/risk"}`,cookie);
let taskList = await takeRequest(`{"apiMapping":"/api/task/getTaskList"}`,cookie);
let supportInfo = await takeRequest(`{"apiMapping":"/api/supportTask/getSupportList"}`,cookie);
if(supportInfo.supportedNum !== supportInfo.supportNeedNum){
await $.wait(1000);
let shareId = await takeRequest(`{"apiMapping":"/api/supportTask/getShareId"}`,cookie);
shareList.push({'user':userName,'code':shareId,'max':false});
console.log(`${userName},助力码：${shareId}`);
}else{
console.log(`${userName},助力已满`);
}
for (let i = 0; i < supportInfo.rewardTime; i++) {
console.log(`${userName},领取助力奖励`);
let supportReward = await takeRequest(`{"apiMapping":"/api/supportTask/getSupportReward"}`,cookie);
console.log(`${userName},获得积分:${supportReward.score || 0},获得京豆:${supportReward.jbean || 0}`);
await $.wait(1000);
}
await $.wait(1000);
for (let i = 0; i < taskList.length; i++) {
let oneTask = taskList[i];
if(!oneTask.taskShow || oneTask.taskId === '1' || oneTask.taskId === '2'){
continue;
}
if(oneTask.totalNum === oneTask.finishNum){
console.log(`${userName},任务：${oneTask.taskName},已完成`);
continue;
}
runFlag = true;
let rewardInfo = {};
console.log(`${userName},任务：${oneTask.taskName},已完成：${oneTask.finishNum}次,需要完成：${oneTask.totalNum}次,`);
if(oneTask.getPrizeNum === 0){
console.log(`${userName},任务：${oneTask.taskName},去执行,等待5秒`);
let doInfo = await takeRequest(`{"parentId":"${oneTask.parentId}","taskId":"${oneTask.taskId}","apiMapping":"/api/task/doTask"}`,cookie);
await $.wait(5000);
await takeRequest(`{"parentId":"${oneTask.parentId}","taskId":"${oneTask.taskId}","timeStamp":${doInfo.timeStamp},"apiMapping":"/api/task/getBrowseStatus"}`,cookie);
console.log(`${userName},任务：${oneTask.taskName},任务完成`);
await $.wait(2000);
}
rewardInfo = await takeRequest(`{"parentId":"${oneTask.parentId}","taskId":"${oneTask.taskId}","timeStamp":${Date.now()},"apiMapping":"/api/task/getReward"}`,cookie);
console.log(`${userName},任务：${oneTask.taskName},领取奖励，获得积分:${rewardInfo.score || 0},获得京豆:${rewardInfo.jbean || 0}`);
await $.wait(1000);
}
}while (runFlag && runTime < 5)
}
async function takeRequest(body,cookie){
let thisBody = `appid=china-joy&functionId=jd_home_pro&body=${body}&t=${Date.now()}&loginType=2`
let myRequest = {
url: `https://api.m.jd.com/api`,
body:thisBody,
headers: {
'Authority':'api.m.jd.com',
'Accept' : `application/json, text/plain, */*`,
'Content-Type':'application/x-www-form-urlencoded',
'Origin' : `https://small-home.jd.com`,
'Cookie' : cookie,
'Accept-Language' : `zh-cn`,
'user-agent': $.isNode() ? (process.env.JD_USER_AGENT ? process.env.JD_USER_AGENT : (require('./USER_AGENTS').USER_AGENT)) : ($.getdata('JDUA') ? $.getdata('JDUA') : "jdapp;iPhone;9.4.4;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"),
'Referer' : `https://small-home.jd.com/`,
'Accept-Encoding':'gzip, deflate, br'
}
};
return new Promise(async resolve => {
$.post(myRequest, (err, resp, data) => {
try {
if(err){
console.log(err);
}else{
data = JSON.parse(data);
}
} catch (e) {
console.log(data);
$.logErr(e, resp)
} finally {
resolve(data.data || {});
}
})
})
}
function Env(t,e){"undefined"!=typeof process&&JSON.stringify(process.env).indexOf("GITHUB")>-1&&process.exit(0);class s{constructor(t){this.env=t}send(t,e="GET"){t="string"==typeof t?{url:t}:t;let s=this.get;return"POST"===e&&(s=this.post),new Promise((e,i)=>{s.call(this,t,(t,s,r)=>{t?i(t):e(s)})})}get(t){return this.send.call(this.env,t)}post(t){return this.send.call(this.env,t,"POST")}}return new class{constructor(t,e){this.name=t,this.http=new s(this),this.data=null,this.dataFile="box.dat",this.logs=[],this.isMute=!1,this.isNeedRewrite=!1,this.logSeparator="\n",this.startTime=(new Date).getTime(),Object.assign(this,e),this.log("",`🔔${this.name}, 开始!`)}isNode(){return"undefined"!=typeof module&&!!module.exports}isQuanX(){return"undefined"!=typeof $task}isSurge(){return"undefined"!=typeof $httpClient&&"undefined"==typeof $loon}isLoon(){return"undefined"!=typeof $loon}toObj(t,e=null){try{return JSON.parse(t)}catch{return e}}toStr(t,e=null){try{return JSON.stringify(t)}catch{return e}}getjson(t,e){let s=e;const i=this.getdata(t);if(i)try{s=JSON.parse(this.getdata(t))}catch{}return s}setjson(t,e){try{return this.setdata(JSON.stringify(t),e)}catch{return!1}}getScript(t){return new Promise(e=>{this.get({url:t},(t,s,i)=>e(i))})}runScript(t,e){return new Promise(s=>{let i=this.getdata("@chavy_boxjs_userCfgs.httpapi");i=i?i.replace(/\n/g,"").trim():i;let r=this.getdata("@chavy_boxjs_userCfgs.httpapi_timeout");r=r?1*r:20,r=e&&e.timeout?e.timeout:r;const[o,h]=i.split("@"),n={url:`http://${h}/v1/scripting/evaluate`,body:{script_text:t,mock_type:"cron",timeout:r},headers:{"X-Key":o,Accept:"*/*"}};this.post(n,(t,e,i)=>s(i))}).catch(t=>this.logErr(t))}loaddata(){if(!this.isNode())return{};{this.fs=this.fs?this.fs:require("fs"),this.path=this.path?this.path:require("path");const t=this.path.resolve(this.dataFile),e=this.path.resolve(process.cwd(),this.dataFile),s=this.fs.existsSync(t),i=!s&&this.fs.existsSync(e);if(!s&&!i)return{};{const i=s?t:e;try{return JSON.parse(this.fs.readFileSync(i))}catch(t){return{}}}}}writedata(){if(this.isNode()){this.fs=this.fs?this.fs:require("fs"),this.path=this.path?this.path:require("path");const t=this.path.resolve(this.dataFile),e=this.path.resolve(process.cwd(),this.dataFile),s=this.fs.existsSync(t),i=!s&&this.fs.existsSync(e),r=JSON.stringify(this.data);s?this.fs.writeFileSync(t,r):i?this.fs.writeFileSync(e,r):this.fs.writeFileSync(t,r)}}lodash_get(t,e,s){const i=e.replace(/\[(\d+)\]/g,".$1").split(".");let r=t;for(const t of i)if(r=Object(r)[t],void 0===r)return s;return r}lodash_set(t,e,s){return Object(t)!==t?t:(Array.isArray(e)||(e=e.toString().match(/[^.[\]]+/g)||[]),e.slice(0,-1).reduce((t,s,i)=>Object(t[s])===t[s]?t[s]:t[s]=Math.abs(e[i+1])>>0==+e[i+1]?[]:{},t)[e[e.length-1]]=s,t)}getdata(t){let e=this.getval(t);if(/^@/.test(t)){const[,s,i]=/^@(.*?)\.(.*?)$/.exec(t),r=s?this.getval(s):"";if(r)try{const t=JSON.parse(r);e=t?this.lodash_get(t,i,""):e}catch(t){e=""}}return e}setdata(t,e){let s=!1;if(/^@/.test(e)){const[,i,r]=/^@(.*?)\.(.*?)$/.exec(e),o=this.getval(i),h=i?"null"===o?null:o||"{}":"{}";try{const e=JSON.parse(h);this.lodash_set(e,r,t),s=this.setval(JSON.stringify(e),i)}catch(e){const o={};this.lodash_set(o,r,t),s=this.setval(JSON.stringify(o),i)}}else s=this.setval(t,e);return s}getval(t){return this.isSurge()||this.isLoon()?$persistentStore.read(t):this.isQuanX()?$prefs.valueForKey(t):this.isNode()?(this.data=this.loaddata(),this.data[t]):this.data&&this.data[t]||null}setval(t,e){return this.isSurge()||this.isLoon()?$persistentStore.write(t,e):this.isQuanX()?$prefs.setValueForKey(t,e):this.isNode()?(this.data=this.loaddata(),this.data[e]=t,this.writedata(),!0):this.data&&this.data[e]||null}initGotEnv(t){this.got=this.got?this.got:require("got"),this.cktough=this.cktough?this.cktough:require("tough-cookie"),this.ckjar=this.ckjar?this.ckjar:new this.cktough.CookieJar,t&&(t.headers=t.headers?t.headers:{},void 0===t.headers.Cookie&&void 0===t.cookieJar&&(t.cookieJar=this.ckjar))}get(t,e=(()=>{})){t.headers&&(delete t.headers["Content-Type"],delete t.headers["Content-Length"]),this.isSurge()||this.isLoon()?(this.isSurge()&&this.isNeedRewrite&&(t.headers=t.headers||{},Object.assign(t.headers,{"X-Surge-Skip-Scripting":!1})),$httpClient.get(t,(t,s,i)=>{!t&&s&&(s.body=i,s.statusCode=s.status),e(t,s,i)})):this.isQuanX()?(this.isNeedRewrite&&(t.opts=t.opts||{},Object.assign(t.opts,{hints:!1})),$task.fetch(t).then(t=>{const{statusCode:s,statusCode:i,headers:r,body:o}=t;e(null,{status:s,statusCode:i,headers:r,body:o},o)},t=>e(t))):this.isNode()&&(this.initGotEnv(t),this.got(t).on("redirect",(t,e)=>{try{if(t.headers["set-cookie"]){const s=t.headers["set-cookie"].map(this.cktough.Cookie.parse).toString();s&&this.ckjar.setCookieSync(s,null),e.cookieJar=this.ckjar}}catch(t){this.logErr(t)}}).then(t=>{const{statusCode:s,statusCode:i,headers:r,body:o}=t;e(null,{status:s,statusCode:i,headers:r,body:o},o)},t=>{const{message:s,response:i}=t;e(s,i,i&&i.body)}))}post(t,e=(()=>{})){if(t.body&&t.headers&&!t.headers["Content-Type"]&&(t.headers["Content-Type"]="application/x-www-form-urlencoded"),t.headers&&delete t.headers["Content-Length"],this.isSurge()||this.isLoon())this.isSurge()&&this.isNeedRewrite&&(t.headers=t.headers||{},Object.assign(t.headers,{"X-Surge-Skip-Scripting":!1})),$httpClient.post(t,(t,s,i)=>{!t&&s&&(s.body=i,s.statusCode=s.status),e(t,s,i)});else if(this.isQuanX())t.method="POST",this.isNeedRewrite&&(t.opts=t.opts||{},Object.assign(t.opts,{hints:!1})),$task.fetch(t).then(t=>{const{statusCode:s,statusCode:i,headers:r,body:o}=t;e(null,{status:s,statusCode:i,headers:r,body:o},o)},t=>e(t));else if(this.isNode()){this.initGotEnv(t);const{url:s,...i}=t;this.got.post(s,i).then(t=>{const{statusCode:s,statusCode:i,headers:r,body:o}=t;e(null,{status:s,statusCode:i,headers:r,body:o},o)},t=>{const{message:s,response:i}=t;e(s,i,i&&i.body)})}}time(t,e=null){const s=e?new Date(e):new Date;let i={"M+":s.getMonth()+1,"d+":s.getDate(),"H+":s.getHours(),"m+":s.getMinutes(),"s+":s.getSeconds(),"q+":Math.floor((s.getMonth()+3)/3),S:s.getMilliseconds()};/(y+)/.test(t)&&(t=t.replace(RegExp.$1,(s.getFullYear()+"").substr(4-RegExp.$1.length)));for(let e in i)new RegExp("("+e+")").test(t)&&(t=t.replace(RegExp.$1,1==RegExp.$1.length?i[e]:("00"+i[e]).substr((""+i[e]).length)));return t}msg(e=t,s="",i="",r){const o=t=>{if(!t)return t;if("string"==typeof t)return this.isLoon()?t:this.isQuanX()?{"open-url":t}:this.isSurge()?{url:t}:void 0;if("object"==typeof t){if(this.isLoon()){let e=t.openUrl||t.url||t["open-url"],s=t.mediaUrl||t["media-url"];return{openUrl:e,mediaUrl:s}}if(this.isQuanX()){let e=t["open-url"]||t.url||t.openUrl,s=t["media-url"]||t.mediaUrl;return{"open-url":e,"media-url":s}}if(this.isSurge()){let e=t.url||t.openUrl||t["open-url"];return{url:e}}}};if(this.isMute||(this.isSurge()||this.isLoon()?$notification.post(e,s,i,o(r)):this.isQuanX()&&$notify(e,s,i,o(r))),!this.isMuteLog){let t=["","==============📣系统通知📣=============="];t.push(e),s&&t.push(s),i&&t.push(i),console.log(t.join("\n")),this.logs=this.logs.concat(t)}}log(...t){t.length>0&&(this.logs=[...this.logs,...t]),console.log(t.join(this.logSeparator))}logErr(t,e){const s=!this.isSurge()&&!this.isQuanX()&&!this.isLoon();s?this.log("",`❗️${this.name}, 错误!`,t.stack):this.log("",`❗️${this.name}, 错误!`,t)}wait(t){return new Promise(e=>setTimeout(e,t))}done(t={}){const e=(new Date).getTime(),s=(e-this.startTime)/1e3;this.log("",`🔔${this.name}, 结束! 🕛 ${s} 秒`),this.log(),(this.isSurge()||this.isQuanX()||this.isLoon())&&$done(t)}}(t,e)}