函数在所有异步工作完成之前结束

Question

所以我有一个函数可以检查订单是否是 24 小时前，如果是这种情况，我会向用户发送通知，但它似乎并没有完成所有用户的执行，而只是返回某人而其他一些则不是，我认为我在返回承诺时遇到了问题，我不是 javascript 方面的专家，我并不真正了解发生了什么，有时如果一个文档有一个 deviceToken，而不是尝试使用它刚刚完成的所有文档为空，不继续其他用户文档

exports.rememberToFinishOrder = functions.pubsub.schedule('every 3 minutes').onRun(async (context) => {
    var db = admin.firestore();
    const tsToMillis = admin.firestore.Timestamp.now().toMillis()
    const compareDate = new Date(tsToMillis - (24 * 60 * 60 * 1000)) //24 horas
    let snap = await db.collection('orders').where("timestamp","<",new Date(compareDate)).where("status", "in" ,[1,2,4,5,6]).get()
    if(snap.size > 0){
         snap.forEach(async(doc) => {
            const userId = doc.data().uid
            let userSnap = await db.collection('user').doc(userId).get()
                const deviceToken = userSnap.data().deviceToken
                const payload = {
                notification: {
                    title: "¿ Did you received your order ?",
                    body: "We need to know if you have received your order",
                    clickAction: "AppMainActivity"
                },
                data: {
                    ORDER_REMINDER: "ORDER_REMINDER"
                }
            }
            console.log("User: "+doc.data().uid)
            return admin.messaging().sendToDevice(deviceToken,payload) 
        }); 
    } 
});

有时当某些用户的 devicetoken 为空时，它将完成此功能的执行，而不是继续下一个用户，而且它也不会为我的订单集合中的所有用户完成此功能，它会做一些人和一些人不是，这应该是一个原子操作，它会改变该集合中的所有内容，而不仅仅是一些文档

发生了什么？

Answer 1

就像 andresmijares 所说，您是否没有正确处理承诺。 当您进行多个异步调用时，我建议使用 Promise.all() 函数，该函数将等待所有承诺完成后再继续。

exports.rememberToFinishOrder = functions.pubsub.schedule('every 3 minutes').onRun(async (context) => {
    const db = admin.firestore();
    const messaging = admin.messaging();

    const tsToMillis = admin.firestore.Timestamp.now().toMillis()
    const compareDate = new Date(tsToMillis - (24 * 60 * 60 * 1000)) //24 horas
    
    const snap = await db.collection('orders').where("timestamp","<",new Date(compareDate)).where("status", "in" ,[1,2,4,5,6]).get()
    let allPromises = [];

    if(snap.size > 0){
        snap.forEach((doc) => {
            const userId = doc.data().uid;

            allPromises.push(db.collection('user').doc(userId).get().then(userSnapshot => {
                const userData = userSnapshot.data();
                const deviceToken = userData.deviceToken;
                if (userData && deviceToken) {
                    
                    const payload = {
                        notification: {
                            title: "¿ Did you received your order ?",
                            body: "We need to know if you have received your order",
                            clickAction: "AppMainActivity"
                        },
                        data: {
                            ORDER_REMINDER: "ORDER_REMINDER"
                        }
                    }
                    console.log("User: "+doc.data().uid)
                    return messaging.sendToDevice(deviceToken,payload) 
                } else {
                    return;
                }
            }));
        }); 
    }
    return Promise.all(allPromises);
});

编辑： 在发送通知之前，我添加了一个检查以查看 userData 上是否存在 deviceToken。