Node.js - FCM 发送预定主题通知

Question

我正在使用 Angular 应用程序和 Node.js 服务器使用 FCM 向 Android 设备发送主题通知。我正在使用公牛来安排通知。

有两种发送通知的方式：立即发送通知和在特定日期和时间发送通知。

要发送通知，我正在使用 Angular 应用程序和此方法：

  sendTopicNotification(notification: Notification): Observable<any> {
    console.log("send topic");
    return this.http.post(endpoint + `notifications/send/topic/topic${notification.target}`, JSON.stringify(notification), httpOptions).pipe(
      map(result => { return true; })
    );
  }

这是我的 Node.js 代码：

const express = require('express');
const router = express.Router();
const fb = require('../firebase/fb');
const db = fb.firestore();
const fcm = fb.messaging();
const moment = require('moment');

var Queue = require('bull');
var notificationsQueue = new Queue('topic notifications', { redis: { port: 6379, host: '127.0.0.1' } }); // Specify Redis connection using object

const notificationsCollection = 'notifications';
const donationsCollection = 'donations';


router.post('/send/topic/:topic', (req, res) => {
    var topic = `/topics/${req.params.topic.toString()}`;

    var payload = {
        notification: {
            title: req.body.title,
            body: req.body.body
        }
    };

    var options = {
        priority: "high",
        timeToLive: 60 * 60 * 24
    };

    if (req.body.sendDate && req.body.sendHour) {
        var date = req.body.sendDate;
        var hour = req.body.sendHour;
        scheduleMessage(date, hour, topic, payload, options);
    } else {
        sendTopicNotification(topic, payload, options);
    }


    res.send(200);
});

//Schedule the job
async function scheduleMessage(date, hour, topic, payload, options, res) {
    var date = date.toString().split("/");
    var hour = hour.toString().split(":");
    console.log(date[2], date[1], date[0], hour[0], hour[1], 0);
    var jobDate = new Date(date[2], date[1] - 1, date[0], hour[0], hour[1]);

    console.log(jobDate);
    console.log(new Date());
    var jobDelay = ((jobDate.getTime() / 1000) - (Math.floor(new Date().getTime() / 1000)));

    console.log(jobDate.getTime() / 1000);
    console.log(Math.abs(jobDelay));
    console.log(Math.floor(new Date().getTime() / 1000));

    const job = await notificationsQueue.add({
        topic: topic,
        payload: payload,
        options: options
    }, { delay: Math.abs(jobDelay) });
    console.log(date + " " + hour);
}

//Process qued job
notificationsQueue.process(async (job, done) => {
    console.log(job.data);
    sendTopicNotification(job.data.topic, job.data.payload, job.data.options);
});

//Send notificaiton
function sendTopicNotification(topic, payload, options) {
    var currentTime = new Date().getTime();

    var target;
    switch (topic) {
        case "/topics/topicA":
            target = 'Donatorii cu grupa sanguin? A'
            break;
        case "/topics/topicB":
            target = 'Donatorii cu grupa sanguin? B'
            break;
        case "/topics/topicAB":
            target = 'Donatorii cu grupa sanguin? AB'
            break;
        case "/topics/topic0":
            target = 'Donatorii cu grupa sanguin? 0'
            break;
        case "/topics/topicAll":
            target = 'To?i donatorii'
            break;
        default:
            break;
    }
    fcm.sendToTopic(topic, payload, options)
        .then((response) => {
            db.collection(notificationsCollection).doc(currentTime.toString()).set({
                title: payload.notification.title,
                body: payload.notification.body,
                date: currentTime,
                target: target,
                status: "Notificarea a fost trimis?!"
            }).then((res) => {
                console.log('Create new notification ');
            });
            // Response is a message ID string.
            console.log('Successfully sent message:', response);
        })
        .catch((error) => {
            db.collection(notificationsCollection).doc(currentTime.toString()).set({
                title: payload.notification.title,
                body: payload.notification.body,
                date: currentTime,
                target: topic,
                status: "Notificarea nu a fost trimis?!"
            }).then(() => {
                console.log('Create new notification');
            });
            console.log('Error sending message:', error);
        });
}
module.exports = router;

1）。“现在”通知

通知正文（从 Angular 发送）：

{
    body: "test",
    date: undefined,
    status: "Notificarea nu a fost trimis?!",
    target: "A",
    title: "test",
}

这些是结果和日志：

express deprecated res.send(status): Use res.sendStatus(status) instead routes/notifications.js:41:9
Successfully sent message: { messageId: 9203836031271870000 }
Create new notification

通知到达 Android 应用程序，一切正常。

2）。“预定通知”

通知正文（从 Angular 发送）：

{
    body: "test",
    date: undefined,
    sendDate: "29/06/2019",
    sendHour: "07:27",
    status: "Notificarea nu a fost programat?!",
    target: "A",
    title: "test",
}

这些是结果和日志：

2019-06-29T04:27:00.000Z
2019-06-29T04:25:35.070Z
{ topic: '/topics/topicA',
  payload: { notification: { title: 'test', body: 'test' } },
  options: { priority: 'high', timeToLive: 86400 } }
Successfully sent message: { messageId: 5284791767401410000 }
Create new notification 

现在行为有问题。在我重新启动服务器之前，通知不会到达 Android 应用程序。正如您所看到的，它被编程为在 发送2019-06-29T04:27:00.000Z，但即使在更长的时间之后也没有发送任何内容。当我重新启动服务器时，Android 应用程序将收到最后发送的通知。

所以我的问题是在第二种情况：

• 延迟后不发送通知；
• 通知似乎没有存储在队列中，因此在我重新启动服务器后只会发送最后一个；
• 在我重新启动服务器后，之前安排的通知似乎不断发送。例如：发送第一个通知，重新启动，发送第二个，重新启动，发送第一个等。

我错过了什么？

Answer 1

我发现您的代码有两个小问题。

1. 作业延迟以秒而不是毫秒为单位发送。

替换{ delay: Math.abs(jobDelay) });为{ delay: Math.abs(jobDelay) * 1e3 });

2. 您需要在处理完作业后调用 done() 。

done();之后添加sendTopicNotification(job.data.topic, job.data.payload, job.data.options);。