diff --git a/ljzf.js b/ljzf.js new file mode 100644 index 0000000..89a7283 --- /dev/null +++ b/ljzf.js @@ -0,0 +1,1298 @@ +/* +小程序:霖久智服 +变量:G_ljzfhd多号&或换行 +不需要抓包小程序登录后写入手机号即可 +*/ +// 禁用 punycode 弃用警告 +process.removeAllListeners('warning'); +process.on('warning', (warning) => { + if (warning.name === 'DeprecationWarning' && warning.message.includes('punycode')) { + return; + } + console.warn(warning.name, warning.message); +}); + +const $ = new Env('霖久智服'); +const axios = require('axios'); +let request = require("request"); +request = request.defaults({ + jar: true +}); + +// ============================================配置管理============================================ +const CONFIG = { + NOTIFY: 1, // 通知开关: 0=关闭通知, 1=打开通知 + DEBUG: 0, // 调试模式: 0=关闭调试, 1=打开调试(会输出详细日志) + MAX_RETRY: 3, // 最大重试次数: 请求失败后的重试次数 + DELAY_MS: 30000, // 延迟时间: 看广告间隔时间(毫秒), 默认30秒 + AD_COUNT: 9, // 看广告次数: 每个账号看广告的次数 + READ_COUNT: 10, // 公众号浏览次数: 每个账号浏览公众号的次数 + REQUEST_TIMEOUT: 10000 // 请求超时: HTTP请求超时时间(毫秒) +}; + +// 配置说明: +// 1. NOTIFY: 控制是否发送通知到手机/邮箱等 +// - 需要配置 sendNotify.js 和安装 got 库: npm install got +// - 如不需要通知，设置为 0 即可 +// 2. DEBUG: 开启后会输出详细的请求和响应数据，用于排查问题 +// 3. DELAY_MS: 建议设置30秒以上，避免请求过快被限制 +// 4. AD_COUNT: 根据实际情况调整，过多可能无效 +// 5. READ_COUNT: 公众号浏览次数，默认10次 + +// 日志管理类 +class Logger { + constructor(debug = false) { + this.debugMode = debug; + this.logs = []; + } + + info(msg, showTime = true) { + const timeStr = showTime ? `[${new Date().toLocaleString()}] ` : ''; + const logMsg = `${timeStr}ℹ️ ${msg}`; + console.log(logMsg); + this.logs.push(logMsg); + } + + success(msg, showTime = true) { + const timeStr = showTime ? `[${new Date().toLocaleString()}] ` : ''; + const logMsg = `${timeStr}✅ ${msg}`; + console.log(logMsg); + this.logs.push(logMsg); + } + + error(msg, showTime = true) { + const timeStr = showTime ? `[${new Date().toLocaleString()}] ` : ''; + const logMsg = `${timeStr}❌ ${msg}`; + console.log(logMsg); + this.logs.push(logMsg); + } + + warn(msg, showTime = true) { + const timeStr = showTime ? `[${new Date().toLocaleString()}] ` : ''; + const logMsg = `${timeStr}⚠️ ${msg}`; + console.log(logMsg); + this.logs.push(logMsg); + } + + debug(msg, showTime = true) { + if (!this.debugMode) return; + const timeStr = showTime ? `[${new Date().toLocaleString()}] ` : ''; + const logMsg = `${timeStr}🔍 [DEBUG] ${msg}`; + console.log(logMsg); + this.logs.push(logMsg); + } + + getLogs() { + return this.logs.join('\n'); + } +} + +const logger = new Logger(CONFIG.DEBUG); +const { log } = console; +const Notify = CONFIG.NOTIFY; +const debug = CONFIG.DEBUG; +let G_ljzfhd = ($.isNode() ? process.env.G_ljzfhd : $.getdata("G_ljzfhd")) || "" +let G_ljzfhdArr = []; +let data = ''; +let msg = ''; +let ckid = ''; // 全局变量存储用户ID + +// 统计信息 +let stats = { + totalAccounts: 0, + successAccounts: 0, + failedAccounts: 0, + totalPoints: 0, + earnedPoints: 0, // 本次获得的积分 + signInSuccess: 0, + signInFailed: 0, + adSuccess: 0, + adFailed: 0, + taskSuccess: 0, + taskFailed: 0, + errors: [], + warnings: [], // 警告信息 + accountDetails: [] // 存储每个账号的详细信息 +}; +var hours = new Date().getMonth(); +var timestamp = Math.round(new Date().getTime()).toString(); + +// HTTP请求封装函数 +async function makeRequest(options, retryCount = 0) { + try { + logger.debug(`发起请求: ${options.method} ${options.url}`); + logger.debug(`请求参数: ${JSON.stringify(options, null, 2)}`); + + const response = await axios.request({ + ...options, + timeout: CONFIG.REQUEST_TIMEOUT + }); + + logger.debug(`响应数据: ${JSON.stringify(response.data, null, 2)}`); + return response; + } catch (error) { + logger.error(`请求失败: ${error.message}`); + + if (retryCount < CONFIG.MAX_RETRY) { + logger.warn(`第 ${retryCount + 1} 次重试...`); + await $.wait(2000); // 等待2秒后重试 + return makeRequest(options, retryCount + 1); + } + + throw error; + } +} + +// 延迟函数 +function delay(ms) { + return new Promise(resolve => setTimeout(resolve, ms)); +} +!(async () => { + if (typeof $request !== "undefined") { + await GetRewrite(); + } else { + if (!(await Envs())) + return; + else { + + const beijingTime = new Date( + new Date().getTime() + new Date().getTimezoneOffset() * 60 * 1000 + + 8 * 60 * 60 * 1000).toLocaleString(); + + logger.info('='.repeat(50)); + logger.info(`🚀 霖久智服脚本开始执行`); + logger.info(`⏰ 北京时间: ${beijingTime}`); + logger.info('='.repeat(50)); + + addNotifyStr(`🚀 霖久智服 - ${beijingTime}`, true); + + stats.totalAccounts = G_ljzfhdArr.length; + logger.info(`共找到 ${G_ljzfhdArr.length} 个账号`); + logger.debug(`账号数组: ${JSON.stringify(G_ljzfhdArr)}`); + for (let index = 0; index < G_ljzfhdArr.length; index++) { + + let num = index + 1 + logger.info(`\n${'='.repeat(20)} 第 ${num} 个账号 ${'='.repeat(20)}`); + addNotifyStr(`\n==== 开始【第 ${num} 个账号】====\n`, true) + + G_ljzfhd = G_ljzfhdArr[index]; + + try { + logger.info(`📱 开始处理账号: ${G_ljzfhd}`); + const accountStartTime = Date.now(); + await checkin0(); // 获取token + const accountEndTime = Date.now(); + const accountDuration = ((accountEndTime - accountStartTime) / 1000).toFixed(2); + stats.successAccounts++; + logger.success(`✨ 账号 ${G_ljzfhd} 所有任务执行完成 (耗时: ${accountDuration}秒)`); + addNotifyStr(`✅ 账号执行成功 (耗时: ${accountDuration}秒)`, false); + } catch (error) { + stats.failedAccounts++; + const errorMsg = `账号 ${G_ljzfhd}: ${error.message || error}`; + stats.errors.push(errorMsg); + logger.error(`❌ 账号 ${G_ljzfhd} 执行失败: ${error.message || error}`); + logger.error(`错误堆栈: ${error.stack || '无堆栈信息'}`); + addNotifyStr(`❌ 账号执行失败: ${error.message || error}`, false); + } + } + + // 生成执行报告 + await generateReport(); + await SendMsg(msg); + } + } +})() + .catch((e) => { + logger.error(`脚本执行异常: ${e.message}`); + log(e); + }) + .finally(() => $.done()) + +// 生成执行报告 +async function generateReport() { + logger.info('\n' + '='.repeat(50)); + logger.info('📊 执行报告统计'); + logger.info('='.repeat(50)); + + const successRate = stats.totalAccounts > 0 ? ((stats.successAccounts / stats.totalAccounts) * 100).toFixed(2) : 0; + const report = [ + `📈 总账号数: ${stats.totalAccounts}`, + `✅ 成功账号: ${stats.successAccounts} | ❌ 失败账号: ${stats.failedAccounts}`, + `📊 成功率: ${successRate}%`, + ``, + `🎆 签到: 成功 ${stats.signInSuccess} 次 | 失败 ${stats.signInFailed} 次`, + `📺 看广告: 成功 ${stats.adSuccess} 次 | 失败 ${stats.adFailed} 次`, + `🎯 任务: 成功 ${stats.taskSuccess} 次 | 失败 ${stats.taskFailed} 次`, + ``, + `💰 本次获得积分: ${stats.earnedPoints}`, + `💎 账户总积分: ${stats.totalPoints}` + ]; + + report.forEach(line => { + logger.info(line); + addNotifyStr(line, false); + }); + + // 显示错误详情 + if (stats.errors.length > 0) { + logger.error('\n❌ 错误详情:'); + addNotifyStr('\n❌ 错误详情:', false); + stats.errors.forEach((error, index) => { + logger.error(` ${index + 1}. ${error}`); + addNotifyStr(` ${index + 1}. ${error}`, false); + }); + } + + // 添加账号详情 + if (stats.accountDetails.length > 0) { + logger.info('\n📱 账号详情:'); + addNotifyStr('\n📱 账号详情:', false); + stats.accountDetails.forEach((account, index) => { + const earnedInfo = account.earned ? ` (+${account.earned})` : ''; + const statusIcon = account.status === 'success' ? '✅' : '❌'; + const detail = ` ${statusIcon} ${index + 1}. ${account.phone} - ${account.points}积分${earnedInfo}`; + logger.info(detail); + addNotifyStr(detail, false); + }); + } + + logger.info('='.repeat(50)); + addNotifyStr('\n' + '='.repeat(30), false); +} +async function checkin0() { + return new Promise((resolve) => { + var options = { + method: 'POST', + url: 'https://linjiucloud-api.ysservice.com.cn/mc/member/autoMember', + headers: { + Host: 'linjiucloud-api.ysservice.com.cn', + xweb_xhr: '1', + 'X-Client-Id': '64', + 'X-Tenant-Id': '10111', + Referer: 'https://servicewechat.com/wx0a9f159eddb2c5f8/105/page-frame.html', + Accept: '*/*', + 'Accept-Encoding': 'gzip, deflate, br', + 'User-Agent': 'PostmanRuntime-ApipostRuntime/1.1.0', + Connection: 'keep-alive', + 'Content-Type': 'application/json' + }, + data: `{"channel":"CHARGE_PLATFORM","tenantId":"10111","mobile":${G_ljzfhd}}` + }; + if (debug) { + log(`\n【debug】=============== 这是 请求 url ===============`); + log(JSON.stringify(options)); + } + axios.request(options).then(async function (response) { + try { + data = response.data; + if (debug) { + log(`\n\n【debug】===============这是 返回data==============`); + log(JSON.stringify(response.data)); + } + + + if (!data.data) { + throw new Error('获取用户ID失败，请检查手机号是否正确'); + } + ckid = data.data; + logger.info(`✅ 成功获取用户ID: ${ckid}`); + logger.debug(`用户ID详情: ${JSON.stringify(ckid)}`); + + // 执行签到 + logger.info('\n📝 开始执行签到任务...'); + await checkin(); + + // 获取并执行任务 + logger.info('\n🎯 开始获取任务列表...'); + await checkin3(); + + // 公众号浏览任务 + logger.info(`\n� 开始公众号浏览任务共 (共${CONFIG.READ_COUNT}次)...`); + for (let i = 1; i <= CONFIG.READ_COUNT; i++) { + logger.info(`[${i}/${CONFIG.READ_COUNT}] 正在浏览公众号...`); + const readResult = await checkinRead(i); + + // 如果达到上限，停止继续浏览 + if (readResult && readResult.reachedLimit) { + logger.info('ℹ️ 公众号浏览任务已达上限，停止继续执行'); + break; + } + + if (i < CONFIG.READ_COUNT) { + logger.info(`⏳ 等待 ${CONFIG.DELAY_MS / 1000} 秒后继续...`); + await $.wait(CONFIG.DELAY_MS); + } + } + + // 看广告任务 + logger.info(`\n📺 开始看广告任务 (共${CONFIG.AD_COUNT}次)...`); + for (let i = 1; i <= CONFIG.AD_COUNT; i++) { + logger.info(`[${i}/${CONFIG.AD_COUNT}] 正在观看广告...`); + const adResult = await checkin1(i); + + // 如果达到上限，停止继续看广告 + if (adResult && adResult.reachedLimit) { + logger.info('ℹ️ 广告任务已达上限，停止继续执行'); + break; + } + + if (i < CONFIG.AD_COUNT) { + logger.info(`⏳ 等待 ${CONFIG.DELAY_MS / 1000} 秒后继续...`); + await $.wait(CONFIG.DELAY_MS); + } + } + + // 查询最终积分 + logger.info('\n💰 查询账户积分...'); + await checkin2(); + + } catch (e) { + logger.error(`处理响应数据异常: ${e.message}`); + logger.debug(`异常详情: ${e.stack}`); + throw e; + } + }).catch(function (error) { + logger.error(`请求失败: ${error.message}`); + if (error.response) { + logger.error(`响应状态码: ${error.response.status}`); + logger.debug(`响应数据: ${JSON.stringify(error.response.data)}`); + } + throw error; + }).then(res => { + resolve(); + }); + }) + +} +async function checkin() { + return new Promise((resolve) => { + var options = { + method: 'POST', + url: 'https://linjiucloud-api.ysservice.com.cn/mt/web/action/add', + headers: { + Host: 'linjiucloud-api.ysservice.com.cn', + 'X-Auth-Token': '', + 'X-Project-id': '', + xweb_xhr: '1', + 'X-Client-Id': '64', + 'X-Tenant-Id': '10111', + Referer: 'https://servicewechat.com/wx0a9f159eddb2c5f8/105/page-frame.html', + Accept: '*/*', + 'Accept-Encoding': 'gzip, deflate, br', + 'User-Agent': 'PostmanRuntime-ApipostRuntime/1.1.0', + Connection: 'keep-alive', + 'Content-Type': 'application/json' + }, + data: `{"actionRecordCO":{"actionType":"SIGN_IN","actionUnit":"1","channel":"LJZF","createdBy":"${ckid}","unitCount":"1"},"tenantId":"10111"}` + }; + if (debug) { + log(`\n【debug】=============== 这是 请求 url ===============`); + log(JSON.stringify(options)); + } + axios.request(options).then(async function (response) { + try { + data = response.data; + if (debug) { + log(`\n\n【debug】===============这是 返回data==============`); + log(JSON.stringify(response.data)); + } + + if (data.code == 0) { + const points = data.data.pointCount || 0; + stats.signInSuccess++; + stats.earnedPoints += points; + logger.success(`✅ 签到成功，获得 ${points} 积分`); + addNotifyStr(`✅ 签到: +${points}积分`, false); + } else { + stats.signInFailed++; + const msg = data.message || '未知错误'; + logger.warn(`⚠️ 签到失败: ${msg}`); + addNotifyStr(`⚠️ 签到: ${msg}`, false); + // 只记录非正常的错误，已完成/达到上限不算警告 + if (!msg.includes('已完成') && !msg.includes('达到上限') && !msg.includes('超上限')) { + stats.warnings.push(`签到失败: ${msg}`); + } + } + } catch (e) { + stats.signInFailed++; + logger.error(`签到处理异常: ${e.message}`); + stats.warnings.push(`签到异常: ${e.message}`); + } + }).catch(function (error) { + stats.signInFailed++; + logger.error(`签到请求失败: ${error.message}`); + stats.errors.push(`签到请求失败: ${error.message}`); + }).then(res => { + resolve(); + }); + }) + +} +async function checkinRead(readIndex = 0) { + return new Promise((resolve) => { + var options = { + method: 'POST', + url: 'https://linjiucloud-api.ysservice.com.cn/mt/web/action/add', + headers: { + Host: 'linjiucloud-api.ysservice.com.cn', + 'X-Project-id': '', + xweb_xhr: '1', + 'X-Client-Id': '64', + 'X-Tenant-Id': '10111', + Referer: 'https://servicewechat.com/wx0a9f159eddb2c5f8/105/page-frame.html', + Accept: '*/*', + 'Accept-Encoding': 'gzip, deflate, br', + 'User-Agent': 'PostmanRuntime-ApipostRuntime/1.1.0', + Connection: 'keep-alive', + 'Content-Type': 'application/json' + }, + data: `{"actionRecordCO":{"actionType":"READ","actionUnit":"1","channel":"LJZF","createdBy":"${ckid}","unitCount":"1","week":""},"tenantId":"10111"}` + }; + if (debug) { + log(`\n【debug】=============== 这是 请求 url ===============`); + log(JSON.stringify(options)); + } + axios.request(options).then(async function (response) { + try { + data = response.data; + if (debug) { + log(`\n\n【debug】===============这是 返回data==============`); + log(JSON.stringify(response.data)); + } + + if (data.code == 0) { + const points = data.data.pointCount || 0; + stats.taskSuccess++; + stats.earnedPoints += points; + logger.success(`✅ 第${readIndex}次浏览公众号成功，获得 ${points} 积分`); + addNotifyStr(` � 广浏览${readIndex}: +${points}积分`, false); + resolve({ success: true, reachedLimit: false }); + } else { + stats.taskFailed++; + const msg = data.message || '未知错误'; + logger.warn(`⚠️ 第${readIndex}次浏览公众号失败: ${msg}`); + addNotifyStr(` ⚠️ 浏览${readIndex}: ${msg}`, false); + + // 检测是否达到上限 + const reachedLimit = msg.includes('达到上限') || msg.includes('超上限') || msg.includes('已完成') || msg.includes('已达上限'); + if (reachedLimit) { + logger.info('💡 提示: 今日公众号浏览任务已达上限'); + } + resolve({ success: false, reachedLimit: reachedLimit }); + } + } catch (e) { + stats.taskFailed++; + logger.error(`公众号浏览处理异常: ${e.message}`); + stats.errors.push(`浏览${readIndex}异常: ${e.message}`); + resolve({ success: false, reachedLimit: false }); + } + }).catch(function (error) { + stats.taskFailed++; + logger.error(`公众号浏览请求失败: ${error.message}`); + stats.errors.push(`浏览${readIndex}请求失败: ${error.message}`); + resolve({ success: false, reachedLimit: false }); + }); + }) + +} +async function checkin1(adIndex = 0) { + return new Promise((resolve) => { + var options = { + method: 'POST', + url: 'https://linjiucloud-api.ysservice.com.cn/mt/web/action/add', + headers: { + Host: 'linjiucloud-api.ysservice.com.cn', + 'X-Project-id': '', + xweb_xhr: '1', + 'X-Client-Id': '64', + 'X-Tenant-Id': '10111', + Referer: 'https://servicewechat.com/wx0a9f159eddb2c5f8/105/page-frame.html', + Accept: '*/*', + 'Accept-Encoding': 'gzip, deflate, br', + 'User-Agent': 'PostmanRuntime-ApipostRuntime/1.1.0', + Connection: 'keep-alive', + 'Content-Type': 'application/json' + }, + data: `{"actionRecordCO":{"actionType":"AD","actionUnit":"1","channel":"LJZF","createdBy":"${ckid}","unitCount":"1","week":""},"tenantId":"10111"}` + }; + if (debug) { + log(`\n【debug】=============== 这是 请求 url ===============`); + log(JSON.stringify(options)); + } + axios.request(options).then(async function (response) { + try { + data = response.data; + if (debug) { + log(`\n\n【debug】===============这是 返回data==============`); + log(JSON.stringify(response.data)); + } + + if (data.code == 0) { + const points = data.data.pointCount || 0; + stats.adSuccess++; + stats.earnedPoints += points; + logger.success(`✅ 第${adIndex}次看广告成功，获得 ${points} 积分`); + addNotifyStr(` 📺 广告${adIndex}: +${points}积分`, false); + resolve({ success: true, reachedLimit: false }); + } else { + stats.adFailed++; + const msg = data.message || '未知错误'; + logger.warn(`⚠️ 第${adIndex}次看广告失败: ${msg}`); + addNotifyStr(` ⚠️ 广告${adIndex}: ${msg}`, false); + + // 检测是否达到上限 + const reachedLimit = msg.includes('达到上限') || msg.includes('超上限') || msg.includes('已完成') || msg.includes('已达上限'); + if (reachedLimit) { + logger.info('💡 提示: 今日广告任务已达上限'); + } + resolve({ success: false, reachedLimit: reachedLimit }); + } + } catch (e) { + stats.adFailed++; + logger.error(`广告处理异常: ${e.message}`); + stats.errors.push(`广告${adIndex}异常: ${e.message}`); + resolve({ success: false, reachedLimit: false }); + } + }).catch(function (error) { + stats.adFailed++; + logger.error(`广告请求失败: ${error.message}`); + stats.errors.push(`广告${adIndex}请求失败: ${error.message}`); + resolve({ success: false, reachedLimit: false }); + }); + }) + +} +async function checkin2() { + return new Promise((resolve) => { + var options = { + method: 'GET', + url: `https://linjiucloud-api.ysservice.com.cn/mc/member/memberPoint?mobile=${G_ljzfhd}&tenantId=10111`, + headers: { + Host: 'linjiucloud-api.ysservice.com.cn', + 'X-Project-id': '', + xweb_xhr: '1', + 'X-Client-Id': '64', + 'X-Tenant-Id': '10111', + Referer: 'https://servicewechat.com/wx0a9f159eddb2c5f8/105/page-frame.html', + Accept: '*/*', + 'Accept-Encoding': 'gzip, deflate, br', + 'User-Agent': 'PostmanRuntime-ApipostRuntime/1.1.0', + Connection: 'keep-alive', + 'Content-Type': 'application/json' + }, + }; + if (debug) { + log(`\n【debug】=============== 这是 请求 url ===============`); + log(JSON.stringify(options)); + } + axios.request(options).then(async function (response) { + try { + data = response.data; + if (debug) { + log(`\n\n【debug】===============这是 返回data==============`); + log(JSON.stringify(response.data)); + } + + if (data.code !== 0) { + const errorMsg = `查询积分失败: ${data.message || '未知错误'}`; + logger.error(errorMsg); + stats.errors.push(errorMsg); + return; + } + + const currentPoints = data.data.availablePoints || 0; + stats.totalPoints += currentPoints; + + // 计算本次获得的积分（如果有上次记录） + const lastAccount = stats.accountDetails.find(acc => acc.phone === G_ljzfhd); + const earnedThisTime = lastAccount ? currentPoints - lastAccount.points : 0; + + const accountInfo = { + phone: G_ljzfhd, + points: currentPoints, + earned: earnedThisTime > 0 ? earnedThisTime : 0, + status: 'success', + timestamp: new Date().toLocaleString() + }; + stats.accountDetails.push(accountInfo); + + logger.success(`💎 账号 ${G_ljzfhd} 当前总积分: ${currentPoints}`); + if (earnedThisTime > 0) { + logger.info(`📈 本次获得: ${earnedThisTime} 积分`); + } + addNotifyStr(`\n💰 当前积分: ${currentPoints}`, false); + + + } catch (e) { + logger.error(`积分查询处理异常: ${e.message}`); + stats.errors.push(`积分查询异常: ${e.message}`); + } + }).catch(function (error) { + logger.error(`积分查询请求失败: ${error.message}`); + stats.errors.push(`积分查询失败: ${error.message}`); + }).then(res => { + resolve(); + }); + }) + +} +async function checkin3() { + let customers = []; // 用于存储customer_id的数组 + let taskDetails = []; // 保存任务详情到局部变量 + return new Promise((resolve) => { + var options = { + method: 'POST', + url: `https://linjiucloud-api.ysservice.com.cn/mt/mini/task/list`, + headers: { + Host: 'linjiucloud-api.ysservice.com.cn', + 'X-Project-id': '', + xweb_xhr: '1', + 'X-Client-Id': '64', + 'X-Tenant-Id': '10111', + Referer: 'https://servicewechat.com/wx0a9f159eddb2c5f8/105/page-frame.html', + Accept: '*/*', + 'Accept-Encoding': 'gzip, deflate, br', + 'User-Agent': 'PostmanRuntime-ApipostRuntime/1.1.0', + Connection: 'keep-alive', + 'Content-Type': 'application/json' + }, + data: `{"memberId":"${G_ljzfhd}","tenantId":"10111"}` + }; + if (debug) { + log(`\n【debug】=============== 这是 请求 url ===============`); + log(JSON.stringify(options)); + } + axios.request(options).then(async function (response) { + try { + data = response.data; + if (debug) { + log(`\n\n【debug】===============这是 返回data==============`); + log(JSON.stringify(response.data)); + } + + if (data.code !== 0) { + const errorMsg = `获取任务列表失败: ${data.message || '未知错误'}`; + logger.warn(`⚠️ ${errorMsg}`); + stats.errors.push(errorMsg); + return; + } + + if (!data.data || data.data.length === 0) { + logger.info(`ℹ️ 暂无可执行的任务`); + addNotifyStr(`ℹ️ 暂无额外任务`, false); + return; + } + + // 保存任务列表到局部变量，避免被后续请求覆盖 + taskDetails = [...data.data]; + + logger.info(`📋 发现 ${taskDetails.length} 个任务`); + addNotifyStr(`\n🎯 任务列表 (共${taskDetails.length}个):`, false); + + // 打印任务详情 + logger.info(`\n任务详情列表：`); + taskDetails.forEach((task, idx) => { + const taskInfo = { + 序号: idx + 1, + 任务类型: task.tmplType || '未知', + 任务名称: task.title || task.name || task.tmplType, + 任务描述: task.description || task.desc || '-', + 奖励积分: task.pointCount || task.points || '未知', + 任务状态: task.status || task.state || '-' + }; + logger.info(` ${idx + 1}. [${taskInfo.任务类型}] ${taskInfo.任务名称}`); + logger.info(` └─ 描述: ${taskInfo.任务描述}`); + logger.info(` └─ 奖励: ${taskInfo.奖励积分}积分 | 状态: ${taskInfo.任务状态}`); + logger.debug(` └─ 完整数据: ${JSON.stringify(task)}`); + customers.push(task.tmplType); + }); + logger.info(``); + + // 执行任务（跳过READ和AD类型，这两个任务会单独循环执行） + logger.info(`\n开始执行任务...`); + for (let index = 0; index < customers.length; index++) { + const customer = customers[index]; + const taskDetail = taskDetails[index] || {}; + const taskName = taskDetail.title || taskDetail.name || customer; + + // 跳过READ和AD类型的任务，它们会在后面单独循环执行 + if (customer === 'READ' || customer === 'AD') { + logger.info(`\n🎯 [${index + 1}/${customers.length}] 跳过: ${taskName} (将在后续循环中执行)`); + continue; + } + + logger.info(`\n🎯 [${index + 1}/${customers.length}] 执行: ${taskName}`); + await checkin4(customer, index + 1, taskName); + if (index < customers.length - 1) { + logger.debug(`等待2秒后执行下一个任务...`); + await $.wait(2000); + } + } + + + + + } catch (e) { + logger.error(`任务列表处理异常: ${e.message}`); + stats.errors.push(`任务列表异常: ${e.message}`); + } + }).catch(function (error) { + logger.error(`任务列表请求失败: ${error.message}`); + stats.errors.push(`任务列表失败: ${error.message}`); + }).then(res => { + resolve(); + }); + }) + +} +async function checkin4(customer, taskIndex = 0, taskName = '') { + return new Promise((resolve) => { + const displayName = taskName || customer; + var options = { + method: 'POST', + url: 'https://linjiucloud-api.ysservice.com.cn/mt/web/action/add', + headers: { + Host: 'linjiucloud-api.ysservice.com.cn', + 'X-Project-id': '', + xweb_xhr: '1', + 'X-Client-Id': '64', + 'X-Tenant-Id': '10111', + Referer: 'https://servicewechat.com/wx0a9f159eddb2c5f8/105/page-frame.html', + Accept: '*/*', + 'Accept-Encoding': 'gzip, deflate, br', + 'User-Agent': 'PostmanRuntime-ApipostRuntime/1.1.0', + Connection: 'keep-alive', + 'Content-Type': 'application/json' + }, + data: `{"actionRecordCO":{"actionType":"${customer}","actionUnit":"1","channel":"LJZF","createdBy":"${ckid}","unitCount":"1","week":""},"tenantId":"10111"}` + }; + + if (debug) { + logger.debug(`发送任务请求: ${displayName} (${customer})`); + log(`\n【debug】=============== 这是 请求 url ===============`); + log(JSON.stringify(options)); + } + + axios.request(options).then(async function (response) { + try { + data = response.data; + if (debug) { + log(`\n\n【debug】===============这是 返回data==============`); + log(JSON.stringify(response.data)); + } + + if (data.code == 0) { + const points = data.data.pointCount || 0; + stats.taskSuccess++; + stats.earnedPoints += points; + logger.success(` ✅ 完成! 获得 ${points} 积分 (累计: ${stats.earnedPoints})`); + addNotifyStr(` ✅ 任务${taskIndex} [${displayName}]: +${points}积分`, false); + } else { + stats.taskFailed++; + const msg = data.message || '未知错误'; + logger.warn(` ⚠️ 失败: ${msg}`); + addNotifyStr(` ⚠️ 任务${taskIndex} [${displayName}]: ${msg}`, false); + // 只记录真正的错误，已完成/达到上限/配置问题不算警告 + if (!msg.includes('已完成') && + !msg.includes('达到上限') && + !msg.includes('超上限') && + !msg.includes('配置问题') && + !msg.includes('已加过') && + !msg.includes('任务异常')) { + stats.errors.push(`任务${taskIndex}[${displayName}]失败: ${msg}`); + } + } + } catch (e) { + stats.taskFailed++; + logger.error(`任务${taskIndex} [${displayName}] 处理异常: ${e.message}`); + stats.errors.push(`任务${taskIndex}[${displayName}]异常: ${e.message}`); + } + }).catch(function (error) { + stats.taskFailed++; + logger.error(`任务${taskIndex} [${displayName}] 请求失败: ${error.message}`); + stats.errors.push(`任务${taskIndex}[${displayName}]失败: ${error.message}`); + }).then(res => { + resolve(); + }); + }) + +} +async function Envs() { + if (G_ljzfhd) { + if (G_ljzfhd.indexOf("&") != -1) { + G_ljzfhd.split("&").forEach((item) => { + const trimmedItem = item.trim(); + if (trimmedItem) { + G_ljzfhdArr.push(trimmedItem); + } + }); + } else if (G_ljzfhd.indexOf("\n") != -1) { + G_ljzfhd.split("\n").forEach((item) => { + const trimmedItem = item.trim(); + if (trimmedItem) { + G_ljzfhdArr.push(trimmedItem); + } + }); + } else { + const trimmedItem = G_ljzfhd.trim(); + if (trimmedItem) { + G_ljzfhdArr.push(trimmedItem); + } + } + + if (G_ljzfhdArr.length === 0) { + logger.error(`变量 G_ljzfhd 为空，请检查配置`); + addNotifyStr(`❌ 变量 G_ljzfhd 为空，请检查配置`, false); + return false; + } + + logger.info(`✅ 成功加载 ${G_ljzfhdArr.length} 个账号`); + } else { + logger.error(`未填写变量 G_ljzfhd`); + addNotifyStr(`❌ 未填写变量 G_ljzfhd，请先配置环境变量`, false); + return false; + } + + return true; +} +function addNotifyStr(str, is_log = true) { + if (is_log) { + log(`${str}\n`) + } + msg += `${str}\n` +} + +// ============================================发送消息============================================ \\ +async function SendMsg(message) { + if (!message) { + logger.warn('通知消息为空，跳过发送'); + return; + } + + if (Notify > 0) { + try { + logger.info('📤 准备发送通知...'); + if ($.isNode()) { + try { + // 尝试加载 sendNotify（青龙面板自带或本地的） + const notify = require('./sendNotify'); + await notify.sendNotify($.name, message); + logger.success('✅ 通知发送成功'); + } catch (notifyError) { + // 如果是模块未找到错误 + if (notifyError.code === 'MODULE_NOT_FOUND') { + logger.warn('⚠️ 未找到 sendNotify.js 文件'); + logger.info('💡 提示: 将 CONFIG.NOTIFY 设置为 0 可关闭通知功能'); + } else if (notifyError.message && notifyError.message.includes('got')) { + logger.warn('⚠️ 通知模块缺少依赖'); + logger.info('💡 青龙面板用户：在依赖管理中安装 axios'); + logger.info('💡 本地用户：npm install axios'); + } else { + logger.error(`❌ 通知发送失败: ${notifyError.message}`); + } + logger.debug(`错误详情: ${notifyError.stack}`); + // 通知失败不影响主流程，继续执行 + logger.info('ℹ️ 通知发送失败，但脚本已正常执行完成'); + } + } else { + $.msg(message); + logger.success('✅ 通知已推送'); + } + } catch (error) { + logger.error(`❌ 通知处理异常: ${error.message}`); + logger.debug(`错误详情: ${error.stack}`); + logger.info('ℹ️ 通知发送失败，但脚本已正常执行完成'); + } + } else { + logger.info('ℹ️ 通知功能已关闭'); + log(message); + } +} +var MD5 = function (string) { function RotateLeft(lValue, iShiftBits) { return (lValue << iShiftBits) | (lValue >>> (32 - iShiftBits)); } function AddUnsigned(lX, lY) { var lX4, lY4, lX8, lY8, lResult; lX8 = (lX & 0x80000000); lY8 = (lY & 0x80000000); lX4 = (lX & 0x40000000); lY4 = (lY & 0x40000000); lResult = (lX & 0x3FFFFFFF) + (lY & 0x3FFFFFFF); if (lX4 & lY4) { return (lResult ^ 0x80000000 ^ lX8 ^ lY8); } if (lX4 | lY4) { if (lResult & 0x40000000) { return (lResult ^ 0xC0000000 ^ lX8 ^ lY8); } else { return (lResult ^ 0x40000000 ^ lX8 ^ lY8); } } else { return (lResult ^ lX8 ^ lY8); } } function F(x, y, z) { return (x & y) | ((~x) & z); } function G(x, y, z) { return (x & z) | (y & (~z)); } function H(x, y, z) { return (x ^ y ^ z); } function I(x, y, z) { return (y ^ (x | (~z))); } function FF(a, b, c, d, x, s, ac) { a = AddUnsigned(a, AddUnsigned(AddUnsigned(F(b, c, d), x), ac)); return AddUnsigned(RotateLeft(a, s), b); } function GG(a, b, c, d, x, s, ac) { a = AddUnsigned(a, AddUnsigned(AddUnsigned(G(b, c, d), x), ac)); return AddUnsigned(RotateLeft(a, s), b); } function HH(a, b, c, d, x, s, ac) { a = AddUnsigned(a, AddUnsigned(AddUnsigned(H(b, c, d), x), ac)); return AddUnsigned(RotateLeft(a, s), b); } function II(a, b, c, d, x, s, ac) { a = AddUnsigned(a, AddUnsigned(AddUnsigned(I(b, c, d), x), ac)); return AddUnsigned(RotateLeft(a, s), b); } function ConvertToWordArray(string) { var lWordCount; var lMessageLength = string.length; var lNumberOfWords_temp1 = lMessageLength + 8; var lNumberOfWords_temp2 = (lNumberOfWords_temp1 - (lNumberOfWords_temp1 % 64)) / 64; var lNumberOfWords = (lNumberOfWords_temp2 + 1) * 16; var lWordArray = Array(lNumberOfWords - 1); var lBytePosition = 0; var lByteCount = 0; while (lByteCount < lMessageLength) { lWordCount = (lByteCount - (lByteCount % 4)) / 4; lBytePosition = (lByteCount % 4) * 8; lWordArray[lWordCount] = (lWordArray[lWordCount] | (string.charCodeAt(lByteCount) << lBytePosition)); lByteCount++; } lWordCount = (lByteCount - (lByteCount % 4)) / 4; lBytePosition = (lByteCount % 4) * 8; lWordArray[lWordCount] = lWordArray[lWordCount] | (0x80 << lBytePosition); lWordArray[lNumberOfWords - 2] = lMessageLength << 3; lWordArray[lNumberOfWords - 1] = lMessageLength >>> 29; return lWordArray; } function WordToHex(lValue) { var WordToHexValue = "", WordToHexValue_temp = "", lByte, lCount; for (lCount = 0; lCount <= 3; lCount++) { lByte = (lValue >>> (lCount * 8)) & 255; WordToHexValue_temp = "0" + lByte.toString(16); WordToHexValue = WordToHexValue + WordToHexValue_temp.substr(WordToHexValue_temp.length - 2, 2); } return WordToHexValue; } function Utf8Encode(string) { string = string.replace(/\r\n/g, "\n"); var utftext = ""; for (var n = 0; n < string.length; n++) { var c = string.charCodeAt(n); if (c < 128) { utftext += String.fromCharCode(c); } else if ((c > 127) && (c < 2048)) { utftext += String.fromCharCode((c >> 6) | 192); utftext += String.fromCharCode((c & 63) | 128); } else { utftext += String.fromCharCode((c >> 12) | 224); utftext += String.fromCharCode(((c >> 6) & 63) | 128); utftext += String.fromCharCode((c & 63) | 128); } } return utftext; } var x = Array(); var k, AA, BB, CC, DD, a, b, c, d; var S11 = 7, S12 = 12, S13 = 17, S14 = 22; var S21 = 5, S22 = 9, S23 = 14, S24 = 20; var S31 = 4, S32 = 11, S33 = 16, S34 = 23; var S41 = 6, S42 = 10, S43 = 15, S44 = 21; string = Utf8Encode(string); x = ConvertToWordArray(string); a = 0x67452301; b = 0xEFCDAB89; c = 0x98BADCFE; d = 0x10325476; for (k = 0; k < x.length; k += 16) { AA = a; BB = b; CC = c; DD = d; a = FF(a, b, c, d, x[k + 0], S11, 0xD76AA478); d = FF(d, a, b, c, x[k + 1], S12, 0xE8C7B756); c = FF(c, d, a, b, x[k + 2], S13, 0x242070DB); b = FF(b, c, d, a, x[k + 3], S14, 0xC1BDCEEE); a = FF(a, b, c, d, x[k + 4], S11, 0xF57C0FAF); d = FF(d, a, b, c, x[k + 5], S12, 0x4787C62A); c = FF(c, d, a, b, x[k + 6], S13, 0xA8304613); b = FF(b, c, d, a, x[k + 7], S14, 0xFD469501); a = FF(a, b, c, d, x[k + 8], S11, 0x698098D8); d = FF(d, a, b, c, x[k + 9], S12, 0x8B44F7AF); c = FF(c, d, a, b, x[k + 10], S13, 0xFFFF5BB1); b = FF(b, c, d, a, x[k + 11], S14, 0x895CD7BE); a = FF(a, b, c, d, x[k + 12], S11, 0x6B901122); d = FF(d, a, b, c, x[k + 13], S12, 0xFD987193); c = FF(c, d, a, b, x[k + 14], S13, 0xA679438E); b = FF(b, c, d, a, x[k + 15], S14, 0x49B40821); a = GG(a, b, c, d, x[k + 1], S21, 0xF61E2562); d = GG(d, a, b, c, x[k + 6], S22, 0xC040B340); c = GG(c, d, a, b, x[k + 11], S23, 0x265E5A51); b = GG(b, c, d, a, x[k + 0], S24, 0xE9B6C7AA); a = GG(a, b, c, d, x[k + 5], S21, 0xD62F105D); d = GG(d, a, b, c, x[k + 10], S22, 0x2441453); c = GG(c, d, a, b, x[k + 15], S23, 0xD8A1E681); b = GG(b, c, d, a, x[k + 4], S24, 0xE7D3FBC8); a = GG(a, b, c, d, x[k + 9], S21, 0x21E1CDE6); d = GG(d, a, b, c, x[k + 14], S22, 0xC33707D6); c = GG(c, d, a, b, x[k + 3], S23, 0xF4D50D87); b = GG(b, c, d, a, x[k + 8], S24, 0x455A14ED); a = GG(a, b, c, d, x[k + 13], S21, 0xA9E3E905); d = GG(d, a, b, c, x[k + 2], S22, 0xFCEFA3F8); c = GG(c, d, a, b, x[k + 7], S23, 0x676F02D9); b = GG(b, c, d, a, x[k + 12], S24, 0x8D2A4C8A); a = HH(a, b, c, d, x[k + 5], S31, 0xFFFA3942); d = HH(d, a, b, c, x[k + 8], S32, 0x8771F681); c = HH(c, d, a, b, x[k + 11], S33, 0x6D9D6122); b = HH(b, c, d, a, x[k + 14], S34, 0xFDE5380C); a = HH(a, b, c, d, x[k + 1], S31, 0xA4BEEA44); d = HH(d, a, b, c, x[k + 4], S32, 0x4BDECFA9); c = HH(c, d, a, b, x[k + 7], S33, 0xF6BB4B60); b = HH(b, c, d, a, x[k + 10], S34, 0xBEBFBC70); a = HH(a, b, c, d, x[k + 13], S31, 0x289B7EC6); d = HH(d, a, b, c, x[k + 0], S32, 0xEAA127FA); c = HH(c, d, a, b, x[k + 3], S33, 0xD4EF3085); b = HH(b, c, d, a, x[k + 6], S34, 0x4881D05); a = HH(a, b, c, d, x[k + 9], S31, 0xD9D4D039); d = HH(d, a, b, c, x[k + 12], S32, 0xE6DB99E5); c = HH(c, d, a, b, x[k + 15], S33, 0x1FA27CF8); b = HH(b, c, d, a, x[k + 2], S34, 0xC4AC5665); a = II(a, b, c, d, x[k + 0], S41, 0xF4292244); d = II(d, a, b, c, x[k + 7], S42, 0x432AFF97); c = II(c, d, a, b, x[k + 14], S43, 0xAB9423A7); b = II(b, c, d, a, x[k + 5], S44, 0xFC93A039); a = II(a, b, c, d, x[k + 12], S41, 0x655B59C3); d = II(d, a, b, c, x[k + 3], S42, 0x8F0CCC92); c = II(c, d, a, b, x[k + 10], S43, 0xFFEFF47D); b = II(b, c, d, a, x[k + 1], S44, 0x85845DD1); a = II(a, b, c, d, x[k + 8], S41, 0x6FA87E4F); d = II(d, a, b, c, x[k + 15], S42, 0xFE2CE6E0); c = II(c, d, a, b, x[k + 6], S43, 0xA3014314); b = II(b, c, d, a, x[k + 13], S44, 0x4E0811A1); a = II(a, b, c, d, x[k + 4], S41, 0xF7537E82); d = II(d, a, b, c, x[k + 11], S42, 0xBD3AF235); c = II(c, d, a, b, x[k + 2], S43, 0x2AD7D2BB); b = II(b, c, d, a, x[k + 9], S44, 0xEB86D391); a = AddUnsigned(a, AA); b = AddUnsigned(b, BB); c = AddUnsigned(c, CC); d = AddUnsigned(d, DD); } var temp = WordToHex(a) + WordToHex(b) + WordToHex(c) + WordToHex(d); return temp.toLowerCase(); } +function randomString(m) { + for (var e = m > 0 && void 0 !== m ? m : 21, t = ""; t.length < e;) t += Math.random().toString(36).slice(2); + return t.slice(0, e) +} +function randomnum(e) { + e = e || 32; + var t = "1234567890", + a = t.length, + n = ""; + for (i = 0; i < e; i++) + n += t.charAt(Math.floor(Math.random() * a)); + return n +} +function Env(t, e) { + "undefined" != typeof process && JSON.stringify(process.env).indexOf("GITHUB") > -1 && process.exit(0); + + class s { + constructor(t) { + this.env = t + } + + send(t, e = "GET") { + t = "string" == typeof t ? { + url: t + } : t; + let s = this.get; + return "POST" === e && (s = this.post), new Promise((e, i) => { + s.call(this, t, (t, s, r) => { + t ? i(t) : e(s) + }) + }) + } + + get(t) { + return this.send.call(this.env, t) + } + + post(t) { + return this.send.call(this.env, t, "POST") + } + } + + return new class { + constructor(t, e) { + this.name = t, this.http = new s(this), this.data = null, this.dataFile = "box.dat", this.logs = [], this.isMute = !1, this.isNeedRewrite = !1, this.logSeparator = "\n", this.startTime = (new Date).getTime(), Object.assign(this, e), this.log("", `🔔${this.name}, 开始!`) + } + + 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 + } + + toObj(t, e = null) { + try { + return JSON.parse(t) + } catch { + return e + } + } + + toStr(t, e = null) { + try { + return JSON.stringify(t) + } catch { + return e + } + } + + getjson(t, e) { + let s = e; + const i = this.getdata(t); + if (i) try { + s = JSON.parse(this.getdata(t)) + } catch { } + return s + } + + setjson(t, e) { + try { + return this.setdata(JSON.stringify(t), e) + } catch { + return !1 + } + } + + getScript(t) { + return new Promise(e => { + this.get({ + url: t + }, (t, s, i) => e(i)) + }) + } + + runScript(t, e) { + return new Promise(s => { + let i = this.getdata("@chavy_boxjs_userCfgs.httpapi"); + i = i ? i.replace(/\n/g, "").trim() : i; + let r = this.getdata("@chavy_boxjs_userCfgs.httpapi_timeout"); + r = r ? 1 * r : 20, r = e && e.timeout ? e.timeout : r; + const [o, h] = i.split("@"), n = { + url: `http://${h}/v1/scripting/evaluate`, + body: { + script_text: t, + mock_type: "cron", + timeout: r + }, + headers: { + "X-Key": o, + Accept: "*/*" + } + }; + this.post(n, (t, e, i) => s(i)) + }).catch(t => this.logErr(t)) + } + + loaddata() { + if (!this.isNode()) return {}; { + this.fs = this.fs ? this.fs : require("fs"), this.path = this.path ? this.path : require("path"); + const t = this.path.resolve(this.dataFile), + e = this.path.resolve(process.cwd(), this.dataFile), + s = this.fs.existsSync(t), + i = !s && this.fs.existsSync(e); + if (!s && !i) return {}; { + const i = s ? t : e; + try { + return JSON.parse(this.fs.readFileSync(i)) + } catch (t) { + return {} + } + } + } + } + + writedata() { + if (this.isNode()) { + this.fs = this.fs ? this.fs : require("fs"), this.path = this.path ? this.path : require("path"); + const t = this.path.resolve(this.dataFile), + e = this.path.resolve(process.cwd(), this.dataFile), + s = this.fs.existsSync(t), + i = !s && this.fs.existsSync(e), + r = JSON.stringify(this.data); + s ? this.fs.writeFileSync(t, r) : i ? this.fs.writeFileSync(e, r) : this.fs.writeFileSync(t, r) + } + } + + lodash_get(t, e, s) { + const i = e.replace(/\[(\d+)\]/g, ".$1").split("."); + let r = t; + for (const t of i) + if (r = Object(r)[t], void 0 === r) return s; + return r + } + + lodash_set(t, e, s) { + return Object(t) !== t ? t : (Array.isArray(e) || (e = e.toString().match(/[^.[\]]+/g) || []), e.slice(0, -1).reduce((t, s, i) => Object(t[s]) === t[s] ? t[s] : t[s] = Math.abs(e[i + 1]) >> 0 == +e[i + 1] ? [] : {}, t)[e[e.length - 1]] = s, t) + } + + getdata(t) { + let e = this.getval(t); + if (/^@/.test(t)) { + const [, s, i] = /^@(.*?)\.(.*?)$/.exec(t), r = s ? this.getval(s) : ""; + if (r) try { + const t = JSON.parse(r); + e = t ? this.lodash_get(t, i, "") : e + } catch (t) { + e = "" + } + } + return e + } + + setdata(t, e) { + let s = !1; + if (/^@/.test(e)) { + const [, i, r] = /^@(.*?)\.(.*?)$/.exec(e), o = this.getval(i), + h = i ? "null" === o ? null : o || "{}" : "{}"; + try { + const e = JSON.parse(h); + this.lodash_set(e, r, t), s = this.setval(JSON.stringify(e), i) + } catch (e) { + const o = {}; + this.lodash_set(o, r, t), s = this.setval(JSON.stringify(o), i) + } + } else s = this.setval(t, e); + return s + } + + getval(t) { + return this.isSurge() || this.isLoon() ? $persistentStore.read(t) : this.isQuanX() ? $prefs.valueForKey(t) : this.isNode() ? (this.data = this.loaddata(), this.data[t]) : this.data && this.data[t] || null + } + + setval(t, e) { + return this.isSurge() || this.isLoon() ? $persistentStore.write(t, e) : this.isQuanX() ? $prefs.setValueForKey(t, e) : this.isNode() ? (this.data = this.loaddata(), this.data[e] = t, this.writedata(), !0) : this.data && this.data[e] || null + } + + initGotEnv(t) { + this.got = this.got ? this.got : require("got"), this.cktough = this.cktough ? this.cktough : require("tough-cookie"), this.ckjar = this.ckjar ? this.ckjar : new this.cktough.CookieJar, t && (t.headers = t.headers ? t.headers : {}, void 0 === t.headers.Cookie && void 0 === t.cookieJar && (t.cookieJar = this.ckjar)) + } + + get(t, e = (() => { })) { + t.headers && (delete t.headers["Content-Type"], delete t.headers["Content-Length"]), this.isSurge() || this.isLoon() ? (this.isSurge() && this.isNeedRewrite && (t.headers = t.headers || {}, Object.assign(t.headers, { + "X-Surge-Skip-Scripting": !1 + })), $httpClient.get(t, (t, s, i) => { + !t && s && (s.body = i, s.statusCode = s.status), e(t, s, i) + })) : this.isQuanX() ? (this.isNeedRewrite && (t.opts = t.opts || {}, Object.assign(t.opts, { + hints: !1 + })), $task.fetch(t).then(t => { + const { + statusCode: s, + statusCode: i, + headers: r, + body: o + } = t; + e(null, { + status: s, + statusCode: i, + headers: r, + body: o + }, o) + }, t => e(t))) : this.isNode() && (this.initGotEnv(t), this.got(t).on("redirect", (t, e) => { + try { + if (t.headers["set-cookie"]) { + const s = t.headers["set-cookie"].map(this.cktough.Cookie.parse).toString(); + s && this.ckjar.setCookieSync(s, null), e.cookieJar = this.ckjar + } + } catch (t) { + this.logErr(t) + } + }).then(t => { + const { + statusCode: s, + statusCode: i, + headers: r, + body: o + } = t; + e(null, { + status: s, + statusCode: i, + headers: r, + body: o + }, o) + }, t => { + const { + message: s, + response: i + } = t; + e(s, i, i && i.body) + })) + } + + post(t, e = (() => { })) { + if (t.body && t.headers && !t.headers["Content-Type"] && (t.headers["Content-Type"] = "application/x-www-form-urlencoded"), t.headers && delete t.headers["Content-Length"], this.isSurge() || this.isLoon()) this.isSurge() && this.isNeedRewrite && (t.headers = t.headers || {}, Object.assign(t.headers, { + "X-Surge-Skip-Scripting": !1 + })), $httpClient.post(t, (t, s, i) => { + !t && s && (s.body = i, s.statusCode = s.status), e(t, s, i) + }); + else if (this.isQuanX()) t.method = "POST", this.isNeedRewrite && (t.opts = t.opts || {}, Object.assign(t.opts, { + hints: !1 + })), $task.fetch(t).then(t => { + const { + statusCode: s, + statusCode: i, + headers: r, + body: o + } = t; + e(null, { + status: s, + statusCode: i, + headers: r, + body: o + }, o) + }, t => e(t)); + else if (this.isNode()) { + this.initGotEnv(t); + const { + url: s, + ...i + } = t; + this.got.post(s, i).then(t => { + const { + statusCode: s, + statusCode: i, + headers: r, + body: o + } = t; + e(null, { + status: s, + statusCode: i, + headers: r, + body: o + }, o) + }, t => { + const { + message: s, + response: i + } = t; + e(s, i, i && i.body) + }) + } + } + + time(t, e = null) { + const s = e ? new Date(e) : new Date; + let i = { + "M+": s.getMonth() + 1, + "d+": s.getDate(), + "H+": s.getHours(), + "m+": s.getMinutes(), + "s+": s.getSeconds(), + "q+": Math.floor((s.getMonth() + 3) / 3), + S: s.getMilliseconds() + }; + /(y+)/.test(t) && (t = t.replace(RegExp.$1, (s.getFullYear() + "").substr(4 - RegExp.$1.length))); + for (let e in i) new RegExp("(" + e + ")").test(t) && (t = t.replace(RegExp.$1, 1 == RegExp.$1.length ? i[e] : ("00" + i[e]).substr(("" + i[e]).length))); + return t + } + + msg(e = t, s = "", i = "", r) { + const o = t => { + if (!t) return t; + if ("string" == typeof t) return this.isLoon() ? t : this.isQuanX() ? { + "open-url": t + } : this.isSurge() ? { + url: t + } : void 0; + if ("object" == typeof t) { + if (this.isLoon()) { + let e = t.openUrl || t.url || t["open-url"], + s = t.mediaUrl || t["media-url"]; + return { + openUrl: e, + mediaUrl: s + } + } + if (this.isQuanX()) { + let e = t["open-url"] || t.url || t.openUrl, + s = t["media-url"] || t.mediaUrl; + return { + "open-url": e, + "media-url": s + } + } + if (this.isSurge()) { + let e = t.url || t.openUrl || t["open-url"]; + return { + url: e + } + } + } + }; + if (this.isMute || (this.isSurge() || this.isLoon() ? $notification.post(e, s, i, o(r)) : this.isQuanX() && $notify(e, s, i, o(r))), !this.isMuteLog) { + let t = ["", "==============📣系统通知📣=============="]; + t.push(e), s && t.push(s), i && t.push(i), console.log(t.join("\n")), this.logs = this.logs.concat(t) + } + } + + log(...t) { + t.length > 0 && (this.logs = [...this.logs, ...t]), console.log(t.join(this.logSeparator)) + } + + logErr(t, e) { + const s = !this.isSurge() && !this.isQuanX() && !this.isLoon(); + s ? this.log("", `❗️${this.name}, 错误!`, t.stack) : this.log("", `❗️${this.name}, 错误!`, t) + } + + wait(t) { + return new Promise(e => setTimeout(e, t)) + } + + done(t = {}) { + const e = (new Date).getTime(), + s = (e - this.startTime) / 1e3; + this.log("", `🔔${this.name}, 结束! 🕛 ${s} 秒`), this.log(), (this.isSurge() || this.isQuanX() || this.isLoon()) && $done(t) + } + }(t, e) +} \ No newline at end of file diff --git a/wqwl_new_蒙娜丽莎.js b/wqwl_new_蒙娜丽莎.js new file mode 100644 index 0000000..aa3df2c --- /dev/null +++ b/wqwl_new_蒙娜丽莎.js @@ -0,0 +1,226 @@ +/** + * 脚本：wqwl_new_蒙娜丽莎.js + * 作者：wqwlkj 裙：960690899 + * 描述：微信小程序蒙娜丽莎，抓包请求参数webChatID，CustomerID,CustomerName，tokenStr（登录或者签到才有）格式：webChatID1#CustomerID1#CustomerName1#tokenStr#备注1 + * 环境变量：wqwl_mnls，多个换行或新建多个变量（不能混合使用） + * 环境变量描述： + * cron: 15 1 9 * * * + */ + +//签到ck是24小时过期，可以不玩 + +/** + * 入口：https://gitee.com/cobbWmy/img/raw/master/mengnalisha.jpg + * 写本不易走个头呗 + */ + +//环境变量 +const ckName = 'wqwl_mnls'; +//脚本名称 +const scriptName = '微信小程序蒙娜丽莎'; +//本地版本 +const version = 1.0; +//是否需要文件存储 +const isNeedFile = true; +//ck长度 +const ckLength = 4; +//日志是否需要具体时间 +const isNeedTimes = false; + +const proxy = process.env["wqwl_daili"] || ''; +const isProxy = process.env["wqwl_useProxy"] || false; +const bfs = process.env["wqwl_bfs"] || 4; +const isNotify = process.env["wqwl_isNotify"] || true; +const isDebug = process.env["wqwl_isDebug"] || 2; + +/** + * 其他全局环境变量说明 + * wqwl_daili：代理链接，需要返回单挑txt格式 + * wqwl_useProxy：是否用代理，默认使用（填了代理链接） + * wqwl_bfs：并发数，默认4 + * wqwl_isNotify：是否进行通知 + * wqwl_isDebug：是否调试输出请求 + */ + + +const axios = require('axios'); +const fs = require('fs'); +const qs = require('qs'); + +let wqwlkj; +// 先下载依赖文件 +async function downloadRequire() { + const filePath = 'wqwl_require.js'; + const url = 'https://raw.githubusercontent.com/298582245/wqwl_qinglong/refs/heads/main/wqwl_require.js'; + + if (fs.existsSync(filePath)) { + console.log('✅wqwl_require.js已存在，无需重新下载，如有报错请重新下载覆盖\n'); + wqwlkj = require('./wqwl_require'); + return true; + } else { + console.log('正在下载wqwl_require.js，请稍等...\n'); + console.log(`如果下载过慢，可以手动下载wqwl_require.js，并保存为wqwl_require.js，并重新运行脚本`); + console.log('地址：' + url); + try { + const res = await axios.get(url); + fs.writeFileSync(filePath, res.data); + console.log('✅ 下载完成\n'); + wqwlkj = require('./wqwl_require'); + return true; + } catch (e) { + console.log('❌ 下载失败，请手动下载wqwl_require.js\n'); + console.log('地址：' + url); + return false; + } + } +} + + +// 立即执行下载并等待完成 +!(async function () { + const downloadIsSuccess = await downloadRequire(); + if (!downloadIsSuccess) { + console.log('❌ 依赖文件下载失败，脚本终止'); + process.exit(1); + } + if (!wqwlkj.WQWLBase || !wqwlkj.WQWLBaseTask) { + console.log('❌ wqwl_require.js 未发现WQWLBase类、WQWLBaseTask类，请重新下载新版本'); + process.exit(1); + } + + class Task extends wqwlkj.WQWLBaseTask { + constructor(ck, index, base) { + // 调用父类构造函数 + super(ck, index, base); + this.baseUrl = 'https://mcs.monalisagroup.com.cn/member/doAction'; + } + + async init() { + const ckData = this.ck.split('#') + // console.log(ckData) + if (ckData.length < ckLength) { + this.sendMessage(`${this.index + 1} 环境变量有误，请检查环境变量是否正确`, true); + return false; + } + else if (ckData.length === ckLength) { + this.remark = `${ckData[0].slice(0, 8)}-${this.index}`; + } + else { + this.remark = ckData[ckLength]; + } + this.webChatID = ckData[0] + this.CustomerID = ckData[1] + this.CustomerName = ckData[2] + this.tokenStr = ckData[3] + + + if (this.proxyConfig && this.isProxy) { + this.proxy = await wqwlkj.getProxy(this.index, this.proxyConfig) + this.sendMessage(`✅ 使用代理：${this.proxy}`) + } + else { + this.proxy = '' + this.sendMessage(`⚠️ 不使用代理`) + } + if (isNeedFile) { + if (!this.base.fileData[this.remark]) + this.base.fileData[this.remark] = {} + let ua; + if (!this.base.fileData[this.remark]['ua']) { + this.base.fileData[this.remark]['ua'] = this.base.wqwlkj.generateRandomUA() + } + ua = this.base.fileData[this.remark]['ua'] + this.sendMessage(`🎲 使用ua：${ua.slice(0, 50)}`) + + this.headers = { + Connection: 'keep-alive', + 'xweb_xhr': '1', + 'User-Agent': ua, + 'Content-Type': 'application/x-www-form-urlencoded', + Accept: '*/*', + 'Sec-Fetch-Site': 'cross-site', + 'Sec-Fetch-Mode': 'cors', + 'Sec-Fetch-Dest': 'empty', + Referer: 'https://servicewechat.com/wxce6a8f654e81b7a4/459/page-frame.html', + 'Accept-Language': 'zh-CN,zh;q=0.9', + 'Accept-Encoding': 'gzip, deflate' + } + } + + return true + } + + async checkin() { + const methodName = '签到' + const method = async () => { + const options = { + url: `${this.baseUrl}`, + method: "POST", + data: qs.stringify({ + action: 'sign', + CustomerID: this.CustomerID, + CustomerName: this.CustomerName, + StoreID: 0, + OrganizationID: 0, + brand: 'MON', + tokenStr: this.tokenStr + } + ) + } + const res = await this.request(options, 0) + if (res?.status === 0) { + this.sendMessage(`✅ [${methodName}] 成功,获得：${res?.resultInfo}积分`, true) + } + else { + throw new Error(`接口返回：${res?.status === 7 ? '今日已经签到过啦' : (res?.msg || res?.errmsg || "未知错误信息")}`) + + } + } + return await this.safeExecute(method, methodName) + } + + + async info() { + const methodName = '个人信息' + const method = async () => { + const options = { + url: `${this.baseUrl}`, + method: "POST", + data: qs.stringify({ + action: 'getCustomer', + webChatID: this.webChatID, + brand: 'MON', + } + ) + } + const res = await this.request(options, 0) + if (res?.status === 0) { + this.sendMessage(`✅ [${methodName}] 成功,当前积分：${res?.resultInfo[0]?.Integral}`, true) + } + else { + throw new Error(`接口返回：${res?.msg || res?.errmsg || "未知错误信息"}`) + } + } + return await this.safeExecute(method, methodName) + } + + async main() { + const init = await this.init() + if (!init) return; + await this.checkin() + await this.base.wqwlkj.sleep(3) + await this.info() + } + + } + + if (wqwlkj.WQWLBase && wqwlkj.WQWLBaseTask) { + const base = new wqwlkj.WQWLBase(wqwlkj, ckName, scriptName, version, isNeedFile, proxy, isProxy, bfs, isNotify, isDebug, isNeedTimes); + await base.runTasks(Task); + } + else { + // 如果 wqwl_require.js 没有导出 WQWLBase，可能需要手动处理 + console.log('❌ wqwl_require.js 未发现WQWLBase类、WQWLBaseTask类，请重新下载新版本'); + console.log('地址：' + url); + } +})(); \ No newline at end of file diff --git a/蒙娜丽莎.py b/蒙娜丽莎.py index 3748589..1cee8c8 100644 --- a/蒙娜丽莎.py +++ b/蒙娜丽莎.py @@ -1,197 +1,219 @@ -# -*- coding: utf-8 -*- -# @Time : 2025-11-28 -# @Author : chmodxxoo（整合版本） -# @Version ：4.1 -# @Desc : 蒙娜丽莎小程序：自动获取token → 自动签到，一体化脚本（日志调试 + 精简推送） - -import os -import time -import random import requests +import json +import os +import logging +from datetime import datetime +import sys -try: - from notify import send -except ImportError: - print("未找到 notify.py，将仅在控制台输出日志。") - def send(title, content): - print(f"--- 通知 ---\n{title}\n{content}\n-------------") - - -# ====================================================== -# 第 1 部分：获取 code → tokenStr -# ====================================================== -ENV_NAMES = { - "wxid": "soy_wxid_data", - "code_url": "soy_codeurl_data" -} - -message_list = [] - -def get_env(name): - v = os.getenv(name, "").strip() - if not v: - message_list.append(f"❌ 环境变量[{name}]为空！") - return None - #message_list.append(f"✅ 成功读取环境变量[{name}]") - return v - -def get_wxid_list(): - data = get_env(ENV_NAMES["wxid"]) - if not data: - return [] - return [x.strip() for x in data.split("\n") if x.strip()] - -def get_code(wxid, code_url): - """用 wxid 换取 code""" - headers = {"Content-Type": "application/json"} - payload = {"appid": "wxce6a8f654e81b7a4", "wxid": wxid} - try: - r = requests.post(code_url, json=payload, headers=headers, timeout=15).json() - if r.get("status") is True: - code = r.get("Data", {}).get("code") - if code: - print(f"[INFO] wxid[{wxid}] 获取 code 成功") - return code - except Exception as e: - print(f"[ERROR] wxid[{wxid}] 获取 code 失败：{e}") - return None - -def get_customer_token(code): - """调用 doAction 获取 CustomerID + tokenStr""" - url = "https://mcs.monalisagroup.com.cn/member/doAction" - headers = { - 'Accept-Encoding': 'gzip,compress,br,deflate', - 'content-type': 'application/x-www-form-urlencoded', - 'Connection': 'keep-alive', - 'Referer': 'https://servicewechat.com/wxce6a8f654e81b7a4/462/page-frame.html', - 'Host': 'mcs.monalisagroup.com.cn', - 'User-Agent': 'Mozilla/5.0' - } - - data = ( - f"brand=MON&webChatName=%E5%BE%AE%E4%BF%A1%E7%94%A8%E6%88%B7&telephone=&code={code}&remarks=&action=addCustomer" - f"&customerName=%E5%BE%AE%E4%BF%A1%E7%94%A8%E6%88%B7&storeID=&address=-&Province=&City=&Region=" - ) - - try: - r = requests.post(url, headers=headers, data=data, timeout=15).json() - if "tokenStr" in r and r.get("resultInfo"): - customer_id = r["resultInfo"][0]["CustomerID"] - tokenStr = r["tokenStr"] - print(f"[INFO] 获取成功：CustomerID={customer_id} tokenStr={tokenStr}") - return f"{customer_id}#{tokenStr}" - except Exception as e: - print(f"[ERROR] 获取 tokenStr 失败：{e}") - - return None - - -# ====================================================== -# 第 2 部分：签到模块 -# ====================================================== -class MNLS: - def __init__(self, index, account): - self.index = index - self.customerId, self.tokenStr = account.split("#") - self.mobile = "" - self.score = 0 - self.msg = "" - - self.headers = { +class MonalisaSign: + def __init__(self): + self.base_url = "https://mcs.monalisagroup.com.cn" + self.session = requests.Session() + + # 配置日志 + logging.basicConfig( + level=logging.INFO, + format='%(asctime)s - %(levelname)s - %(message)s' + ) + self.logger = logging.getLogger(__name__) + + def parse_environment_config(self): + """ + 从环境变量 MNLS 解析配置，支持多个账号 + + Returns: + list: 包含多个账号配置的列表，每个元素是包含 customer_id 和 token_str 的字典 + """ + env_value = os.getenv('MNLS') + if not env_value: + raise ValueError("环境变量 MNLS 未设置") + + # 支持多个账号，用&分隔 + accounts = [] + account_strings = env_value.split('&') + + for i, account_str in enumerate(account_strings): + account_str = account_str.strip() + if not account_str: + continue + + parts = account_str.split('#') + if len(parts) != 2: + raise ValueError(f"第 {i+1} 个账号格式错误，应为 CustomerID#tokenStr") + + accounts.append({ + "customer_id": parts[0].strip(), + "token_str": parts[1].strip(), + "index": i + 1 # 账号序号，用于标识 + }) + + if not accounts: + raise ValueError("未找到有效的账号配置") + + return accounts + + def sign_in(self, customer_id, token_str, account_index=1): + """ + 执行签到操作 + + Args: + customer_id (str): 用户ID + token_str (str): token字符串 + account_index (int): 账号序号 + + Returns: + dict: 签到结果 + """ + # 请求URL + url = f"{self.base_url}/member/doAction" + + # 严格按照抓包中的请求体格式 + data = { + "action": "sign", + "CustomerID": customer_id, + "CustomerName": "微信用户", # 固定为"微信用户" + "StoreID": "0", + "OrganizationID": "0", + "Brand": "MON", + "tokenStr": token_str + } + + # 严格按照抓包中的请求头 + headers = { "Host": "mcs.monalisagroup.com.cn", "Connection": "keep-alive", - "User-Agent": "Mozilla/5.0", "Content-Type": "application/x-www-form-urlencoded", - "Referer": "https://servicewechat.com/wxce6a8f654e81b7a4/462/page-frame.html", - "Accept-Encoding": "gzip,compress,br,deflate" + "Accept-Encoding": "gzip,compress,br,deflate", + "User-Agent": "Mozilla/5.0 (iPhone; CPU iPhone OS 16_6_1 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 MicroMessenger/8.0.65(0x1800412e) NetType/WIFI Language/zh_CN", + "Referer": "https://servicewechat.com/wxce6a8f654e81b7a4/459/page-frame.html" } - - def hide_phone(self, phone): - if not phone or len(phone) != 11: - return phone - return phone[:3] + "****" + phone[7:] - - def get_info(self): - url = "https://mcs.monalisagroup.com.cn/member/doAction" - data = f"brand=MON&customerID={self.customerId}&action=getCustInfoByID" + try: - r = requests.post(url, headers=self.headers, data=data).json() - if r.get("status") == 0: - info = r["resultInfo"][0] - self.mobile = self.hide_phone(info["Telephone"]) - self.score = info["Integral"] - print(f"[INFO] 账号{self.index} 信息获取成功：手机号={self.mobile} 积分={self.score}") - return True - except Exception as e: - print(f"[ERROR] 账号{self.index} 获取信息失败：{e}") - return False - - def sign(self): - url = "https://mcs.monalisagroup.com.cn/member/doAction" - data = ( - f"brand=MON&action=sign&CustomerID={self.customerId}&CustomerName=%E5%BE%AE%E4%BF%A1%E7%94%A8%E6%88%B7&" - f"StoreID=0&OrganizationID=0&ItemType=002&Brand=MON&tokenStr={self.tokenStr}" - ) - try: - r = requests.post(url, headers=self.headers, data=data).json() - if r.get("status") == 0: - self.msg = f"签到成功，获得积分：{r.get('resultInfo')}" - elif r.get("status") == 7: - self.msg = "今天已经签到过了" + self.logger.info(f"开始签到 - 账号{account_index} - 用户ID: {customer_id}") + + # 发送POST请求 + response = self.session.post( + url, + data=data, + headers=headers, + timeout=10 + ) + + # 记录响应信息 + self.logger.info(f"账号{account_index} - HTTP状态码: {response.status_code}") + self.logger.info(f"账号{account_index} - 响应内容: {response.text}") + + # 解析响应 + if response.status_code == 200: + result = response.json() + self.logger.info(f"账号{account_index} - 签到结果: {result}") + return { + "success": True, + "status": result.get("status"), + "resultInfo": result.get("resultInfo"), + "integralStatus": result.get("integralStatus"), + "raw_response": result + } else: - self.msg = f"签到失败：{r}" - print(f"[INFO] 账号{self.index} 签到状态：{self.msg}") - except Exception as e: - self.msg = f"签到异常：{e}" - print(f"[ERROR] 账号{self.index} 签到异常：{e}") + self.logger.error(f"账号{account_index} - 请求失败，状态码: {response.status_code}") + return { + "success": False, + "error": f"HTTP错误: {response.status_code}", + "raw_response": response.text + } + + except requests.exceptions.RequestException as e: + self.logger.error(f"账号{account_index} - 网络请求异常: {str(e)}") + return { + "success": False, + "error": f"网络异常: {str(e)}" + } + except json.JSONDecodeError as e: + self.logger.error(f"账号{account_index} - JSON解析失败: {str(e)}") + return { + "success": False, + "error": f"响应格式错误: {str(e)}", + "raw_response": response.text if 'response' in locals() else None + } - def run(self): - self.get_info() - self.sign() - self.get_info() # 更新积分 - return f"账号{self.index} → {self.msg}，积分：{self.score}" +def main(): + """主函数""" + sign_client = MonalisaSign() + + try: + # 从环境变量解析配置 + accounts = sign_client.parse_environment_config() + print(f"✅ 成功读取 {len(accounts)} 个账号配置") + + # 记录总体结果 + all_success = True + results = [] + + # 循环执行每个账号的签到 + for account in accounts: + print(f"\n====== 开始处理账号 {account['index']} ======") + print(f"用户ID: {account['customer_id']}") + + # 执行签到 + result = sign_client.sign_in( + customer_id=account["customer_id"], + token_str=account["token_str"], + account_index=account["index"] + ) + + # 记录结果 + result["account_index"] = account["index"] + result["customer_id"] = account["customer_id"] + results.append(result) + + # 输出当前账号结果 + if result["success"]: + print(f"🎉 账号{account['index']} 签到成功!") + print(f"状态码: {result.get('status')}") + print(f"结果信息: {result.get('resultInfo')}") + print(f"积分状态: {result.get('integralStatus')}") + else: + print(f"❌ 账号{account['index']} 签到失败!") + print(f"错误信息: {result.get('error')}") + all_success = False + + print(f"====== 账号 {account['index']} 处理完成 ======\n") + + # 输出汇总结果 + print("\n" + "="*50) + print("📊 签到汇总结果:") + success_count = sum(1 for r in results if r["success"]) + print(f"成功: {success_count}/{len(accounts)}") + + for result in results: + status = "✅ 成功" if result["success"] else "❌ 失败" + print(f"账号{result['account_index']}: {status}") + + if not result["success"]: + print(f" 错误: {result.get('error')}") + + # 根据结果设置退出码 + if not all_success: + print("\n⚠️ 有账号签到失败，请检查!") + sys.exit(1) + else: + print("\n🎉 所有账号签到成功!") + sys.exit(0) + + except ValueError as e: + print(f"❌ 配置错误: {e}") + print("\n请按以下格式设置环境变量 MNLS:") + print("单个账号:") + print("export MNLS=\"CustomerID#tokenStr\"") + print("多个账号（用&分隔）:") + print("export MNLS=\"CustomerID1#tokenStr1&CustomerID2#tokenStr2&CustomerID3#tokenStr3\"") + print("示例:") + print("export MNLS=\"1725675#f294ee23-ba20-43f1-9bef-222e92e07809\"") + print("export MNLS=\"1725675#f294ee23-ba20-43f1-9bef-222e92e07809&1725676#abcd1234-ef56-78gh-90ij-klmnopqrstuv&1725677#wxyz9876-54fe-32dc-10ba-abcdefghijkl\"") + sys.exit(1) + except Exception as e: + print(f"❌ 程序执行异常: {e}") + sys.exit(1) - -# ====================================================== -# 主流程整合 -# ====================================================== if __name__ == "__main__": - code_url = get_env(ENV_NAMES["code_url"]) - wxid_list = get_wxid_list() - - if not code_url or not wxid_list: - print("\n".join(message_list)) - exit(0) - - account_list = [] - - print("\n===== 开始获取 CustomerID#tokenStr =====") - for wxid in wxid_list: - code = get_code(wxid, code_url) - if not code: - continue - account = get_customer_token(code) - if account: - account_list.append(account) - time.sleep(random.uniform(1, 2)) - - if not account_list: - print("❌ 未获取到任何账号 tokenStr") - exit(0) - - # ====================================================== - # 进入自动签到 - # ====================================================== - print("\n===== 开始签到 =====") - msg_final = [] - for idx, acc in enumerate(account_list, start=1): - result = MNLS(idx, acc).run() - msg_final.append(result) - time.sleep(random.uniform(2, 4)) - - # 控制台输出完整日志 - output = "\n".join(message_list + msg_final) - print(output) - - # 最终推送：只包含签到结果和积分 - send("蒙娜丽莎自动签到结果", "\n".join(msg_final)) \ No newline at end of file + main() \ No newline at end of file