0

一直在尝试一切以使其特别适用于 async each 方法。for (resultsHistory 的 const 元素) 也不起作用。

我正在尝试通过在其上运行 foreach 并执行 mysql 查询来修改先前查询的结果数组。

但是，这需要等待查询完成。

有没有办法在没有我手动放置的 setTimeout(function() { } 以等待查询完成的情况下访问这些结果？

        function getUserLikes(params, callback) {
            var usersArrayCat = [];
            console.log(`length of array ${params.length}`)
                                // 1 here means 1 request at a time
            async.eachLimit(params, 1, function (element, cb) {
                element.liked = 0;
                var queryLiked = `SELECT * from users_likes WHERE user_id = \"${req.body.userid}\" AND product_id = \"${element.product_id}\"`;
                connectionPromise.query(queryLiked, function (err, result) {
                    if (!result) {
                    } else if (result.length == 0) {

                    } else {
                        element.liked = result[0].userlike;

                        usersArrayCat.push(element);
                      //  console.log(usersArrayCat);
                        cb();
                    }
                })
            }, function (err) {
                if (err) return callback(err);
                callback(null, usersArrayCat)
            });
        };

    getUserLikes(resultsHistory, function (e) {
    console.log(e);
       });     



        if(!res.headersSent) {

            setTimeout(function() {  

            res.send(JSON.stringify({"status": 200 ,"error": null, "top3":resultsHistory}));
            }, 150);


        }
4

2 回答 2

0

看我的回答：

function getUserLikes(params, callback) {
    var usersArrayCat = [];
    console.log(`length of array ${params.length}`)
    // 1 here means 1 request at a time
    async.eachLimit(params, 1, function (element, cb) {
        element.liked = 0;
        var queryLiked = `SELECT * from users_likes WHERE user_id = \"${req.body.userid}\" AND product_id = \"${element.product_id}\"`;
        connectionPromise.query(queryLiked, function (err, result) {
            if (!result) {
            } else if (result.length == 0) {

            } else {
                element.liked = result[0].userlike;

                usersArrayCat.push(element);
                //  console.log(usersArrayCat);

            }
            cb();
        })
    }, function (err) {
        if (err) return callback(err);
        callback(null, usersArrayCat)
    });
};

getUserLikes(resultsHistory, function (e, usersArrayCat) {
    if (e) {
        console.log(e);
        return res.send({status: 400, error: e}); // your error response
    }
    console.log(usersArrayCat); // your usersArrayCat with liked property
    res.send(JSON.stringify({ // why your need return a string intead of json object ???
        "status": 200,
        "error": null,
        "top3": usersArrayCat // I think return `usersArrayCat` is a right way
    }));
});
于 2018-11-05T07:46:40.603 回答
0

设法让它像这样工作，但仍然不确定这是否是正确的方法。

async function getUserLikes(resultsHistory) {
    for (const element of resultsHistory) {
        element.liked = 0;
        let queryLiked = `SELECT * from users_likes WHERE user_id = \"${req.body.userid}\" AND product_id = \"${element.product_id}\"`;
        let liked = await conn2.query(queryLiked);

        if (liked[0]) {
            element.liked = liked[0].userlike;
        }        
    }
    if(!res.headersSent) {
        conn2.release();     
        let newres = resultsHistory.sort(
            firstBy(function (v1, v2) { return v2.rating - v1.rating; })
             .thenBy(function (v1, v2) { return v2.dranktimes - v1.dranktimes; })
        ).filter( function(history) {             
            return history.event === eventName;
        }).slice(0, 3);

       res.send({"status": 200 ,"error": null, "top3":newres});       
    }
}

getUserLikes(resultsHistory);
于 2018-11-05T09:01:39.927 回答