From a67038d292e677a37880b720e775a83b58d522da Mon Sep 17 00:00:00 2001
From: XiaoGe-LiBai <60430782+XiaoGe-LiBai@users.noreply.github.com>
Date: Fri, 24 May 2024 16:58:04 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=20huluwa-notify.js?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 huluwa-notify.js | 324 -----------------------------------------------
 1 file changed, 324 deletions(-)
 delete mode 100644 huluwa-notify.js

diff --git a/huluwa-notify.js b/huluwa-notify.js
deleted file mode 100644
index 859afd3..0000000
--- a/huluwa-notify.js
+++ /dev/null
@@ -1,324 +0,0 @@
-/**
- 葫芦娃中签查询 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();