From e084a68e74db551b789fd59f44813e8d0233dc04 Mon Sep 17 00:00:00 2001 From: zjk2017 <2548836866@qq.com> Date: Sun, 14 Jul 2024 13:27:11 +0800 Subject: [PATCH] Create jlzx.js --- jlzx.js | 530 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 530 insertions(+) create mode 100644 jlzx.js diff --git a/jlzx.js b/jlzx.js new file mode 100644 index 0000000..d752baf --- /dev/null +++ b/jlzx.js @@ -0,0 +1,530 @@ +/* +@随缘撸豆 +江铃智行 app +cron: 22 8,19 * * * + +5.27 就一个签到 随缘玩吧 服务器闲着也是闲着 + +------------------------ 青龙--配置文件-贴心复制区域 ---------------------- +抓取superapp.jmc.com.cn中的Access-Token + +export jlzx="Access-Token " + +多账号用 换行 或 @ 分割 +一天1~5分 挂一年能换点东西 +====================================================================================================================================== +20240714 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":"HD202401010007"}` + }; + // 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); +}