我在最外面弄了一个对象，用于最终的输出。 var data = {};
然后逻辑是这样的：
- mysql查询一条数据，return一个实体；
- 根据查到的实体，mysql查询一堆数据，return这堆数据；
- 根据查询到这堆数据，每条数据再去mysql查询一堆数据，return这堆数据；
然后我写成这样就写不下去了： var data = {}; test.queryEntityAsync(id) //查询实体 .then(function(entity){ data.entity = entity; return test.queryItems(entity.prop1);//根据实体查询一堆数据 }) .then(function(items){ data.entity.items = items; …然后需要把这堆数据里的每条都进行mysql查询，最后再输出这个json，这里用Promise要怎么写呢？ })
@429365799 谢谢，我最后这样写的： var data = {}; test.queryEntityAsync(id) //查询实体 .then(function(entity){ data.entity = entity; return test.queryItems(entity.prop1);//根据实体查询一堆数据 }) .then(function(items){ data.entity.items = items; var asyncFuncs = []; data.entity.items.forEach(function(item){ asyncFuncs.push(test.mysqlQueryAsync(item.id)); }) Promise.all(asyncFuncs).then(function(){ //…result process… return data; }) })
非常感谢，确实实现了我的业务逻辑。只不过美中不足的是多了一层hell。不知道是不是有更好的解决方案。
var data = {}; test.queryEntityAsync(id) //查询实体 .then(function(entity){ data.entity = entity; return test.queryItems(entity.prop1);//根据实体查询一堆数据 }) .then(function(items){ data.entity.items = items; var asyncFuncs = []; data.entity.items.forEach(function(item){ asyncFuncs.push(test.mysqlQueryAsync(item.id)); }) return Promise.all(asyncFuncs); }) .then(result => { // … }) .catch(err => { // 错误处理 })
自己简单封装个就行了。
static wrapCallback(...args){
let root = args.shift()
let func_path = args.shift()
let func = _.get(root,func_path)
let err = ""
if(typeof func != "function"){
err = new Error(func_path + " is not function")
}
let log = (this.req && this.req.log) || (this.log && this.log.bind(this)) || console.log
log("wrapFunc",root.name + "." + func_path, err && err.toString())
if(err){
throw err
}
return new Promise((resolve,reject) => {
let next = (err,data) => {
if(err){
reject(err)
return
}
resolve(data)
}
func.apply(this,args.concat(next))
})
}
调用：
await wrapCallback(Fs,"exists",src).catch((e) => exists = e)
