diff --git a/huluwa_notify.js b/huluwa_notify.js new file mode 100644 index 0000000..859afd3 --- /dev/null +++ b/huluwa_notify.js @@ -0,0 +1,324 @@ +/** + 葫芦娃中签查询 v1.0.0 + + cron: 30 10 * * * + const $ = new Env("葫芦娃中签查询"); + + 自行抓包把token(一般在请求头里)填到变量中, 多账号用换行隔开(可自定义) + + 环境变量 XLTH_COOKIE 新联惠购 + 环境变量 GLYP_COOKIE 贵旅优品 + 环境变量 KGLG_COOKIE 空港乐购 + 环境变量 HLQG_COOKIE 航旅黔购 + 环境变量 ZHCS_COOKIE 遵行出山 + 环境变量 GYQP_COOKIE 贵盐黔品 + 环境变量 LLSC_COOKIE 乐旅商城 + 环境变量 YLQX_COOKIE 驿路黔寻 + */ + +const SPLIT = "\n"; // 分割符(可自定义) + +const axios = require('axios'); +const crypto = require('crypto'); +const moment = require('moment'); +const notify = require('./sendNotify'); + +const XLTH_APPID = 'wxded2e7e6d60ac09d'; // 新联惠购 +const GLYP_APPID = 'wx61549642d715f361'; // 贵旅优品 +const KGLG_APPID = 'wx613ba8ea6a002aa8'; // 空港乐购 +const HLQG_APPID = 'wx936aa5357931e226'; // 航旅黔购 +const ZHCS_APPID = 'wx624149b74233c99a'; // 遵航出山 +const GYQP_APPID = 'wx5508e31ffe9366b8'; // 贵盐黔品 +const LLSC_APPID = 'wx821fb4d8604ed4d6'; // 乐旅商城 +const YLQX_APPID = 'wxee0ce83ab4b26f9c'; // 驿路黔寻 + +const HOST = 'https://gw.huiqunchina.com'; +const AK = '00670fb03584fbf44dd6b136e534f495'; +const SK = '0d65f24dbe2bc1ede3c3ceeb96ef71bb'; + +let sendMessage = []; + +function delay (time) { + return new Promise(resolve => setTimeout(resolve, time)); +} + +function calculateDigest (body, sk) { + const hmac = crypto.createHmac('sha256', sk); + hmac.update(body); + const signature = hmac.digest('base64'); + return signature; +} + +function calculateSignature (method, url, ak, sk, date) { + const strToSign = `${method.toUpperCase()}\n${url}\n\n${ak}\n${date}\n`; + const hmac = crypto.createHmac('sha256', sk); + hmac.update(strToSign); + const signature = hmac.digest('base64'); + return signature; +} + +function buildHeader (method, url, body) { + const date = moment().utc().format('ddd, DD MMM YYYY HH:mm:ss [GMT]'); + const signature = calculateSignature(method, url, AK, SK, date); + const digest = calculateDigest(body, SK); + const headers = { + 'Content-Type': 'application/json', + 'X-HMAC-SIGNATURE': signature, + 'X-HMAC-ACCESS-KEY': AK, + 'X-HMAC-ALGORITHM': 'hmac-sha256', + 'X-HMAC-DIGEST': digest, + 'X-HMAC-Date': date, + 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/98.0.4758.102 Safari/537.36 MicroMessenger/7.0.20.1781(0x6700143B) NetType/WIFI MiniProgramEnv/Windows WindowsWechat/WMPF XWEB/6945' + }; + return headers; +} + +async function getUserInfo (appId, token) { + const url = '/front-manager/api/customer/queryById/token'; + const method = 'post'; + const data = { appId }; + const headers = buildHeader(method, url, JSON.stringify(data)); + headers['X-access-token'] = token; + + let resData; + await axios(HOST + url, { method: method, data: data, headers: headers }) + .then(res => { + resData = res.data; + }) + .catch(err => { + resData = err.response.data; + }); + return resData; +} + +async function getChannelActivity (id, token) { + const url = '/front-manager/api/customer/promotion/channelActivity'; + const method = 'post'; + const data = { id }; + const headers = buildHeader(method, url, JSON.stringify(data)); + headers['X-access-token'] = token; + + let resData; + await axios(HOST + url, { method: method, data: data, headers: headers }) + .then(res => { + resData = res.data; + }) + .catch(err => { + resData = err.response.data; + }); + return resData; +} + + +/** 查询 */ +async function getWinningCustomers (activityId, token) { + const url = '/front-manager/api/customer/promotion/getWinningCustomers'; + const method = 'post'; + const data = { activityId }; + const headers = buildHeader(method, url, JSON.stringify(data)); + headers['X-access-token'] = token; + + let resData; + await axios(HOST + url, { method: method, data: data, headers: headers }) + .then(res => { + resData = res.data; + }) + .catch(err => { + resData = err.response.data; + }); + return resData; +} + +async function autoSubmit (appId, token) { + let channelId = ''; + let channelName = ''; + if (appId === XLTH_APPID) { + channelId = '8'; + channelName = '新联惠购'; + } + if (appId === GLYP_APPID) { + channelId = '7'; + channelName = '贵旅优品'; + } + if (appId === KGLG_APPID) { + channelId = '2'; + channelName = '空港乐购'; + } + if (appId === HLQG_APPID) { + channelId = '6'; + channelName = '航旅黔购'; + } + if (appId === ZHCS_APPID) { + channelId = '5'; + channelName = '遵行出山'; + } + if (appId === GYQP_APPID) { + channelId = '3'; + channelName = '贵盐黔品'; + } + if (appId === LLSC_APPID) { + channelId = '1'; + channelName = '乐旅商城'; + } + if (appId === YLQX_APPID) { + channelId = '9'; + channelName = '驿路黔寻'; + } + + try { + const res1 = await getUserInfo(appId, token); + if (res1.code != '10000') { + console.log(res1.message); + sendMessage.push(res1.message); + return; + } + const realName = res1.data.realName; + const phone = res1.data.phone; + console.log(`当前用户[${phone}]`); + sendMessage.push(`当前用户[${phone}]`); + + const res2 = await getChannelActivity(channelId, token); + if (res2.code != '10000') { + console.log(res2.message); + sendMessage.push(res2.message); + return; + } + const activityId = res2.data.id; + const activityName = res2.data.name; + console.log(`活动名称[${activityName}]`); + sendMessage.push(`活动名称[${activityName}]`); + + const res5 = await getWinningCustomers(activityId, token) + if (res5.code != '10000') { + console.log(res5.message); + sendMessage.push(res5.message); + return; + } + console.log(`小程序:${channelName},活动名称「${activityName}」,\n【中签结果:${res5.message ?? '--'}】`); + sendMessage.push(`小程序:${channelName},活动名称「${activityName}」,\n【中签结果:${res5.message ?? '--'}】`); + // 发送飞书机器人 + + } catch (err) { + console.log(`运行异常[${err.message}]`); + sendMessage.push(`运行异常[${err.message}]`); + } +} + +async function main () { + const XLTH_COOKIE_ARR = process.env.XLTH_COOKIE; // 新联惠购 + const GLYP_COOKIE_ARR = process.env.GLYP_COOKIE; // 贵旅优品 + const KGLG_COOKIE_ARR = process.env.KGLG_COOKIE; // 空港乐购 + const HLQG_COOKIE_ARR = process.env.HLQG_COOKIE; // 航旅黔购 + const ZHCS_COOKIE_ARR = process.env.ZHCS_COOKIE; // 遵行出山 + const GYQP_COOKIE_ARR = process.env.GYQP_COOKIE; // 贵盐黔品 + const LLSC_COOKIE_ARR = process.env.LLSC_COOKIE; // 乐旅商城 + const YLQX_COOKIE_ARR = process.env.YLQX_COOKIE; // 驿路黔寻 + + if (XLTH_COOKIE_ARR) { + console.log('新联惠购查询开始'); + sendMessage.push('新联惠购查询开始'); + for (let [index, item] of XLTH_COOKIE_ARR.split(SPLIT).entries()) { + console.log(`----第${index + 1}个号----`); + sendMessage.push(`----第${index + 1}个号----`); + await autoSubmit(XLTH_APPID, item); + await delay(1000); + } + console.log('新联惠购查询结束\n'); + sendMessage.push('新联惠购查询结束\n'); + } + + if (GLYP_COOKIE_ARR) { + console.log('贵旅优品查询开始'); + sendMessage.push('贵旅优品查询开始'); + for (let [index, item] of GLYP_COOKIE_ARR.split(SPLIT).entries()) { + console.log(`----第${index + 1}个号----`); + sendMessage.push(`----第${index + 1}个号----`); + await autoSubmit(GLYP_APPID, item); + await delay(1000); + } + console.log('贵旅优品查询结束\n'); + sendMessage.push('贵旅优品查询结束\n'); + } + + if (KGLG_COOKIE_ARR) { + console.log('空港乐购查询开始'); + sendMessage.push('新联惠购查询开始'); + for (let [index, item] of KGLG_COOKIE_ARR.split(SPLIT).entries()) { + console.log(`----第${index + 1}个号----`); + sendMessage.push(`----第${index + 1}个号----`); + await autoSubmit(KGLG_APPID, item); + await delay(1000); + } + console.log('空港乐购查询结束\n'); + sendMessage.push('空港乐购查询结束\n'); + } + + if (HLQG_COOKIE_ARR) { + console.log('航旅黔购查询开始'); + sendMessage.push('新联惠购查询开始'); + for (let [index, item] of HLQG_COOKIE_ARR.split(SPLIT).entries()) { + console.log(`----第${index + 1}个号----`); + sendMessage.push(`----第${index + 1}个号----`); + await autoSubmit(HLQG_APPID, item); + await delay(1000); + } + console.log('航旅黔购查询结束\n'); + sendMessage.push('航旅黔购查询结束\n'); + } + + if (ZHCS_COOKIE_ARR) { + console.log('遵行出山查询开始'); + sendMessage.push('新联惠购查询开始'); + for (let [index, item] of ZHCS_COOKIE_ARR.split(SPLIT).entries()) { + console.log(`----第${index + 1}个号----`); + sendMessage.push(`----第${index + 1}个号----`); + await autoSubmit(ZHCS_APPID, item); + await delay(1000); + } + console.log('遵行出山查询结束\n'); + sendMessage.push('遵行出山查询结束\n'); + } + + if (GYQP_COOKIE_ARR) { + console.log('贵盐黔品查询开始'); + sendMessage.push('贵盐黔品查询开始'); + for (let [index, item] of GYQP_COOKIE_ARR.split(SPLIT).entries()) { + console.log(`----第${index + 1}个号----`); + sendMessage.push(`----第${index + 1}个号----`); + await autoSubmit(GYQP_APPID, item); + await delay(1000); + } + console.log('贵盐黔品查询结束\n'); + sendMessage.push('贵盐黔品查询结束\n'); + } + + if (LLSC_COOKIE_ARR) { + console.log('乐旅商城查询开始'); + sendMessage.push('乐旅商城查询开始'); + for (let [index, item] of LLSC_COOKIE_ARR.split(SPLIT).entries()) { + console.log(`----第${index + 1}个号----`); + sendMessage.push(`----第${index + 1}个号----`); + await autoSubmit(LLSC_APPID, item); + await delay(1000); + } + console.log('乐旅商城查询结束\n'); + sendMessage.push('乐旅商城查询结束\n'); + } + + if (YLQX_COOKIE_ARR) { + console.log('驿路黔寻查询开始'); + sendMessage.push('驿路黔寻查询开始'); + for (let [index, item] of YLQX_COOKIE_ARR.split(SPLIT).entries()) { + console.log(`----第${index + 1}个号----`); + sendMessage.push(`----第${index + 1}个号----`); + await autoSubmit(YLQX_APPID, item); + await delay(1000); + } + console.log('驿路黔寻查询结束\n'); + sendMessage.push('驿路黔寻查询结束\n'); + } + + await notify.sendNotify(`葫芦娃中签查询`, sendMessage.join('\n'), {},); +} + +main();