sign

function/qlApi.js

@@ -0,0 +1,166 @@
+/*
+ * @Author: chenghao
+ * @Date: 2022-02-14 10:19:21
+ * @Last Modified by: chenghao
+ * @Last Modified time: 2022-03-20 13:57:10
+ * @Desc: 青龙依赖
+ * @From: https://github.com/whyour/qinglong/issues/1369
+ */
+const axios = require('axios')
+const QL_URL = 'http://127.0.0.1:5700'
+const CLIENT_ID = process.env.CLIENT_ID
+const CLIENT_SECRET = process.env.CLIENT_SECRET
+
+/**
+ *获取青龙token
+ */
+function getQLToken() {
+  return new Promise((resolve, reject) => {
+    axios
+      .get(
+        QL_URL +
+          `/open/auth/token?client_id=${CLIENT_ID}&client_secret=${CLIENT_SECRET}`
+      )
+      .then(res => {
+        if (res.data.code === 200) {
+          resolve(res.data.data.token)
+        } else {
+          reject(res.data.message)
+        }
+      })
+  })
+}
+
+/**
+ *构造请求头
+ * @returns headers
+ */
+async function generateRequestHeader() {
+  return new Promise(async resolve => {
+    const token = await getQLToken()
+    resolve({
+      Authorization: 'Bearer ' + token,
+      'User-Agent':
+        'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/89.0.4577.63 Safari/537.36',
+      'Content-Type': 'application/json;charset=UTF-8',
+      'Accept-Encoding': 'gzip, deflate',
+      'Accept-Language': 'zh-CN,zh;q=0.9'
+    })
+  })
+}
+
+/**
+ *初始化请求实例
+ * @returns axios instance
+ */
+async function init() {
+  if (!CLIENT_ID || !CLIENT_SECRET)
+    return Promise.reject('未获取到 CLIENT_ID 或 CLIENT_SECRET')
+  const headers = await generateRequestHeader()
+  return new Promise(resolve => {
+    resolve(
+      axios.create({
+        baseURL: QL_URL,
+        timeout: 10000,
+        headers
+      })
+    )
+  })
+}
+
+/**
+ *
+ *获取青龙环境变量
+ * @param {*} instance
+ * @returns [] envlist
+ */
+function getQLEnvs(instance, searchValue = 'JD_COOKIE') {
+  return new Promise(resolve => {
+    instance
+      .get('/open/envs', {
+        params: {
+          searchValue,
+          t: +new Date()
+        }
+      })
+      .then(res => {
+        resolve(res.data.data.filter(v => v.status === 0))
+      })
+  })
+}
+
+/**
+ *创建ck环境变量
+ * @param {*} instance
+ * @param {*} [ck=[]]
+ * @returns
+ */
+function createCkEnv(instance, ck = []) {
+  return new Promise(resolve => {
+    instance
+      .post(`/open/envs?t=${+new Date()}`, ck)
+      .then(res => {
+        resolve(res.data)
+      })
+      .catch(error => {
+        console.log(error.response.data)
+      })
+  })
+}
+
+/**
+ * 更新环境变量
+ * @param {*} instance
+ * @param {*} ck
+ * @returns
+ */
+function updateCkEnv(instance, ck = {}) {
+  return new Promise(resolve => {
+    instance
+      .put(`/open/envs?t=${+new Date()}`, ck)
+      .then(res => {
+        resolve(res.data)
+      })
+      .catch(error => {
+        console.log(error.response.data)
+      })
+  })
+}
+
+/**
+ * 删除环境变量
+ * @param {*} instance
+ * @param {*} ckIds
+ * @returns
+ */
+function deleteCkEnv(instance, ckIds = []) {
+  return new Promise(resolve => {
+    instance({
+      method: 'delete',
+      url: `/open/envs?t=${+new Date()}`,
+      data: ckIds
+    }).then(resolve)
+  })
+}
+
+/**
+ *切换ck状态
+ * @param {*} instance
+ * @param {*} path
+ * @param {*} id
+ * @returns
+ */
+function toggleCKEnv(instance, id, path = 'enable') {
+  return new Promise(resolve => {
+    instance.put(`/open/envs/${path}?t=${+new Date()}`, [id]).then(res => {
+      resolve(res.data)
+    })
+  })
+}
+
+exports.createEnv = createCkEnv
+exports.deleteEnv = deleteCkEnv
+exports.getEnv = getQLEnvs
+exports.initInstance = init
+exports.updateCkEnv = updateCkEnv
+exports.toggleCKEnv = toggleCKEnv

jd_aliyunautoSignin.js

@@ -0,0 +1,207 @@
+/*
+cron "0 9 * * *" jd_aliyunautoSignin.js, tag=阿里云盘签到
+*/
+
+const axios = require('axios')
+const { initInstance, getEnv, updateCkEnv } = require('./function/qlApi.js')
+const notify = require('./sendNotify')
+
+const updateAccesssTokenURL = 'https://auth.aliyundrive.com/v2/account/token'
+const signinURL =
+  'https://member.aliyundrive.com/v1/activity/sign_in_list?_rx-s=mobile'
+const rewardURL =
+  'https://member.aliyundrive.com/v1/activity/sign_in_reward?_rx-s=mobile'
+
+// 使用 refresh_token 更新 access_token
+function updateAccesssToken(queryBody, remarks) {
+  const errorMessage = [remarks, '更新 access_token 失败']
+  return axios(updateAccesssTokenURL, {
+    method: 'POST',
+    data: queryBody,
+    headers: { 'Content-Type': 'application/json' }
+  })
+    .then(d => d.data)
+    .then(d => {
+      const { code, message, nick_name, refresh_token, access_token } = d
+      if (code) {
+        if (
+          code === 'RefreshTokenExpired' ||
+          code === 'InvalidParameter.RefreshToken'
+        )
+          errorMessage.push('refresh_token 已过期或无效')
+        else errorMessage.push(message)
+        return Promise.reject(errorMessage.join(', '))
+      }
+      return { nick_name, refresh_token, access_token }
+    })
+    .catch(e => {
+      errorMessage.push(e.message)
+      return Promise.reject(errorMessage.join(', '))
+    })
+}
+
+//签到列表
+function sign_in(access_token, remarks) {
+  const sendMessage = [remarks]
+  return axios(signinURL, {
+    method: 'POST',
+    data: {
+      isReward: false
+    },
+    headers: {
+      Authorization: access_token,
+      'Content-Type': 'application/json'
+    }
+  })
+    .then(d => d.data)
+    .then(async json => {
+      if (!json.success) {
+        sendMessage.push('签到失败', json.message)
+        return Promise.reject(sendMessage.join(', '))
+      }
+
+      sendMessage.push('签到成功')
+
+      const { signInLogs, signInCount } = json.result
+      const currentSignInfo = signInLogs[signInCount - 1] // 当天签到信息
+
+      sendMessage.push(`本月累计签到 ${signInCount} 天`)
+
+      // 未领取奖励列表
+      const rewards = signInLogs.filter(
+        v => v.status === 'normal' && !v.isReward
+      )
+
+      if (rewards.length) {
+        for await (reward of rewards) {
+          const signInDay = reward.day
+          try {
+            const rewardInfo = await getReward(access_token, signInDay)
+            sendMessage.push(
+              `第${signInDay}天奖励领取成功: 获得${rewardInfo.name || ''}${
+                rewardInfo.description || ''
+              }`
+            )
+          } catch (e) {
+            sendMessage.push(`第${signInDay}天奖励领取失败:`, e)
+          }
+        }
+      } else if (currentSignInfo.isReward) {
+        sendMessage.push(
+          `今日签到获得${currentSignInfo.reward.name || ''}${
+            currentSignInfo.reward.description || ''
+          }`
+        )
+      }
+
+      return sendMessage.join(', ')
+    })
+    .catch(e => {
+      sendMessage.push('签到失败')
+      sendMessage.push(e.message)
+      return Promise.reject(sendMessage.join(', '))
+    })
+}
+
+// 领取奖励
+function getReward(access_token, signInDay) {
+  return axios(rewardURL, {
+    method: 'POST',
+    data: { signInDay },
+    headers: {
+      authorization: access_token,
+      'Content-Type': 'application/json'
+    }
+  })
+    .then(d => d.data)
+    .then(json => {
+      if (!json.success) {
+        return Promise.reject(json.message)
+      }
+
+      return json.result
+    })
+}
+
+// 获取环境变量
+async function getRefreshToken() {
+  let instance = null
+  try {
+    instance = await initInstance()
+  } catch (e) {}
+
+  let refreshToken = process.env.refreshToken || []
+  try {
+    if (instance) refreshToken = await getEnv(instance, 'refreshToken')
+  } catch (e) {}
+
+  let refreshTokenArray = []
+
+  if (Array.isArray(refreshToken)) refreshTokenArray = refreshToken
+  else if (refreshToken.indexOf('&') > -1)
+    refreshTokenArray = refreshToken.split('&')
+  else if (refreshToken.indexOf('\n') > -1)
+    refreshTokenArray = refreshToken.split('\n')
+  else refreshTokenArray = [refreshToken]
+
+  if (!refreshTokenArray.length) {
+    console.log('未获取到refreshToken, 程序终止')
+    process.exit(1)
+  }
+
+  return {
+    instance,
+    refreshTokenArray
+  }
+}
+
+!(async () => {
+  const { instance, refreshTokenArray } = await getRefreshToken()
+
+  const message = []
+  let index = 1
+  for await (refreshToken of refreshTokenArray) {
+    let remarks = refreshToken.remarks || `账号${index}`
+    const queryBody = {
+      grant_type: 'refresh_token',
+      refresh_token: refreshToken.value || refreshToken
+    }
+
+    try {
+      const { nick_name, refresh_token, access_token } =
+        await updateAccesssToken(queryBody, remarks)
+
+      if (nick_name && nick_name !== remarks)
+        remarks = `${nick_name}(${remarks})`
+
+      // 更新环境变量
+      if (instance) {
+        let params = {
+          name: refreshToken.name,
+          value: refresh_token,
+          remarks: refreshToken.remarks || nick_name // 优先存储原有备注信息
+        }
+        // 新版青龙api
+        if (refreshToken.id) {
+          params.id = refreshToken.id
+        }
+        // 旧版青龙api
+        if (refreshToken._id) {
+          params._id = refreshToken._id
+        }
+        await updateCkEnv(instance, params)
+      }
+
+      const sendMessage = await sign_in(access_token, remarks)
+      console.log(sendMessage)
+      console.log('\n')
+      message.push(sendMessage)
+    } catch (e) {
+      console.log(e)
+      console.log('\n')
+      message.push(e)
+    }
+    index++
+  }
+  await notify.sendNotify(`阿里云盘签到`, message.join('\n'))
+})()