update

jd_19E_friends.js

@@ -0,0 +1,654 @@
+if (process.env.JD_19E != "true") {
+    console.log('\n默认不运行,安全性自行衡量,设置变量export JD_19E="true"来运行\n')
+    return
+}
+/*
+建议手动先点开一次
+1 8,15 * * * jd_19E_friends.js
+快速升级，跑一次即可
+*/
+
+
+const $ = new Env('热爱奇旅升级');
+
+const jdCookieNode = $.isNode() ? require('./jdCookie.js') : '';
+
+let cookiesArr = [],
+    cookie = '';
+let secretp = '',
+    inviteId = []
+
+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'), ...jsonParse($.getdata('CookiesJD') || "[]").map(item => item.cookie)].filter(item => !!item);
+}
+const JD_API_HOST = 'https://api.m.jd.com/client.action';
+
+$.shareCodesArr = [];
+let groups = []
+!(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;
+    }
+    console.log('\n仅升级，快速跑完\n')
+    await getUA()
+    for (let i = 0; i < cookiesArr.length; i++) {
+        if (cookiesArr[i]) {
+            cookie = cookiesArr[i];
+            $.UserName = decodeURIComponent(cookie.match(/pt_pin=([^; ]+)(?=;?)/) && cookie.match(/pt_pin=([^; ]+)(?=;?)/)[1])
+            $.index = i + 1;
+            $.isLogin = true;
+            $.nickName = '';
+            message = '';
+            console.log(`\n******开始【京东账号${$.index}】${$.nickName || $.UserName}*********\n`);
+            //   await shareCodesFormat()
+            $.newShareCodes = []
+			await get_secretp()
+			if ($.huobao == false) {
+			console.log(`火爆`); continue;
+			}
+            await promote_collectAtuoScore() //定时领取
+            let res
+			try {
+				res = await promote_getTaskDetail()
+                await promote_sign()
+				do {
+                    var ret = await promote_raise()
+                    await $.wait(1000)
+                } while (ret)
+            } catch (e) {
+                $.log('', `❌ ${$.name}, 失败! 原因: ${e}!`, '')
+            }
+        }
+    }      
+})()
+.catch((e) => {
+        $.log('', `❌ ${$.name}, 失败! 原因: ${e}!`, '')
+    })
+    .finally(() => {
+        $.done();
+    })
+
+function transform(str) {
+    var REQUEST = new Object,
+        data = str.slice(str.indexOf("?") + 1, str.length - 1),
+        aParams = data.substr(1).split("&");
+    for (i = 0; i < aParams.length; i++) {　　
+        var aParam = aParams[i].split("=");　　
+        REQUEST[aParam[0]] = aParam[1]
+    }
+    return REQUEST
+}
+
+function get_secretp() {
+    let body = {};
+    return new Promise((resolve) => {
+        $.post(taskPostUrl("promote_getHomeData", body), async(err, resp, data) => {
+            //console.log(data)
+            try {
+                if (err) {
+                    console.log(`${JSON.stringify(err)}`)
+                    console.log(`${$.name} API请求失败，请检查网路重试`)
+                } else {
+                    if (safeGet(data)) {
+                        data = JSON.parse(data);
+						$.huobao = data.data.success
+                        if (data.code == 0) {
+                            if (data.data && data.data.bizCode === 0) {
+                                secretp = data.data.result.homeMainInfo.secretp
+								
+                          }
+                        } 
+						
+                    }
+                }
+            } catch (e) {
+                $.logErr(e, resp)
+            } finally {
+                resolve(data);
+            }
+        })
+    })
+}
+
+function promote_sign() {
+    let body = { "ss": { "extraData": { "log": "", "sceneid": "RAhomePageh5" }, "secretp": secretp, "random": randomString(6) } };
+    return new Promise((resolve) => {
+        $.post(taskPostUrl("promote_sign", body), async(err, resp, data) => {
+            try {
+                if (err) {
+                    console.log(`${JSON.stringify(err)}`)
+                    console.log(`${$.name} API请求失败，请检查网路重试`)
+                } else {
+                    if (safeGet(data)) {
+                        data = JSON.parse(data);
+                        if (data.code === 0) {
+                            if (data.data && data['data']['bizCode'] === 0) {
+
+                                console.log(`签到成功`)
+                                resolve(true)
+                            } else {
+                                resolve(false)
+                            }
+                        } else {
+                            console.log(`签到失败:${JSON.stringify(data)}\n`)
+                            resolve(false)
+                        }
+                    }
+                }
+            } catch (e) {
+                $.logErr(e, resp)
+            } finally {
+                resolve(data);
+            }
+        })
+    })
+}
+
+function promote_collectAtuoScore() {
+    let body = { "ss": { "extraData": { "log": "", "sceneid": "RAhomePageh5" }, "secretp": secretp, "random": randomString(6) } };
+    return new Promise((resolve) => {
+        $.post(taskPostUrl("promote_collectAutoScore", body), async(err, resp, data) => {
+            try {
+                if (err) {
+                    console.log(`${JSON.stringify(err)}`)
+                    console.log(`${$.name} API请求失败，请检查网路重试`)
+                } else {
+                    if (safeGet(data)) {
+                        data = JSON.parse(data);
+                        if (data.code === 0) {
+                            if (data.data && data['data']['bizCode'] === 0) {
+
+                                console.log(`成功领取${data.data.result.produceScore}个币`)
+                            }
+                        } else {
+                            //console.log(`\n\nsecretp失败:${JSON.stringify(data)}\n`)
+                        }
+                    }
+                }
+            } catch (e) {
+                $.logErr(e, resp)
+            } finally {
+                resolve(data);
+            }
+        })
+    })
+}
+
+function promote_getTaskDetail() {
+    let body = {};
+    return new Promise((resolve) => {
+        $.post(taskPostUrl("promote_getTaskDetail", body), async(err, resp, data) => {
+            try {
+                if (err) {
+                    console.log(`${JSON.stringify(err)}`)
+                    console.log(`${$.name} API请求失败，请检查网路重试`)
+                } else {
+                    if (safeGet(data)) {
+                        data = JSON.parse(data);
+                        if (data.code === 0) {
+                            if (data.data && data['data']['bizCode'] === 0) {
+								inviteIdss = data.data.result.inviteId
+								if (!inviteIdss) {
+                                    console.log("黑号")
+                                    resolve("")
+                                }
+								console.log(inviteIdss)
+                                inviteId.push(data.data.result.inviteId)
+                                resolve(data.data.result)
+                            }
+                        } else {
+                            //console.log(`\n\nsecretp失败:${JSON.stringify(data)}\n`)
+                        }
+                    }
+                }
+            } catch (e) {
+                $.logErr(e, resp)
+            } finally {
+                resolve(data);
+            }
+        })
+    })
+}
+function promote_collectScore(taskToken, taskId) {
+    let body = { "taskId": taskId, "taskToken": taskToken, "actionType": 1, "ss": { "extraData": { "log": "", "sceneid": "RAhomePageh5" }, "secretp": secretp, "random": randomString(6) } };
+
+    return new Promise((resolve) => {
+        $.post(taskPostUrl("promote_collectScore", body), async(err, resp, data) => {
+            try {
+                if (err) {
+                    console.log(`${JSON.stringify(err)}`)
+                    console.log(`${$.name} API请求失败，请检查网路重试`)
+                } else {
+                    if (safeGet(data)) {
+                        data = JSON.parse(data);
+                        if (data.code === 0) {
+                            if (data.data && data['data']['bizCode'] === 0) {
+                                console.log(data.msg)
+                            }
+                        } else {
+                            console.log(`\n 失败:${JSON.stringify(data)}\n`)
+                        }
+                    }
+                }
+            } catch (e) {
+                $.logErr(e, resp)
+            } finally {
+                resolve(data);
+            }
+        })
+    })
+}
+
+function help(inviteId) {
+    let body = { "actionType": 0, "inviteId": inviteId,"ss": { "extraData": { "log": "", "sceneid": "RAhomePageh5" }, "secretp": secretp, "random": randomString(6) } };
+    return new Promise((resolve) => {
+        $.post(taskPostUrl("promote_collectScore", body), async(err, resp, data) => {
+            try {
+                if (err) {
+                    console.log(`${JSON.stringify(err)}`)
+                    console.log(`${$.name} API请求失败，请检查网路重试`)
+                } else {
+                    if (safeGet(data)) {
+                        data = JSON.parse(data);
+                        //console.log(data)
+                        //if (data.data.bizCode === 0) {
+                            //if (data.data && data['data']['bizCode'] === 0) {
+                              //  console.log(data.bizMsg)
+                            //}
+                        //} else {
+                           // console.log(`\n 失败:` + data.bizMsg)
+                       // }
+                    }
+                }
+            } catch (e) {
+                $.logErr(e, resp)
+            } finally {
+                resolve(data);
+            }
+        })
+    })
+}
+function promote_raise() {
+    let s = Math.floor((Math.random()*3)) +1
+    let body = {"scenceId":s, "ss": { "extraData": { "log": "", "sceneid": "RAhomePageh5" }, "secretp": secretp, "random": randomString(6) } };
+    return new Promise((resolve) => {
+        $.post(taskPostUrl("promote_raise", body), async(err, resp, data) => {
+            try {
+                if (err) {
+                    console.log(`${JSON.stringify(err)}`)
+                    console.log(`${$.name} API请求失败，请检查网路重试`)
+                } else {
+                    if (safeGet(data)) {
+                        data = JSON.parse(data);
+                        if (data.code === 0) {
+                            if (data.data && data['data']['bizCode'] === 0) {
+
+                                console.log(`升级成功`)
+                                resolve(true)
+                            } else {
+                                resolve(false)
+                            }
+                        } else {
+                            console.log(`升级失败:${JSON.stringify(data)}\n`)
+                            resolve(false)
+                        }
+                    }
+                }
+            } catch (e) {
+                $.logErr(e, resp)
+            } finally {
+                resolve(data);
+            }
+        })
+    })
+}
+function promote_pk_getHomeData() {
+    return new Promise((resolve) => {
+        $.post(taskPostUrl("promote_pk_getHomeData", {}), async(err, resp, data) => {
+            try {
+                if (err) {
+                    console.log(`${JSON.stringify(err)}`)
+                    console.log(`${$.name} API请求失败，请检查网路重试`)
+                } else {
+                    if (safeGet(data)) {
+                        data = JSON.parse(data);
+                        } else {
+                            console.log(`\n\n 失败:${JSON.stringify(data)}\n`)
+                        }
+                    }
+            } catch (e) {
+                $.logErr(e, resp)
+            } finally {
+                resolve(data);
+            }
+        })
+    })
+}
+
+function getEncryptedPinColor() {
+    return new Promise((resolve) => {
+        $.post(taskPostUrl2("getEncryptedPinColor", {}), async(err, resp, data) => {
+            try {
+                if (err) {
+                    console.log(`${JSON.stringify(err)}`)
+                    console.log(`${$.name} API请求失败，请检查网路重试`)
+                } else {
+                    if (safeGet(data)) {
+                        data = JSON.parse(data);
+                        } else {
+                            console.log(`\n\n 失败:${JSON.stringify(data)}\n`)
+                        }
+                    }
+            } catch (e) {
+                $.logErr(e, resp)
+            } finally {
+                resolve(data);
+            }
+        })
+    })
+}
+
+
+function collectFriendRecordColor(mpin) {
+    return new Promise((resolve) => {
+        $.post(taskPostUrl("collectFriendRecordColor", {"mpin": mpin, "businessCode": "20136", "assistType": "2", "shareSource": 1}), async(err, resp, data) => {
+            try {
+                if (err) {
+                    console.log(`${JSON.stringify(err)}`)
+                    console.log(`${$.name} API请求失败，请检查网路重试`)
+                } else {
+                    if (safeGet(data)) {
+                        data = JSON.parse(data);
+                        } else {
+                            console.log(`\n\n 失败:${JSON.stringify(data)}\n`)
+                        }
+                    }
+            } catch (e) {
+                $.logErr(e, resp)
+            } finally {
+                resolve(data);
+            }
+        })
+    })
+}
+
+
+function promote_pk_joinGroup(groupJoinInviteId) {
+    let body = {"inviteId": groupJoinInviteId, "ss": {extraData: {log: "", sceneid: 'RAhomePageh5'}, secretp: secretp, random: randomString(6)}, "confirmFlag": 1};
+    return new Promise((resolve) => {
+        $.post(taskPostUrl("promote_pk_joinGroup", body), async(err, resp, data) => {
+            try {
+                if (err) {
+                    console.log(`${JSON.stringify(err)}`)
+                    console.log(`${$.name} API请求失败，请检查网路重试`)
+                } else {
+                    if (safeGet(data)) {
+                        data = JSON.parse(data);
+                        } else {
+                            console.log(`\n\n 失败:${JSON.stringify(data)}\n`)
+                        }
+                    }
+            } catch (e) {
+                $.logErr(e, resp)
+            } finally {
+                resolve(data);
+            }
+        })
+    })
+}
+function taskPostUrl(functionId, body) {
+    return {
+        //functionId=promote_getHomeData&body={}&client=wh5&clientVersion=1.0.0
+        url: `${JD_API_HOST}`,
+        body: `functionId=${functionId}&body=${escape(JSON.stringify(body))}&client=m&clientVersion=-1&appid=signed_wh5`,
+        headers: {
+            'Cookie': cookie,
+            'Host': 'api.m.jd.com',
+            'Connection': 'keep-alive',
+            'Content-Type': 'application/x-www-form-urlencoded',
+            "User-Agent": $.UA,
+            'Origin': 'https://wbbny.m.jd.com',
+            'Accept-Language': 'zh-cn',
+            'Accept-Encoding': 'gzip, deflate, br',
+        }
+    }
+}
+
+function taskPostUrl2(functionId, body) {
+    return {
+        url: `${JD_API_HOST}?functionId=${functionId}&client=wh5`,
+        body: `body=${escape(JSON.stringify(body))}`,
+        headers: {
+            'Cookie': cookie,
+            'Host': 'api.m.jd.com',
+            'Connection': 'keep-alive',
+            'Content-Type': 'application/x-www-form-urlencoded',
+            "User-Agent": $.UA,
+            'Accept-Language': 'zh-cn',
+            'Accept-Encoding': 'gzip, deflate, br',
+            'Origin': 'https://wbbny.m.jd.com',
+        }
+    }
+}
+
+
+
+function getUA() {
+    $.UA = `jdapp;android;10.0.6;11;9363537336739353-2636733333439346;network/wifi;model/KB2000;addressid/138121554;aid/9657c795bc73349d;oaid/;osVer/30;appBuild/88852;partner/oppo;eufv/1;jdSupportDarkMode/0;Mozilla/5.0 (Linux; Android 11; KB2000 Build/RP1A.201005.001; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/77.0.3865.120 MQQBrowser/6.2 TBS/045537 Mobile Safari/537.36`
+}
+
+function randomString(e) {
+    e = e || 32;
+    let t = "abcdef0123456789",
+        a = t.length,
+        n = "";
+    for (i = 0; i < e; i++)
+        n += t.charAt(Math.floor(Math.random() * a));
+    return n
+}
+
+function randomNum(e) {
+    e = e || 32;
+    let t = "0123456789",
+        a = t.length,
+        n = "";
+    for (i = 0; i < e; i++)
+        n += t.charAt(Math.floor(Math.random() * a));
+    return n
+}
+
+function safeGet(data) {
+    try {
+        if (typeof JSON.parse(data) == "object") {
+            return true;
+        }
+    } catch (e) {
+        console.log(e);
+        console.log(`京东服务器访问数据为空，请检查自身设备网络情况`);
+        return false;
+    }
+}
+
+function jsonParse(str) {
+    if (typeof str == "string") {
+        try {
+            return JSON.parse(str);
+        } catch (e) {
+            console.log(e);
+            $.msg($.name, '', '请勿随意在BoxJs输入框修改内容\n建议通过脚本去获取cookie')
+            return [];
+        }
+    }
+}
+// prettier-ignore
+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)
+}

jd_dpqd.js

@@ -30,25 +30,24 @@ const token = [
   "4BE1B58FE1360409A5967CAD1127B5A8",
   "34864F266AFC02DDB7EEAD5A2AF9B4F7",
   "7166EF6ED03BA34C3DBBA1ADB27E56C1",
-  "09947018BD0B4AC7E218519F81551296",
+  "C031053EDBD2C047C072C53F80D82577",
   "18FB7E1DE514D5E40D880585D4145DEC",
   "CACEC89AD3A20309748FEC03B0B0C50C",
-  "D881655EDC90A9B4387ACFE495CA3F18",
+  "E7C2D644F989BBA3ADB563A682E591C6",
   "6359776E10B514A773610D94579BFA3B",
   "D40F4D162DD53F2CE9F1C48176461634",
   "3AF4B68A4BB3BD09D371B766E6A1B721",
   "273EC9E9CA27DFDD85478972A1A0ED6F",
   "A7DDDEAE3438B27260BDC8B1A555CE6F",
   "3B27B2B9E70249C339D66F27B7E133F0",
-  "BE26A80288BECA1CAB80B5643CE716B4",
+  "AED3C29E6DA2F0AA84C08F0F726D59C2",
   "6CB820BAC6C0CD8D1F90C342F0EA1018",
   "ADF510FDA71E07151B8F8AD4964A5D90",
-  "37F05E334A3F6D36E54E13892CE379A9",
+  "1936460C9F6D9543EBED5443D76AF14C",
   "35BA76ED53A953E03F77EE5379C28BE5",
   "038B83D1D0D374F58821C7EDC4F3B5AE",
   "0EED5C32E8002D6EF892D3995A0A9AA5",
   "D5A12069E47F17718EF7E7381444A5FE",
-  "80BD65344753D10B8C61EA2EF4B61946",
   "501933E61B74CEE450856EDD10AAF7CB",
   "9F64084BD36FE0EBCDE1EDC956656501",
   "7516691B34E89137D3C911BBF7D86ACD"

jd_joy_park_run.ts

@@ -2,7 +2,8 @@
 汪汪乐园-跑步+组队
 默认翻倍到0.04红包结束,修改请设置变量
 export JD_JOY_PARK_RUN_ASSETS="0.04"
-20 0-23/2 * * * jd_joy_park_run.ts
+cron:30 0 * * * *
+30 0 * * * * jd_joy_park_run.ts
 new Env('极速版汪汪赛跑');
 
 **/
@@ -27,7 +28,7 @@ let assets: number = 0, captainId: string = '', h5stTool: H5ST = null
 
   
 
-    assets = parseFloat(process.env.JD_JOY_PARK_RUN_ASSETS || '0.08')
+    assets = parseFloat(process.env.JD_JOY_PARK_RUN_ASSETS || '0.04')
     let rewardAmount: number = 0
     try {
       h5stTool = new H5ST('448de', 'jdltapp;', fp_448de)
@@ -39,18 +40,23 @@ let assets: number = 0, captainId: string = '', h5stTool: H5ST = null
         console.log('可提现', rewardAmount)
         res = await api('runningPrizeDraw', {"linkId": "L-sOanK_5RJCz7I314FpnQ", "type": 2})
         await wait(2000)
+        if (res.success){
                console.log(res.data.message)
+           } else {
+                console.log('提现失败：', res.errMsg)
+             }
       }
 
       for (let t of res?.data?.detailVos || []) {
-        if (getDate(new Date(t.createTime)) === new Date().getDate()) {
+        if (t.amount > 0 && getDate(new Date(t.createTime)) === new Date().getDate()) {
           sum = add(sum, t.amount)
+          success++
         } else {
           break
         }
       }
-      console.log('成功', success)
-      console.log('收益', sum)
+      console.log('今日成功', success, '次')
+      console.log('今日收益', sum, '元')
 
       res = await team('runningTeamInfo', {"linkId": "L-sOanK_5RJCz7I314FpnQ"})
       if (!captainId) {
@@ -58,10 +64,12 @@ let assets: number = 0, captainId: string = '', h5stTool: H5ST = null
           console.log('成为队长')
           captainId = res.data.captainId
         } else if (res.data.members.length !== 6) {
-          console.log('队伍未满', res.data.members.length)
+          console.log('队伍未满', res.data.members.length, '人')
+          console.log('战队收益', res.data.teamSumPrize, '元')
           captainId = res.data.captainId
         } else {
-          console.log('队伍已满')
+          console.log('队伍已满', res.data.members.length, '人')
+          console.log('战队收益', res.data.teamSumPrize, '元')
         }
       } else if (captainId && res.data.members.length === 0) {
         console.log('已有组队ID，未加入队伍')
@@ -82,28 +90,57 @@ let assets: number = 0, captainId: string = '', h5stTool: H5ST = null
           o2s(res, '组队失败')
         }
       } else {
-        console.log('已组队', res.data.members.length)
-        console.log('战队收益', res.data.teamSumPrize)
+        console.log('已组队', res.data.members.length, '人')
+        console.log('战队收益', res.data.teamSumPrize, '元')
       }
 
 
       h5stTool = new H5ST('b6ac3', 'jdltapp;', fp_b6ac3)
       await h5stTool.__genAlgo()
       res = await runningPageHome()
-      console.log('🧧', res.data.runningHomeInfo.prizeValue)
-      await wait(2000)
+      console.log('🧧总金额', res.data.runningHomeInfo.prizeValue, '元')
       
-      console.log('能量恢复中', secondsToMinutes(res.data.runningHomeInfo.nextRunningTime / 1000), '能量棒', res.data.runningHomeInfo.energy)
-      if (res.data.runningHomeInfo.nextRunningTime && res.data.runningHomeInfo.nextRunningTime / 1000 < 300) {
+      let energy: number = res.data.runningHomeInfo.energy
+      console.log('💊 X', res.data.runningHomeInfo.energy, '个能量棒') 
+      await wait(2000)
+      if (res.data.runningHomeInfo.nextRunningTime){
+      console.log('⏳体力恢复中，还有', secondsToMinutes(res.data.runningHomeInfo.nextRunningTime / 1000))
+        if (res.data.runningHomeInfo.nextRunningTime / 1000 < 300) {
           await wait(res.data.runningHomeInfo.nextRunningTime)
           res = await runningPageHome()
-        console.log('能量恢复中', secondsToMinutes(res.data.runningHomeInfo.nextRunningTime / 1000), '能量棒', res.data.runningHomeInfo.energy)
+          console.log('体力恢复完成，开始跑步....')
           await wait(1000)
+        } else {
+            console.log('⏳等体力恢复在跑吧！');
+            continue;
+               }
+      } else {
+          console.log('体力已恢复，开始跑步....')
       }
 
+      await startRunning(res, assets)
+      for (let i = 0; i < energy; i++) {
+        console.log('💉消耗能量棒跑步....')
+        res = await api('runningUseEnergyBar', {"linkId": "L-sOanK_5RJCz7I314FpnQ"})
+        //console.log(res.errMsg)
+        res = await runningPageHome()
+        await startRunning(res, assets)
+        await wait(1000)
+      }
+      res = await runningPageHome()
+      console.log('🧧总金额', res.data.runningHomeInfo.prizeValue, '元')
+      await wait(2000)
+    } catch (e) {
+      console.log('Error', e)
+      await wait(3000)
+    }
+  }
+})()
+
+async function startRunning(res: any, assets: number) {
   if (!res.data.runningHomeInfo.nextRunningTime) {
     console.log('终点目标', assets)
-        for (let i = 0; i < 10; i++) {
+    for (let i = 0; i < 5; i++) {
       res = await api('runningOpenBox', {"linkId": "L-sOanK_5RJCz7I314FpnQ"})
       if (parseFloat(res.data.assets) >= assets) {
         let assets: number = parseFloat(res.data.assets)
@@ -113,28 +150,19 @@ let assets: number = 0, captainId: string = '', h5stTool: H5ST = null
       } else {
         if (res.data.doubleSuccess) {
           console.log('翻倍成功', parseFloat(res.data.assets))
-              await wait(5000)
+          await wait(10000)
         } else if (!res.data.doubleSuccess && !res.data.runningHomeInfo.runningFinish) {
           console.log('开始跑步', parseFloat(res.data.assets))
-              await wait(5000)
+          await wait(10000)
         } else {
           console.log('翻倍失败')
           break
         }
       }
-          await wait(5000)
     }
   }
-
-      res = await runningPageHome()
-      console.log('🧧', res.data.runningHomeInfo.prizeValue)
-      await wait(2000)
-    } catch (e) {
-      console.log('Error', e)
   await wait(3000)
 }
-  }
-})()
 
 async function api(fn: string, body: object) {
   let timestamp: number = Date.now(), h5st: string = ''

jd_tanwei.js

@@ -64,7 +64,9 @@ async function twqyj() {
     for (let key of Object.keys(tk.assignmentList).reverse()){
         let vo = tk.assignmentList[key]
         if (vo.completionFlag || vo.assignmentType == 30) {
-            console.log('任务已完成')
+            console.log('此任务已完成')
+        } else if (new Date(vo.assignmentStartTime).getTime() > Date.now()) {
+            console.log('此任务还没到开放时间:',vo.assignmentStartTime)
         } else {
 		    if (vo.ext && vo.ext.extraType == 'sign1'){
 	              await sign(encryptProjectId,vo.encryptAssignmentId)