发送消息前执行查询

Question

我正在用 NodeJS 制作一个 Messenger 机器人。我希望用户能够请求他们所有的火车。问题是我们想在 NodeJS 向用户发送消息之前执行查询。

我搜索了异步函数

function handlePostback(sender_psid, received_postback) {
let response;

// Get the payload for the postback
let payload = received_postback.payload;

// Set the response based on the postback payload
switch(payload){
    case "yes" : 
    let data = null
    axios.get('http://api.irail.be/connections/?from=Mechelen&to=Puurs&date=010219&time=1650&timesel=departure&format=json&lang=en&fast=false&typeOfTransport=trains&alerts=false&resul1=1')
    .then(function (response) {
    // handle success
    data = data.response;
 })
response = {
        "text": data.connections.arrival.name
    }
   break;
 }
  callSendAPI(sender_psid, response);
}
function callSendAPI(sender_psid, response) {
// Construct the message body
let request_body = {
    "recipient": {
        "id": sender_psid
    },
    "message": response
}
// Send the HTTP request to the Messenger Platform
request({
    "uri": "https://graph.facebook.com/v2.6/me/messages",
    "qs": { "access_token": PAGE_ACCESS_TOKEN },
    "method": "POST",
    "json": request_body
}, (err, res, body) => {
    if (!err) {
        console.log('message sent!')
    } else {
        console.error("Unable to send message:" + err);
    }
});
}

如您所见，在执行查询之前，脚本已将消息发送给 Messenger 上的用户。

Answer 1

将 callSendAPI() 放入您的 Axios 回调中

function handlePostback(sender_psid, received_postback) {

let response;

// Get the payload for the postback
let payload = received_postback.payload;

// Set the response based on the postback payload
switch (payload) {
    case "yes":
        let data = null
        axios.get('http://api.irail.be/connections/?from=Mechelen&to=Puurs&date=010219&time=1650&timesel=departure&format=json&lang=en&fast=false&typeOfTransport=trains&alerts=false&resul1=1')
            .then(function(response) {
                // handle success
                data = data.response;
            })
        response = {
            "text": data.connections.arrival.name
        }
            callSendAPI(sender_psid, response);

        break;
 }
}

Answer 2

您的代码中存在一些不必要的变量和问题（例如，data = data.response 可能应该是 data = response.data），这将是带有 async/await 和箭头函数的现代版本。在这种情况下您不需要回调函数，callSendAPI 将在 AJAX 请求之后被调用。我还删除了 switch，因为一个简单的 if 就足够了：

const handlePostback = async (sender_psid, received_postback) => {
    // Get the payload for the postback
    const payload = received_postback.payload;

    // Set the response based on the postback payload
    if (payload === 'yes') {
        try {
            const response = await axios.get('http://api.irail.be/connections/?from=Mechelen&to=Puurs&date=010219&time=1650&timesel=departure&format=json&lang=en&fast=false&typeOfTransport=trains&alerts=false&resul1=1');
            callSendAPI(sender_psid, {
                'text': response.data.connections.arrival.name
            });
        } catch (err) {
            console.log(err);
        }
    }
};

旁注：假设您也在使用 superagent，我不会使用 2 种不同的方式来执行 http 请求？因为 http.request 可能与 Node.js 一起使用，但 request 看起来像超级代理人 ;)

发送消息前执行查询

Execute query before sending message

mysql

webhooks

node.js

facebook-messenger