|
@@ -1,302 +1,4 @@
|
|
|
-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) // 每半小时
|
|
|
-
|
|
|
-exports.init = init
|
|
|
+const api = require('./api')
|
|
|
+api.init()
|
|
|
+schedule.scheduleJob('00 */30 * * * *', api.init) // 每半小时
|