Firebase 的 Cloud Functions：不向所有用户发送通知

Question

我已经使用 Firebase 和 Flutter 应用创建了一个电子商务 Android 应用来更新 Firebase 节点。

我想在管理员更新汇率时向所有用户发送通知。

下面是我编写的代码，用于使用 Cloud Function 向所有已注册的令牌发送更新通知，但它只将通知发送到 Flutter 应用而不是两个应用。

我不知道我做错了什么。

这是我的函数代码：

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

exports.helloWorld=functions.database.ref('Rates').onUpdate(evt =>{
    const payload={
        notification:{
            title:"Today's Rate",
            body :"Click here to see today's gold rate",
            badge: '1',
            sound: 'default'
        }
    }
    return admin.database().ref('fcm-token').once('value').then(allToken =>{
        if(allToken.val()){
            console.log('token available');
            const token = Object.keys(allToken.val());
            console.log(admin.messaging().sendToDevice(token, payload));
            return admin.messaging().sendToDevice(token, payload);
        }else{
            console.log('No Token Available');
            throw new Error("Profile doesn't exist")
        }
    });
});

这是我的Realtime Database Structure 的图片。

Answer 1

不确定，但尝试替换

databaseReference.push().setValue(new Tokens(token));

与

databaseReference.child(token).setValue(new Tokens(token));

Answer 2

根据您数据库中的provided screenshot，您数据库中/fcm-token下面的数据有两种不同的格式。

当您手动添加数据时，您使用了以下格式：

{
  "fcm-token": {
    "someRegistrationToken": {
      "token": "someRegistrationToken"
    },
    "someOtherRegistrationToken": {
      "token": "someOtherRegistrationToken"
    }
    ...
  },
  ...
}

然而，从您的“自动注册”条目中，您使用以下方式添加了令牌：

{
  "fcm-token": {
    "somePushId": {
      "fcmToken": "someRegistrationToken"
    },
    "someOtherPushId": {
      "fcmToken": "someOtherRegistrationToken"
    },
    ...
  },
  ...
}

在您的 Cloud Functions 代码中，您使用 Object.keys(allToken.val()) 将存储在 /fcm-token 下的所有键收集到一个数组中，这将为您提供一个包含推送 ID 和 FCM 令牌混合的数组，这不是您想要的，这就是为什么某些设备缺少通知。

简而言之，选择一种格式或另一种格式。

临时解决办法

使用您现有的混合结构，您可以使用以下内容，这将忽略您用作键的内容并仅提取令牌：

return admin.database().ref('fcm-token').once('value').then(allTokensSnapshot => {
    if (allTokensSnapshot.exists()) {
        console.log('Tokens available');
        const tokenArray = [];
        allTokensSnapshot.forEach((tokenSnapshot) => {
            let token = tokenSnapshot.hasChild('fcmToken')
                ? tokenSnapshot.child('fcmToken').val()
                : tokenSnapshot.child('token').val();
            tokenArray.push(token);
        });

        return admin.messaging().sendToDevice(tokenArray, payload);
    } else {
        console.log('No tokens available');
        throw new Error('No tokens available');
    }
});

数据库扁平化

就我个人而言，我会将其展平，以便您可以按原样使用您的代码，但这需要更改您将令牌添加到数据库的方式：

数据库结构：

{
  "fcm-token": {
    "someRegistrationToken": true,
    "someOtherRegistrationToken": true,
    ...
  }
}

（如果需要，您也可以使用设备所有者的用户 ID 代替 true）

客户端代码：

FirebaseInstanceId.getInstance().getInstanceId()
  .addOnSuccessListener(new OnSuccessListener<InstanceIdResult>() {
    @Override
    public void onSuccess(InstanceIdResult result) {
      DatabaseReference allTokensRef = FirebaseDatabase.getInstance().getReference().child("fcm-token");

      String token = result.getToken();
      Log.e("Test", "FCM Registration Token: " + token);

      SharedPreferences preferences = this.getSharedPreferences("com.jk.jkjwellers", MODE_PRIVATE);
      if(!(preferences.getBoolean("FCMAdded", false))){
        allTokensRef.child(token).setValue(true);
        preferences.edit().putBoolean("FCMAdded",true).apply();
      }
    }
  })
  .addOnFailureListener(new OnFailureListener() {
    @Override
    public void onFailure(@NonNull Exception e) {
      Log.e("Test", "Failed to get FCM registration token", e);
    }
  });