代码

  1. // token 换取文件 
  3. const axios = require('axios')
  4. // const dbs = require('../models/mo')
  5. const Config = require('../models/config')
  7. const token = () => new Promise(async (res, rej) => {
  8.   const times = (new Date()).getTime() //当前时间戳
  9.   axToke = (cd) => {
  10.     let config = {
  11.       appid: 'wxf37a0371d5c7a359',
  12.       secret: '4802d7147d421ad8e775f95ca98d7180',
  13.       grant_type: 'client_credential'
  14.     }
  15.     let url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=' + config.appid + '&secret=' + config.secret
  16.     axios.get(url).then(res => {
  17.       cd(res.data)
  18.     }, err => {
  19.       cd(err)
  20.     })
  21.   }
  23.   // let accessTokes = await dbs.findo(Config, {})
  24.   let accessTokes = await Config.findOne({})
  25.   console.log('查询tokes', accessTokes, times);
  26.   if (accessTokes.accessToken == null) {
  27.     axToke(cd => {
  28.       let key = {
  29.         _id: accessTokes._id
  30.       }
  31.       let obj = {
  32.         '$set': {
  33.           accessToken: cd.access_token, //toke
  34.           tokeTime: times + (cd.expires_in - 100) * 1000 // toke到期时间
  35.         }
  36.       }
  37.       Config.update(key, obj).then(r => {
  38.         Config.findOne({}).then(rs => {
  39.           console.log('新增tokes', rs);
  40.           res(rs)
  41.         })
  42.       })
  43.     })
  44.   } else if (accessTokes.tokeTime <= times) {
  45.     console.log('toke过期', accessTokes.tokeTime, times);
  46.     axToke(cd => {
  47.       let key = {
  48.         _id: accessTokes._id
  49.       }
  50.       let obj = {
  51.         '$set': {
  52.           accessToken: cd.access_token, //toke
  53.           tokeTime: times + (cd.expires_in - 100) * 1000 // toke到期时间
  54.         }
  55.       }
  56.       Config.update(key, obj).then(r => {
  57.         Config.findOne({}).then(rs => {
  58.           console.log('新增tokes', rs);
  59.           res(rs)
  60.         })
  61.       })
  62.     })
  63.   } else {
  64.     console.log('toke有效', accessTokes);
  65.     res(accessTokes)
  66.   }
  67. })
  69. module.exports = token