2回答

Scott

2017-03-27

说明拿到的 data 是不正确，也就是 执行上传这个环节有问题。

先把路径修改一下： __dirname+'/2.jpg' 改成 path.join(__dirname+'/2.jpg')，然后把 uploadMaterial 里面的返回内容打印一下：

var _data = response.body

console.log(_data)

我们看看这个 data 提示的是什么

0

7

Scott

回复

dravenxiaokai

这个需要倒推反查，不显示图片，说明要么是微信平台没收到你的回复策略，要么是回复策略的 xml 不对，从代码里，把即将回复之前的 xml 打印一下，再把回复之前拿到的图片信息也打印一下，看看哪里有问题

2017-04-01

共7条回复

dravenxiaokai

提问者

2017-03-26

//wechat.js
'use strict'

var Promise = require('bluebird')
var request = Promise.promisify(require('request'))
var util = require('./util')
var fs = require('fs')
var tpl = require('./tpl')

var prefix = 'https://api.weixin.qq.com/cgi-bin/'
var api = {
	accessToken:prefix+'token?grant_type=client_credential',
	upload:prefix + 'media/upload?'
}
function Wechat(opts){
	var that = this;
	this.appID = opts.appID
	this.appSecret = opts.appSecret
	this.getAccessToken = opts.getAccessToken
	this.saveAccessToken = opts.saveAccessToken

	this.fetchAccessToken()
}

Wechat.prototype.updateAccessToken = function(data) {
	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){
			// var data = response[1] 这是个坑！
			var data = response.body
			var now = (new Date().getTime())
			var expires_in = now + (data.expires_in - 20) * 1000
			data.expires_in = expires_in
			resolve(data)
		})	
	})	
}
Wechat.prototype.uploadMaterial = function(type,filepath) {
	var that = this
	var form = {
		media:fs.createReadStream(filepath)
	}

	return new Promise(function(resolve,reject){
		that
		.fetchAccessToken()
		.then(function(data){
			var url = api.upload + 'access_token='+data.access_token+'&type='+type
			// console.log(url)
			request({method:'POST',url:url,formData:form,json:true})
			.then(function(response){
				// var _data = response[1] 这是个坑！
				var _data = response.body
				// console.log('hhhhhhhhhhhhhhhh'+_data.data)
				if(_data){
					resolve(_data)
				}else{
					throw new Error('Upload marterial fails')
				}
			})
			.catch(function(err){
				reject(err)
			})
		})
		

	})	
}
Wechat.prototype.fetchAccessToken = function(data){
	var that = this
	if(this.access_token && this.expires_in){
		if(this.isValidAccessToken(this)){
			return Promise.resolve(this)
		}
	}
	this.getAccessToken()
	.then(function(data){
		try{
			// data.JSON.parse(data)
			data = JSON.parse(data)
		}catch(e){
			return that.updateAccessToken(data)
		}
		if(that.isValidAccessToken(data)){//判断票据是否有效
			// Promise.resolve(data)
			return Promise.resolve(data);//这里加return
		}else{
			return that.updateAccessToken()//否则更新票据
		}
	})
	.then(function(data){
		//存储access_token,expires_in
		that.access_token = data.access_token
		that.expires_in = data.expires_in

		that.saveAccessToken(data)
		return Promise.resolve(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.reply = function(){
	var content = this.body
	var message = this.weixin
	var xml = util.tpl(content,message)
	this.status = 200
	this.type = 'application/xml'
	this.body = xml
}
module.exports = Wechat

0

0