Проблема с запросом в цикле foreach в узле js - PullRequest
Новая
       10

Проблема с запросом в цикле foreach в узле js

0 голосов
/ 15 октября 2019

Я получаю результаты из запроса и хочу передать значение из результата в следующем запросе. Вот мой кодНо это не работает, я тоже попробовал функцию setTimeOut. 

dbcon.query('SELECT ci_offers.*, ci_advertisers.id as merchant_id, ci_advertisers.full_name, ci_advertisers.phone, ci_advertisers.companylogo FROM ci_offers, ci_advertisers WHERE ci_offers.advertiser_id = ci_advertisers.id AND ci_offers.is_active=1', function(error, results, fields) {

      if (error) throw error;

      if (results.length > 0) {
            var objectOffer;
            var objCoin;
            // async.forEachOf(results, function (dataElement, i, inner_callback){

            results.forEach((val) => {

                objectOffer = jsonParser(val);

                var token_id = objectOffer.token_id;

                var redeem_coin_grabbed = 0;

                if (token_id > 0) {

                  dbcon.query('SELECT count(id) as coingrabbed FROM ci_grabcoin_details_for_game WHERE user_id = ? AND coin_id= 33', [user_id, token_id], function(error1, results1, fields1) {

                    if (error1) throw error1;

                    });


                }
                val["coingrabbed"] = redeem_coin_grabbed;

                final.push(val);
            });
        }

        res.send(final);
    });

1 Ответ

0 голосов
/ 15 октября 2019

Пожалуйста, проверьте, работает ли это, используя эту идею https://stackoverflow.com/a/7053992/9216722

let final = [];

dbcon.query('SELECT ci_offers.*, ci_advertisers.id as merchant_id, ci_advertisers.full_name, ci_advertisers.phone, ci_advertisers.companylogo FROM ci_offers, ci_advertisers WHERE ci_offers.advertiser_id = ci_advertisers.id AND ci_offers.is_active=1', function(error, results, fields) {

  if (error) throw error;

  if (results.length > 0) {
        var objectOffer;
        var objCoin;
        // async.forEachOf(results, function (dataElement, i, inner_callback){

        let done = false;
        let count = 0;
        const markDone = (err) => {
            count++;
            if ( !done && results.length === count) {
                done = true;
                res.send(final);
            }
        };


        results.forEach((val) => {

            objectOffer = jsonParser(val);

            var token_id = objectOffer.token_id;

            var redeem_coin_grabbed = 0;

            if (token_id > 0) {

              dbcon.query('SELECT count(id) as coingrabbed FROM ci_grabcoin_details_for_game WHERE user_id = ? AND coin_id= 33', [user_id, token_id], function(error1, results1, fields1) {

                if (error1) throw error1;

                });


            }
            val["coingrabbed"] = redeem_coin_grabbed;

            final.push(val);

            markDone();

        });
    }

});
...