diff --git a/wx_lccd.js b/wx_lccd.js new file mode 100644 index 0000000..cba3a61 --- /dev/null +++ b/wx_lccd.js @@ -0,0 +1,494 @@ +/** + * cron 5 15 * * * + * Show:微信小程序-莱充充电 + * 变量名: + * 变量值:https://shop.laichon.com/api/v1/ headers下的authorization 去掉JWT 只要后面的 # openid 多账户换行或者& + * 示例 ejxxxxxx#o0sa51.... + * scriptVersionNow = "0.0.1"; + */ + +const $ = new Env("微信小程序-莱充充电"); +const notify = $.isNode() ? require('./sendNotify') : ''; +let ckName = "wx_lccd"; +let envSplitor = ["&", "\n"]; //多账号分隔符 +let strSplitor = "#"; //多变量分隔符 +let userIdx = 0; +let userList = []; +class UserInfo { + constructor(str) { + this.index = ++userIdx; + this.ck = str.split(strSplitor)[0]; + this.ck1 = str.split(strSplitor)[1]; + this.ckStatus = true; + this.signStatus = "" + this.headers = { + "Host": "shop.laichon.com", + "Connection": "keep-alive", + "Content-Length": "9", + "authorization": "JWT " + this.ck, + "charset": "utf-8", + "openid": this.ck1, + "service-code": "WYC-MI-WEIXIN", + "User-Agent": "Mozilla/5.0 (Linux; Android 10; MI 8 Lite Build/QKQ1.190910.002; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/116.0.0.0 Mobile Safari/537.36 XWEB/1160027 MMWEBSDK/20231002 MMWEBID/2585 MicroMessenger/8.0.43.2480(0x28002B51) WeChat/arm64 Weixin NetType/WIFI Language/zh_CN ABI/arm64 MiniProgramEnv/android", + "content-type": "application/x-www-form-urlencoded", + "Accept-Encoding": "gzip,compress,br,deflate", + "Referer": "https://servicewechat.com/wxa68db1dabe823e7e/316/page-frame.html" + } + } + async main() { + + await this.task_sign(); + if (this.signStatus == 0) { + await this.task_sign(); + } else if (this.signStatus == 1) { + $.log(`签到翻倍`) + await this.task_double(); + } + $.log(`完成充电和看视频任务`) + await this.task_complete(3) + await this.task_complete(4) + } + async task_sign() { + try { + let options = { + fn: "签到", + method: "get", + url: `https://shop.laichon.com/api/v1/task/getSignTask`, + headers: this.headers, + } + let { body: result } = await $.httpRequest(options); + //console.log(options); + //console.log(result); + if (result.code == 1) { + if (result.data.isSign == 0) { + //未签到 + $.log(`未签到`) + this.signStatus = 0 + } else { + $.log(`已签到`) + this.signStatus = 1 + } + } else { + this.signStatus = 2 + } + } catch (e) { + console.log(e); + } + } + async task_double() { + try { + let options = { + fn: "签到翻倍", + method: "get", + url: `https://shop.laichon.com/api/v1/task/pointsDouble`, + headers: this.headers, + } + let { body: result } = await $.httpRequest(options); + //console.log(options); + //console.log(result); + if(result.code_key == "success"){ + $.log(`完成 +1`) + } + } catch (e) { + console.log(e); + } + } + async task_complete(id) { + try { + let options = { + fn: "完成任务", + method: "post", + url: `https://shop.laichon.com/api/v1/task/taskComplete`, + headers: this.headers, + body: `task_id=${id}` + } + let { body: result } = await $.httpRequest(options); + //console.log(options); + //console.log(result); + if(result.code_key == "success"){ + $.log(`完成 +1`) + } + } catch (e) { + console.log(e); + } + } +} + + + +!(async () => { + if (!(await checkEnv())) return; + if (userList.length > 0) { + let taskall = []; + for (let user of userList) { + if (user.ckStatus) { + taskall.push(await user.main()); + } + } + await Promise.all(taskall); + } + await $.sendMsg($.logs.join("\n")) +})() + .catch((e) => console.log(e)) + .finally(() => $.done()); + +//******************************************************** +/** + * 变量检查与处理 + * @returns + */ +async function checkEnv() { + let userCookie = ($.isNode() ? process.env[ckName] : $.getdata(ckName)) || ""; + if (userCookie) { + let e = envSplitor[0]; + for (let o of envSplitor) + if (userCookie.indexOf(o) > -1) { + e = o; + break; + } + for (let n of userCookie.split(e)) n && userList.push(new UserInfo(n)); + } else { + console.log(`未找到变量[${ckName}]`); + return; + } + return console.log(`共找到${userList.length}个账号`), true; //true == !0 +} +function Env(t, s) { + return new (class { + constructor(t, s) { + this.name = t; + this.data = null; + this.dataFile = "box.dat"; + this.logs = []; + this.logSeparator = "\n"; + this.startTime = new Date().getTime(); + Object.assign(this, s); + this.log("", `\ud83d\udd14${this.name}, \u5f00\u59cb!`); + } + 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; + } + 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), + s = this.path.resolve(process.cwd(), this.dataFile), + e = this.fs.existsSync(t), + i = !e && this.fs.existsSync(s); + if (!e && !i) return {}; + { + const i = e ? t : s; + 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), + s = this.path.resolve(process.cwd(), this.dataFile), + e = this.fs.existsSync(t), + i = !e && this.fs.existsSync(s), + o = JSON.stringify(this.data); + e ? this.writeFileSync(t, o) : i ? this.fs.writeFileSync(s, o) : this.fs.writeFileSync(t, o); + } + } + lodash_get(t, s, e) { + const i = s.replace(/\[(\d+)\]/g, ".$1").split("."); + let o = t; + for (const t of i) if (((o = Object(o)[t]), void 0 === o)) return e; + return o; + } + lodash_set(t, s, e) { + return Object(t) !== t + ? t + : (Array.isArray(s) || (s = s.toString().match(/[^.[\]]+/g) || []), + (s + .slice(0, -1) + .reduce( + (t, e, i) => + Object(t[e]) === t[e] + ? t[e] + : (t[e] = Math.abs(s[i + 1]) >> 0 == +s[i + 1] ? [] : {}), + t + )[s[s.length - 1]] = e), + t); + } + getdata(t) { + let s = this.getval(t); + if (/^@/.test(t)) { + const [, e, i] = /^@(.*?)\.(.*?)$/.exec(t), + o = e ? this.getval(e) : ""; + if (o) + try { + const t = JSON.parse(o); + s = t ? this.lodash_get(t, i, "") : s; + } catch (t) { + s = ""; + } + } + return s; + } + setdata(t, s) { + let e = !1; + if (/^@/.test(s)) { + const [, i, o] = /^@(.*?)\.(.*?)$/.exec(s), + h = this.getval(i), + a = i ? ("null" === h ? null : h || "{}") : "{}"; + try { + const s = JSON.parse(a); + this.lodash_set(s, o, t), (e = this.setval(JSON.stringify(s), i)); + } catch (s) { + const h = {}; + this.lodash_set(h, o, t), (e = this.setval(JSON.stringify(h), i)); + } + } else e = this.setval(t, s); + return e; + } + getval(t) { + if (this.isSurge() || this.isLoon()) { + return $persistentStore.read(t); + } else if (this.isQuanX()) { + return $prefs.valueForKey(t); + } else if (this.isNode()) { + this.data = this.loaddata(); + return this.data[t]; + } else { + return this.data && this.data[t] || null; + } + } + setval(t, s) { + if (this.isSurge() || this.isLoon()) { + return $persistentStore.write(t, s); + } else if (this.isQuanX()) { + return $prefs.setValueForKey(t, s); + } else if (this.isNode()) { + this.data = this.loaddata(); + this.data[s] = t; + this.writedata(); + return true; + } else { + return this.data && this.data[s] || 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(); + if (t) { + t.headers = t.headers ? t.headers : {}; + if (typeof t.headers.Cookie === "undefined" && typeof t.cookieJar === "undefined") { + t.cookieJar = this.ckjar; + } + } + } + /** + * @param {Object} options + * @returns {String} 将 Object 对象 转换成 queryStr: key=val&name=senku + */ + queryStr(options) { + return Object.entries(options) + .map(([key, value]) => `${key}=${typeof value === 'object' ? JSON.stringify(value) : value}`) + .join('&'); + } + isJSONString(str) { + try { + var obj = JSON.parse(str); + if (typeof obj == 'object' && obj) { + return true; + } else { + return false; + } + } catch (e) { + return false; + } + } + isJson(obj) { + var isjson = typeof (obj) == "object" && Object.prototype.toString.call(obj).toLowerCase() == "[object object]" && !obj.length; + return isjson; + } + async sendMsg(message) { + if (!message) return; + if ($.isNode()) { + await notify.sendNotify($.name, message) + } else { + $.msg($.name, '', message) + } + } + async httpRequest(options) { + let t = { + ...options + }; + if (!t.headers) { + t.headers = {} + } + if (t.params) { + t.url += '?' + this.queryStr(t.params); + } + t.method = t.method.toLowerCase(); + if (t.method === 'get') { + delete t.headers['Content-Type']; + delete t.headers['Content-Length']; + delete t.headers['content-Type']; + delete t.headers['content-Length']; + delete t["body"] + } + if (t.method === 'post') { + let contentType; + + if (!t.body) { + t.body = "" + } else { + if (typeof t.body == "string") { + if (this.isJSONString(t.body)) { + contentType = 'application/json' + } else { + contentType = 'application/x-www-form-urlencoded' + } + } else if (this.isJson(t.body)) { + t.body = JSON.stringify(t.body); + contentType = 'application/json'; + } + } + if (!t.headers['Content-Type']) { + t.headers['Content-Type'] = contentType; + } + delete t.headers['Content-Length']; + } + if (this.isNode()) { + this.initGotEnv(t); + let httpResult = await this.got(t); + if (this.isJSONString(httpResult.body)) { + httpResult.body = JSON.parse(httpResult.body) + } + return httpResult; + } + if (this.isQuanX()) { + t.method = t.method.toUpperCase() + return new Promise((resolve, reject) => { + $task.fetch(t).then(response => { + if (this.isJSONString(response.body)) { + response.body = JSON.parse(response.body) + } + resolve(response) + }) + }) + } + } + randomNumber(length) { + const characters = '0123456789'; + return Array.from({ length }, () => characters[Math.floor(Math.random() * characters.length)]).join(''); + } + randomString(length) { + const characters = 'abcdefghijklmnopqrstuvwxyz0123456789'; + return Array.from({ length }, () => characters[Math.floor(Math.random() * characters.length)]).join(''); + } + timeStamp() { + return new Date().getTime() + } + uuid() { + return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function (c) { + var r = Math.random() * 16 | 0, + v = c == 'x' ? r : (r & 0x3 | 0x8); + return v.toString(16); + }); + } + time(t) { + let s = { + "M+": new Date().getMonth() + 1, + "d+": new Date().getDate(), + "H+": new Date().getHours(), + "m+": new Date().getMinutes(), + "s+": new Date().getSeconds(), + "q+": Math.floor((new Date().getMonth() + 3) / 3), + S: new Date().getMilliseconds(), + }; + /(y+)/.test(t) && + (t = t.replace( + RegExp.$1, + (new Date().getFullYear() + "").substr(4 - RegExp.$1.length) + )); + for (let e in s) + new RegExp("(" + e + ")").test(t) && + (t = t.replace( + RegExp.$1, + 1 == RegExp.$1.length + ? s[e] + : ("00" + s[e]).substr(("" + s[e]).length) + )); + return t; + } + msg(s = t, e = "", i = "", o) { + const h = (t) => + !t || (!this.isLoon() && this.isSurge()) + ? t + : "string" == typeof t + ? this.isLoon() + ? t + : this.isQuanX() + ? { "open-url": t } + : void 0 + : "object" == typeof t && (t["open-url"] || t["media-url"]) + ? this.isLoon() + ? t["open-url"] + : this.isQuanX() + ? t + : void 0 + : void 0; + this.isMute || + (this.isSurge() || this.isLoon() + ? $notification.post(s, e, i, h(o)) + : this.isQuanX() && $notify(s, e, i, h(o))); + let logs = ['', '==============📣系统通知📣==============']; + logs.push(t); + e ? logs.push(e) : ''; + i ? logs.push(i) : ''; + console.log(logs.join('\n')); + this.logs = this.logs.concat(logs); + } + log(...t) { + t.length > 0 && (this.logs = [...this.logs, ...t]), + console.log(t.join(this.logSeparator)); + } + logErr(t, s) { + const e = !this.isSurge() && !this.isQuanX() && !this.isLoon(); + e + ? this.log("", `\u2757\ufe0f${this.name}, \u9519\u8bef!`, t.stack) + : this.log("", `\u2757\ufe0f${this.name}, \u9519\u8bef!`, t); + } + wait(t) { + return new Promise((s) => setTimeout(s, t)); + } + done(t = {}) { + const s = new Date().getTime(), + e = (s - this.startTime) / 1e3; + this.log( + "", + `\ud83d\udd14${this.name}, \u7ed3\u675f! \ud83d\udd5b ${e} \u79d2` + ) + this.log() + if (this.isNode()) { + process.exit(1) + } + if (this.isQuanX()) { + $done(t) + } + } + })(t, s); +}