mirror of
https://github.com/smallfawn/QLScriptPublic.git
synced 2026-11-05 22:36:53 +08:00
220 lines
9.0 KiB
JavaScript
220 lines
9.0 KiB
JavaScript
/*
|
||
------------------------------------------
|
||
@Description: 旧衣客(JYK) - 微信小程序静默登录 + 每日签到
|
||
cron: 22 9 * * *
|
||
------------------------------------------
|
||
变量名：jyk
|
||
变量值：wx_server 里的 openid/账号标识，多账号用 & 或换行分隔（可加 #备注）
|
||
|
||
依赖变量：
|
||
wx_server_url 默认 http://192.168.31.196:8787
|
||
wx_auth 必填，wx_server 鉴权值
|
||
------------------------------------------
|
||
契约（appid wx3f0209cc35a953a4，host jyk.scjyx.com）：
|
||
（迁移自 YYB-GO 系脚本，原脚本已 code 登录）
|
||
|
||
登录 POST /api/index/get_openid {code, pid:"", device_info:"android_MEIZU_22_370"}
|
||
-> errno==0，data.access_token；头 Authorization: Bearer <token> + X-Payconfig-Id:2
|
||
状态 GET /api/checkin/home -> data.{enabled, today_signed, can_sign}
|
||
签到 ① POST /api/checkin/prepare -> data.ad_token
|
||
② POST /api/checkin/sign {ad_token} -> errno==0 成功
|
||
响应壳：{errno:0, data}；errno!=0 视为失败/未开启。只做普通签到，不做广告签到。
|
||
------------------------------------------
|
||
*/
|
||
|
||
const { Env } = require("../tools/env.js");
|
||
const $ = new Env("旧衣客签到");
|
||
const axios = require("axios");
|
||
const fs = require("fs");
|
||
const path = require("path");
|
||
const WeChatServer = require("./wcs.js");
|
||
|
||
const ckName = "jyk";
|
||
const MINI_APP_ID = "wx3f0209cc35a953a4";
|
||
const TARGET_VERSION = "68";
|
||
const BASE_URL = "https://jyk.scjyx.com";
|
||
const PAYCONFIG_ID = "2";
|
||
const PID = "";
|
||
const DEVICE_INFO = "android_MEIZU_22_370";
|
||
const TOKEN_CACHE_FILE = path.join(__dirname, "jyk_token_cache.json");
|
||
const USER_AGENT =
|
||
"Mozilla/5.0 (Linux; Android 12; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 " +
|
||
"Chrome/107.0.0.0 Mobile Safari/537.36 MicroMessenger/8.0.5 MiniProgramEnv/android";
|
||
|
||
const EP_LOGIN = "/api/index/get_openid";
|
||
const EP_HOME = "/api/checkin/home";
|
||
const EP_PREPARE = "/api/checkin/ad/prepare";
|
||
const EP_SIGN = "/api/checkin/sign";
|
||
const EP_AD_SIGN = "/api/checkin/ad/sign";
|
||
|
||
const wechat = new WeChatServer({
|
||
url: process.env.wx_server_url || "http://192.168.31.196:8787",
|
||
appid: MINI_APP_ID,
|
||
auth: process.env.wx_auth || "",
|
||
});
|
||
|
||
function readCache() {
|
||
try {
|
||
if (!fs.existsSync(TOKEN_CACHE_FILE)) return {};
|
||
return JSON.parse(fs.readFileSync(TOKEN_CACHE_FILE, "utf8")) || {};
|
||
} catch (e) {
|
||
return {};
|
||
}
|
||
}
|
||
function writeCache(cache) {
|
||
try {
|
||
fs.writeFileSync(TOKEN_CACHE_FILE, JSON.stringify(cache, null, 2), "utf8");
|
||
} catch (e) {
|
||
$.log(`写入token缓存失败: ${e.message || e}`);
|
||
}
|
||
}
|
||
function parseAccount(raw = "") {
|
||
const [id, remark] = String(raw).split("#").map((s) => (s || "").trim());
|
||
return { openid: id, remark: remark || "" };
|
||
}
|
||
function short(v, n = 200) {
|
||
const t = typeof v === "string" ? v : JSON.stringify(v);
|
||
return !t ? "" : t.length > n ? `${t.slice(0, n)}...` : t;
|
||
}
|
||
|
||
class Task {
|
||
constructor(raw) {
|
||
this.index = $.userIdx++;
|
||
this.account = parseAccount(raw);
|
||
this.token = "";
|
||
}
|
||
log(text) {
|
||
$.log(`账号[${this.index}]${this.account.remark ? `[${this.account.remark}]` : ""} ${text}`);
|
||
}
|
||
headers() {
|
||
const h = {
|
||
"content-type": "application/json",
|
||
"X-Payconfig-Id": PAYCONFIG_ID,
|
||
Referer: `https://servicewechat.com/${MINI_APP_ID}/${TARGET_VERSION}/page-frame.html`,
|
||
"User-Agent": USER_AGENT,
|
||
};
|
||
if (this.token) h.Authorization = `Bearer ${this.token}`;
|
||
return h;
|
||
}
|
||
async request(method, apiPath, payload) {
|
||
const res = await axios.request({
|
||
method,
|
||
url: `${BASE_URL}${apiPath}`,
|
||
data: method === "POST" ? payload || {} : undefined,
|
||
headers: this.headers(),
|
||
timeout: 20000,
|
||
validateStatus: () => true,
|
||
});
|
||
if (res.status !== 200) {
|
||
if (res.data && typeof res.data === "object") return res.data;
|
||
throw new Error(`${apiPath} HTTP ${res.status}: ${short(res.data)}`);
|
||
}
|
||
return res.data;
|
||
}
|
||
async getCode() {
|
||
const { data } = await wechat.getCode(this.account.openid);
|
||
if (data && data.status === false) throw new Error(`wx_server 取code失败: ${data.message || short(data)}`);
|
||
const code = data?.data?.code || data?.code;
|
||
if (!code || typeof code !== "string") throw new Error(`wx_server 未返回 code: ${short(data)}`);
|
||
return code;
|
||
}
|
||
async login() {
|
||
const code = await this.getCode();
|
||
const res = await this.request("POST", EP_LOGIN, { code, pid: PID, device_info: DEVICE_INFO });
|
||
if (Number(res?.errno) !== 0) throw new Error(`登录失败: ${res?.errmsg || res?.msg || short(res)}`);
|
||
const info = res.data || {};
|
||
this.token = String(info.access_token || "");
|
||
if (!this.token) throw new Error(`登录未返回 access_token: ${short(res)}`);
|
||
const cache = readCache();
|
||
cache[this.account.openid] = { token: this.token, updatedAt: new Date().toISOString() };
|
||
writeCache(cache);
|
||
this.log("登录成功");
|
||
}
|
||
async home() {
|
||
const res = await this.request("GET", EP_HOME);
|
||
if (Number(res?.errno) !== 0) throw new Error(`home失败: ${res?.errmsg || short(res)}`);
|
||
return res.data || {};
|
||
}
|
||
async sign() {
|
||
const signed = await this.request("POST", EP_SIGN, {});
|
||
if (Number(signed?.errno) === 0) {
|
||
const d = signed.data || {};
|
||
return this.log(`✅ 签到成功${d.score !== undefined ? `，获得 ${d.score} 积分` : ""}${d.integral !== undefined ? `，积分 ${d.integral}` : ""}`);
|
||
}
|
||
if (/已签|签到过|重复|已完成/.test(String(signed?.errmsg || signed?.msg || ""))) return this.log(`✅ 今日已签到（${signed.errmsg || signed.msg}）`);
|
||
this.log(`❌ 签到失败: ${signed?.errmsg || signed?.msg || short(signed)}`);
|
||
}
|
||
async prepareAndSign() {
|
||
const prepared = await this.request("POST", EP_PREPARE);
|
||
if (Number(prepared?.errno) !== 0) return this.log(`❌ 广告签到 prepare 失败: ${short(prepared)}`);
|
||
const adToken = String((prepared.data || {}).ad_token || "");
|
||
if (!adToken) return this.log("❌ 广告签到 prepare 未返回 ad_token");
|
||
await $.wait(10 * 1000)
|
||
const signed = await this.request("POST", EP_AD_SIGN, { ad_token: adToken });
|
||
if (Number(signed?.errno) === 0) {
|
||
const d = signed.data || {};
|
||
this.log(`✅ 广告签到成功${d.score !== undefined ? `，获得 ${d.score} 积分` : ""}${d.integral !== undefined ? `，积分 ${d.integral}` : ""}`);
|
||
await $.wait(30 * 1000)
|
||
await this.checkin_sign('ad');
|
||
return
|
||
}
|
||
if (/已签|签到过|重复|已完成/.test(String(signed?.errmsg || signed?.msg || ""))) return this.log(`✅ 今日已签到（${signed.errmsg || signed.msg}）`);
|
||
this.log(`❌ 广告签到失败: ${signed?.errmsg || signed?.msg || short(signed)}`);
|
||
}
|
||
async checkin_sign(type) {
|
||
let home;
|
||
try {
|
||
home = await this.home();
|
||
} catch (e) {
|
||
if (/token|登录|未授权|失效|过期|401/i.test(String(e.message))) {
|
||
this.token = "";
|
||
await this.login();
|
||
home = await this.home();
|
||
} else throw e;
|
||
}
|
||
if (type == 'ad') {
|
||
if (home.ad && home.ad.today_count < home.ad.daily_limit) {
|
||
await this.prepareAndSign();
|
||
} else {
|
||
this.log("✅ 今日广告签到已完成签到或不可签")
|
||
}
|
||
|
||
} else {
|
||
if (!home.enabled) return this.log("普通签到未开启");
|
||
if (home.today_signed || !home.can_sign) {
|
||
this.log("✅ 今日普通签到已签到或不可签")
|
||
} else {
|
||
await this.sign();
|
||
}
|
||
if (home.ad && home.ad.today_count < home.ad.daily_limit) {
|
||
await this.prepareAndSign();
|
||
} else {
|
||
this.log("✅ 今日广告签到已完成签到或不可签")
|
||
}
|
||
}
|
||
}
|
||
async ensureLogin() {
|
||
const cached = readCache()[this.account.openid] || {};
|
||
if (!this.token && cached.token) { this.token = cached.token; this.log("使用缓存token"); return; }
|
||
if (!this.token) await this.login();
|
||
}
|
||
async run() {
|
||
if (!this.account.openid) { this.log("跳过：变量值里没有 openid"); return; }
|
||
try {
|
||
await this.ensureLogin();
|
||
await this.checkin_sign();
|
||
} catch (e) {
|
||
this.log(`执行失败: ${e.message || e}`);
|
||
}
|
||
}
|
||
}
|
||
|
||
!(async () => {
|
||
$.checkEnv(ckName);
|
||
if (!$.userCount) { $.log(`未找到变量 ${ckName}`); return; }
|
||
for (let i = 0; i < $.userList.length; i++) {
|
||
await new Task($.userList[i]).run();
|
||
if (i < $.userList.length - 1) await $.wait(1500, 3000);
|
||
}
|
||
})().catch((e) => $.log(e.message || e)).finally(() => $.done());
|