mirror of
https://github.com/smallfawn/QLScriptPublic.git
synced 2025-12-17 23:35:02 +08:00
北京现代
This commit is contained in:
smallfawn
785
bjxd.js
785
bjxd.js
@@ -1,785 +0,0 @@
|
||||
/*
|
||||
北京现代
|
||||
(不是北京汽车)
|
||||
|
||||
积分换实物，积分涨的比较慢，自己决定跑不跑吧
|
||||
|
||||
捉域名bm2-api.bluemembers.com.cn任意包的token填到bjxdCookie里，多账户换行隔开
|
||||
安卓CK需要在对应的CK后面加上#android
|
||||
不加默认为IOS CK，不通用
|
||||
|
||||
重写：打开APP获取
|
||||
[task_local]
|
||||
#北京现代
|
||||
58 0,9-22/4 * * * https://raw.githubusercontent.com/leafTheFish/DeathNote/main/bjxd.js, tag=北京现代, enabled=true
|
||||
[rewrite_local]
|
||||
https://bm2-api.bluemembers.com.cn/v1/app/white/lovecar/banner url script-request-header https://raw.githubusercontent.com/leafTheFish/DeathNote/main/bjxd.js
|
||||
[MITM]
|
||||
hostname = bm2-api.bluemembers.com.cn
|
||||
|
||||
定时：一天一两次
|
||||
cron: 36 7,20 * * *
|
||||
|
||||
const $ = new Env("北京现代")
|
||||
*/
|
||||
//Tue Feb 18 2025 06:05:49 GMT+0000 (Coordinated Universal Time)
|
||||
//Base:https://github.com/echo094/decode-js
|
||||
//Modify:https://github.com/smallfawn/decode_action
|
||||
const _0x8716db = new _0x4cda8f("北京现代");
|
||||
let _0x268653 = ["\n"];
|
||||
let _0x2fdc9f = "bjxdCookie";
|
||||
let _0x219a02 = (_0x8716db.isNode() ? process.env[_0x2fdc9f] : _0x8716db.getdata(_0x2fdc9f)) || "";
|
||||
let _0x2d9559 = [];
|
||||
let _0x2c43fb = 0;
|
||||
let _0x1b86b6 = 0;
|
||||
let _0x30fc44 = "application/json;charset=utf-8";
|
||||
let _0x1d8bc9 = "ModernCar/8.10.0 (iPhone; iOS 15.0; Scale/3.00)";
|
||||
let _0x8c33cb = "iOS";
|
||||
let _0x5403e8 = 7;
|
||||
let _0x32da0f = 8;
|
||||
let _0x1a4387 = 300;
|
||||
let _0x491d53 = 1000;
|
||||
let _0x49a9ae = 1.02;
|
||||
let _0x194108 = "bjxd";
|
||||
let _0x6567ed = "https://leafxcy.coding.net/api/user/leafxcy/project/validcode/shared-depot/validCode/git/blob/master/code.json";
|
||||
class _0x4c27a8 {
|
||||
constructor(_0x17c2ed) {
|
||||
this.index = ++_0x2c43fb;
|
||||
this.name = this.index;
|
||||
this.valid = false;
|
||||
let _0x465c2e = _0x17c2ed.split("#");
|
||||
this.token = _0x465c2e[0];
|
||||
this.device = _0x465c2e[1] || _0x8c33cb;
|
||||
}
|
||||
async taskApi(_0x3967b8 = {}) {
|
||||
let _0x4dd0e8 = {};
|
||||
try {
|
||||
let _0x1c0362 = _0x3967b8.url.replace("//", "/").split("/")[1];
|
||||
let _0x1e768b = _0x3967b8.url;
|
||||
if (_0x3967b8.queryParam) {
|
||||
_0x1e768b += "?" + _0x8716db.json2str(_0x3967b8.queryParam, "&", true);
|
||||
}
|
||||
const _0x206c16 = {
|
||||
Host: _0x1c0362,
|
||||
Connection: "keep-alive",
|
||||
token: this.token,
|
||||
"User-Agent": _0x1d8bc9,
|
||||
device: this.device
|
||||
};
|
||||
let _0x47c42e = {
|
||||
url: _0x1e768b,
|
||||
headers: _0x206c16,
|
||||
timeout: 5000
|
||||
};
|
||||
if (_0x3967b8.body) {
|
||||
_0x47c42e.headers["Content-Type"] = _0x3967b8["Content-Type"] || _0x30fc44;
|
||||
if (typeof _0x3967b8.body === "object") {
|
||||
if (_0x47c42e.headers["Content-Type"].includes("json")) {
|
||||
_0x47c42e.body = JSON.stringify(_0x3967b8.body);
|
||||
} else {
|
||||
for (let _0x35ecf0 in _0x3967b8.body) {
|
||||
typeof _0x3967b8.body[_0x35ecf0] === "object" && (_0x3967b8.body[_0x35ecf0] = JSON.stringify(_0x3967b8.body[_0x35ecf0]));
|
||||
}
|
||||
_0x47c42e.body = _0x8716db.json2str(_0x3967b8.body, "&");
|
||||
}
|
||||
} else {
|
||||
_0x47c42e.body = _0x3967b8.body;
|
||||
}
|
||||
}
|
||||
if (_0x3967b8.urlObjectParam) {
|
||||
Object.assign(_0x47c42e, _0x3967b8.urlObjectParam);
|
||||
}
|
||||
if (_0x3967b8.headerParam) {
|
||||
Object.assign(_0x47c42e.headers, _0x3967b8.headerParam);
|
||||
}
|
||||
_0x4dd0e8 = Object.assign({}, await _0x521f1c(_0x3967b8.method, _0x47c42e));
|
||||
_0x4dd0e8.statusCode = _0x4dd0e8?.["err"]?.["response"]?.["statusCode"] || _0x4dd0e8?.["resp"]?.["statusCode"];
|
||||
_0x4dd0e8.statusCode != 200 && console.log("[" + _0x3967b8.fn + "]返回[" + _0x4dd0e8.statusCode + "]");
|
||||
if (_0x4dd0e8?.["resp"]?.["body"]) {
|
||||
if (typeof _0x4dd0e8.resp.body === "object") {
|
||||
_0x4dd0e8.result = _0x4dd0e8.resp.body;
|
||||
} else {
|
||||
try {
|
||||
_0x4dd0e8.result = JSON.parse(_0x4dd0e8.resp.body);
|
||||
} catch (_0x3866e6) {
|
||||
console.log("[" + _0x3967b8.fn + "]没有返回json数据");
|
||||
_0x4dd0e8.result = _0x4dd0e8.resp.body;
|
||||
}
|
||||
}
|
||||
}
|
||||
} catch (_0x1e3872) {
|
||||
console.log(_0x1e3872);
|
||||
} finally {
|
||||
return Promise.resolve(_0x4dd0e8);
|
||||
}
|
||||
}
|
||||
async getUserInfo() {
|
||||
let _0x38b266 = {};
|
||||
try {
|
||||
let _0xcaf926 = {
|
||||
fn: "getUserInfo",
|
||||
method: "get",
|
||||
url: "https://bm2-api.bluemembers.com.cn/v1/app/account/users/info"
|
||||
};
|
||||
_0x38b266 = Object.assign({}, await this.taskApi(_0xcaf926));
|
||||
if (typeof _0x38b266?.["result"] === "object") {
|
||||
let _0x4299a4 = _0x38b266.result;
|
||||
if (_0x4299a4.code == 0) {
|
||||
this.valid = true;
|
||||
this.hid = _0x4299a4.data.hid;
|
||||
this.name = _0x4299a4.data.nickname;
|
||||
this.phone = _0x4299a4.data.phone;
|
||||
this.mixPhone = this.phone.slice(0, 3) + "****" + this.phone.slice(7, 13);
|
||||
this.nid = _0x4299a4.data.nid;
|
||||
this.score = _0x4299a4.data.score_value;
|
||||
this.isSign = _0x4299a4.data.if_signed_in;
|
||||
_0x8716db.logAndNotify("昵称：" + this.name);
|
||||
_0x8716db.logAndNotify("手机：" + this.mixPhone);
|
||||
} else {
|
||||
_0x8716db.logAndNotify("登录失败：" + _0x4299a4.msg);
|
||||
}
|
||||
}
|
||||
} catch (_0x304632) {
|
||||
console.log(_0x304632);
|
||||
} finally {
|
||||
return Promise.resolve(_0x38b266);
|
||||
}
|
||||
}
|
||||
async getScore() {
|
||||
let _0x12fb1e = {};
|
||||
try {
|
||||
let _0x43a101 = {
|
||||
fn: "getScore",
|
||||
method: "get",
|
||||
url: "https://bm2-api.bluemembers.com.cn/v1/app/account/users/info"
|
||||
};
|
||||
_0x12fb1e = Object.assign({}, await this.taskApi(_0x43a101));
|
||||
if (typeof _0x12fb1e?.["result"] === "object") {
|
||||
let _0x332edd = _0x12fb1e.result;
|
||||
_0x332edd.code == 0 ? (this.score = _0x332edd.data.score_value, _0x8716db.logAndNotify("积分：" + this.score)) : console.log("查询积分失败：" + _0x332edd.msg);
|
||||
}
|
||||
} catch (_0x163403) {
|
||||
console.log(_0x163403);
|
||||
} finally {
|
||||
return Promise.resolve(_0x12fb1e);
|
||||
}
|
||||
}
|
||||
async reward_list() {
|
||||
let _0x3f6116 = {};
|
||||
try {
|
||||
let _0xe5198f = {
|
||||
fn: "reward_list",
|
||||
method: "get",
|
||||
url: "https://bm2-api.bluemembers.com.cn/v1/app/user/reward_list"
|
||||
};
|
||||
_0x3f6116 = Object.assign({}, await this.taskApi(_0xe5198f));
|
||||
if (typeof _0x3f6116?.["result"] === "object") {
|
||||
let _0x56041 = _0x3f6116.result;
|
||||
if (_0x56041.code == 0) {
|
||||
let _0x2fbcf1 = _0x56041.data.list.filter(_0x5ae0ff => _0x5ae0ff.hid == _0x56041.data.hid);
|
||||
let _0x4a8869 = _0x2fbcf1[0].score;
|
||||
_0x4a8869 >= _0x5403e8 ? (console.log("获取到签到积分" + _0x4a8869 + "的请求，满足门槛，进行签到"), await this.reward_report(_0x56041.data), this.isSign = true) : console.log("获取到签到积分" + _0x4a8869 + "的请求，小于门槛，不进行签到");
|
||||
} else {
|
||||
console.log("获取签到奖励信息失败：" + _0x56041.msg);
|
||||
}
|
||||
}
|
||||
} catch (_0x64bff7) {
|
||||
console.log(_0x64bff7);
|
||||
} finally {
|
||||
return Promise.resolve(_0x3f6116);
|
||||
}
|
||||
}
|
||||
async reward_report(_0x589132) {
|
||||
let _0x46c394 = {};
|
||||
try {
|
||||
const _0x34c67b = {
|
||||
hid: _0x589132.hid,
|
||||
hash: _0x589132.rewardHash,
|
||||
sm_deviceId: ""
|
||||
};
|
||||
let _0x4c6530 = {
|
||||
fn: "reward_report",
|
||||
method: "post",
|
||||
url: "https://bm2-api.bluemembers.com.cn/v1/app/user/reward_report",
|
||||
body: _0x34c67b
|
||||
};
|
||||
_0x46c394 = Object.assign({}, await this.taskApi(_0x4c6530));
|
||||
if (typeof _0x46c394?.["result"] === "object") {
|
||||
let _0x435e80 = _0x46c394.result;
|
||||
_0x435e80.code == 0 ? console.log("签到成功") : console.log("签到失败：" + _0x435e80.msg);
|
||||
}
|
||||
} catch (_0x149902) {
|
||||
console.log(_0x149902);
|
||||
} finally {
|
||||
return Promise.resolve(_0x46c394);
|
||||
}
|
||||
}
|
||||
async taskList() {
|
||||
let _0x17e315 = {};
|
||||
try {
|
||||
let _0x4b8eca = {
|
||||
fn: "taskList",
|
||||
method: "get",
|
||||
url: "https://bm2-api.bluemembers.com.cn/v1/app/user/task/list"
|
||||
};
|
||||
_0x17e315 = Object.assign({}, await this.taskApi(_0x4b8eca));
|
||||
if (typeof _0x17e315?.["result"] === "object") {
|
||||
let _0x537fef = _0x17e315.result;
|
||||
_0x537fef.code == 0 ? (!_0x537fef.data.action12.status && (await this.appScore(12)), !_0x537fef.data.action39.status && (await this.ask_info())) : console.log("获取任务列表失败：" + _0x537fef.msg);
|
||||
}
|
||||
} catch (_0x217171) {
|
||||
console.log(_0x217171);
|
||||
} finally {
|
||||
return Promise.resolve(_0x17e315);
|
||||
}
|
||||
}
|
||||
async appScore(_0x2e08b2) {
|
||||
let _0x56f9a9 = {};
|
||||
try {
|
||||
let _0x139670 = {
|
||||
fn: "appScore",
|
||||
method: "post",
|
||||
url: "https://bm2-api.bluemembers.com.cn/v1/app/score",
|
||||
body: {
|
||||
action: Number(_0x2e08b2)
|
||||
}
|
||||
};
|
||||
_0x56f9a9 = Object.assign({}, await this.taskApi(_0x139670));
|
||||
if (typeof _0x56f9a9?.["result"] === "object") {
|
||||
let _0x2398d7 = _0x56f9a9.result;
|
||||
_0x2398d7.code == 0 ? _0x2398d7.data.is_stop ? console.log("完成任务[" + _0x2e08b2 + "]成功，获得" + _0x2398d7.data.score + "积分") : console.log("任务[" + _0x2e08b2 + "]已完成过") : console.log("完成任务[" + _0x2e08b2 + "]失败：" + _0x2398d7.msg);
|
||||
}
|
||||
} catch (_0x4aaf25) {
|
||||
console.log(_0x4aaf25);
|
||||
} finally {
|
||||
return Promise.resolve(_0x56f9a9);
|
||||
}
|
||||
}
|
||||
async ask_info() {
|
||||
let _0x8f513e = {};
|
||||
try {
|
||||
let _0x2a7cc6 = {
|
||||
fn: "ask_info",
|
||||
method: "get",
|
||||
url: "https://bm2-api.bluemembers.com.cn/v1/app/special/daily/ask_info",
|
||||
queryParam: {
|
||||
date: _0x8716db.time("yyyyMMdd")
|
||||
}
|
||||
};
|
||||
_0x8f513e = Object.assign({}, await this.taskApi(_0x2a7cc6));
|
||||
if (typeof _0x8f513e?.["result"] === "object") {
|
||||
let _0x5469c5 = _0x8f513e.result;
|
||||
if (_0x5469c5.code == 0) {
|
||||
if (_0x5469c5.data.state == 1) {
|
||||
console.log("开始答题：");
|
||||
console.log(_0x5469c5.data.question_info.content);
|
||||
for (let _0x296803 of _0x5469c5.data.question_info.option) {
|
||||
console.log(_0x296803.option + ": " + _0x296803.option_content);
|
||||
}
|
||||
await this.ask_answer(_0x5469c5.data.question_info);
|
||||
} else {
|
||||
console.log("今日已完成答题");
|
||||
}
|
||||
} else {
|
||||
console.log("获取任务列表失败：" + _0x5469c5.msg);
|
||||
}
|
||||
}
|
||||
} catch (_0x45d564) {
|
||||
console.log(_0x45d564);
|
||||
} finally {
|
||||
return Promise.resolve(_0x8f513e);
|
||||
}
|
||||
}
|
||||
async ask_answer(_0x4ee39a) {
|
||||
let _0x320116 = {};
|
||||
try {
|
||||
let _0x16af4f = _0x8716db.randomList(_0x4ee39a.option);
|
||||
console.log("随机选择[" + _0x16af4f.option + "]");
|
||||
const _0x5c6056 = {
|
||||
answer: _0x16af4f.option,
|
||||
questions_hid: _0x4ee39a.questions_hid
|
||||
};
|
||||
let _0x237782 = {
|
||||
fn: "ask_answer",
|
||||
method: "post",
|
||||
url: "https://bm2-api.bluemembers.com.cn/v1/app/special/daily/ask_answer",
|
||||
body: _0x5c6056
|
||||
};
|
||||
_0x320116 = Object.assign({}, await this.taskApi(_0x237782));
|
||||
if (typeof _0x320116?.["result"] === "object") {
|
||||
let _0x30d161 = _0x320116.result;
|
||||
_0x30d161.code == 0 ? _0x30d161.data.state == 2 ? console.log("回答正确，获得" + _0x30d161.data.answer_score + "积分") : console.log("回答错误") : console.log("回答失败：" + _0x30d161.msg);
|
||||
}
|
||||
} catch (_0x26cc04) {
|
||||
console.log(_0x26cc04);
|
||||
} finally {
|
||||
return Promise.resolve(_0x320116);
|
||||
}
|
||||
}
|
||||
async userTask() {
|
||||
let _0x4937de = {};
|
||||
try {
|
||||
_0x8716db.logAndNotify("\n============= 账号[" + this.index + "] =============");
|
||||
await this.getUserInfo();
|
||||
if (!this.valid) {
|
||||
return;
|
||||
}
|
||||
for (let _0x50258e = 0; _0x50258e < 50 && !this.isSign; _0x50258e++) {
|
||||
await this.reward_list();
|
||||
}
|
||||
await this.taskList();
|
||||
await this.getScore();
|
||||
} catch (_0x5859d2) {
|
||||
console.log(_0x5859d2);
|
||||
} finally {
|
||||
return Promise.resolve(_0x4937de);
|
||||
}
|
||||
}
|
||||
}
|
||||
!(async () => {
|
||||
if (typeof $request !== "undefined") {
|
||||
await _0x14afab();
|
||||
} else {
|
||||
/*if (!(await _0x2b9e78())) {
|
||||
return;
|
||||
}*/
|
||||
if (!_0x5783c6()) {
|
||||
return;
|
||||
}
|
||||
for (let _0x446442 of _0x2d9559) {
|
||||
await _0x446442.userTask();
|
||||
}
|
||||
}
|
||||
})().catch(_0x2a23c4 => console.log(_0x2a23c4)).finally(() => _0x8716db.done());
|
||||
async function _0x14afab() {
|
||||
if ($request.url.includes("v1/app/white/lovecar/banner")) {
|
||||
try {
|
||||
let _0x13b4b6 = $request.headers.token;
|
||||
let _0x4dcfbd = _0x268653[0];
|
||||
for (let _0x44475f of _0x268653) {
|
||||
if (_0x219a02?.["includes"](_0x44475f)) {
|
||||
_0x4dcfbd = _0x44475f;
|
||||
break;
|
||||
}
|
||||
}
|
||||
if (!_0x219a02?.["includes"](_0x13b4b6)) {
|
||||
let _0x1b71ef = _0x219a02 ? _0x219a02.split(_0x4dcfbd) : [];
|
||||
_0x1b71ef.push(_0x13b4b6);
|
||||
_0x219a02 = _0x1b71ef.join(_0x4dcfbd);
|
||||
_0x8716db.setdata(_0x219a02, _0x2fdc9f);
|
||||
_0x8716db.msg("获取第" + _0x1b71ef.length + "个账户CK成功，保存到变量[" + _0x2fdc9f + "]: " + _0x13b4b6);
|
||||
}
|
||||
} catch (_0x4cf3b5) {}
|
||||
}
|
||||
}
|
||||
function _0x5783c6() {
|
||||
if (_0x219a02) {
|
||||
let _0x3f061f = _0x268653[0];
|
||||
for (let _0x4cde89 of _0x268653) {
|
||||
if (_0x219a02.indexOf(_0x4cde89) > -1) {
|
||||
_0x3f061f = _0x4cde89;
|
||||
break;
|
||||
}
|
||||
}
|
||||
for (let _0x442d1d of _0x219a02.split(_0x3f061f)) {
|
||||
if (_0x442d1d) {
|
||||
_0x2d9559.push(new _0x4c27a8(_0x442d1d));
|
||||
}
|
||||
}
|
||||
_0x1b86b6 = _0x2d9559.length;
|
||||
} else {
|
||||
console.log("未找到CK: " + _0x2fdc9f);
|
||||
return false;
|
||||
}
|
||||
console.log("共找到" + _0x1b86b6 + "个账号");
|
||||
return true;
|
||||
}
|
||||
async function _0x2b9e78(_0x52f9ac = 0) {
|
||||
let _0x454209 = false;
|
||||
try {
|
||||
let _0x20d7ff = {
|
||||
url: _0x6567ed,
|
||||
timeout: 5000
|
||||
};
|
||||
let _0x239829 = null;
|
||||
let _0x457fa9 = await _0x521f1c("get", _0x20d7ff);
|
||||
if (_0x457fa9.err) {
|
||||
console.log("服务器错误[" + _0x457fa9?.["resp"]?.["statusCode"] + "]，重试...");
|
||||
} else {
|
||||
try {
|
||||
_0x239829 = JSON.parse(_0x457fa9.resp.body);
|
||||
_0x239829?.["code"] == 0 && (_0x239829 = JSON.parse(_0x239829.data.file.data));
|
||||
} catch (_0x5d759c) {}
|
||||
}
|
||||
if (!_0x239829) {
|
||||
if (_0x52f9ac < _0x32da0f) {
|
||||
let _0x22b7e = Math.floor(Math.random() * _0x491d53) + _0x1a4387;
|
||||
_0x454209 = await _0x2b9e78(++_0x52f9ac);
|
||||
}
|
||||
} else {
|
||||
_0x239829?.["commonNotify"] && _0x239829.commonNotify.length > 0 && _0x8716db.logAndNotify(_0x239829.commonNotify.join("\n") + "\n");
|
||||
_0x239829?.["commonMsg"] && _0x239829.commonMsg.length > 0 && console.log(_0x239829.commonMsg.join("\n") + "\n");
|
||||
if (_0x239829[_0x194108]) {
|
||||
let _0x1d6833 = _0x239829[_0x194108];
|
||||
_0x1d6833.status == 0 ? _0x49a9ae >= _0x1d6833.version ? (_0x454209 = true, console.log(_0x1d6833.msg[_0x1d6833.status]), console.log(_0x1d6833.updateMsg), console.log("现在运行的脚本版本是：" + _0x49a9ae + "，最新脚本版本：" + _0x1d6833.latestVersion)) : console.log(_0x1d6833.versionMsg) : console.log(_0x1d6833.msg[_0x1d6833.status]);
|
||||
} else {
|
||||
console.log(_0x239829.errorMsg);
|
||||
}
|
||||
}
|
||||
} catch (_0x3f1377) {
|
||||
console.log(_0x3f1377);
|
||||
} finally {
|
||||
return Promise.resolve(_0x454209);
|
||||
}
|
||||
}
|
||||
async function _0x521f1c(_0x263b8f, _0x513b4c) {
|
||||
return new Promise(_0x40a2b3 => {
|
||||
_0x8716db.send(_0x263b8f, _0x513b4c, async (_0x6e577d, _0x129293, _0xf085c6) => {
|
||||
const _0x348782 = {
|
||||
err: _0x6e577d,
|
||||
req: _0x129293,
|
||||
resp: _0xf085c6
|
||||
};
|
||||
_0x40a2b3(_0x348782);
|
||||
});
|
||||
});
|
||||
}
|
||||
function _0x4cda8f(_0x1e4724, _0xff6f77) {
|
||||
"undefined" != typeof process && JSON.stringify(process.env).indexOf("GITHUB") > -1 && process.exit(0);
|
||||
return new class {
|
||||
constructor(_0x4178f5, _0x2ac14c) {
|
||||
this.name = _0x4178f5;
|
||||
this.notifyStr = "";
|
||||
this.startTime = new Date().getTime();
|
||||
Object.assign(this, _0x2ac14c);
|
||||
console.log(this.name + " 开始运行：\n");
|
||||
}
|
||||
isNode() {
|
||||
return "undefined" != typeof module && !!module.exports;
|
||||
}
|
||||
isQuanX() {
|
||||
return "undefined" != typeof $task;
|
||||
}
|
||||
isSurge() {
|
||||
return "undefined" != typeof $httpClient && "undefined" == typeof $loon;
|
||||
}
|
||||
isLoon() {
|
||||
return "undefined" != typeof $loon;
|
||||
}
|
||||
getdata(_0x4fefce) {
|
||||
let _0x3782e9 = this.getval(_0x4fefce);
|
||||
if (/^@/.test(_0x4fefce)) {
|
||||
const [, _0x34b308, _0x48c0c3] = /^@(.*?)\.(.*?)$/.exec(_0x4fefce);
|
||||
const _0x31bfd6 = _0x34b308 ? this.getval(_0x34b308) : "";
|
||||
if (_0x31bfd6) {
|
||||
try {
|
||||
const _0x479c6a = JSON.parse(_0x31bfd6);
|
||||
_0x3782e9 = _0x479c6a ? this.lodash_get(_0x479c6a, _0x48c0c3, "") : _0x3782e9;
|
||||
} catch (_0x4facad) {
|
||||
_0x3782e9 = "";
|
||||
}
|
||||
}
|
||||
}
|
||||
return _0x3782e9;
|
||||
}
|
||||
setdata(_0x4beabf, _0x590b04) {
|
||||
let _0x38fc86 = false;
|
||||
if (/^@/.test(_0x590b04)) {
|
||||
const [, _0x20017f, _0x55f66f] = /^@(.*?)\.(.*?)$/.exec(_0x590b04);
|
||||
const _0x3e34f7 = this.getval(_0x20017f);
|
||||
const _0x3a6458 = _0x20017f ? "null" === _0x3e34f7 ? null : _0x3e34f7 || "{}" : "{}";
|
||||
try {
|
||||
const _0x2b471b = JSON.parse(_0x3a6458);
|
||||
this.lodash_set(_0x2b471b, _0x55f66f, _0x4beabf);
|
||||
_0x38fc86 = this.setval(JSON.stringify(_0x2b471b), _0x20017f);
|
||||
} catch (_0x1494d0) {
|
||||
const _0xd89f1b = {};
|
||||
this.lodash_set(_0xd89f1b, _0x55f66f, _0x4beabf);
|
||||
_0x38fc86 = this.setval(JSON.stringify(_0xd89f1b), _0x20017f);
|
||||
}
|
||||
} else {
|
||||
_0x38fc86 = this.setval(_0x4beabf, _0x590b04);
|
||||
}
|
||||
return _0x38fc86;
|
||||
}
|
||||
getval(_0x54eb3e) {
|
||||
return this.isSurge() || this.isLoon() ? $persistentStore.read(_0x54eb3e) : this.isQuanX() ? $prefs.valueForKey(_0x54eb3e) : this.isNode() ? (this.data = this.loaddata(), this.data[_0x54eb3e]) : this.data && this.data[_0x54eb3e] || null;
|
||||
}
|
||||
setval(_0x491870, _0x2145f6) {
|
||||
return this.isSurge() || this.isLoon() ? $persistentStore.write(_0x491870, _0x2145f6) : this.isQuanX() ? $prefs.setValueForKey(_0x491870, _0x2145f6) : this.isNode() ? (this.data = this.loaddata(), this.data[_0x2145f6] = _0x491870, this.writedata(), true) : this.data && this.data[_0x2145f6] || null;
|
||||
}
|
||||
send(_0x30ed81, _0x46cad7, _0x1cc856 = () => {}) {
|
||||
if (_0x30ed81 != "get" && _0x30ed81 != "post" && _0x30ed81 != "put" && _0x30ed81 != "delete") {
|
||||
console.log("无效的http方法：" + _0x30ed81);
|
||||
return;
|
||||
}
|
||||
if (_0x30ed81 == "get" && _0x46cad7.headers) {
|
||||
delete _0x46cad7.headers["Content-Type"];
|
||||
delete _0x46cad7.headers["Content-Length"];
|
||||
} else {
|
||||
if (_0x46cad7.body && _0x46cad7.headers) {
|
||||
if (!_0x46cad7.headers["Content-Type"]) {
|
||||
_0x46cad7.headers["Content-Type"] = "application/x-www-form-urlencoded";
|
||||
}
|
||||
}
|
||||
}
|
||||
if (this.isSurge() || this.isLoon()) {
|
||||
if (this.isSurge() && this.isNeedRewrite) {
|
||||
_0x46cad7.headers = _0x46cad7.headers || {};
|
||||
const _0x26fc4f = {
|
||||
"X-Surge-Skip-Scripting": false
|
||||
};
|
||||
Object.assign(_0x46cad7.headers, _0x26fc4f);
|
||||
}
|
||||
let _0x5bc71d = {
|
||||
method: _0x30ed81,
|
||||
url: _0x46cad7.url,
|
||||
headers: _0x46cad7.headers,
|
||||
timeout: _0x46cad7.timeout,
|
||||
data: _0x46cad7.body
|
||||
};
|
||||
if (_0x30ed81 == "get") {
|
||||
delete _0x5bc71d.data;
|
||||
}
|
||||
$axios(_0x5bc71d).then(_0x5bd58f => {
|
||||
const {
|
||||
status: _0x170536,
|
||||
request: _0x1e7cb3,
|
||||
headers: _0x468f75,
|
||||
data: _0x580b03
|
||||
} = _0x5bd58f;
|
||||
const _0x571f3c = {
|
||||
statusCode: _0x170536,
|
||||
headers: _0x468f75,
|
||||
body: _0x580b03
|
||||
};
|
||||
_0x1cc856(null, _0x1e7cb3, _0x571f3c);
|
||||
}).catch(_0x4bda4a => console.log(_0x4bda4a));
|
||||
} else {
|
||||
if (this.isQuanX()) {
|
||||
const _0x327740 = {
|
||||
hints: false
|
||||
};
|
||||
_0x46cad7.method = _0x30ed81.toUpperCase();
|
||||
this.isNeedRewrite && (_0x46cad7.opts = _0x46cad7.opts || {}, Object.assign(_0x46cad7.opts, _0x327740));
|
||||
$task.fetch(_0x46cad7).then(_0x54076a => {
|
||||
const {
|
||||
statusCode: _0x1a879b,
|
||||
request: _0x425de9,
|
||||
headers: _0x3d8419,
|
||||
body: _0x40f74b
|
||||
} = _0x54076a;
|
||||
const _0x206c23 = {
|
||||
statusCode: _0x1a879b,
|
||||
headers: _0x3d8419,
|
||||
body: _0x40f74b
|
||||
};
|
||||
_0x1cc856(null, _0x425de9, _0x206c23);
|
||||
}, _0x3c58de => _0x1cc856(_0x3c58de));
|
||||
} else {
|
||||
if (this.isNode()) {
|
||||
this.got = this.got ? this.got : require("got");
|
||||
const {
|
||||
url: _0x5838e9,
|
||||
..._0x4db42f
|
||||
} = _0x46cad7;
|
||||
const _0x527bb1 = {
|
||||
followRedirect: false
|
||||
};
|
||||
this.instance = this.got.extend(_0x527bb1);
|
||||
this.instance[_0x30ed81](_0x5838e9, _0x4db42f).then(_0x5339a9 => {
|
||||
const {
|
||||
statusCode: _0x3bc338,
|
||||
request: _0x576247,
|
||||
headers: _0x6e3fd4,
|
||||
body: _0x1a837a
|
||||
} = _0x5339a9;
|
||||
const _0x420bc3 = {
|
||||
statusCode: _0x3bc338,
|
||||
headers: _0x6e3fd4,
|
||||
body: _0x1a837a
|
||||
};
|
||||
_0x1cc856(null, _0x576247, _0x420bc3);
|
||||
}, _0x86d1ba => {
|
||||
const {
|
||||
message: _0x53d502,
|
||||
request: _0x507dc9,
|
||||
response: _0x598f0c
|
||||
} = _0x86d1ba;
|
||||
_0x1cc856(_0x53d502, _0x507dc9, _0x598f0c);
|
||||
});
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
time(_0x2ef619, _0x16db29 = null) {
|
||||
let _0x2c3750 = _0x16db29 ? new Date(_0x16db29) : new Date();
|
||||
let _0x5cd64f = {
|
||||
"M+": _0x2c3750.getMonth() + 1,
|
||||
"d+": _0x2c3750.getDate(),
|
||||
"h+": _0x2c3750.getHours(),
|
||||
"m+": _0x2c3750.getMinutes(),
|
||||
"s+": _0x2c3750.getSeconds(),
|
||||
"q+": Math.floor((_0x2c3750.getMonth() + 3) / 3),
|
||||
S: _0x2c3750.getMilliseconds()
|
||||
};
|
||||
/(y+)/.test(_0x2ef619) && (_0x2ef619 = _0x2ef619.replace(RegExp.$1, (_0x2c3750.getFullYear() + "").substr(4 - RegExp.$1.length)));
|
||||
for (let _0x4ccae2 in _0x5cd64f) new RegExp("(" + _0x4ccae2 + ")").test(_0x2ef619) && (_0x2ef619 = _0x2ef619.replace(RegExp.$1, 1 == RegExp.$1.length ? _0x5cd64f[_0x4ccae2] : ("00" + _0x5cd64f[_0x4ccae2]).substr(("" + _0x5cd64f[_0x4ccae2]).length)));
|
||||
return _0x2ef619;
|
||||
}
|
||||
async showmsg() {
|
||||
if (!this.notifyStr) {
|
||||
return;
|
||||
}
|
||||
let _0x69a576 = this.name + " 运行通知\n\n" + this.notifyStr;
|
||||
if (_0x8716db.isNode()) {
|
||||
var _0x4ded0f = require("./sendNotify");
|
||||
console.log("\n============== 推送 ==============");
|
||||
await _0x4ded0f.sendNotify(this.name, _0x69a576);
|
||||
} else {
|
||||
this.msg(_0x69a576);
|
||||
}
|
||||
}
|
||||
logAndNotify(_0x5d20e5) {
|
||||
console.log(_0x5d20e5);
|
||||
this.notifyStr += _0x5d20e5;
|
||||
this.notifyStr += "\n";
|
||||
}
|
||||
logAndNotifyWithTime(_0x13c259) {
|
||||
let _0x5d180a = "[" + this.time("hh:mm:ss.S") + "]" + _0x13c259;
|
||||
console.log(_0x5d180a);
|
||||
this.notifyStr += _0x5d180a;
|
||||
this.notifyStr += "\n";
|
||||
}
|
||||
logWithTime(_0xe9e4ad) {
|
||||
console.log("[" + this.time("hh:mm:ss.S") + "]" + _0xe9e4ad);
|
||||
}
|
||||
msg(_0x281b91 = t, _0x2a5e45 = "", _0x441be7 = "", _0xd75caf) {
|
||||
const _0x3c126f = _0xf16ff0 => {
|
||||
if (!_0xf16ff0) {
|
||||
return _0xf16ff0;
|
||||
}
|
||||
if ("string" == typeof _0xf16ff0) {
|
||||
return this.isLoon() ? _0xf16ff0 : this.isQuanX() ? {
|
||||
"open-url": _0xf16ff0
|
||||
} : this.isSurge() ? {
|
||||
url: _0xf16ff0
|
||||
} : undefined;
|
||||
}
|
||||
if ("object" == typeof _0xf16ff0) {
|
||||
if (this.isLoon()) {
|
||||
let _0x2fda6e = _0xf16ff0.openUrl || _0xf16ff0.url || _0xf16ff0["open-url"];
|
||||
let _0x1bd995 = _0xf16ff0.mediaUrl || _0xf16ff0["media-url"];
|
||||
const _0x5d7302 = {
|
||||
openUrl: _0x2fda6e,
|
||||
mediaUrl: _0x1bd995
|
||||
};
|
||||
return _0x5d7302;
|
||||
}
|
||||
if (this.isQuanX()) {
|
||||
let _0x5464ef = _0xf16ff0["open-url"] || _0xf16ff0.url || _0xf16ff0.openUrl;
|
||||
let _0x3b60b5 = _0xf16ff0["media-url"] || _0xf16ff0.mediaUrl;
|
||||
const _0x3f7c94 = {
|
||||
"open-url": _0x5464ef,
|
||||
"media-url": _0x3b60b5
|
||||
};
|
||||
return _0x3f7c94;
|
||||
}
|
||||
if (this.isSurge()) {
|
||||
let _0x4f4b61 = _0xf16ff0.url || _0xf16ff0.openUrl || _0xf16ff0["open-url"];
|
||||
const _0x40f4f2 = {
|
||||
url: _0x4f4b61
|
||||
};
|
||||
return _0x40f4f2;
|
||||
}
|
||||
}
|
||||
};
|
||||
this.isMute || (this.isSurge() || this.isLoon() ? $notification.post(_0x281b91, _0x2a5e45, _0x441be7, _0x3c126f(_0xd75caf)) : this.isQuanX() && $notify(_0x281b91, _0x2a5e45, _0x441be7, _0x3c126f(_0xd75caf)));
|
||||
let _0x3eabf5 = ["", "============== 系统通知 =============="];
|
||||
_0x3eabf5.push(_0x281b91);
|
||||
_0x2a5e45 && _0x3eabf5.push(_0x2a5e45);
|
||||
_0x441be7 && _0x3eabf5.push(_0x441be7);
|
||||
console.log(_0x3eabf5.join("\n"));
|
||||
}
|
||||
getMin(_0x15962f, _0x2a34e2) {
|
||||
return _0x15962f < _0x2a34e2 ? _0x15962f : _0x2a34e2;
|
||||
}
|
||||
getMax(_0x10b5c9, _0xd6c9d7) {
|
||||
return _0x10b5c9 < _0xd6c9d7 ? _0xd6c9d7 : _0x10b5c9;
|
||||
}
|
||||
padStr(_0x3b72ab, _0x3e7ee5, _0x173b51 = "0") {
|
||||
let _0x444bd6 = String(_0x3b72ab);
|
||||
let _0x5a80d4 = _0x3e7ee5 > _0x444bd6.length ? _0x3e7ee5 - _0x444bd6.length : 0;
|
||||
let _0xbedc9d = "";
|
||||
for (let _0x3f8956 = 0; _0x3f8956 < _0x5a80d4; _0x3f8956++) {
|
||||
_0xbedc9d += _0x173b51;
|
||||
}
|
||||
_0xbedc9d += _0x444bd6;
|
||||
return _0xbedc9d;
|
||||
}
|
||||
json2str(_0x4cb5d6, _0x36e3c5, _0x2ec4bc = false) {
|
||||
let _0x4d114d = [];
|
||||
for (let _0x207106 of Object.keys(_0x4cb5d6).sort()) {
|
||||
let _0x3811eb = _0x4cb5d6[_0x207106];
|
||||
if (_0x3811eb && _0x2ec4bc) {
|
||||
_0x3811eb = encodeURIComponent(_0x3811eb);
|
||||
}
|
||||
_0x4d114d.push(_0x207106 + "=" + _0x3811eb);
|
||||
}
|
||||
return _0x4d114d.join(_0x36e3c5);
|
||||
}
|
||||
str2json(_0x153294, _0x4b27fb = false) {
|
||||
let _0x593ed4 = {};
|
||||
for (let _0xdc7f24 of _0x153294.split("&")) {
|
||||
if (!_0xdc7f24) {
|
||||
continue;
|
||||
}
|
||||
let _0x221d9d = _0xdc7f24.indexOf("=");
|
||||
if (_0x221d9d == -1) {
|
||||
continue;
|
||||
}
|
||||
let _0x48bba3 = _0xdc7f24.substr(0, _0x221d9d);
|
||||
let _0x2a45fc = _0xdc7f24.substr(_0x221d9d + 1);
|
||||
if (_0x4b27fb) {
|
||||
_0x2a45fc = decodeURIComponent(_0x2a45fc);
|
||||
}
|
||||
_0x593ed4[_0x48bba3] = _0x2a45fc;
|
||||
}
|
||||
return _0x593ed4;
|
||||
}
|
||||
randomPattern(_0x39c9a4, _0x782889 = "abcdef0123456789") {
|
||||
let _0x167a1 = "";
|
||||
for (let _0x4c9048 of _0x39c9a4) {
|
||||
if (_0x4c9048 == "x") {
|
||||
_0x167a1 += _0x782889.charAt(Math.floor(Math.random() * _0x782889.length));
|
||||
} else {
|
||||
_0x4c9048 == "X" ? _0x167a1 += _0x782889.charAt(Math.floor(Math.random() * _0x782889.length)).toUpperCase() : _0x167a1 += _0x4c9048;
|
||||
}
|
||||
}
|
||||
return _0x167a1;
|
||||
}
|
||||
randomString(_0x600a62, _0x1be07f = "abcdef0123456789") {
|
||||
let _0x23158e = "";
|
||||
for (let _0x1ed705 = 0; _0x1ed705 < _0x600a62; _0x1ed705++) {
|
||||
_0x23158e += _0x1be07f.charAt(Math.floor(Math.random() * _0x1be07f.length));
|
||||
}
|
||||
return _0x23158e;
|
||||
}
|
||||
randomList(_0x4acba4) {
|
||||
let _0x91a694 = Math.floor(Math.random() * _0x4acba4.length);
|
||||
return _0x4acba4[_0x91a694];
|
||||
}
|
||||
wait(_0x530f72) {
|
||||
return new Promise(_0x3e7b59 => setTimeout(_0x3e7b59, _0x530f72));
|
||||
}
|
||||
async done(_0x5b659f = {}) {
|
||||
await this.showmsg();
|
||||
const _0x1541e5 = new Date().getTime();
|
||||
const _0x2fa0de = (_0x1541e5 - this.startTime) / 1000;
|
||||
console.log("\n" + this.name + " 运行结束，共运行了 " + _0x2fa0de + " 秒！");
|
||||
if (this.isSurge() || this.isQuanX() || this.isLoon()) {
|
||||
$done(_0x5b659f);
|
||||
}
|
||||
}
|
||||
}(_0x1e4724, _0xff6f77);
|
||||
}
|
||||
639
bjxd.py
Normal file
639
bjxd.py
Normal file
@@ -0,0 +1,639 @@
|
||||
"""
|
||||
北京现代 APP 自动任务脚本
|
||||
功能：自动完成签到、浏览文章、每日答题等任务
|
||||
DOG :QQ 2979873337 努力中（🤩） 禁止使用 此人是探子 任何人见了避而远之
|
||||
环境变量：
|
||||
BJXD: str - 北京现代 APP api token (多个账号用英文逗号分隔，建议每个账号一个变量)
|
||||
BJXD1/BJXD2/BJXD3: str - 北京现代 APP api token (每个账号一个变量)
|
||||
BJXD_ANSWER: str - 预设答案 (可选, ABCD 中的一个)
|
||||
HUNYUAN_API_KEY: str - 腾讯混元AI APIKey (可选)
|
||||
|
||||
cron: 25 6 * * *
|
||||
"""
|
||||
|
||||
import os
|
||||
import random
|
||||
import time
|
||||
from datetime import datetime
|
||||
from typing import List, Dict, Any
|
||||
import requests
|
||||
from urllib3.exceptions import InsecureRequestWarning, InsecurePlatformWarning
|
||||
|
||||
# 禁用 SSL 警告
|
||||
requests.packages.urllib3.disable_warnings(InsecureRequestWarning)
|
||||
requests.packages.urllib3.disable_warnings(InsecurePlatformWarning)
|
||||
|
||||
|
||||
class BeiJingHyundai:
|
||||
"""北京现代APP自动任务类"""
|
||||
|
||||
# 基础配置
|
||||
NAME = "北京现代 APP 自动任务"
|
||||
BASE_URL = "https://bm2-api.bluemembers.com.cn"
|
||||
|
||||
# API endpoints
|
||||
API_USER_INFO = "/v1/app/account/users/info"
|
||||
API_MY_SCORE = "/v1/app/user/my_score"
|
||||
API_TASK_LIST = "/v1/app/user/task/list"
|
||||
API_SIGN_LIST = "/v1/app/user/reward_list"
|
||||
API_SIGN_SUBMIT = "/v1/app/user/reward_report"
|
||||
API_ARTICLE_LIST = "/v1/app/white/article/list2"
|
||||
API_ARTICLE_DETAIL = "/v1/app/white/article/detail_app/{}"
|
||||
API_ARTICLE_SCORE_SUBMIT = "/v1/app/score"
|
||||
API_QUESTION_INFO = "/v1/app/special/daily/ask_info"
|
||||
API_QUESTION_SUBMIT = "/v1/app/special/daily/ask_answer"
|
||||
|
||||
# 预设的备用 share_user_hid 列表
|
||||
BACKUP_HIDS = [
|
||||
"a6688ec1a9ee429fa7b68d50e0c92b1f",
|
||||
"bb8cd2e44c7b45eeb8cc5f7fa71c3322",
|
||||
"5f640c50061b400c91be326c8fe0accd",
|
||||
"55a5d82dacd9417483ae369de9d9b82d",
|
||||
]
|
||||
|
||||
def __init__(self):
|
||||
"""初始化实例变量"""
|
||||
self.token: str = "" # 当前用户token
|
||||
self.user: Dict[str, Any] = {} # 当前用户信息
|
||||
self.users: List[Dict[str, Any]] = [] # 所有用户信息列表
|
||||
self.correct_answer: str = "" # 正确答案
|
||||
self.preset_answer: str = "" # 预设答案
|
||||
self.ai_api_key: str = "" # 腾讯混元AI APIKey
|
||||
self.wrong_answers: set = set() # 错误答案集合
|
||||
self.log_content: str = "" # 日志内容
|
||||
|
||||
def log(self, content: str, print_to_console: bool = True) -> None:
|
||||
"""添加日志"""
|
||||
if print_to_console:
|
||||
print(content)
|
||||
self.log_content += content + "\n"
|
||||
|
||||
def push_notification(self) -> None:
|
||||
"""推送通知"""
|
||||
try:
|
||||
QLAPI.notify(self.NAME, self.log_content)
|
||||
except NameError:
|
||||
print(f"\n\n🚀 推送通知\n\n{self.NAME}\n\n{self.log_content}")
|
||||
|
||||
def make_request(self, method: str, endpoint: str, **kwargs) -> Dict[str, Any]:
|
||||
"""
|
||||
发送API请求
|
||||
Args:
|
||||
method: 请求方法 (GET/POST)
|
||||
endpoint: API端点
|
||||
**kwargs: 请求参数
|
||||
Returns:
|
||||
Dict[str, Any]: API响应数据
|
||||
"""
|
||||
url = f"{self.BASE_URL}{endpoint}"
|
||||
headers = {"token": self.token, "device": "android"}
|
||||
if "headers" not in kwargs:
|
||||
kwargs["headers"] = headers
|
||||
else:
|
||||
kwargs["headers"].update(headers)
|
||||
try:
|
||||
response = requests.request(method, url, **kwargs)
|
||||
response.raise_for_status()
|
||||
return response.json()
|
||||
except requests.exceptions.RequestException as e:
|
||||
self.log(f"❌ API request failed: {str(e)}")
|
||||
return {"code": -1, "msg": str(e)}
|
||||
|
||||
def get_user_info(self) -> Dict[str, Any]:
|
||||
"""
|
||||
获取用户信息
|
||||
Returns:
|
||||
Dict[str, Any]: 用户信息字典，获取失败返回空字典
|
||||
"""
|
||||
response = self.make_request("GET", self.API_USER_INFO)
|
||||
print(f"get_user_info API response ——> {response}")
|
||||
|
||||
if response["code"] == 0:
|
||||
data = response["data"]
|
||||
# 直接生成掩码后的手机号
|
||||
masked_phone = f"{data['phone'][:3]}******{data['phone'][-2:]}"
|
||||
return {
|
||||
"token": self.token,
|
||||
"hid": data["hid"],
|
||||
"nickname": data["nickname"],
|
||||
"phone": masked_phone, # 直接存储掩码后的手机号
|
||||
"score_value": data["score_value"],
|
||||
"share_user_hid": "",
|
||||
"task": {"sign": False, "view": False, "question": False},
|
||||
}
|
||||
|
||||
self.log(f"❌ 账号已失效, 请重新获取 token: {self.token}")
|
||||
return {}
|
||||
|
||||
def get_score_details(self) -> None:
|
||||
"""显示积分详情，包括总积分、今日变动和最近记录"""
|
||||
params = {"page_no": "1", "page_size": "10"} # 获取最近10条记录
|
||||
response = self.make_request("GET", self.API_MY_SCORE, params=params)
|
||||
print(f"get_score_details API response ——> {response}")
|
||||
|
||||
if response["code"] == 0:
|
||||
data = response["data"]
|
||||
# 先获取今日记录
|
||||
today = datetime.now().strftime("%Y-%m-%d")
|
||||
today_records = [
|
||||
record
|
||||
for record in data["points_record"]["list"]
|
||||
if record["created_at"].startswith(today)
|
||||
]
|
||||
|
||||
# 计算今日积分变化
|
||||
today_score = sum(
|
||||
int(record["score_str"].strip("+")) for record in today_records
|
||||
)
|
||||
today_score_str = f"+{today_score}" if today_score > 0 else str(today_score)
|
||||
self.log(f"🎉 总积分: {data['score']} | 今日积分变动: {today_score_str}")
|
||||
|
||||
# 输出今日积分记录
|
||||
if today_records:
|
||||
self.log("今日积分记录：")
|
||||
for record in today_records:
|
||||
self.log(
|
||||
f"{record['created_at']} {record['desc']} {record['score_str']}"
|
||||
)
|
||||
else:
|
||||
self.log("今日暂无积分变动")
|
||||
|
||||
# 任务相关
|
||||
def check_task_status(self, user: Dict[str, Any]) -> None:
|
||||
"""检查任务状态"""
|
||||
response = self.make_request("GET", self.API_TASK_LIST)
|
||||
print(f"get_task_status API response ——> {response}")
|
||||
|
||||
if response["code"] != 0:
|
||||
self.log(f'❌ 获取任务列表失败: {response["msg"]}')
|
||||
return
|
||||
|
||||
actions = response.get("data", {})
|
||||
|
||||
# 检查签到任务
|
||||
if "action4" in actions:
|
||||
user["task"]["sign"] = actions["action4"].get("status") == 1
|
||||
else:
|
||||
self.log("❌ task list action4 签到任务 不存在")
|
||||
|
||||
# 检查浏览文章任务
|
||||
if "action12" in actions:
|
||||
user["task"]["view"] = actions["action12"].get("status") == 1
|
||||
else:
|
||||
self.log("❌ task list action12 浏览文章任务 不存在")
|
||||
|
||||
# 检查答题任务
|
||||
if "action39" in actions:
|
||||
user["task"]["question"] = actions["action39"].get("status") == 1
|
||||
else:
|
||||
self.log("❌ task list action39 答题任务 不存在")
|
||||
|
||||
# 签到相关
|
||||
def get_sign_info(self) -> None:
|
||||
"""执行签到任务"""
|
||||
max_attempts = 5 # 最大尝试次数
|
||||
best_score = 0
|
||||
best_params = None
|
||||
|
||||
for attempt in range(max_attempts):
|
||||
response = self.make_request("GET", self.API_SIGN_LIST)
|
||||
print(f"get_sign_info (attempt {attempt + 1}) API response ——> {response}")
|
||||
|
||||
if response["code"] != 0:
|
||||
self.log(f'❌ 获取签到列表失败: {response["msg"]}')
|
||||
break
|
||||
|
||||
data = response["data"]
|
||||
hid = data["hid"]
|
||||
reward_hash = data["rewardHash"]
|
||||
|
||||
for item in data["list"]:
|
||||
if item["hid"] == hid:
|
||||
current_score = item["score"]
|
||||
print(
|
||||
f"第{attempt + 1}次获取签到列表: score={current_score} hid={hid} rewardHash={reward_hash}"
|
||||
)
|
||||
|
||||
if current_score > best_score:
|
||||
best_score = current_score
|
||||
best_params = (hid, reward_hash, current_score)
|
||||
print(f"当前可获得签到积分: {best_score}")
|
||||
break
|
||||
|
||||
if attempt < max_attempts - 1: # 不是最后一次循环
|
||||
print(f"继续尝试获取更高积分, 延时5-10s")
|
||||
time.sleep(random.randint(5, 10))
|
||||
else: # 最后一次循环 即将提交签到
|
||||
print(f"即将提交签到, 延时3-4s")
|
||||
time.sleep(random.randint(3, 4))
|
||||
|
||||
if best_params:
|
||||
self.submit_sign(*best_params)
|
||||
else:
|
||||
self.log("❌ 未能获取到有效的签到参数")
|
||||
|
||||
def submit_sign(self, hid: str, reward_hash: str, score: int) -> None:
|
||||
"""提交签到"""
|
||||
json_data = {
|
||||
"hid": hid,
|
||||
"hash": reward_hash,
|
||||
"sm_deviceId": "",
|
||||
"ctu_token": None,
|
||||
}
|
||||
response = self.make_request("POST", self.API_SIGN_SUBMIT, json=json_data)
|
||||
print(f"submit_sign API response ——> {response}")
|
||||
|
||||
if response["code"] == 0:
|
||||
self.log(f"✅ 签到成功 | 积分 +{score}")
|
||||
else:
|
||||
self.log(f'❌ 签到失败: {response["msg"]}')
|
||||
|
||||
# 文章浏览相关
|
||||
def get_article_list(self) -> List[str]:
|
||||
"""获取文章列表"""
|
||||
params = {
|
||||
"page_no": "1",
|
||||
"page_size": "20",
|
||||
"type_hid": "",
|
||||
}
|
||||
response = self.make_request("GET", self.API_ARTICLE_LIST, params=params)
|
||||
print(f"get_article_list API response ——> {response}")
|
||||
|
||||
if response["code"] == 0:
|
||||
# 从文章列表中随机选择3个ID
|
||||
article_list = [item["data_id"] for item in response["data"]["list"]]
|
||||
return random.sample(article_list, min(3, len(article_list)))
|
||||
|
||||
self.log(f'❌ 获取文章列表失败: {response["msg"]}')
|
||||
return []
|
||||
|
||||
def get_article_detail(self, article_id: str) -> None:
|
||||
"""浏览文章"""
|
||||
self.log(f"浏览文章 article_id: {article_id}")
|
||||
endpoint = self.API_ARTICLE_DETAIL.format(article_id)
|
||||
self.make_request("GET", endpoint)
|
||||
|
||||
def submit_article_score(self) -> None:
|
||||
"""提交文章积分"""
|
||||
json_data = {
|
||||
"ctu_token": "",
|
||||
"action": 12,
|
||||
}
|
||||
response = self.make_request(
|
||||
"POST", self.API_ARTICLE_SCORE_SUBMIT, json=json_data
|
||||
)
|
||||
print(f"submit_article_score API response ——> {response}")
|
||||
|
||||
if response["code"] == 0:
|
||||
score = response["data"]["score"]
|
||||
self.log(f"✅ 浏览文章成功 | 积分 +{score}")
|
||||
else:
|
||||
self.log(f'❌ 浏览文章失败: {response["msg"]}')
|
||||
|
||||
# 答题相关
|
||||
def get_question_info(self, share_user_hid: str) -> None:
|
||||
"""执行答题任务"""
|
||||
params = {"date": datetime.now().strftime("%Y%m%d")}
|
||||
response = self.make_request("GET", self.API_QUESTION_INFO, params=params)
|
||||
print(f"get_question_info API response ——> {response}")
|
||||
if response["code"] != 0:
|
||||
self.log(f'❌ 获取问题失败: {response["msg"]}')
|
||||
return
|
||||
# response['data']['state'] 1=表示未答题 2=已答题且正确 3=答错且未有人帮忙答题 4=答错但有人帮忙答题
|
||||
if response["data"].get("state") == 3:
|
||||
self.log("今日已答题但回答错误，当前无人帮助答题，跳过")
|
||||
return
|
||||
if response["data"].get("state") != 1:
|
||||
if response["data"].get("answer"):
|
||||
answer = response["data"]["answer"][0]
|
||||
if answer in ["A", "B", "C", "D"]:
|
||||
self.correct_answer = answer
|
||||
self.log(f"今日已答题，跳过，答案：{answer}")
|
||||
return
|
||||
self.log("今日已答题，但未获取到答案，跳过")
|
||||
return
|
||||
|
||||
question_info = response["data"]["question_info"]
|
||||
questions_hid = question_info["questions_hid"]
|
||||
|
||||
# 构建问题字符串，只包含未被标记为错误的选项
|
||||
question_str = f"{question_info['content']}\n"
|
||||
valid_options = []
|
||||
for option in question_info["option"]:
|
||||
if option["option"] not in self.wrong_answers:
|
||||
valid_options.append(option)
|
||||
question_str += f'{option["option"]}. {option["option_content"]}\n'
|
||||
else:
|
||||
print(f"跳过错误选项 {option['option']}. {option['option_content']}")
|
||||
|
||||
print(f"\n问题详情:\n{question_str}")
|
||||
|
||||
# 如果只剩一个选项，直接使用
|
||||
if len(valid_options) == 1:
|
||||
answer = valid_options[0]["option"]
|
||||
self.log(f"仅剩一个选项，使用答案: {answer}")
|
||||
time.sleep(random.randint(3, 5))
|
||||
self.submit_question_answer(questions_hid, answer, share_user_hid)
|
||||
return
|
||||
|
||||
# 获取答案并提交
|
||||
answer = self.get_question_answer(question_str)
|
||||
|
||||
time.sleep(random.randint(3, 5))
|
||||
self.submit_question_answer(questions_hid, answer, share_user_hid)
|
||||
|
||||
def get_ai_answer(self, question: str) -> str:
|
||||
"""获取AI答案"""
|
||||
headers = {
|
||||
"Authorization": f"Bearer {self.ai_api_key}",
|
||||
"Content-Type": "application/json",
|
||||
}
|
||||
prompt = f"你是一个专业的北京现代汽车专家，请直接给出这个单选题的答案，并且不要带'答案'等其他内容。\n{question}"
|
||||
json_data = {
|
||||
"model": "hunyuan-turbo",
|
||||
"messages": [{"role": "user", "content": prompt}],
|
||||
"enable_enhancement": True,
|
||||
"force_search_enhancement": True,
|
||||
"enable_instruction_search": True,
|
||||
}
|
||||
|
||||
try:
|
||||
response = requests.post(
|
||||
"https://api.hunyuan.cloud.tencent.com/v1/chat/completions",
|
||||
headers=headers,
|
||||
json=json_data,
|
||||
)
|
||||
response.raise_for_status()
|
||||
response_json = response.json()
|
||||
print(f"腾讯混元AI API response ——> {response_json}")
|
||||
|
||||
# 获取AI回答内容并转大写
|
||||
ai_response = response_json["choices"][0]["message"]["content"].upper()
|
||||
|
||||
# 使用集合操作找出有效答案
|
||||
valid_answers = set("ABCD") - self.wrong_answers
|
||||
found_answers = set(ai_response) & valid_answers
|
||||
|
||||
# 如果找到答案则返回其中一个
|
||||
if found_answers:
|
||||
return found_answers.pop()
|
||||
else:
|
||||
print(f"❌ 没有找到符合的 AI 答案")
|
||||
return ""
|
||||
|
||||
except Exception as e:
|
||||
print(f"腾讯混元AI API 请求失败: {str(e)}")
|
||||
|
||||
return ""
|
||||
|
||||
def get_question_answer(self, question: str) -> str:
|
||||
"""获取答题答案"""
|
||||
# 1. 存在正确答案时，使用正确答案
|
||||
if self.correct_answer:
|
||||
self.log(f"使用历史正确答案: {self.correct_answer}")
|
||||
return self.correct_answer
|
||||
|
||||
# 2. 存在预设答案时，使用预设答案
|
||||
if self.preset_answer:
|
||||
self.log(f"使用预设答案: {self.preset_answer}")
|
||||
return self.preset_answer
|
||||
|
||||
# 3. 存在AI APIKey时，使用AI答案
|
||||
if self.ai_api_key:
|
||||
ai_answer = self.get_ai_answer(question)
|
||||
if ai_answer:
|
||||
self.log(f"使用AI答案: {ai_answer}")
|
||||
return ai_answer
|
||||
|
||||
# 4. 随机选择答案（排除错误答案）
|
||||
answer = self.get_random_answer()
|
||||
self.log(f"随机答题，答案: {answer}")
|
||||
return answer
|
||||
|
||||
def get_random_answer(self) -> str:
|
||||
"""获取随机答案，排除已知错误答案"""
|
||||
available_answers = set(["A", "B", "C", "D"]) - self.wrong_answers
|
||||
if not available_answers:
|
||||
self.wrong_answers.clear()
|
||||
available_answers = set(["A", "B", "C", "D"])
|
||||
return random.choice(list(available_answers))
|
||||
|
||||
def get_answered_question(self) -> None:
|
||||
"""从已答题账号获取答案"""
|
||||
params = {"date": datetime.now().strftime("%Y%m%d")}
|
||||
response = self.make_request("GET", self.API_QUESTION_INFO, params=params)
|
||||
print(f"get_answered_question API response ——> {response}")
|
||||
if response["code"] != 0:
|
||||
self.log(f'❌ 从已答题账号获取问题失败: {response["msg"]}')
|
||||
return
|
||||
# response['data']['state'] 1=表示未答题 2=已答题且正确 4=已答题但错误
|
||||
if response["code"] == 0 and response["data"].get("answer"):
|
||||
answer = response["data"]["answer"][0]
|
||||
if answer in ["A", "B", "C", "D"]:
|
||||
self.correct_answer = answer
|
||||
self.log(f"从已答题账号获取到答案：{answer}")
|
||||
return
|
||||
self.log("从已答题账号获取答案失败")
|
||||
|
||||
def submit_question_answer(
|
||||
self, question_id: str, answer: str, share_user_hid: str
|
||||
) -> None:
|
||||
"""提交答题答案"""
|
||||
json_data = {
|
||||
"answer": answer,
|
||||
"questions_hid": question_id,
|
||||
"ctu_token": "",
|
||||
}
|
||||
if share_user_hid:
|
||||
json_data["date"] = datetime.now().strftime("%Y%m%d")
|
||||
json_data["share_user_hid"] = share_user_hid
|
||||
|
||||
response = self.make_request("POST", self.API_QUESTION_SUBMIT, json=json_data)
|
||||
print(f"submit_question_answer API response ——> {response}")
|
||||
|
||||
if response["code"] == 0:
|
||||
data = response["data"]
|
||||
if data["state"] == 3: # 答错
|
||||
# 记录错误答案
|
||||
self.wrong_answers.add(answer)
|
||||
# 如果是正确答案，清除它
|
||||
if self.correct_answer == answer:
|
||||
self.correct_answer = ""
|
||||
# 如果是预设答案，清除它
|
||||
if self.preset_answer == answer:
|
||||
self.preset_answer = ""
|
||||
self.log("❌ 答题错误")
|
||||
elif data["state"] == 2: # 答对了
|
||||
if self.correct_answer != answer:
|
||||
self.correct_answer = answer
|
||||
score = data["answer_score"]
|
||||
self.log(f"✅ 答题正确 | 积分 +{score}")
|
||||
else:
|
||||
self.log(f'❌ 答题失败: {response["msg"]}')
|
||||
|
||||
def get_backup_share_hid(self, user_hid: str) -> str:
|
||||
"""从备用 hid 列表中获取一个不同于用户自身的 hid"""
|
||||
available_hids = [hid for hid in self.BACKUP_HIDS if hid != user_hid]
|
||||
return random.choice(available_hids) if available_hids else ""
|
||||
|
||||
def run(self) -> None:
|
||||
"""运行主程序"""
|
||||
# 使用列表保持顺序，使用集合实现去重
|
||||
tokens = []
|
||||
tokens_set = set()
|
||||
|
||||
# 方式1: 从BJXD环境变量获取(逗号分隔的多个token)
|
||||
token_str = os.getenv("BJXD")
|
||||
if token_str:
|
||||
# 过滤空值并保持顺序添加
|
||||
for token in token_str.split(","):
|
||||
token = token.strip()
|
||||
if token and token not in tokens_set:
|
||||
tokens.append(token)
|
||||
tokens_set.add(token)
|
||||
|
||||
# 方式2: 从BJXD1/BJXD2/BJXD3等环境变量获取
|
||||
i = 1
|
||||
empty_count = 0 # 记录连续空值的数量
|
||||
while empty_count < 5: # 连续5个空值才退出
|
||||
token = os.getenv(f"BJXD{i}")
|
||||
if not token:
|
||||
empty_count += 1
|
||||
else:
|
||||
token = token.strip()
|
||||
if token and token not in tokens_set: # 确保token不是空字符串且未重复
|
||||
empty_count = 0 # 重置连续空值计数
|
||||
tokens.append(token)
|
||||
tokens_set.add(token)
|
||||
i += 1
|
||||
|
||||
if not tokens:
|
||||
self.log(
|
||||
"⛔️ 未获取到 tokens, 请检查环境变量 BJXD 或 BJXD1/BJXD2/... 是否填写"
|
||||
)
|
||||
self.push_notification()
|
||||
return
|
||||
|
||||
self.log(f"👻 共获取到用户 token {len(tokens)} 个")
|
||||
|
||||
self.ai_api_key = os.getenv("HUNYUAN_API_KEY", "")
|
||||
self.log(
|
||||
"💯 已获取到腾讯混元 AI APIKey, 使用腾讯混元 AI 答题"
|
||||
if self.ai_api_key
|
||||
else "😭 未设置腾讯混元 AI HUNYUAN_API_KEY 环境变量，使用随机答题"
|
||||
)
|
||||
|
||||
# 获取预设答案
|
||||
self.preset_answer = os.getenv("BJXD_ANSWER", "").upper()
|
||||
if self.preset_answer:
|
||||
if self.preset_answer in ["A", "B", "C", "D"]:
|
||||
self.log(f"📝 已获取预设答案: {self.preset_answer}")
|
||||
else:
|
||||
self.preset_answer = ""
|
||||
self.log("❌ 预设答案格式错误，仅支持 A/B/C/D")
|
||||
|
||||
# 获取所有用户信息
|
||||
for token in tokens:
|
||||
self.token = token
|
||||
user = self.get_user_info()
|
||||
if user:
|
||||
self.users.append(user)
|
||||
|
||||
if not self.users:
|
||||
self.log("❌ 未获取到有效用户")
|
||||
return
|
||||
|
||||
# 设置分享用户ID
|
||||
for i, user in enumerate(self.users):
|
||||
prev_index = (i - 1) if i > 0 else len(self.users) - 1
|
||||
# 如果有多个用户且上一个用户不是自己，使用上一个用户的 hid
|
||||
if len(self.users) > 1 and self.users[prev_index]["hid"] != user["hid"]:
|
||||
user["share_user_hid"] = self.users[prev_index]["hid"]
|
||||
else:
|
||||
# 否则从备用 hid 列表中选择一个
|
||||
user["share_user_hid"] = self.get_backup_share_hid(user["hid"])
|
||||
|
||||
# 执行任务
|
||||
self.log("\n============ 执行任务 ============")
|
||||
for i, user in enumerate(self.users, 1):
|
||||
# 更新当前用户信息
|
||||
self.token = user["token"]
|
||||
self.user = user
|
||||
|
||||
# 随机延迟
|
||||
if i > 1:
|
||||
print("\n进行下一个账号, 等待 5-10 秒...")
|
||||
time.sleep(random.randint(5, 10))
|
||||
|
||||
self.log(f"\n======== ▷ 第 {i} 个账号 ◁ ========")
|
||||
|
||||
# 打印用户信息
|
||||
self.log(
|
||||
f"👻 用户名: {self.user['nickname']} | "
|
||||
f"手机号: {self.user['phone']} | "
|
||||
f"积分: {self.user['score_value']}\n"
|
||||
f"🆔 用户hid: {self.user['hid']}\n"
|
||||
f"🆔 分享hid: {self.user['share_user_hid']}"
|
||||
)
|
||||
|
||||
# 检查任务状态
|
||||
self.check_task_status(self.user)
|
||||
self.log(f"任务状态: {self.user['task']}")
|
||||
|
||||
# 调试使用 设置任务状态
|
||||
# self.user["task"]["sign"] = False
|
||||
# self.user["task"]["view"] = False
|
||||
# self.user["task"]["question"] = False
|
||||
|
||||
# 签到
|
||||
if not self.user["task"]["sign"]:
|
||||
self.get_sign_info()
|
||||
time.sleep(random.randint(5, 10))
|
||||
else:
|
||||
self.log("✅ 签到任务 已完成，跳过")
|
||||
|
||||
# 阅读文章
|
||||
if not self.user["task"]["view"]:
|
||||
article_ids = self.get_article_list()
|
||||
if article_ids:
|
||||
for article_id in article_ids: # 已经只有3篇了
|
||||
self.get_article_detail(article_id)
|
||||
time.sleep(random.randint(10, 15))
|
||||
self.submit_article_score()
|
||||
else:
|
||||
self.log("✅ 浏览文章任务 已完成，跳过")
|
||||
|
||||
# 答题
|
||||
if not self.user["task"]["question"]:
|
||||
self.get_question_info(self.user["share_user_hid"])
|
||||
else:
|
||||
self.log("✅ 答题任务 已完成，跳过")
|
||||
if not self.correct_answer:
|
||||
self.get_answered_question()
|
||||
|
||||
self.log("\n============ 积分详情 ============")
|
||||
for i, user in enumerate(self.users, 1):
|
||||
if i > 1:
|
||||
print("\n进行下一个账号, 等待 5-10 秒...")
|
||||
time.sleep(random.randint(5, 10))
|
||||
|
||||
# 更新当前用户信息
|
||||
self.token = user["token"]
|
||||
self.user = user
|
||||
|
||||
self.log(f"\n======== ▷ 第 {i} 个账号 ◁ ========")
|
||||
|
||||
# 打印用户信息
|
||||
self.log(
|
||||
f"👻 用户名: {self.user['nickname']} | 手机号: {self.user['phone']}"
|
||||
)
|
||||
|
||||
# 显示积分详情
|
||||
self.get_score_details()
|
||||
|
||||
# 最后推送通知
|
||||
self.push_notification()
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
BeiJingHyundai().run()
|
||||
Reference in New Issue
Block a user