关注和取消都获取不到XML数据
config/wechat.txt
空
libs/utils.js
'use strict'
var fs = require('fs');
var Promise = require('bluebird');
// 读取文件
exports.readFileAsync = function(fpath, encoding){
return new Promise(function(resolve, reject){
fs.readFile(fpath, encoding, function(err, content){
// console.log("err : " + JSON.stringify(err));
if(err){
reject(err);
}
else {
// console.log("content : " + JSON.stringify(content));
resolve(content);
}
})
})
}
// 写入文件
exports.writeFileAsync = function(fpath, content){
return new Promise(function(resolve, reject){
fs.writeFile(fpath, content, function(err){
if(err){
reject(err);
}
else {
resolve();
}
})
})
}wechat/g.js
'use strict'
var sha1 = require('sha1');
var getRawBody = require('raw-body');
var Wechat = require('./wechat');
// 中间件
module.exports = function(opts){
// 初始化wechat 管理票据的更新
var wechat = new Wechat(opts);
console.log("++++++");
return function *(next){
console.log(this.query);
// 加密逻辑
var token = opts.token;
var signature = this.query.signature;
var nonce = this.query.nonce;
var timestamp = this.query.timestamp;
var echostr = this.query.echostr;
var str = [token, timestamp, nonce].sort().join('');
var sha = sha1(str);
console.log(this.method);
if(this.method === 'GET'){
if(sha === signature){
this.body = echostr + '';
}
else {
this.body = 'get wrong';
}
}
else if(this.method === 'POST'){
if(sha !== signature){
this.body = 'post wrong';
return false;
}
var data = yield getRawBody(this.req, {
length : this.length,
limit : '1mb',
encoding : this.charset
});
console.log('post ' + data.toString());
}
}
}wechat/wechat.js
'use strict'
var Promise = require('bluebird');
var request = Promise.promisify(require('request'));
var prefix = 'https://api.weixin.qq.com/cgi-bin/'
var api = {
accessToken : prefix + 'token?grant_type=client_credential'
}
//https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET
function Wechat(opts){
// 读取和写入票据
var that = this;
this.appID = opts.appID;
this.appSecret = opts.appSecret;
this.getAccessToken = opts.getAccessToken;
this.saveAccessToken = opts.saveAccessToken;
this.getAccessToken()
.then (function(data){
// 读取票据
try {
data = JSON.parse(data)
}
catch(e){
// 捕获异常 更新票据
return that.updateAccessToken();
}
// 判断票据是否在有效期内 检查合法性
if(that.isValidAccessToken(data)){
// 如果合法 传下去
return Promise.resolve(data);
}
else {
// 如果不合法过期 则更新票据
return that.updateAccessToken();
}
})
.then(function(data){ // 最终票据结果
// 把access_token挂到实例上
that.access_token = data.access_token;
// 把过期时间挂到实例上
that.expires_in = data.expires_in;
// 储存票据
that.saveAccessToken(data);
})
};
// 合法性检查
Wechat.prototype.isValidAccessToken = function(data){
// 验证是否存在
if(!data || !data.access_token || !data.expires_in){
return false;
}
var access_token = data.access_token;
var expires_in = data.expires_in;
var now = (new Date().getTime());
if(now < expires_in) {
// 未过期
return true;
}
else{
// 已过期
return false;
}
}
// 更新票据
Wechat.prototype.updateAccessToken = function(){
var appID = this.appID;
var appSecret = this.appSecret;
var url = api.accessToken + '&appid=' + appID + '&secret=' + appSecret;
return new Promise(function(resolve, reject){
// 向某个服务器发送请求
request({
url : url,
json : true
}).then(function(response){
// console.log(response);
var data = response.body;
var now = (new Date().getTime());
// 过期时间提前20秒更新 考虑网络延迟
var expires_in = now + (data.expires_in - 20)*1000;
// 缩短后的过期时间复制给数据本身
data.expires_in = expires_in;
// 继续向下传递
resolve(data);
})
});
};
module.exports = Wechat;app.js
'use strict'
var Koa = require('koa');
var path = require('path');
var wechat = require('./wechat/g');
var util = require('./libs/util');
var wechat_file = path.join(__dirname, './config/wechat.txt');
var config = {
wechat : {
appID : 'wx987f75bb63a127b7',
appSecret : '202a0ae869cfffd0cb24d18d32686577',
token : 'whjtest',
getAccessToken : function(){
return util.readFileAsync(wechat_file)
},
saveAccessToken : function(data){
data = JSON.stringify(data);
return util.writeFileAsync(wechat_file, data)
}
}
};
var app = new Koa();
// functioan 后 加 * 生成器函数 是一种可以从中退出并在之后重新进入的函
app.use(wechat(config.wechat));
app.listen(80);
console.log('localhost:80');package.json
{
"name": "mp",
"version": "1.0.0",
"description": "",
"main": "index.js",
"scripts": {
"test": "echo \"Error: no test specified\" && exit 1"
},
"author": {
"name": "whj",
"email": "1004609378@qq.com"
},
"license": "ISC",
"dependencies": {
"bluebird": "^3.5.0",
"koa": "^1.2.0",
"sha1": "^1.1.1"
},
"devDependencies": {
"raw-body": "^2.2.0",
"request": "^2.81.0"
}
}打印出来的内容
localhost:80
{ signature: '483cccc745a6be740609452a7ab25936f98b18cc',
echostr: '1071629943448784895',
timestamp: '1492076093',
nonce: '748994395' }
GET再之后，无论是关注，取消关注，都没有任何打印出来了
如图，课程有打印出xml的内容，但是我的并没有
725
收起
正在回答 回答被采纳积分+3
相似问题
登录后可查看更多问答，登录/注册
