xmtravel/indexAction.js

const { default: axios } = require('axios')
const dayjs = require('dayjs')
const duration = require('dayjs/plugin/duration')
const schedule = require('node-schedule')
const { baseURL, cookie, deviceId, bark } = require('./config')
require('./console')

dayjs.extend(duration)

let cookies = typeof cookie === 'object' ? cookie : [cookie]
let currentCookie = ''

const xmTravelAxios = axios.create()
const barkAxios = axios.create()

const TRAVEL_BASE_URL = baseURL + 'xmTravel/'

xmTravelAxios.interceptors.request.use(req => {
  req.headers['X-Requested-With'] = 'XMLHttpRequest'
  req.headers['Accept-Language'] = 'zh-cn'
  req.headers['MT-Request-ID'] = getGUID()
  req.headers[
    'User-Agent'
  ] = `Mozilla/5.0 (iPhone; CPU iPhone OS 14_8 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 moutaiapp/1.2.1 device-id/${deviceId}`
  req.headers['Referer'] =
    'https://h5.moutai519.com.cn/gux/game/main?appConfig=2_1_2'
  req.headers['Cookie'] = currentCookie
  req.headers['Accept'] = 'application/json, text/javascript, */*; q=0.01'
  req.headers['Content-Type'] = 'application/json'
  req.headers['MT-APP-Version'] = '1.0.0'
  req.headers['Origin'] = 'https://h5.moutai519.com.cn'
  return req
})

function getGUID(key = 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx') {
  return key.replace(/[xy]/g, function (c) {
    var r = (Math.random() * 16) | 0
    var v = c == 'x' ? r : (r & 0x3) | 0x8

    return v.toString(16)
  })
}

function log(...msg) {
  console.log(`账号${cookies.indexOf(currentCookie) + 1}`, ...msg)
}

function sendBarkMsg(msg) {
  log(msg)
  if (!bark) return false
  return barkAxios({
    method: 'get',
    url: `${bark}/${encodeURIComponent('xmtravel')}/${encodeURIComponent(
      msg
    )}?group=${encodeURIComponent('xmtravel')}`
  })
}

async function httpRequest(url, method = 'get', _data) {
  let params = ''
  let data = {}
  if (method === 'get') {
    params = _data
  } else {
    data = _data
  }
  return await xmTravelAxios({
    url,
    method,
    data,
    params
  })
    .then(d => d.data)
    .catch(async d => {
      if (d.response.status === 500 && d.response.data) {
        return Promise.resolve(d.response.data)
      }
      if (d.response.status === 401 && d.response.data) {
        await sendBarkMsg(`登录失效, 请更新 cookie 配置`)
        return Promise.reject('登录失效')
      }
      log(d)
    })
}

function getUserIsolationPageData() {
  console.log()
  log('查询小茅运信息:')
  return httpRequest(
    baseURL + 'isolationPage/getUserIsolationPageData',
    'get',
    {
      __timestamp: +new Date()
    }
  ).then(async d => {
    // energy: 耐力值
    // xmy: 小茅运值
    let { energy, energyReward, xmy, xmTravel } = d.data
    // status: 1. 未开始 2. 进行中 3. 已完成
    // remainChance: 今日剩余旅行次数
    // travelEndTime: 旅行结束时间
    let { status, remainChance, travelEndTime } = xmTravel
    let { value } = energyReward // 可领取申购耐力值奖励
    let endTime = travelEndTime * 1000
    log('当前小茅运值:', xmy)

    if (value) {
      await getUserEnergyAward()
      energy += value
    }

    let { currentPeriodCanConvertXmyNum } = await getExchangeRateInfo()
    log('本月剩余旅行奖励:', currentPeriodCanConvertXmyNum)

    if (currentPeriodCanConvertXmyNum <= 0) {
      // 当月无可领取奖励
      return Promise.reject()
    }

    // 未开始
    if (status === 1) {
      if (energy < 100) {
        log('耐力不足, 当前耐力值:', energy)
        return Promise.reject()
      }
    }

    // 进行中
    if (status === 2) {
      log('旅行暂未结束')
      log('本次旅行结束时间: ', dayjs(endTime).format('YYYY-MM-DD HH:mm:ss'))
      log(
        '本次旅行剩余时间: ',
        dayjs.duration(endTime - +new Date()).format('HH 小时 mm 分钟 ss 秒')
      )
      return Promise.reject()
    }

    return {
      remainChance, // 剩余次数
      finish: status === 3
    }
  })
}

// 获取本月剩余奖励耐力值
function getExchangeRateInfo() {
  return httpRequest(baseURL + 'synthesize/exchangeRateInfo', 'get', {
    __timestamp: +new Date()
  }).then(d => {
    let { currentPeriodCanConvertXmyNum } = d.data

    return { currentPeriodCanConvertXmyNum }
  })
}

function getXmTravelInfo() {
  console.log()
  log('获取旅行信息: ')
  return httpRequest(TRAVEL_BASE_URL + 'getXmTravelInfo', 'get', {
    __timestamp: +new Date()
  }).then(d => {
    let { lastStartTravelTs, travelTotalTime, remainTravelCnt, travelStatus } =
      d.data

    let startTime = dayjs(lastStartTravelTs)
    let endTime = startTime.add(3, 'h')
    let firstTravel = !dayjs().isSame(startTime, 'day')

    if (firstTravel) {
      log('今日暂未开始旅行')
    }

    let finish = travelStatus === 3
    if (!finish) {
      log('旅行暂未结束')
      log(
        '本次旅行开始时间: ',
        dayjs(lastStartTravelTs).format('YYYY-MM-DD HH:mm:ss')
      )
      log(
        '本次旅行结束时间: ',
        startTime.add(3, 'h').format('YYYY-MM-DD HH:mm:ss')
      )
      log(
        '本次旅行剩余时间: ',
        dayjs.duration(endTime - +new Date()).format('HH 小时 mm 分钟 ss 秒')
      )
      return Promise.reject()
    }
    if (!remainTravelCnt) log('当日旅行次数已耗尽')
    else log('剩余旅行次数: ', remainTravelCnt)
    return {
      remainTravelCnt,
      finish: finish && !firstTravel // 今日已首次旅行过且当前已完成
    }
  })
}

function getUserEnergyAward() {
  console.log()
  log('获取申购耐力值: ')
  return httpRequest(
    baseURL + 'isolationPage/getUserEnergyAward',
    'post',
    {}
  ).then(d => {
    if (d.code === 200) {
      log('耐力值领取成功')
    } else {
      log('耐力值领取失败', d.message || '')
      return Promise.reject()
    }
  })
}

function getXmTravelReward() {
  console.log()
  log('查询旅行奖励: ')
  return httpRequest(TRAVEL_BASE_URL + 'getXmTravelReward', 'get', {
    __timestamp: +new Date()
  }).then(d => {
    if (d.code === 2000 && d.data.travelRewardXmy) {
      log('可获取小茅运: ', d.data.travelRewardXmy)
      return d.data.travelRewardXmy
    } else {
      log('旅行暂未完成', d.message || '')
      return Promise.reject()
    }
  })
}

function receiveReward(travelRewardXmy) {
  console.log()
  log('领取旅行奖励: ')
  return httpRequest(TRAVEL_BASE_URL + 'receiveReward', 'post', {}).then(d => {
    if (d.code === 2000) {
      sendBarkMsg('成功领取旅行奖励小茅运' + travelRewardXmy)
    } else {
      log('领取失败', d.message || '')
      return Promise.reject()
    }
  })
}

function startTravel() {
  console.log()
  log('开始旅行: ')
  return httpRequest(TRAVEL_BASE_URL + 'startTravel', 'post', {}).then(d => {
    if (d.code === 2000) {
      log('开始旅行成功')
    } else {
      log('开始旅行失败', d.message || '')
      return Promise.reject()
    }
  })
}

function shareReward() {
  console.log()
  log('每日首次分享可领取耐力:')
  return httpRequest(TRAVEL_BASE_URL + 'shareReward', 'post', {}).then(d => {
    if (d.code === 2000) {
      log('分享成功')
    } else {
      log('分享失败', d.message || '')
      return Promise.reject()
    }
  })
}

async function init() {
  console.log('开始执行')
  let time = +dayjs().format('HH')
  if (time >= 9 && time < 20) {
    for await (i of cookies) {
      currentCookie = i
      try {
        let { remainChance, finish } = await getUserIsolationPageData()
        // let { remainTravelCnt, finish } = await getXmTravelInfo()
        if (finish) {
          let travelRewardXmy = await getXmTravelReward()
          await receiveReward(travelRewardXmy)
          await shareReward()
        }
        if (remainChance) await startTravel()
      } catch (e) {}
    }
  } else {
    console.log()
    console.log('活动未开始')
  }

  console.log()
  console.log('脚本执行完毕')
  console.log()
}

init()
// schedule.scheduleJob('00 */30 * * * *', init) // 每半小时