From 08a78f94d9d2ca0744939c75faa02badb8112a54 Mon Sep 17 00:00:00 2001 From: xiaoge <2381919454@qq.com> Date: Tue, 30 May 2023 17:12:31 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=8A=E5=88=A9=E7=89=9B=E5=A5=B6=E5=B0=8F?= =?UTF-8?q?=E7=A8=8B=E5=BA=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ylnn.js | 519 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 519 insertions(+) create mode 100644 ylnn.js diff --git a/ylnn.js b/ylnn.js new file mode 100644 index 0000000..666de52 --- /dev/null +++ b/ylnn.js @@ -0,0 +1,519 @@ +/* +@随缘撸豆 + 伊利牛奶小程序 cron 45 12 * * * https://raw.githubusercontent.com/liuqi6968/-/main/ylnn.js + + 地址: #小程序://伊利/1jrunQEW7zfybgI + +5.27 完成签到 + +------------------------ 青龙--配置文件-贴心复制区域 ---------------------- +# 伊利牛奶 小程序 +#小程序://伊利/1jrunQEW7zfybgI +抓取 https://msmarket.msx.digitalyili.com 中的access-token +export ylnn=" access-token " +多账号用 换行 或 @ 分割 +注意脚本运行以后 在登录小程序ck会失效 + + +这个就是以前畅意100 以前玩过的可以找客服把积分移过到这个小程序里面 +*/ + +const $ = new Env("伊利牛奶") +const CK_NAME = "ylnn" +const Notify = 1 // 通知控制 +const tgLogFlag = 1 // 是否tg发送通知, 偷撸车使用, 默认0--不发送 +let msg = '' +//=========================================================================== + +//=========================================================================== +// +async function main(userInfo) { + + await userInfo.sign() + await userInfo.point() + + + +} + + +class UserInfo { + constructor(index, str) { + this.user_log = `${$.name}\n` + this.index = index + 1 + + if (tgLogFlag) { + try { + this.ck = str + } catch (error) { + console.log(error) + } + } + + + } + + + +async sign() { + let name = "签到"; + let options = { + method: "post", + url: `https://msmarket.msx.digitalyili.com/gateway/api/member/daily/sign`, + headers: { + "Host": "msmarket.msx.digitalyili.com", + "charset": "utf-8", + "content-type": "application/json", + "access-token": `${this.ck}` + }, + body: `{}` + }; + // console.log(options); + + let res = await httpRequest(options); + // console.log(res); + if (res.status == true) { + this.cusLog(`账号 ${this.index} : 签到成功`) + } else if (res.status == false) { + this.cusLog(`账号 ${this.index} : ck过期 请重新抓取 access-token`) + } else this.cusLog(`账号[${this.index}] ${name} 失败 ❌ 了呢`), console.log(res); + } +async point() { + let name = "个人信息"; + let options = { + method: "get", + url: `https://msmarket.msx.digitalyili.com/gateway/api/member/point`, + headers: { + "Host": "msmarket.msx.digitalyili.com", + "charset": "utf-8", + "content-type": "application/json", + "access-token": `${this.ck}` + } + + }; + // console.log(options); + + let res = await httpRequest(options); + // console.log(res); + if (res.status == true) { + this.cusLog(`账号 ${this.index} 总积分 : ${res.data} `) + } else if (res.status == false) { + this.cusLog(`账号 ${this.index} : ck过期 请重新抓取 access-token`) + } else this.cusLog(`账号[${this.index}] ${name} 失败 ❌ 了呢`), console.log(res); + } + + + + + + + + + + + + async Sendtg_bot() { + const TelegramBot = require('node-telegram-bot-api'); + const tg_token = process.env.tg_token; + // console.log(tg_token); + let bot = new TelegramBot(tg_token); + let msg = this.user_log; + // console.log(`=================`); + // console.log(this.chatId, msg); + await bot.sendMessage(this.chatId, msg); + } + + + cusLog(a) { + if (tgLogFlag) { + console.log(` ${a}`); + msg += `\n ${a}`; + this.user_log += `\n ${a}`; + } else { + console.log(` ${a}`); + msg += `\n ${a}`; + } + } + + +} + + + + + +/////////////////////////////////////////////////////////////////// + +// 入口 +!(async () => { + const notify = require("./sendNotify"); + $.doubleLog(await $.yiyan()); + let users = await getUsers(CK_NAME, async (index, element) => { + let userInfo = new UserInfo(index, element); + return userInfo; + }); + + list = []; + users.forEach(async element => { + list.push(main(element)); + }); + + await Promise.all(list); + +})() + .catch((e) => console.log(e)) + .finally(() => $.done()); + + +// ============================================================================== +async function getUsers(ckName, fnUserInfo) { + let userList = []; + let userCookie = process.env[ckName]; + let envSplicer = ["@", "\n", "&"]; + let userCount = 0; + if (userCookie) { + let e = envSplicer[0]; + for (let o of envSplicer) + if (userCookie.indexOf(o) > -1) { + e = o; + break; + } + let arr = userCookie.split(e); + for (let index = 0; index < arr.length; index++) { + const element = arr[index]; + element && userList.push(await fnUserInfo(index, element)); + } + userCount = userList.length; + } else { + console.log("抓取https://msmarket.msx.digitalyili.com 中的access-token"); + } + console.log(`共找到${userCount}个账号`), !0; + return userList; +} + +async function httpRequest(options, type = false) { + return new Promise((resolve) => { + try { + $.send(options, async (err, res_body, res_format, res) => { + if (err) { + console.log(`错误, 检查点--2`); return; + } + if (!type) { + resolve(res_body); + } resolve(res_format); + }); + } catch (error) { + console.log(error); + } + + }); +} + + + + + + + +// ============================================================================================================================ + +// 新的 env 函数, 增加自定义功能 yml-11.12改 合并 +function Env(name, env) { + "undefined" != typeof process && + JSON.stringify(process.env).indexOf("GITHUB") > -1 && + process.exit(0); + return new (class { + constructor(name, env) { + this.name = name; + this.notifyStr = ""; + this.notifyFlag = false; + this.startTime = new Date().getTime(); + Object.assign(this, env); + console.log(`${this.name} 开始运行: \n`); + } + isNode() { + return "undefined" != typeof module && !!module.exports; + } + send(options, e = () => { }) { + let m = options.method.toLowerCase(); + let t = options; + if (m != "get" && m != "post" && m != "put" && m != "delete") { + console.log(`无效的http方法: ${m}`); + return; + } + if (m == "get" && t.headers) { + // delete t.headers["Content-Type"]; + delete t.headers["Content-Length"]; + } else if (t.body && t.headers) { + if (t.headers["content-type"]) { + let tem = t.headers["content-type"]; + delete t.headers["content-type"]; + t.headers["Content-Type"] = tem; + } else if (t.body && t.headers) { + if (!t.headers["Content-Type"]) + t.headers["Content-Type"] = "application/x-www-form-urlencoded"; + } + } + if (this.isNode()) { + this.request = this.request ? this.request : require("request"); + this.request(options, function (error, response) { + if (error) throw new Error(error); + let res_body = response.body; + let res = response; + try { + if (typeof res_body == "string") { + if ($.isJsonStr(res_body)) { + res_body = JSON.parse(res_body); + let res_format = $.formatJson(response.body); + e(null, res_body, res_format, res); + } else e(null, res_body, res_format, res); + } else e(null, res_body, res_format, res); + } catch (error) { + console.log(error); + let a = `ENV -- request 请求错误, 检查点1\n${error}`; + e(a, null, null, null); + } + }); + } + } + isJsonStr(str) { + if (typeof str == "string") { + try { + if (typeof JSON.parse(str) == "object") { + return true; + } + } catch (e) { + return false; + } + } + return false; + } + formatJson(value) { + var json = value; + var i = 0, + len = 0, + tab = " ", + targetJson = "", + indentLevel = 0, + inString = false, + currentChar = null; + for (i = 0, len = json.length; i < len; i += 1) { + currentChar = json.charAt(i); + switch (currentChar) { + case "{": + case "[": + if (!inString) { + targetJson += currentChar + "\n" + repeat(tab, indentLevel + 1); + indentLevel += 1; + } else { + targetJson += currentChar; + } + break; + case "}": + case "]": + if (!inString) { + indentLevel -= 1; + targetJson += "\n" + repeat(tab, indentLevel) + currentChar; + } else { + targetJson += currentChar; + } + break; + case ",": + if (!inString) { + targetJson += ",\n" + repeat(tab, indentLevel); + } else { + targetJson += currentChar; + } + break; + case ":": + if (!inString) { + targetJson += ": "; + } else { + targetJson += currentChar; + } + break; + case " ": + case "\n": + case "\t": + if (inString) { + targetJson += currentChar; + } + break; + case '"': + if (i > 0 && json.charAt(i - 1) !== "\\") { + inString = !inString; + } + targetJson += currentChar; + break; + default: + targetJson += currentChar; + break; + } + } + function repeat(s, count) { + return new Array(count + 1).join(s); + } + function repeat(s, count) { + return new Array(count + 1).join(s); + } + return targetJson; + } + type(str) { + if (this.strCode(str) > 20) { + return console.log(`数据类型是: ${typeof str}`); + } + return console.log(`${str}数据类型是: ${typeof str}`); + } + strCode(str) { + var count = 0; + if (str) { + let len = str.length; + for (var i = 0; i < len; i++) { + if (str.charCodeAt(i) > 255) { + count += 2; + } else { + count++; + } + } + return count; + } else return 0; + } + async SendMsg(message) { + if (!message) return; + if (Notify > 0) { + if ($.isNode()) { + var notify = require("./sendNotify"); + await notify.sendNotify($.name, message); + } else { + console.log($.name, "", message); + } + } else { + console.log(message); + } + } + getMin(a, b) { + return a < b ? a : b; + } + getMax(a, b) { + return a < b ? b : a; + } + json2str(obj, c, encodeUrl = false) { + let ret = []; + for (let keys of Object.keys(obj).sort()) { + let v = obj[keys]; + if (v && encodeUrl) v = encodeURIComponent(v); + ret.push(keys + "=" + v); + } + return ret.join(c); + } + str2json(str, decodeUrl = false) { + let ret = {}; + for (let item of str.split("&")) { + if (!item) continue; + let idx = item.indexOf("="); + if (idx == -1) continue; + let k = item.substr(0, idx); + let v = item.substr(idx + 1); + if (decodeUrl) v = decodeURIComponent(v); + ret[k] = v; + } + return ret; + } + randomStr(len, up = false, charset = "abcdef0123456789") { + let str = ""; + for (let i = 0; i < len; i++) { + str += charset.charAt(Math.floor(Math.random() * charset.length)); + } + if (!up) { + return str; + } + return str.toUpperCase(); + } + phoneNum(phone_num) { + if (phone_num.length == 11) { + let data = phone_num.replace(/(\d{3})\d{4}(\d{4})/, "$1****$2"); + return data; + } else { + return phone_num; + } + } + randomInt(min, max) { + return Math.round(Math.random() * (max - min) + min); + } + async yiyan() { + this.request = this.request ? this.request : require("request"); + return new Promise((resolve) => { + var options = { + method: "GET", + url: "https://v1.hitokoto.cn/", + headers: {}, + }; + this.request(options, function (error, response) { + let data = JSON.parse(response.body); + let data_ = `[一言]: ${data.hitokoto} by--${data.from}`; + resolve(data_); + }); + }); + } + wait(t) { + return new Promise((e) => setTimeout(e, t * 1000)); + } + ts(type = false, _data = "") { + let myDate = new Date(); + let a = ""; + switch (type) { + case 10: + a = Math.round(new Date().getTime() / 1000).toString(); + break; + case 13: + a = Math.round(new Date().getTime()).toString(); + break; + case "h": + a = myDate.getHours(); + break; + case "m": + a = myDate.getMinutes(); + break; + case "y": + a = myDate.getFullYear(); + break; + case "h": + a = myDate.getHours(); + break; + case "mo": + a = myDate.getMonth(); + break; + case "d": + a = myDate.getDate(); + break; + case "ts2Data": + if (_data != "") { + time = _data; + if (time.toString().length == 13) { + let date = new Date(time + 8 * 3600 * 1000); + a = date.toJSON().substr(0, 19).replace("T", " "); + } else if (time.toString().length == 10) { + time = time * 1000; + let date = new Date(time + 8 * 3600 * 1000); + a = date.toJSON().substr(0, 19).replace("T", " "); + } + } + break; + default: + a = "未知错误,请检查"; + break; + } + return a; + } + doubleLog(a) { + console.log(` ${a}`); + msg += `\n ${a}`; + } + async done(t = {}) { + await $.SendMsg(msg); + const e = new Date().getTime(), + s = (e - this.startTime) / 1e3; + console.log(`\n${this.name} 运行结束，共运行了 ${s} 秒！`); + } + })(name, env); +}