Cloud Function中使用forEach遍历查询结果时sendToDevice方法无法正常发送消息问题排查

我帮你梳理下修改后函数里的几个核心问题，这些应该就是导致消息发送失败的原因，同时附上修复后的完整代码：

核心问题点 #

1. 参数顺序完全搞反了：HTTP触发器的参数是(request, response)，你写成了(res, response)，导致res.body根本拿不到请求里的实际数据——这会让后续的订单信息、查询用的token全部失效，是最根源的问题。
2. 未定义的关键变量：usersRef和token都没有初始化，usersRef需要先关联到Firestore的users集合，token得从请求体里取（比如前端传的查询标识）。
3. 过早发送响应：你在异步获取token的过程中就调用了response.send()，云函数一旦发送响应就会立即终止执行，后面的sendToDevice逻辑大概率没机会跑完，而且多个用户的情况下多次调用response.send会直接报错（一个HTTP请求只能响应一次）。
4. 异步操作没处理好：query.forEach里的tokens.get()是异步操作，但你没用async/await等待它完成，函数会直接跳过这部分逻辑结束。
5. 小语法错误：response.send([results, , payload])里多了个逗号，会导致语法报错。

修复后的完整代码 #

const admin = require('firebase-admin');
admin.initializeApp(); // 确保Admin SDK已初始化，没加的话一定要补上

exports.sendMessage = functions.https.onRequest(async (request, response) => { 
  try {
    // 1. 修正参数顺序，从request里拿请求体
    const body = request.body; 
    const orderTotal = body.total; 
    const orderId = String(body.id); 
    // 2. 从请求体获取查询用的token，初始化users集合引用
    const targetToken = body.token;
    const usersRef = admin.firestore().collection('users');

    // 3. 执行用户查询
    const querySnapshot = await usersRef.where('token', '==', targetToken).get(); 
    if (querySnapshot.empty) { 
      console.log('No matching users found.'); 
      return response.status(404).send({ error: '没有找到匹配的用户' }); 
    } 

    // 4. 收集所有有效的FCM Token
    const allFcmTokens = [];
    // 用for...of替代forEach，支持异步等待
    for (const userDoc of querySnapshot.docs) { 
      const tokensSnapshot = await usersRef.doc(userDoc.id).collection('tokens').get();
      tokensSnapshot.forEach(tokenDoc => {
        const fcmToken = tokenDoc.data().fcmToken;
        // 过滤空的无效token，避免FCM报错
        if (fcmToken) {
          allFcmTokens.push(fcmToken);
        }
      });
    }

    if (allFcmTokens.length === 0) {
      console.log('没有可用的FCM Token');
      return response.status(400).send({ error: '没有可发送消息的Token' });
    }

    // 5. 构建消息Payload（修正细节：mutable_content用布尔值，data字段转字符串）
    const payload = { 
      notification: { 
        title_loc_key: 'notify_title', 
        subtitle_loc_key: 'notify_subtitle', 
        body_loc_key: 'notify_body', 
        badge: '1', 
        sound: 'cha-ching.caf', 
        mutable_content: true // FCM要求这里是布尔值，不是字符串
      }, 
      data: { 
        'total': String(orderTotal), // FCM的data字段必须是字符串
        'orderId': orderId 
      } 
    }; 

    // 6. 等待消息发送完成后再响应
    const messagingResponse = await admin.messaging().sendToDevice(allFcmTokens, payload);
    console.log('消息发送成功:', messagingResponse);
    return response.status(200).send({ 
      success: true, 
      发送数量: allFcmTokens.length, 
      响应详情: messagingResponse 
    });

  } catch (error) {
    console.error('发送消息出错:', error);
    return response.status(500).send({ error: error.message });
  }
});

额外检查建议 #

• 确认用户文档里的token字段和你查询用的targetToken值完全匹配，避免查询条件写错。
• 检查tokens子集合里的字段名是不是fcmToken，别拼写错了。
• 去Firebase控制台的函数日志里看具体错误信息，如果是FCM返回的错误，通常会提示是token无效、权限不足还是其他问题，方便进一步排查。

内容的提问来源于stack exchange，提问作者GIJoeCodes