Реализовать asyn c await в api respone - PullRequest
Новая
       5

Реализовать asyn c await в api respone

0 голосов
/ 05 марта 2020

Я использую Node JS для разработки API. Ниже приведен код API. 

exports.getAllUser = async (req, res) => {
   let acoList = [], i=0;
   let condaions = {
       deleted: 0,
   };
   let attributes = ['id', 'name', 'email', 'type', 'phone', 'gender', 'main_sys_id', 'avatar', 'in_service', 'created_by']
   await Methods.getAllData(User, condaions, attributes).then((userList) => {
        if (userList) {
            // Methods.successResponse(req, res, userList);
            console.log(userList.length, 'length of user')
            userList.map(user => {
                i = i+1;

                if ( user.dataValues.type == 'aco' ) {
                    let condations = {
                        aquisition_member_id: user.dataValues.id,
                        deleted: 0
                    }

                    Methods.getDetailsFromTwoAssociateTable(condations, Task, DetailTask).then(task => {
                        acoList.push(
                            {
                                user:user,
                                task: task
                            }
                        )
                    })
                }
                // if( i == userList.length-1 ){
                //     Methods.successResponse(req, res, acoList);
                // }
            })
        }
    }).catch((error) => {
        ErrorResMethods.errorResponse(req, res, error);
    })

   setTimeout(() => {
     Methods.successResponse(req, res, acoList)
   }, 5000);
}

Здесь я попытался реализовать Asyn c для сбора данных, и после сбора данных он даст ответ.

, но используя Asyn c это невозможно. Вот почему я реализовал с помощью setTimeOut ().

Очевидно, что это не очень хорошая практика, но как я могу отправить ответ после выполнения первой задачи.

Ответы [ 2 ]

1 голос
/ 05 марта 2020

Есть много проблем с кодом, который вы опубликовали, вы должны стремиться к чему-то вроде этого. 

exports.getAllUser = (req, res) => {
  let condations = {
    deleted: 0,
  }
  const attributes = ['id', 'name', 'email', 'type', 'phone', 'gender', 'main_sys_id', 'avatar', 'in_service', 'created_by']

  // you should return something if you are planning on using the function elsewhere
  // like const users = await getAllUsers()
  return Methods.getAllData(User, condations, attributes).then(async (userList) => {
    if (userList) {
      console.log(userList.length, 'length of user')
      const acoList = await userList.reduce(async (acc, user) => {
        if (user.dataValues.type === 'aco') {
          condations = {
            aquisition_member_id: user.dataValues.id,
            deleted: 0,
          }

          const task = await Methods.getDetailsFromTwoAssociateTable(condations, Task, DetailTask)
          acc.push({
            user: user,
            task: task,
          })
        }
        return acc
      }, [])
      Methods.successResponse(req, res, acoList)
      return acoList
    }
    return userList
  }).catch(error => {
    ErrorResMethods.errorResponse(req, res, error)
    return []
  })
}
1 голос
/ 05 марта 2020

Вы можете использовать код следующим образом: 

// ... initialization of variables as per required
await Methods.getAllData(User, condaions, attributes).then((userList) => {

  if (userList) {
        console.log(userList.length, 'length of user')
        return Promise.each(userList, (list, key, length) => {    
            // prepare acoList here and return acoList
        }).then((acoList) => {
            return acoList
        })                
    } else {
        // handle else condition and return empty acoList
    }
}).then((acoList) => {
  Methods.successResponse(req, res, acoList)
}).catch((error) => {
  ErrorResMethods.errorResponse(req, res, error);
})
...