Sequelize Query в Nest.JS не разрешается до возврата - PullRequest
Новая
       35

Sequelize Query в Nest.JS не разрешается до возврата

0 голосов
/ 18 апреля 2019

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

Код выглядит следующим образом: 

public async getOrderById(orderId:string) {
    const order: [any] = await this.dbInstance.query('exec getOrder :orderID' {replacements: {orderID: orderId}, type: sequelize.QueryTypes.SELECT});
    const orderLines: [any] = await this.dbInstance.query('exec getOrderLines :orderID' {replacements: {orderID: orderId}, type: sequelize.QueryTypes.SELECT});

    const orderArray: any = order.map((o) => { 
         return {
            orderId,
            customerId: o.CustomerID
            total: o.total,
            lines: []
          };
    });

    const orderResponse: Order = orderArray[0];

    orderLines.forEach(async (orderLine) => { 
         let addItem: any;
         addItem = {
                itemNumber: orderLine.itemNumber,
                quantity: orderLine.quantity,
                unitPrice: orderLine.unitPrice,
                orderLineDetails: []
         };

        await this.dbInstance.query('exec getLineDetails :orderLineId{replacements: {orderLineId: orderLine.orderLineId}, type: sequelize.QueryTypes.SELECT})
         .then( (details) => { 
             details.forEach((detail) => {
                addItem.orderLineDetails.push({
                    name: detail.name,
                    value: detail.val
                });
             });
         });

        orderResponse.orderLines.push(addItem);
    });

    return orderResponse;

}

Таким образом, код попадет вforEach в строках заказа создает элемент добавления, но затем он нажимает addItem, прежде чем ждать, когда будет создан результат orderLineDetails и добавлен в массив orderLineDetails.Если я позволю всему этому работать, точка останова с push для orderLineDetails будет работать через секунду после того, как ответ уже будет возвращен.

Чего мне не хватает?

1 Ответ

1 голос
/ 18 апреля 2019

Таким образом, проблема заключалась в методе, который я использовал для выполнения отображений (forEach), которые не были асинхронными, наряду с изменением базовой коллекции в цикле.

В итоге я сделал это изменение: 

const orderLinePromises = orderLines.map(async (orderLine) => { 
    let addItem : any;

     addItem = {
            itemNumber: orderLine.itemNumber,
            quantity: orderLine.quantity,
            unitPrice: orderLine.unitPrice,
            orderLineDetails: []
     };

     const details = await this.dbInstance.query('exec getLineDetails :orderLineId{replacements: {orderLineId: orderLine.orderLineId}, type: sequelize.QueryTypes.SELECT});
      addItem.orderLineDetails = details.map((detail) => {
            return {
               name: detail.name,
               value: detail.val,
            };
      );

     return addItem;

});

orderResponse.orderLines = await Promise.all(orderLinePromises);

return orderResponse;
...