app.js

/* eslint-disable no-await-in-loop */
const url = require('url');
const log4js = require('log4js');
const recording = require('log4js/lib/appenders/recording');

log4js.configure({
  appenders: {
    vcr: {
      type: 'recording',
    },
    out: {
      type: 'console',
    },
  },
  categories: { default: { appenders: ['vcr', 'out'], level: 'info' } },
});

const logger = log4js.getLogger();
const JSEncrypt = require('node-jsencrypt');
// process.env['NODE_TLS_REJECT_UNAUTHORIZED'] = '0'
const superagent = require('superagent');
const config = require('../config');
const accounts = require('../accounts');
const serverChan = require('../serverChan');
const telegramBot = require('../telegramBot');

const client = superagent.agent();
const headers = {
  'User-Agent': `Mozilla/5.0 (Linux; U; Android 11; ${config.model} Build/RP1A.201005.001) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/74.0.3729.136 Mobile Safari/537.36 Ecloud/${config.version} Android/30 clientId/${config.clientId} clientModel/${config.model} clientChannelId/qq proVersion/1.0.6`,
  Referer: 'https://m.cloud.189.cn/zhuanti/2016/sign/index.jsp?albumBackupOpened=1',
  'Accept-Encoding': 'gzip, deflate',
  Host: 'cloud.189.cn',
};

const getEncrypt = () => new Promise((resolve, reject) => {
  if (config.pubKey) {
    resolve(config.pubKey);
    return;
  }
  superagent.post('https://open.e.189.cn/api/logbox/config/encryptConf.do')
    .send('appId=cloud')
    .end((err, res) => {
      if (err) {
        reject(err);
        return;
      }
      const json = JSON.parse(res.text);
      if (json.result === 0) {
        resolve(json.data.pubKey);
      } else {
        reject(json.data);
      }
    });
});

const redirectURL = () => new Promise((resolve, reject) => {
  superagent.get('https://cloud.189.cn/api/portal/loginUrl.action?redirectURL=https://cloud.189.cn/web/redirect.html?returnURL=/main.action')
    .end((err, res) => {
      if (err) {
        reject(err);
        return;
      }
      const { query } = url.parse(res.redirects[1], true);
      resolve(query);
    });
});

const getLoginFormData = (username, password, encryptKey) => new Promise((resolve, reject) => {
  redirectURL().then((query) => {
    superagent.post('https://open.e.189.cn/api/logbox/oauth2/appConf.do')
      .set({
        'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:74.0) Gecko/20100101 Firefox/76.0',
        Referer: 'https://open.e.189.cn/',
        lt: query.lt,
        REQID: query.reqId,
      })
      .type('form')
      .send({
        version: '2.0',
        appKey: 'cloud',
      })
      .end((err, res) => {
        if (err) {
          reject(err);
          return;
        }
        const resData = JSON.parse(res.text);
        if (resData.result === '0') {
          const keyData = `-----BEGIN PUBLIC KEY-----\n${encryptKey}\n-----END PUBLIC KEY-----`;
          const jsencrypt = new JSEncrypt();
          jsencrypt.setPublicKey(keyData);
          const usernameEncrypt = Buffer.from(jsencrypt.encrypt(username), 'base64').toString('hex');
          const passwordEncrypt = Buffer.from(jsencrypt.encrypt(password), 'base64').toString('hex');
          const formData = {
            returnUrl: resData.data.returnUrl,
            paramId: resData.data.paramId,
            lt: query.lt,
            REQID: query.reqId,
            userName: `{NRP}${usernameEncrypt}`,
            password: `{NRP}${passwordEncrypt}`,
          };
          resolve(formData);
        } else {
          reject(new Error(resData.msg));
        }
      });
  }).catch((err) => {
    reject(err);
  });
});

const login = (formData) => new Promise((resolve, reject) => {
  const data = {
    appKey: 'cloud',
    version: '2.0',
    accountType: '01',
    mailSuffix: '@189.cn',
    validateCode: '',
    returnUrl: formData.returnUrl,
    paramId: formData.paramId,
    captchaToken: '',
    dynamicCheck: 'FALSE',
    clientType: '1',
    cb_SaveName: '0',
    isOauth2: false,
    userName: formData.userName,
    password: formData.password,
  };
  superagent.post('https://open.e.189.cn/api/logbox/oauth2/loginSubmit.do')
    .set({
      'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:74.0) Gecko/20100101 Firefox/76.0',
      Referer: 'https://open.e.189.cn/',
      lt: formData.lt,
      REQID: formData.REQID,
    })
    .type('form')
    .send(data)
    .end((err, res) => {
      if (err) {
        reject(err);
        return;
      }
      const json = JSON.parse(res.text);
      if (json.result !== 0) {
        reject(json.msg);
        return;
      }
      client.get(json.toUrl)
        .set(headers)
        .end((e, r) => {
          if (e) {
            reject(e);
            return;
          }
          resolve(r.statusCode);
        });
    });
});

const doGet = (taskUrl) => new Promise((resolve, reject) => {
  const q = url.parse(taskUrl, true);
  client.get(taskUrl)
    .set({
      ...headers,
      Host: q.host,
    })
    .end((err, res) => {
      if (err) {
        reject(err);
        return;
      }
      resolve(JSON.parse(res.text));
    });
});

const mask = (s, start, end) => s.split('').fill('*', start, end).join('');

// 登录流程 1.获取公钥 -> 2.获取登录参数 -> 3.获取登录地址,跳转到登录页
const doLogin = (userName, password) => new Promise((resolve, reject) => {
  getEncrypt()
    .then((encryptKey) => getLoginFormData(userName, password, encryptKey))
    .then((formData) => login(formData))
    .then(() => resolve('登录成功'))
    .catch((error) => {
      logger.error(`登录失败:${JSON.stringify(error)}`);
      reject(error);
    });
});

// 任务 1.签到 2.天天抽红包 3.自动备份抽红包
const doTask = async () => {
  const tasks = [
    `https://cloud.189.cn/mkt/userSign.action?rand=${new Date().getTime()}&clientType=TELEANDROID&version=${config.version}&model=${config.model}`,
    'https://m.cloud.189.cn/v2/drawPrizeMarketDetails.action?taskId=TASK_SIGNIN&activityId=ACT_SIGNIN',
    'https://m.cloud.189.cn/v2/drawPrizeMarketDetails.action?taskId=TASK_SIGNIN_PHOTOS&activityId=ACT_SIGNIN',
    'https://m.cloud.189.cn/v2/drawPrizeMarketDetails.action?taskId=TASK_2022_FLDFS_KJ&activityId=ACT_SIGNIN',
  ];

  const result = [];
  for (let index = 0; index < tasks.length; index += 1) {
    const task = tasks[index];
    const res = await doGet(task);
    if (index === 0) {
      // 签到
      result.push(`${res.isSign ? '已经签到过了，' : ''}签到获得${res.netdiskBonus}M空间`);
    } else if (res.errorCode === 'User_Not_Chance') {
      result.push(`第${index}次抽奖失败,次数不足`);
    } else {
      result.push(`第${index}次抽奖成功,抽奖获得${res.prizeName}`);
    }
  }
  return result;
};

const pushServerChan = (title, desp) => {
  if (!serverChan.sendKey) { return; }
  const data = {
    title,
    desp,
  };
  superagent.post(`https://sctapi.ftqq.com/${serverChan.sendKey}.send`)
    .type('form')
    .send(data)
    .end((err, res) => {
      if (err) {
        logger.error(`ServerChan推送失败:${JSON.stringify(err)}`);
        return;
      }
      const json = JSON.parse(res.text);
      if (json.code !== 0) {
        logger.error(`ServerChan推送失败:${JSON.stringify(json)}`);
      } else {
        logger.info('ServerChan推送成功');
      }
    });
};

const pushTelegramBot = (title, desp) => {
  if (!(telegramBot.botToken && telegramBot.chatId)) { return; }
  const data = {
    chat_id: telegramBot.chatId,
    text: title + "\n\n" + desp,
  };
  superagent.post(`https://api.telegram.org/bot${telegramBot.botToken}/sendMessage`)
    .type('form')
    .send(data)
    .end((err, res) => {
      if (err) {
        logger.error(`TelegramBot推送失败:${JSON.stringify(err)}`);
        return;
      }
      const json = JSON.parse(res.text);
      if (!json.ok) {
        logger.error(`TelegramBot推送失败:${JSON.stringify(json)}`);
      } else {
        logger.info('TelegramBot推送成功');
      }
    });
};

const push = (title, desp) => {
  pushServerChan(title, desp);
  pushTelegramBot(title, desp);
}

// 开始执行程序
async function main() {
  for (let index = 0; index < accounts.length; index += 1) {
    const account = accounts[index];
    const { userName, password } = account;
    if (userName && password) {
      const userNameInfo = mask(userName, 3, 7);
      try {
        logger.log(`账户 ${userNameInfo}开始执行`);
        await doLogin(userName, password);
        const result = await doTask();
        result.forEach((r) => logger.log(r));
        logger.log('任务执行完毕');
      } catch (e) {
        if (e.code === 'ECONNRESET') {
          throw e;
        }
      } finally {
        logger.log(`账户 ${userNameInfo}执行完毕`);
      }
    }
  }
}

(async () => {
  try {
    await main();
  } finally {
    const events = recording.replay();
    const content = events.map((e) => `${e.data.join('')}`).join('  \n');
    push('天翼云盘自动签到任务', content);
    recording.erase();
  }
})();