更新 CloudFunctions 上的子集合

Question

我需要帮助。

我的项目中有 2 个集合，一个称为 Products，另一个称为 Users。

我将选定的产品信息复制到用户的子集合中作为收藏夹，在这种情况下：

用户（收藏）> 用户（文档）> 收藏（收藏）> 产品（文档）

我的想法是创建一个云功能，它将监视“产品集合”产品（集合）>产品（文档）中任何产品的任何更新，然后将这些更改反映在用户>收藏夹子集合中在此处更新产品的值：

用户（收藏）> 用户（文档）> 收藏（收藏）> 产品（文档）

这怎么可能来自 index.js ？这是我的代码：

const functions = require('firebase-functions');
const admin = require('firebase-admin');
admin.initializeApp();

    exports.updateFavoritedProducts = functions.firestore.document('products/{productId}').onUpdate((change, context) => {

admin.firestore().collection('products').get(queryProductsSnapshot => {

    queryProductsSnapshot.forEach(productQuery => {
    const pricePQ = productQuery.price;

    console.log('tetesfsf');

    return admin.firestore().collection('users').get(queryUsersSnapshot => {
            queryUsersSnapshot.forEach(userSnapshot => {

                return admin.firestore().collection('users').doc(userSnapshot.id).collection('favorites').get(queryUserProductsSnapshot => {
                    queryUserProductsSnapshot.forEach(queryUserProductSnapshot => {
                        if (queryUserProductSnapshot.id === productQuery.id) {

                            return admin.firestore().doc(`users/${userSnapshot.id}/favorites/${queryUserProductSnapshot.id}`).update({ amountVolume: '123456'
                            })
                        } else {
                            console.log("No events found");
                            return null
                        }
                    })
                });
            })
            })
    });
})
});

Answer 1

我使用 user1889692 的答案更新了我项目中一个嵌套更深的子集合中的所有文档。

时间线（集合）>时间线（文档）>发布者ID（集合）>发布者IDID（文档）>帖子（集合）>帖子ID（文档）

这是我的工作代码：

 exports.onCreateTimelineTest = functions.firestore
   .document("/timelineTest/{buguId}")
   .onCreate(async (snapshot, context) => {

 const timeNow =new Date();
 const db = admin.firestore();
     return db.collection("timeline")
     .get()
     .then((timelineQuerySnapshot) => {
     timelineQuerySnapshot.forEach(async(timelineQuerySnapshot) => {


       console.log("all the documnets inside timeline are", timelineQuerySnapshot.id);

        await db.collection("timeline")
        .doc(timelineQuerySnapshot.id)
         .collection("publisherId")
         .get()
         .then((publisherSnapshot)=>{
         publisherSnapshot.forEach(async(publisherSnapshot)=>{


           console.log("all the documnets inside timeline are", publisherSnapshot.id);

         await db.collection("timeline")
          .doc(timelineQuerySnapshot.id)
          .collection("publisherId")
          .doc(publisherSnapshot.id)
          .collection("posts")
          .where('uploadTime', '<=', timeNow)
          .get()
          .then((postSnap)=>{
         postSnap.forEach(async(postSnap)=>{


         console.log("all the documnets inside timeline are", postSnap.id);

         return db.collection("timeline")
         .doc(timelineQuerySnapshot.id)
         .collection("publisherId")
         .doc(publisherSnapshot.id)
         .collection("posts")
         .doc(postSnap.id)
         .set({
         'name': 'madhav'
                          }).catch((err)=>{
                          console.log('Error getting documents', err);
                          return Promise.reject(err);
                          });
                       });
         return null
         }).catch((err) => {
                    console.log('Error getting documents', err);
                    return Promise.reject(err);
                   });
         });
         return null
         }).catch((err) => {
          console.log('Error getting documents', err);
          return Promise.reject(err);
         });
     });
     return null
     }).catch((err) => {
      console.log('Error getting documents', err);
      return Promise.reject(err);
     });

  });

Answer 2

我终于想出了如何使用嵌套承诺来做到这一点。这是解决方案：

exports.updateFavoritedProducts = functions.firestore.document('products/{productId}').onUpdate((change, context) => {
    const data = change.after.data();
    const productID = data.id;

 return db.collection('products').where('id', '==', productID).get().then((productsQuerySnap) => {

    productsQuerySnap.forEach((productQuerySnap) => {
        const newPrice = productQuerySnap.data().price;
        const newPriceUnit = productQuerySnap.data().priceUnit;

        db.collection('users').get().then((usersQuerySnap) => {
            usersQuerySnap.forEach((userQuerySnap) => {

                return db.collection('users').doc(userQuerySnap.id).collection('favorites').doc(productQuerySnap.id).update({ 
                    price: newPrice,
                    priceUnit : newPriceUnit

                 }).catch((err) => {
                    console.log('Error getting documents', err);
                    return Promise.reject(err);
                    });
                });
                return null
            })
            .catch((err) => {
                console.log('Error getting documents', err);
                return Promise.reject(err);
            });
        return null
    });
    return null
})
    .catch((err) => {
        console.log('Error getting documents', err);
        return Promise.reject(err);
    });
});

Answer 3

如果您想创建一个触发所有用户的所有产品更新的云函数，请将其声明为：

functions.firestore.document('users/{userId}/products/{productId}').onUpdate((change, context) => {

如果你想在函数体内访问userId 或productId，你可以得到它们：

context.params.userId
context.params.productId