Несколько функций Firebase не работают

Question

Я пытался использовать несколько облачных функций для запуска при создании определенных событий.Они оба пишут в разные позиции базы данных Firebase.Но как мне указать, какие облачные функции будут запущены, а затем извлечь определенные данные, которые будут записаны в базу данных?

Ниже мой код.

Мой JS

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

admin.initializeApp();

exports.sendNotification = functions.database.ref('/Lecture_Materials/{MIS}/{Systems_Devt}/{Systems_DevtId}/name')
.onWrite(( change,context) =>{

// Grab the current value of what was written to the Realtime Database.
var eventSnapshot = change.after.val();
var str1 = "Lecture material uploaded: " + eventSnapshot;
console.log(eventSnapshot);

var topic = "Management.Information.System";
var payload = {
    data: {
        name: str1,
    }
};

// Send a message to devices subscribed to the provided topic.
return admin.messaging().sendToTopic(topic, payload)
    .then(function (response) {
        // See the MessagingTopicResponse reference documentation for the
        // contents of response.
        console.log("Successfully sent message:", response);
        return;
    })
    .catch(function (error) {
        console.log("Error sending message:", error);
    });
});

exports.sendNotification1 = functions.database.ref('/Lecture_Materials/{MIS}/{Enterprise_Sys}/{Enterprise_SysId}/name')
.onWrite(( change,context) =>{

// Grab the current value of what was written to the Realtime Database.
var eventSnapshot = change.after.val();
var str1 = "Lecture material uploaded: " + eventSnapshot;
console.log(eventSnapshot);

var topic = "Management.Information.System";
var payload = {
    data: {
        name1: str1,
    }
};

// Send a message to devices subscribed to the provided topic.
return admin.messaging().sendToTopic(topic, payload)
    .then(function (response) {
        // See the MessagingTopicResponse reference documentation for the
        // contents of response.
        console.log("Successfully sent message:", response);
        return;
    })
    .catch(function (error) {
        console.log("Error sending message:", error);
    });
});

Мой onMessage Получено

public class MyFirebaseMessagingService extends FirebaseMessagingService {
@Override
public void onMessageReceived(RemoteMessage remoteMessage) {

    // Check if message contains a data payload.
    if (remoteMessage.getData().size() > 0) {
        showNotification(remoteMessage.getData().get("name"));
        showNotification1(remoteMessage.getData().get("name1"));
    }

    // Check if message contains a notification payload.
    if (remoteMessage.getNotification() != null) {

    }
}

private void showNotification1(String name1) {
    Intent intent = new Intent(this, MainActivity.class);
    intent.addFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP);
    PendingIntent pendingIntent = PendingIntent.getActivity(this, 0 /* Request code */, intent,
            PendingIntent.FLAG_ONE_SHOT);

    Uri defaultSoundUri= RingtoneManager.getDefaultUri(RingtoneManager.TYPE_NOTIFICATION);
    NotificationCompat.Builder notificationBuilder = new NotificationCompat.Builder(this)
            .setContentTitle("Lecture Notes(Enterprise Systems)")
            .setSmallIcon(R.mipmap.ic_launcher)
            .setContentText(name1)
            .setAutoCancel(true)
            .setSound(defaultSoundUri)
            .setContentIntent(pendingIntent);

    NotificationManager notificationManager =
            (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE);

    notificationManager.notify(0 /* ID of notification */, notificationBuilder.build());
}

private void showNotification(String name) {
    Intent intent = new Intent(this, MainActivity.class);
    intent.addFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP);
    PendingIntent pendingIntent = PendingIntent.getActivity(this, 0 /* Request code */, intent,
            PendingIntent.FLAG_ONE_SHOT);

    Uri defaultSoundUri= RingtoneManager.getDefaultUri(RingtoneManager.TYPE_NOTIFICATION);
    NotificationCompat.Builder notificationBuilder = new NotificationCompat.Builder(this)
            .setContentTitle("Lecture Notes(System Dev't)")
            .setSmallIcon(R.mipmap.ic_launcher)
            .setContentText(name)
            .setAutoCancel(true)
            .setSound(defaultSoundUri)
            .setContentIntent(pendingIntent);

    NotificationManager notificationManager =
            (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE);

    notificationManager.notify(0 /* ID of notification */, notificationBuilder.build());
}
}

В чем может быть проблема?

Answer 1

У вас есть две облачные функции, которые запускаются по следующим двум путям:

/Lecture_Materials/{MIS}/{Systems_Devt}/{Systems_DevtId}/name
/Lecture_Materials/{MIS}/{Enterprise_Sys}/{Enterprise_SysId}/name

Каждый из сегментов, заключенных в {}, определяет переменную.Если вы удалите имена переменных, оба тезиса будут /Lecture_Materials/*/*/*/name.Это означает, что с точки зрения облачных функций эти функции запускаются по одному и тому же пути.

Если вы хотите, чтобы каждая функция запускалась для отдельной операции, вам необходимо убедиться, что путь является уникальным.Типичный подход заключается в использовании путей, подобных этому:

/Lecture_Materials/Systems_Devt/{MIS}/{Systems_Devt}/{Systems_DevtId}/name
/Lecture_Materials/Enterprise_Sys/{MIS}/{Enterprise_Sys}/{Enterprise_SysId}/name

Если {Systems_Devt} и ваши текущие пути на самом деле не являются подстановочными знаками, а предназначены для буквенных строк, вы также можете сохранить свои текущие пути и удалитьте {}:

/Lecture_Materials/{MIS}/Systems_Devt/{Systems_DevtId}/name
/Lecture_Materials/{MIS}/Enterprise_Sys/{Enterprise_SysId}/name