mirror of
https://github.com/zjk2017/ArcadiaScriptPublic.git
synced 2025-12-16 23:19:29 +08:00
531 lines
18 KiB
JavaScript
531 lines
18 KiB
JavaScript
/*
|
||
@随缘撸豆
|
||
江铃智行 app
|
||
cron: 22 8,19 * * *
|
||
|
||
2024.8.8 就一个签到 随缘玩吧 服务器闲着也是闲着
|
||
|
||
------------------------ 青龙--配置文件-贴心复制区域 ----------------------
|
||
抓取superapp.jmc.com.cn中的Access-Token
|
||
|
||
export jlzx="Access-Token "
|
||
|
||
多账号用 换行 或 @ 分割
|
||
一天1~5分 挂一年能换点东西
|
||
======================================================================================================================================
|
||
20240808 ArcadiaScriptPublic 频道：https://t.me/ArcadiaScript 群组：https://t.me/ArcadiaScriptPublic 拉库https://github.com/zjk2017/ArcadiaScriptPublic
|
||
注释掉一言报错 签到前后打印总积分 看到底签到了没有
|
||
======================================================================================================================================
|
||
*/
|
||
|
||
const $ = new Env("江铃智行")
|
||
const CK_NAME = "jlzx"
|
||
const Notify = 0 // 通知控制
|
||
const tgLogFlag = 1 // 是否tg发送通知, 偷撸车使用, 默认0--不发送
|
||
let msg = ''
|
||
//===========================================================================
|
||
|
||
//===========================================================================
|
||
|
||
async function main(userInfo) {
|
||
|
||
await userInfo.grxx()
|
||
await userInfo.sign()
|
||
// 使用该函数
|
||
sleepForTenSeconds().then(() => {
|
||
userInfo.grxx()
|
||
|
||
console.log('休眠结束 签到之后..............');
|
||
});
|
||
// await userInfo.Sendtg_bot()
|
||
|
||
|
||
|
||
}
|
||
function sleepForTenSeconds() {
|
||
return new Promise(resolve => {
|
||
setTimeout(() => {
|
||
console.log('休眠了10秒！');
|
||
resolve(); // 通知Promise已完成
|
||
}, 10000); // 10000毫秒 = 10秒
|
||
});
|
||
}
|
||
class UserInfo {
|
||
constructor(index, str) {
|
||
this.user_log = `${$.name}\n`
|
||
this.index = index + 1
|
||
|
||
if (tgLogFlag) {
|
||
try {
|
||
this.mopenid = str.split("##")[0]
|
||
this.chatId = str.split("##")[1]
|
||
|
||
this.ck = str
|
||
|
||
//this.ts = ts13()
|
||
} catch (error) {
|
||
console.log(error)
|
||
}
|
||
}
|
||
|
||
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
async sign() {
|
||
let name = "签到";
|
||
let options = {
|
||
method: "post",
|
||
url: `https://superapp.jmc.com.cn/jmc-zx-app-owner/v1/signIn/add`,
|
||
headers: {
|
||
"Host": "superapp.jmc.com.cn",
|
||
"Content-Length": "33",
|
||
"Access-Token": `${this.ck}`,
|
||
"Content-Type": "application/json"
|
||
},
|
||
body: `{"activityCode":"HD202408060001"}`
|
||
};
|
||
// console.log(options);
|
||
let res = await httpRequest(options);
|
||
//console.log(res);
|
||
if (res.resultCode == 0) {
|
||
//this.token = res.token
|
||
this.cusLog(`账号 ${this.index} ${name}: 签到成功 ${res.resultMsg} `)
|
||
} else if (res.resultCode == 100000) {
|
||
this.cusLog(`账号 ${this.index} ${name}: ${res.resultMsg}`)
|
||
} else this.cusLog(`账号[${this.index}] ${name} 失败 ❌ 了呢`), console.log(res);
|
||
}
|
||
async grxx() {
|
||
let name = "个人信息";
|
||
let options = {
|
||
method: "get",
|
||
url: `https://superapp.jmc.com.cn/jmc-zx-app-owner/v1/member/getMemberInfo`,
|
||
headers: {
|
||
"Host": "superapp.jmc.com.cn",
|
||
//"Content-Length": "33",
|
||
"Access-Token": `${this.ck}`,
|
||
// "Content-Type": "application/json"
|
||
}
|
||
};
|
||
// console.log(options);
|
||
let res = await httpRequest(options);
|
||
//console.log(res);
|
||
if (res.resultCode == 0) {
|
||
// this.token = res.token
|
||
this.cusLog(`账号 ${this.index} ${name}: 总积分 ${res.data.integralQuantity} `)
|
||
} else if (res.resultCode == 100000) {
|
||
this.cusLog(`账号 ${this.index} ${name}: ${res.resultMsg}`)
|
||
} 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("未找到CK");
|
||
}
|
||
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);
|
||
}
|