mirror of
https://github.com/XiaoGe-LiBai/yangmao.git
synced 2025-12-17 05:58:14 +08:00
伊利牛奶小程序
This commit is contained in:
xiaoge
519
ylnn.js
Normal file
519
ylnn.js
Normal file
@@ -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);
|
||||
}
|
||||
Reference in New Issue
Block a user