5回答

Scott

2016-06-22

把 response.body 换成 response[1] 试试，看看是不是这里的版本导致的问题。

我用你的代码模拟，

Unhandled rejection Error: Get menu fails
    at /Users/black/scott/wechat-movie-for-test/wechat/wechat.js:861:7

代码是在这里出了错误：

var url = api.menu.del + 'access_token=' + data.access_token
request({url: url, json: true}).then(function(response){

我把 response.body 换成 response[1] 后就 ok 了，再检查下 app.js 里面引入的 reply 中间件是不是这一份文件。

0

1

杰克大叔

对了，这个问题搞定了，现在 'type'无法读取，和慕粉3278383遇到的情况一样

2016-06-22

共1条回复

Scott

2016-06-21

把 wechat.js 这个构造函数的代码全部贴出来看一下，看是不是哪里少了 return

0

1

杰克大叔

更新了，在底下，提问内容太长了不能保存，老师帮忙看一下

2016-06-21

共1条回复

小七努力变大牛

2016-08-27

我也是这边出问题了.... 找了好久 也木有看到... 麻烦能告诉一下   到底是哪里出问题了么?

0

0

杰克大叔

提问者

2016-06-21

'user strict'

var Promise = require('bluebird')
var _ = require('lodash')
var request = Promise.promisify(require('request'))
var util = require('./util')
var fs = require('fs')
var prefix = 'https://api.weixin.qq.com/cgi-bin/'
var api = {
accessToken: prefix + 'token?grant_type=client_credential',
temporary: {
upload: prefix + 'media/upload?',
fetch: prefix + 'media/get?'
},
permanent: {
upload: prefix + 'material/add_material?',
fetch : prefix + 'material/get_material?',
uploadNews: prefix + 'material/add_news?',
uploadNewsPic: prefix + 'media/uploadimg?',
del: prefix + 'material/del_material?',
update: prefix + 'material/update_news?',
count: prefix + 'material/get_materialcount?',
batch: prefix + 'material/batchget_material?'
},
group: {
create: prefix + 'groups/create?',
fetch: prefix + 'groups/get?',
check: prefix + 'groups/getid?',
update: prefix + 'groups/update?',
move: prefix + 'groups/members/update?',
batchupdate: prefix + 'groups/members/batchupdate?',//移动分组
del: prefix + 'groups/delete?'
},
user: {
remark: prefix + 'user/info/updateremark?',
fetch: prefix + 'user/info?',
batchFetch: prefix + 'user/info/batchget?',
list: prefix + 'user/get?'
},
mass: {
group: prefix + 'message/mass/sendall?',
openId: prefix + 'message/mass/send?',
del : prefix + 'message/mass/delete?',
preview: prefix + 'message/mass/preview?',
check: prefix + 'message/mass/get?'
},
menu: {
create: prefix + 'menu/create?',
get: prefix + 'menu/get?',
del: prefix + 'menu/delete?',
current: prefix + 'get_current_selfmenu_info?'
}
}

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.fetchAccessToken = function(data){
var that = this

if (this.access_token && this.expires_in) {
if (this.isValidAccessToken(this)) {
return Promise.resolve(this)
}
}

return this.getAccessToken()
.then(function(data){
try{
data = JSON.parse(data)
}
catch(e){
return that.updateAccessToken(data)
}

if (that.isValidAccessToken(data)) {
return Promise.resolve(data)
}
else{
return that.updateAccessToken()
}
})
.then(function(data){
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.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.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, material, permanent){
var that = this
var form = {}
var uploadUrl = api.temporary.upload
if (permanent) {
uploadUrl = api.permanent.upload

_.extend(form, permanent)
}

if (type === 'pic') {
uploadUrl = api.permanent.uploadNewsPic
}

if (type === 'news') {
uploadUrl = api.permanent.uploadNews
form = material
}
else{
form.media = fs.createReadStream(material)
}

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = uploadUrl + 'access_token=' + data.access_token
if (!permanent) {
url += '&type=' + type
}
else {
form.access_token = data.access_token
}
var options = {
method : 'POST',
url: url,
json: true
}

if (type === 'news') {
options.body = form
}
else{
options.formData = form
}
request(options).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Upload material fails')
}
})
.catch(function(err){
reject(err)
})
})


})
}

Wechat.prototype.fetchMaterial = function(mediaId, type, permanent){
var that = this
var fetchUrl = api.temporary.fetch

if (permanent) {
fetchUrl = api.permanent.fetch
}

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = fetchUrl + 'access_token=' + data.access_token + '&media_id=' + mediaId
var form = {}
var options = {method: 'POST', url: url, json: true}


if (permanent) {
form.media_id = mediaId
form.access_token = data.access_token
options.body = form
}
else{
if (type === 'video') {
url = url.replace('https','http')
}
url += '&media_id' + mediaId
}

if (type === 'news' || type === 'video') {
request(options).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('fetch material fails')
}
})
.catch(function(err){
reject(err)
})
}
else{
resolve(url)
}
})
})
}

Wechat.prototype.deleteMaterial = function(mediaId){
var that = this
var form = {
media_id: mediaId
}

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.permanent.del + 'access_token=' + data.access_token + '&media_id=' + mediaId
request({method: 'POST', url: url,body: form, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Delete material fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.updateMaterial = function(mediaId, news){
var that = this
var form = {
media_id: mediaId
}

_.extend(form, news)

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.permanent.update + 'access_token=' + data.access_token + '&media_id=' + mediaId
request({method: 'POST', url: url,body: form, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Update material fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.countMaterial = function(){
var that = this

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.permanent.count + 'access_token=' + data.access_token
request({method: 'GET', url: url,json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Count material fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.batchMaterial = function(options){
var that = this

options.type = options.type || 'image'
options.offset = options.offset || 0
options.count = options.count || 1

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.permanent.batch + 'access_token=' + data.access_token
request({method: 'POST', url: url, body: options, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Batch material fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.createGroup = function(name){
var that = this

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.group.create + 'access_token=' + data.access_token
var form = {
group: {
name: name
}
}
request({method: 'POST', url: url, body: form, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('CreateGroup material fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.fetchGroups = function(name){
var that = this

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.group.fetch + 'access_token=' + data.access_token

request({url: url, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('fetchGroup material fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.checkGroup = function(openId){
var that = this

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.group.check + 'access_token=' + data.access_token
var form = {
openid: openId
}
console.log(form)
request({method: 'POST', url: url, body: form, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('checkGroup material fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.updateGroup = function(id, name){
var that = this

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.group.update + 'access_token=' + data.access_token
var form = {
group: {
id: id,
name: name
}
}
console.log(url)
console.log(form)
request({method: 'POST', url: url, body: form, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('updateGroup material fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.moveGroup = function(openIds, to){
var that = this

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url
var form ={
to_groupid: to
}

if (_.isArray(openIds)) {
url = api.group.batchupdate + 'access_token=' + data.access_token
form.openid_list = openIds
}
else{
url = api.group.move + 'access_token=' + data.access_token
form.openid = openIds
}
request({method: 'POST', url: url, body: form, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Move Group material fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.deleteGroup = function(id){
var that = this


return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
url = api.group.del + 'access_token=' + data.access_token
var form ={
group: {
id: id
}
}
request({method: 'POST', url: url, body: form, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Delete group material fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.remarkUser = function(openId, remark){
var that = this

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
url = api.user.remark + 'access_token=' + data.access_token
var form ={
openid: openId,
remark: remark
}
request({method: 'POST', url: url, body: form, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Remark group material fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.fetchUsers = function(openIds, lang){
var that = this
var lang =  lang || 'zh_CN'

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var options = {
json: true

}
if (_.isArray(openIds)) {
options.url = api.user.batchFetch + 'access_token=' + data.access_token
options.body ={
user_list: openIds
}
options.method = 'POST'
}
else{
options.url = api.user.fetch + 'access_token=' + data.access_token + '&openid=' + openIds + '&lang=' + lang
}


request(options).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('batchFetchUsers material fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.listUsers = function(openId){
var that = this
var lang =  lang || 'zh_CN'

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.user.list + 'access_token=' + data.access_token
if (openId) {
url +=  '&next_openid=' + openId
}
request({url: url, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('ListUsers fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.sendByGroup = function(type, message, groupId){
var that = this
var msg = {
filter: {},
msgtype: type
}

msg[type] = message

if (!groupId) {
msg.filter.is_to_all = true
}
else{
msg.filter.is_to_all = false,
msg.filter = {
is_to_all : false,
group_id : groupId
}
}

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.mass.group + 'access_token=' + data.access_token

request({method: 'POST', url: url, body: msg, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Send to group fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.sendByOpenId = function(type, message, openIds){
var that = this
var msg = {
msgtype: type,
touser: openIds
}

msg[type] = message

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.mass.openId + 'access_token=' + data.access_token

request({method: 'POST', url: url, body: msg, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Send ID to group fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.deleteMass = function(msgId){

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.mass.del + 'access_token=' + data.access_token

var form = {
msg_id: msgId
}

request({method: 'POST', url: url, body: form, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Delete ID to group fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.previewMass = function(type, message, openId){
var that = this

var msg = {
msgtype: type,
touser: openId
}

msg[type] = message

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.mass.preview + 'access_token=' + data.access_token

request({method: 'POST', url: url, body: msg, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Delete ID to group fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.checkMass = function(msgId){
var that = this

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.mass.check + 'access_token=' + data.access_token
var form = {
msg_id: msgId
}

request({method: 'POST', url: url, body: form, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('checkMass ID to group fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.createMenu = function(menu){
var that = this
console.log(menu)
return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.menu.create + 'access_token=' + data.access_token

request({method: 'POST', url: url, body: menu, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Create menu fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.getMenu = function(){
var that = this

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.menu.get + 'access_token=' + data.access_token

request({url: url, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Get menu fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.deleteMenu = function(){
var that = this

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.menu.del + 'access_token=' + data.access_token

request({url: url, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Get menu fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

Wechat.prototype.getCurrentMenu = function(){
var that = this

return new Promise(function(resolve, reject){
that
.fetchAccessToken()
.then(function(data){
var url = api.menu.current + 'access_token=' + data.access_token

request({url: url, json: true}).then(function(response){
var _data = response.body
if (_data) {
resolve(_data)
}
else{
throw new Error('Get current menu fails')
}
})
.catch(function(err){
reject(err)
})
})
})
}

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

yql

2016-06-20

仔细看视频，有个地方写漏掉了，我也遇到过，看能不能找到哪里漏了

0

3

小小小小小菜鸟

哪里漏掉了

2016-08-07

共3条回复